// Dapper Plus

// Doc: https://dapper-plus.net/getting-started-identity-propagation

​

// @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;

​

public class Program

{   

    public static void Main()

    {

        CreateDatabase();       

        SetGlobalMapping();

        // Generate invoices

        var invoices = new List<Invoice>();

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

        {

            var invoice = new Invoice() { Number = "Invoice_" + i };

            invoice.InvoiceMeta = new InvoiceMeta() { TotalPrice = 5, TotalQuantity = 3 };

            invoice.InvoiceItems = new List<InvoiceItem>();

            for(int j = 0; j < 2; j++)

            {

                invoice.InvoiceItems.Add(new InvoiceItem() { ProductID = j + 1, UnitPrice = j + 1, Quantity = j + 1 });

            }

            invoices.Add(invoice);

        }

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

        connection.BulkInsert(invoices, x => x.InvoiceMeta, x => x.InvoiceItems);

​

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

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

        FiddleHelper.WriteTable("3 - InvoiceItem", connection.Query<InvoiceItem>("SELECT * FROM InvoiceItem"));

    }

    #region Mapping

    public static void SetGlobalMapping()

    {

        DapperPlusManager.Entity<Invoice>().Identity(x => x.InvoiceID)

            .AfterAction((actionKind, invoice) =>

                 {

                     if (actionKind == DapperPlusActionKind.Insert || actionKind == DapperPlusActionKind.Merge)

                     {

                         if (invoice.InvoiceMeta != null)

                         {

                             invoice.InvoiceMeta.InvoiceID = invoice.InvoiceID;

                         }

​

                         if (invoice.InvoiceItems != null)

                         {

                             invoice.InvoiceItems.ForEach(invoiceItem => invoiceItem.InvoiceID = invoice.InvoiceID);

                         }

                     }

                 });

        DapperPlusManager.Entity<InvoiceItem>().Identity(x => x.InvoiceItemID)

            .AfterAction((actionKind, invoiceItem) =>

                 {

                     if (actionKind == DapperPlusActionKind.Insert || actionKind == DapperPlusActionKind.Merge)

                     {

                         if (invoiceItem.InvoiceItemMeta != null)

                         {

                             invoiceItem.InvoiceItemMeta.InvoiceItemID = invoiceItem.InvoiceItemID;

                         }

                     }

                 });

    }

    #endregion

​

    #region Entity

    public class Invoice 

    {

        public int InvoiceID { get; set; }

        public string Number { get; set; }

        public InvoiceMeta InvoiceMeta { get; set; }

        public List<InvoiceItem> InvoiceItems { get; set; }

    }

    public class InvoiceMeta

    {

        public int InvoiceID { get; set; }

        public decimal TotalPrice { get; set; }

        public int TotalQuantity { get; set; }

    }

    public class InvoiceItem

    {

        public int InvoiceItemID { get; set; }

        public int InvoiceID { get; set; }

        public int ProductID { get; set; }

        public decimal UnitPrice { get; set; }

        public decimal UnitDiscount { get; set; }

        public int Quantity { get; set; }

        public InvoiceItemMeta InvoiceItemMeta { get; set; }

    }

    public class InvoiceItemMeta

    {

        public int InvoiceItemID { get; set; }

        public decimal TotalPrice { get; set; }

    }

    #endregion

    #region CreateDatabase

​

    public static void CreateDatabase()

    {

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

        connection.Execute(@"

CREATE TABLE [Invoice]

(

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

    [Number] [VARCHAR](20) NULL,

    CONSTRAINT [PK_Invoice] PRIMARY KEY CLUSTERED 

    (

        [InvoiceID] ASC

    )

)

​

CREATE TABLE [InvoiceMeta]

(

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

    [TotalPrice] [MONEY] NULL,

    [TotalQuantity] [int] NULL,

    CONSTRAINT [PK_InvoiceMeta] PRIMARY KEY CLUSTERED 

    (

        [InvoiceID] ASC

    )

)

​

CREATE TABLE [InvoiceItem]

(

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

    [InvoiceID] [INT] NOT NULL,

    [ProductID] [INT] NOT NULL,

    [UnitPrice] [MONEY] NOT NULL,

    [UnitDiscount] [MONEY] NOT NULL,

    [Quantity] [INT] NOT NULL,

​

    CONSTRAINT [PK_InvoiceItem] PRIMARY KEY CLUSTERED 

    (

        [InvoiceItemID] ASC

    )

)

​

CREATE TABLE [InvoiceItemMeta]

(

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

    [TotalPrice] [MONEY] NULL,

    CONSTRAINT [PK_InvoiceItemMeta] PRIMARY KEY CLUSTERED 

    (

        [InvoiceItemID] ASC

    )

)

");

    }

    #endregion

}