// Dapper Plus

// Doc: https://dapper-plus.net/column-mapping-audit-mode-type

​

// @nuget: Dapper -Version 1.60.6

// @nuget: Z.Dapper.Plus

​

using System;

using System.Collections.Generic;

using System.Data.SqlClient;

using System.Linq;

using Dapper;

using Z.Dapper.Plus;

using Z.BulkOperations;

​

public class Program

{   

    public static void Main()

    {

        CreateDatabase();

        SeedDatabase();

        // Mapping

        DapperPlusManager.Entity<Customer>().Table("Customer")

            .AuditMode(AuditModeType.ExcludeAll)

            .AuditMode(x => new { x.CustomerID, x.Name }, ColumnMappingAuditModeType.Include);

        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 });

​

        // Connection

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

        // Execute

        List<AuditEntry> auditEntries = new List<AuditEntry>(); 

        connection.UseBulkOptions(options => 

        { 

            options.UseAudit = true;

            options.AuditEntries = auditEntries; 

        })

        .BulkMerge(list); 

​

        // Result

        FiddleHelper.WriteTable(auditEntries.SelectMany(x => x.Values));

    }

    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();

            }

        }

    }

    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 });

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

        connection.BulkInsert(list);

    }

}