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);


 
原文地址:https://www.cnblogs.com/xiang-wei/p/7603037.html