MARKUS

        public readonly IDbConnection Connection;

        public async Task<int> ExecuteAsync1(string SQL, SqlMapper.IDynamicParameters parameters, IDbTransaction transaction, CommandType commandType)

        {

            if (Connection.State != System.Data.ConnectionState.Open)

            {

                Connection.Open();

            }

            return await Connection.ExecuteAsync(SQL, parameters, transaction, commandType: commandType);

        }

using NpgsqlTypes;

using Npgsql;

using Npgsql.NameTranslation;

using System.Xml.Linq;

using System.Data.Common;

	public class DOCPAGERepository : BaseRepository, IDOCPAGERepository

				if (this.DBMS == DBMSType.MSSQL)

				{

					var tran = BeginTransaction();

					var parameter = new DynamicParameters();

					var items = docPages.Select(x => new InsertDocPage { docinfo_id = x.DOCINFO_ID, page_number = x.PAGE_NUMBER, page_angle = x.PAGE_ANGLE, page_height = x.PAGE_HEIGHT, page_width = x.PAGE_WIDTH }).ToList();

					parameter.AddTable("DOCPAGES", "TYPE_INSERT_DOCPAGE", items);

					var id = await base.ExecuteAsync("CONVERT_INSERT_DOCPAGE", parameter, tran, commandType: CommandType.StoredProcedure);

					tran.Commit();

					result = true;

				}

				else if (this.DBMS == DBMSType.POSTGRESQL)

				{

                    if (NpgsqlConnection.GlobalTypeMapper.Mappings.Where(f => f.PgTypeName == "type_insert_docpage").Count() == 0)

                        NpgsqlConnection.GlobalTypeMapper.MapComposite<InsertDocPage>("type_insert_docpage");

                    InsertDocPage[] items = docPages.Select(x => new InsertDocPage {docinfo_id = x.DOCINFO_ID, 

                                                                                    page_number = x.PAGE_NUMBER, 

                                                                                    page_angle = x.PAGE_ANGLE,

                                                                                    page_height = x.PAGE_HEIGHT, 

                                                                                    page_width = x.PAGE_WIDTH }).ToArray();

                    var tran = BeginTransaction();

                    NpgsqlCommand command = new NpgsqlCommand("convert_insert_docpage", (NpgsqlConnection)this.Connection);

                    command.CommandType = CommandType.StoredProcedure;

                    var cmdParam = command.CreateParameter();

                    cmdParam.ParameterName = "docpages";

                    cmdParam.DbType = DbType.Object;

                    cmdParam.Value = items;

                    cmdParam.DataTypeName = "type_insert_docpage[]";

                    command.Parameters.Add(cmdParam);

                    await command.ExecuteNonQueryAsync();

                    tran.Commit();

                    result = true;

                }

				else

				{

				}

			{

			}

        // call stored procedure at data access layer for example StudentDAL.cs

        public void CallStoredResultSet<T>(InsertDocPage[] inputParameters) where T : class

        {

            //var conn = _GetOpenConnection();

            //var tran = _BeginTransaction(conn);

            var tran = BeginTransaction();

            NpgsqlCommand command = new NpgsqlCommand("convert_insert_docpage_arr", (NpgsqlConnection)this.Connection );

            command.CommandType = CommandType.StoredProcedure;

            var cmdParam = command.CreateParameter();

            cmdParam.ParameterName = "docpages";

            cmdParam.DbType = DbType.Object;

            cmdParam.Value = inputParameters;

            cmdParam.DataTypeName = "type_insert_docpage[]";

            command.Parameters.Add(cmdParam);

            // throw exception here

            // Can't write CLR type Web.API.Models.UdtSpParameter[] with handler type MappedCompositeHandler`1

            command.ExecuteNonQueryAsync();

			tran.Commit();

            //this.Connection.Close();

        }

        public class InsertDocPage

            [PgName("docinfo_id")]

            public string docinfo_id { get; set; }

            [PgName("page_number")]

            public int page_number { get; set; }

            [PgName("page_width")]

            public string page_width { get; set; }

            [PgName("page_height")]

            public string page_height { get; set; }

            [PgName("page_angle")]

            public int page_angle { get; set; }

            public InsertDocPage() { }

        }

	}

}

        [Test, Description("DocPageInsert")]

            string newConvertDocID = string.Empty;

            string newDocInfo = string.Empty;

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

                newConvertDocID = repository.CreateAsync(ProjectNo, docUri, "111111").GetAwaiter().GetResult();

                Console.WriteLine($"new id : {newConvertDocID}");

            }

            if (!string.IsNullOrEmpty(newConvertDocID))

            {

                using (Markus.Service.DataBase.Repositories.DOCINFORepository repository = new Repositories.DOCINFORepository(ConnectionStr, dbtype))

                    newDocInfo = repository.CreateAsync(newConvertDocID, 10).GetAwaiter().GetResult();

                    Console.WriteLine($"new id : {newDocInfo}");

                if (!string.IsNullOrEmpty(newDocInfo))

                {

                    using (Markus.Service.DataBase.Repositories.DOCPAGERepository repository = new Repositories.DOCPAGERepository(ConnectionStr, dbtype))

                    {

                        List<Entities.DOCPAGE> pages = new List<Entities.DOCPAGE>();

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

                        {

                            pages.Add(new Entities.DOCPAGE { DOCINFO_ID = newDocInfo, PAGE_NUMBER = i + 1, PAGE_WIDTH = "1210", PAGE_HEIGHT = "1210", PAGE_ANGLE = 0 });

                        }

                        var result = repository.CreateAsync(pages).GetAwaiter().GetResult();

                        Console.WriteLine($"new id : {result}");

                    }

                }

using System.Diagnostics;

        [Test, Description("DocPageInsert")]

            string newConvertDocID = string.Empty;

            string newDocInfo = string.Empty;

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

                newConvertDocID = repository.CreateAsync(ProjectNo, docUri, "111111").GetAwaiter().GetResult();

                Console.WriteLine($"new id : {newConvertDocID}");

            }

            if (!string.IsNullOrEmpty(newConvertDocID))

            {

                using (Markus.Service.DataBase.Repositories.DOCINFORepository repository = new Repositories.DOCINFORepository(ConnectionStr, dbtype))

                    newDocInfo = repository.CreateAsync(newConvertDocID, 10).GetAwaiter().GetResult();

                    Console.WriteLine($"new id : {newDocInfo}");

                if (!string.IsNullOrEmpty(newDocInfo))

                {

                    using (Markus.Service.DataBase.Repositories.DOCPAGERepository repository = new Repositories.DOCPAGERepository(ConnectionStr, dbtype))

                    {

                        List<Entities.DOCPAGE> pages = new List<Entities.DOCPAGE>();

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

                        {

                            pages.Add(new Entities.DOCPAGE { DOCINFO_ID = newDocInfo, PAGE_NUMBER = i + 1, PAGE_WIDTH = "1210", PAGE_HEIGHT = "1210", PAGE_ANGLE = 0 });

                        }

                        Stopwatch sw = new Stopwatch();

                        sw.Start();

                        var result = repository.CreateAsync(pages).GetAwaiter().GetResult();

                        sw.Stop();

                        Console.WriteLine($"End Milliseconds id : {sw.ElapsedMilliseconds}");

                    }

                }