sqlbulkcopy 多表批量保存

/// <summary>
/// 批量保存多表
/// </summary>
/// <param name="dt1"></param>
/// <param name="TableName"></param>
/// <returns></returns>
public static void SqlBatchCopy(DataTable dt, string TableName,DataTable dt1, string TableName1)
{
using (SqlTransaction st = Con.BeginTransaction())
{
using (SqlBulkCopy copy = new SqlBulkCopy(Con, SqlBulkCopyOptions.Default, st))
{
for (int i = 0; i < dt.Columns.Count; i++)
{
copy.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
}
copy.DestinationTableName = TableName;
copy.WriteToServer(dt);
}
using (SqlBulkCopy copy = new SqlBulkCopy(Con, SqlBulkCopyOptions.Default, st))
{
for (int i = 0; i < dt1.Columns.Count; i++)
{
copy.ColumnMappings.Add(dt1.Columns[i].ColumnName, dt1.Columns[i].ColumnName);
}
copy.DestinationTableName = TableName1;
copy.WriteToServer(dt1);
}
st.Commit();
}
}

//簡單測試

DataTable tb = new DataTable();
tb.Columns.Add( "Cname1", typeof (string));
DataRow dr = tb.NewRow();
for (int i = 1; i <= 10000; i++)
{
dr = tb.NewRow();
dr[ "Cname1"] = "測試" + i;
tb.Rows.Add(dr);
}

System.Diagnostics. Stopwatch st = new System.Diagnostics.Stopwatch();
st.Start();
using (System.Data.SqlClient.SqlBulkCopy copy = new System.Data.SqlClient.SqlBulkCopy ("server=.;database=TestA;uid=sa;pwd=sasa"))
{
copy.ColumnMappings.Add( "Cname1", "Cname" );
copy.DestinationTableName = "TbA";
copy.WriteToServer(tb);
}
st.Stop();
MessageBox.Show( "新增成功,耗時" + st.ElapsedMilliseconds);

 

 

 

 

 

 

 

 

 

 

 

 

class Program
   {
       static volatile bool result;
       static void Main(string[] args)
       {
          DataSet ds = ExportDataSet();

          //使用2個線程模擬併發操做
          Thread t = new Thread(delegate() { result = Insert(ds); Console.WriteLine(result ? "導入成功" : "導入失敗"); });
          t.Start();
          Thread t1 = new Thread(delegate() { result = Insert(ds); Console.WriteLine(result ? "導入成功" : "導入失敗"); });
          t1.Start();
          Console.ReadLine();
       }

       /// <summary>
       /// 獲取數據DataSet
       /// </summary>
       /// <returns></returns>

       static private DataSet ExportDataSet()
       {

           //局域網的某服務器模擬數據庫遠程鏈接
           SqlConnection RemoteConn = new SqlConnection("Data Source=192.168.0.183;Initial Catalog=Northwind;User ID=sa;Password=sa");



           using (

            /* 目標表與源表結構並不相同，目標表只包含OrderID、CustomerID、EmployeeID、ShipCountry這四個字段。注意這裏字段 是區分大小寫的，否則SqlBulkCopy的WriteToServer方法會報運行時異常：「給定的 ColumnMapping 與源或目標中的任 意列均不匹配」的處理方法。這個地方浪費了我1個小時才發現*/
            SqlDataAdapter oda = new SqlDataAdapter("SELECT [OrderID], [CustomerID], [EmployeeID], [ShipCountry] FROM [Northwind].[dbo].[Orders]", RemoteConn))

           //若是目標表與源表結構徹底一致，則用下面語句便可，msdn的例子也只是這樣

            //SqlDataAdapter oda = new SqlDataAdapter("SELECT * FROM [Ednoland].[dbo].[Score]", RemoteConn))
           {
               DataSet ds = new DataSet();

               oda.Fill(ds, "Orders");//給定表名

                 return ds;

           }

       }

       /// <summary>
       /// 將DataSet導入遠程數據庫(將來放在WebService中)
       /// </summary>
       /// <param name="ds"></param>
       /// <returns></returns>
       public static bool Insert(DataSet ds)
       {


           using (SqlConnection sqlconn = new SqlConnection("Data Source=.;Initial Catalog=Northwind;User ID=sa;Password=sa"))
           {
               sqlconn.Open();
               SqlTransaction sqlbulkTransaction = sqlconn.BeginTransaction(IsolationLevel.ReadCommitted);



               using (SqlBulkCopy sbc = new SqlBulkCopy(sqlconn, SqlBulkCopyOptions.KeepIdentity, sqlbulkTransaction))
               {
                   sbc.BatchSize = 20000;//20000行每鏈接
                   sbc.BulkCopyTimeout = 50;//50秒超時
                   if (ds.Tables == null || ds.Tables.Count == 0)
                       return false;

                   if (ds.Tables.Count == 1)
                   {


                       return BulkInsert(sbc, ds.Tables[0], sqlbulkTransaction); ;

                   }
                   else
                   {
                       bool res = true;
                       foreach (DataTable dt in ds.Tables)
                       {

                           res = BulkInsert(sbc, dt, sqlbulkTransaction);

                       }
                       return res;
                   }

               }
           }

       }

       private static bool BulkInsert(SqlBulkCopy sbc, DataTable dt, SqlTransaction sqlbulkTransaction)
       {

           bool res = true;
                      try
           {

             //將DataTable表名做爲待導入庫中的目標表名
               sbc.DestinationTableName = dt.TableName;



              //將數據集合和目標服務器庫表中的字段對應
               for (int i = 0; i < dt.Columns.Count; i++)
               {
                   //sbc.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
                     sbc.ColumnMappings.Add(i,i);//能夠避免字段大小寫不一致形成沒法映射的問題
               }

               sbc.WriteToServer(dt);

               //提交事務
               sqlbulkTransaction.Commit();
               res = true;
           }
           catch (SqlException ex)
           {
               res = false;
               sqlbulkTransaction.Rollback();
           }

           return res;
       }
   }