// Dapper Plus

// Doc: https://dapper-plus.net/bulk-insert

​

// @nuget: Dapper

// @nuget: Microsoft.Data.SqlClient

// @nuget: Z.Dapper.Plus

​

using System;

using System.Collections.Generic;

using System.Dynamic;

using System.Linq;

using Dapper;

using Microsoft.Data.SqlClient;

using Z.Dapper.Plus;

​

public static partial class MyExtensions

{

    public static ExpandoObject ToExpandoObject(this IDictionary<string, object> dict)

    {

        var expando = new ExpandoObject();

        var expandoDict = (IDictionary<string, object>)expando;

​

        foreach (var keyValue in dict)

        {

            expandoDict.Add(keyValue.Key, keyValue.Value);

        }

​

        return expando;

    }

}

​

public class Program

{   

    public static void Main()

    {

        CreateDatabase();

        DapperPlusManager.Entity<Order>().Table("Orders")

                                         .Identity(x => x.OrderID);

        DapperPlusManager.Entity<ExpandoObject>("MapDapperRow").Table("Orders");

​

        var connection = new SqlConnection(FiddleHelper.GetConnectionStringSqlServer());

        var seedOrders = GenerateOrders(3);

        connection.BulkInsert(seedOrders);

        FiddleHelper.WriteTable("1 - Order Before:", connection.Query<Order>("SELECT * FROM Orders"));

        var orderToInsert = connection.Query("SELECT * FROM Orders").Select(x => ((IDictionary<string, object>)x).ToExpandoObject()).ToList();

        // NOTE: Dapper Plus doesn't work with DapperRow (what is currently returned by `ToList`)

        // In order to make it works, you need to convert it to ExpandoObject by using a method such as `ToExpandoObject`

        connection.BulkInsert("MapDapperRow", orderToInsert);

        FiddleHelper.WriteTable("2 - Order After:", connection.Query<Order>("SELECT * FROM Orders"));

    }

    public class Order 

    {

        public int OrderID { get; set; }

        public string Number { get; set; }

        public decimal TotalPrice { get; set; }

        public int TotalQuantity { get; set; }

    }

    public static List<Order> GenerateOrders(int count)

    {

        var orders = new List<Order>();

        for(int i = 0; i < count; i++)

        {

            orders.Add(new Order() { Number = "Order_" + i, TotalPrice = 1 + i * 1.1m, TotalQuantity = 1 + i });

        }

        return orders;

    }

    public static void CreateDatabase()

    {

        using (var connection = new SqlConnection(FiddleHelper.GetConnectionStringSqlServer()))

        {

            connection.Open();

            using (var command = connection.CreateCommand())

            {

                command.CommandText = @"   

CREATE TABLE [Orders]

(

    [OrderID] [INT] IDENTITY(1,1) NOT NULL,

    [Number] [VARCHAR](20) NULL,

    [TotalPrice] [Money] NULL,

    [TotalQuantity] [int] NULL,

    CONSTRAINT [PK_Orders] PRIMARY KEY CLUSTERED 

    (

        [OrderID] ASC

    )

) ";

                command.ExecuteNonQuery();

            }

        }

    }

}