// Dapper Plus

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

​

// @nuget: Dapper

// @nuget: Microsoft.Data.SqlClient

// @nuget: Z.Dapper.Plus

​

using System.Collections.Generic;

using System.ComponentModel.DataAnnotations;

using System.ComponentModel.DataAnnotations.Schema;

using System.Linq;

using Microsoft.Data.SqlClient;

using Dapper;

using Z.Dapper.Plus;

​

public class Program

{   

    public static void Main()

    {

        // Map your entity

        DapperPlusManager.Entity<Product>()

            .Table("Product")

            .Identity(x => x.ProductID)

            .UseBulkOptions(options => options.ColumnSynchronizeDeleteKeySubsetExpression = x => new { x.StoreID });

        var products = new List<Product>();

        products.Add(new Product() { Name = "Dapper Plus", StoreID = 1, Description = @"Use <a href=""https://dapper-plus.net/"" target=""_blank"">Dapper Plus</a> to extend your IDbConnection with high-performance bulk operations." });

        products.Add(new Product() { Name = "C# Eval Expression", StoreID = 1, Description = @"Use <a href=""https://eval-expression.net/"" target=""_blank"">C# Eval Expression</a> to compile and execute C# code at runtime." });

        products.Add(new Product() { Name = "Entity Framework Extensions", StoreID = 1, Description = @"Use <a href=""https://entityframework-extensions.net/"" target=""_blank"">Entity Framework Extensions</a> to extend your DbContext with high-performance bulk operations." });

        products.Add(new Product() { Name = "Dapper Plus", StoreID = 2, Description = @"Use <a href=""https://dapper-plus.net/"" target=""_blank"">Dapper Plus</a> to extend your IDbConnection with high-performance bulk operations." });

        products.Add(new Product() { Name = "C# Eval Expression", StoreID = 2, Description = @"Use <a href=""https://eval-expression.net/"" target=""_blank"">C# Eval Expression</a> to compile and execute C# code at runtime." });

        products.Add(new Product() { Name = "Entity Framework Extensions", StoreID = 2, Description = @"Use <a href=""https://entityframework-extensions.net/"" target=""_blank"">Entity Framework Extensions</a> to extend your DbContext with high-performance bulk operations." });

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

        connection.CreateTable<Product>();

        // Seed

        connection.BulkInsert(products);

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

        // (Keep only StoreID = 1) Update first product, Remove Second Product

        products = products.Where(x => x.StoreID == 1).ToList();

        products[0].Name += "(Updated)";

        products.RemoveAt(1);

        connection.BulkSynchronize(products);

        // Query data with Dapper

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

    }

    [Table("Product")]

    public class Product

    {

        [Key]

        [DatabaseGenerated(DatabaseGeneratedOption.Identity)]

        public int ProductID { get; set; }

        public int StoreID { get; set; }

        public string Name { get; set; }

        public string Description { get; set; }

    }

}