Dapper Plus Then Bulk Insert

Description

The Dapper Plus ThenBulkInsert method allows to INSERT entities in a database table or a view using a lambda expression.

The lambda expression uses the entity or the IEnumerable from the last Bulk[Action] or ThenBulk[Action] chained method. (The action can be an insert, update, delete or merge operation).

Then Bulk Insert Async

To perform chaining with the ThenBulkInsertAsync method, you first need to initiate an asynchronous operation and then apply this method.

Each step in your database operation that runs asynchronously will need an await.

In this C# example, we prepare a list of orders and their associated invoices to insert into our database asynchronously:

await (await connection.BulkInsertAsync(orders)).ThenBulkInsertAsync(order => order.Invoice);

Then Bulk Insert with "One to One" Relation

The Dapper Plus ThenBulkInsert method allows inserting a related item with a "One to One" relation.

//Insert an order and then the related invoice.
connection.BulkInsert(orderTransaction)
          .ThenBulkInsert(transaction => transaction.order)
          .ThenBulkInsert(order => order.Invoice);

//Insert a list of orders and then the related invoice to every order.
connection.BulkInsert(orderTransaction)
          .ThenBulkInsert(transaction => transaction.orders)
          .ThenBulkInsert(order => order.Invoice);

Then Bulk Insert with "One to Many" Relation

The Dapper Plus ThenBulkInsert method allows inserting related items with a "One to Many" relation.

//Insert an order and then all related items.
connection.BulkInsert(orderTransaction)
          .ThenBulkInsert(transaction => transaction.order)
          .ThenBulkInsert(order => order.Items);

//Insert a list of orders and then all related items to every order.
connection.BulkInsert(orderTransaction)
          .ThenBulkInsert(transaction => transaction.orders);
          .ThenBulkInsert(order => order.Items);

Then Bulk Insert Chaining

The Dapper Plus ThenBulkInsert method allows chaining multiple bulk action methods.

//Insert an order and then all related items. Insert an invoice and then all related items.
connection.BulkInsert(orderTransaction)
          .ThenBulkInsert(transaction => transaction.order)
          .ThenBulkInsert(order => order.Items)
          .BulkInsert(invoiceTransaction)
          .ThenBulkInsert(transaction => transaction.invoice)
          .ThenBulkInsert(invoice => invoice.Items);

//Insert a list of orders and then all related items to every order. Insert a list of invoices 
//and then all related items to every invoice.
connection.BulkInsert(orderTransaction)
          .ThenBulkInsert(transaction => transaction.orders)
          .ThenBulkInsert(order => order.Items)
          .BulkInsert(invoiceTransaction)
          .ThenBulkInsert(transaction => transaction.invoices)
          .ThenBulkInsert(invoice => invoice.Items);
Last updated: 2024-04-24
Author:


Contents