Dapper.NET
トランザクション

構文

• conn.Execute（sql、transaction：tran）; //名前でパラメータを指定する
• conn.Execute（sql、parameters、tran）;
• conn.Query（sql、トランザクション：tran）;
• conn.Query（sql、parameters、tran）;
• conn.ExecuteAsync（sql、transaction：tran）;を待ちます。 // Async
• conn.ExecuteAsync（sql、parameters、tran）;を待ちます。
• conn.QueryAsync（sql、transaction：tran）;を待ちます。
• conn.QueryAsync（sql、parameters、tran）;を待ちます。

トランザクションの使用

この例ではSqlConnectionを使用していますが、IDbConnectionはすべてサポートされています。

また、すべてのIDbTransactionは、関連IDbConnectionからサポートされています。

public void UpdateWidgetQuantity(int widgetId, int quantity)
{
    using(var conn = new SqlConnection("{connection string}")) {
        conn.Open();

        // create the transaction
        // You could use `var` instead of `SqlTransaction`
        using(SqlTransaction tran = conn.BeginTransaction()) {
            try
            {
                var sql = "update Widget set Quantity = @quantity where WidgetId = @id";
                var parameters = new { id = widgetId, quantity };

                // pass the transaction along to the Query, Execute, or the related Async methods.
                conn.Execute(sql, parameters, tran);

                // if it was successful, commit the transaction
                tran.Commit();
            }
            catch(Exception ex)
            {
                // roll the transaction back
                tran.Rollback();

                // handle the error however you need to.
                throw;
            }
        }
    }   
}

インサートのスピードアップ

トランザクションに挿入のグループをラップすると、このStackOverflowの質問/回答に従ってそれらを高速化します。

この方法を使用することも、一括コピーを使用して一連の関連する操作を高速化することもできます。

// Widget has WidgetId, Name, and Quantity properties
public void InsertWidgets(IEnumerable<Widget> widgets)
{
    using(var conn = new SqlConnection("{connection string}")) {
        conn.Open();

        using(var tran = conn.BeginTransaction()) {
            try
            {
                var sql = "insert Widget (WidgetId,Name,Quantity) Values(@WidgetId, @Name, @Quantity)";
                conn.Execute(sql, widgets, tran);
                tran.Commit();
            }
            catch(Exception ex)
            {
                tran.Rollback();
                // handle the error however you need to.
                throw;
            }
        }
    }   
}