using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Data.SqlTypes;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.Windows.Forms;

using SqlClrLib.Model;

namespace ExampleTransaction

{

    public partial class Form1 : Form

    {

        public Form1()

        {

            InitializeComponent();

        }

        private void Form1_Load(object sender, EventArgs e)

        {

            //开发中常常要执行一些耗时的数据操作，比如update、insert、bulk insert、index creation，

            //若顺序执行，则操作总时间是每个单独sql的时间之和，

            //为了加快速度，引入异步执行的做法，比如要要create 10个表以及加数据，则可以开10个线程去分别执行

        }

        [Microsoft.SqlServer.Server.SqlProcedure]

        public static int SaveWarehouseFinalData(Guid fileDefinitionId)

        {

            Console.WriteLine("Start");

            StoredProcedures.Parallel_Declare(new SqlString("Parallel SaveWarehouseFinalData"));

            //Console.WriteLine("Database connection is ... {0}", StoredProcedures.Block.ConnectionString);

            //Console.WriteLine("Max threads count is ... {0}", StoredProcedures.Block.MaxThreads);

            ////ParallelProcedures.Block.IsTransactional = true;

            ////ParallelProcedures.Parallel_UseTransaction("Serializable");

            //依次将存储过程加入到线程池

            StoredProcedures.Parallel_AddSql(new SqlString("usp_WarehouseImportSaveToEAV"), new SqlChars(string.Format("usp_WarehouseImportSaveToEAV '{0}'", fileDefinitionId)));

            StoredProcedures.Parallel_AddSql(new SqlString("usp_WarehouseImportSaveToAdminHistory"), new SqlChars(string.Format("usp_WarehouseImportSaveToAdminHistory '{0}'", fileDefinitionId)));

            StoredProcedures.Parallel_AddSql(new SqlString("usp_WarehouseImportSaveToValResult"), new SqlChars(string.Format("usp_WarehouseImportSaveToValResult '{0}'", fileDefinitionId)));

            //执行save操作(此处用的事务，如果不成功会回滚)

            int failedCount = StoredProcedures.Parallel_Execute();

            //Console.WriteLine("Failed count is ... {0}", failedCount);

            ResultItem[] resultItems = (ResultItem[])StoredProcedures.Parallel_GetExecutionResult();

            foreach (ResultItem r in resultItems)

            {

                //Console.WriteLine(r.ToString());

            }

            //Console.WriteLine("End...");

            return failedCount;

        }

    }

}