示例：
string sql=""; dbhelper.ExecuteNonQuery(sql); DataTable dt = dbhelper.GetDataTable(sql); if (dt != null && dt.Rows.Count > 0) { SqlBulkCopy bcp = new SqlBulkCopy("server=.;database=Service;uid=sa;pwd=123456"); bcp.DestinationTableName = "InventoryDiff"; bcp.WriteToServer(dt); }
简单使用：
private void UpdateTitle(DataTable dt) { { using (SqlBulkCopy sbc = new SqlBulkCopy(SqlHelper.connectionString)) { sbc.BatchSize = dt.Rows.Count;//每批次操作数量 sbc.BulkCopyTimeout = ;//操作允许的超时时间 单位:秒 (超时则事务不提交) sbc.DestinationTableName = "TB_product_NewTitle"; //数据库对应表名 sbc.WriteToServer(dt); } }}
如果出现 DataTable中的字段和数据库的字段不对应的异常信息，需要手动的为DataTable的列 和 数据库中的列 绑定 注意：dataColumns的数据类型，一定要和数据库一样，不然各种报错 字段也区分大小写，一定要注意 /// <summary> /// 批量更新数据到数据库(DataTable列结构保持和数据库表一致) /// </summary> /// <param name="dt"></param> public static void BulkCopyData(Queue<QueueMessage> myQ, int SiteID,int max) { ) { using (SqlBulkCopy sbc = new SqlBulkCopy(SqlHelper.con)) { QueueMessage qm = new QueueMessage(); DataTable dt = new DataTable(); dt.Columns.AddRange( new DataColumn[] { new DataColumn("Sender", typeof(Int32)), new DataColumn("Receiver", typeof(Int32)), new DataColumn("Content", typeof(string)), new DataColumn("CreateTime", typeof(DateTime)), new DataColumn("SenderType", typeof(int)) }); ; ) qcount = max; else qcount = myQ.Count(); ; i < qcount; i++) { qm = myQ.Dequeue() as QueueMessage; DataRow dr = dt.NewRow(); dr["Sender"] = qm.Sender; dr["Receiver"] = qm.Receiver; dr["Content"] = qm.Content; dr["CreateTime"] = qm.CreateTime; dr["SenderType"] = qm.SenderType; dt.Rows.Add(dr); } //把DataTable的列名和数据库的列名绑定 sbc.ColumnMappings.Add("Sender", "Sender"); sbc.ColumnMappings.Add("Receiver", "Receiver"); sbc.ColumnMappings.Add("Content", "Content"); sbc.ColumnMappings.Add("CreateTime", "CreateTime"); sbc.ColumnMappings.Add("SenderType", "SenderType"); sbc.BatchSize = dt.Rows.Count;//每批次操作数量 sbc.BulkCopyTimeout = ;//操作允许的超时时间 单位:秒 (超时则事务不提交) sbc.DestinationTableName = "TB_Message_" + SiteID;//数据库对应表名 sbc.WriteToServer(dt); } } }
