// Bulk Operations

// Doc: https://bulk-operations.net/log

​

// @nuget: Z.BulkOperations

// @nuget: System.Data.SqlClient

​

using System;

using System.Text;

using System.Collections.Generic;

using System.Data.SqlClient;

using System.Data;

using Z.BulkOperations;

public class Program

{

    public static void Main()

    {

        CreateDatabase();

        SeedDatabase();

        Execute();

    }

    public static void Execute()

    {

        // We will execute a BulkMerge on a list that contains 1 new customer and 2 existing customers.

        var list = new List<Customer>();

        list.Add(new Customer() { Name = "Customer_C_Inserted", Description = "Description_Customer_C_Inserted", IsActive = false });

        list.Add(new Customer() { CustomerID = 1, Name = "Customer_A_Updated", Description = "Description_Customer_A_Updated", IsActive = false });

        list.Add(new Customer() { CustomerID = 2, Name = "Customer_B_Updated", Description = "Description_Customer_B_Updated", IsActive = false });

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

        {

            connection.Open();

            // Execute

            var sb = new StringBuilder();

            using (var bulk = new BulkOperation(connection))

            {

                bulk.DestinationTableName = "Customer";

                bulk.Log = s => sb.AppendLine(s);        

                bulk.BulkMerge(list);

            }

​

            Console.WriteLine(sb.ToString());           

        }

    }

    public static void SeedDatabase()

    {

        var list = new List<Customer>();

        list.Add(new Customer() { Name = "Customer_A", Description = "Description_Customer_A", IsActive = false });

        list.Add(new Customer() { Name = "Customer_B", Description = "Description_Customer_B", IsActive = false });

​

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

        {

            connection.Open();

            // SAVE customers

            using (var bulk = new BulkOperation<Customer>(connection))

            {

                // easy to use

                bulk.DestinationTableName = "Customer";

​

                bulk.BulkInsert(list);

            }

        }

    }

    public class Customer

    {

        public int CustomerID { get; set; }

        public string Name { get; set; }

        public string Description { get; set; }

        public Boolean IsActive { get; set; }

    }

    public static void CreateDatabase()

    {

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

        {

            connection.Open();

            using (var command = connection.CreateCommand())

            {

                command.CommandText = @"   

CREATE TABLE [dbo].[Customer] (

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

    [Name]        NVARCHAR (MAX) NULL,

    [Description] NVARCHAR (MAX) NULL,

    [IsActive]    BIT            NOT NULL,

    CONSTRAINT [PK_dbo.Customer] PRIMARY KEY CLUSTERED ([CustomerID] ASC)

);

";

                command.ExecuteNonQuery();

            }

        }

    }

}