Attach an existing connection about npoco HOT 9 CLOSED

Can you please show me how you are using this? I'm currently using it like this in production.

from npoco.

You just have to create a connection, begin a transaction with this connection, create a npoco database passing the previously created connection in constructor and then trying to call the fetch method of npoco database.

from npoco.

Hey, There is a work around, but only if you let NPoco create the transaction. If you need the transaction to be created outside NPoco then I'm proposing the following API. What do you think?

// Should be able to do this
using (var conn = new SqlConnection("connstring"))
{
    conn.Open();

    IDatabase db = new Database(conn);
    db.BeginTransaction();
    var results = db.Execute("insert into abc(name) select 'wow'");
    db.CompleteTransaction();
}

// Otherwise here is what I'm thinking
using (var conn = new SqlConnection("connstring"))
{
    conn.Open();
    var tran = conn.BeginTransaction();

    IDatabase db = new Database(conn);
    db.SetTransaction(tran);
    db.Execute("insert into abc(name) select 'wow'");
    //tran.Commit() or ....
    //db.CompleteTransaction(); can commit here if needed
}

from npoco.

Wow Adam, thank you very much for your support! I think the second solution looks like much more flexible because the database object are in an object that is created after the transaction created but your first solution should also be implemented if it's not the case. Thank you again for your great product.

from npoco.

The first solution is what it does now. Will get a new release out this weekend some time. Will be 1.0.3.

from npoco.

1.0.3 is out on NuGet. Can you please have a look and let me know.

from npoco.

Thank you, i will look this night ;)

from npoco.

I updated to the newest version and it work perfectly.

This is what I do with my own "session" object.

   public System.Collections.Generic.List<Table> GetTables(Data.Sessions.Session session)
   {
     Database database = new Database(session.Connection.InternalConnection);

     if (session.Connection.Transaction != null)
        database.SetTransaction(session.Connection.Transaction);

     return database.Query<Table>(
        "SELECT Name, SCHEMA_NAME(schema_id) AS SchemaName " +
        "FROM sys.tables " +
        "WHERE name <> 'dtproperties' " +
        "ORDER BY schemaName, name").ToList();
   }

from npoco.

Excellent. Thanks for the feedback.

from npoco.