DataTable 批量插入SqlServer数据库 使用:SqlBulkCopy

 

简单使用:
     private void UpdateTitle(DataTable dt)
        {
           
            if (dt != null && dt.Rows.Count > 0)
            {
                using (SqlBulkCopy sbc = new SqlBulkCopy(SqlHelper.connectionString))
                {
                    sbc.BatchSize = dt.Rows.Count;//每批次操作数量
                    sbc.BulkCopyTimeout = 60;//操作允许的超时时间 单位:秒 (超时则事务不提交)
                    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)
        {
            if (myQ != null && myQ.Count > 0)
            {
                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)) 
            });
int qcount=0; if (max > 0) qcount = max; else qcount = myQ.Count(); for (int i = 0; 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 = 60;//操作允许的超时时间 单位:秒 (超时则事务不提交) sbc.DestinationTableName = "TB_Message_" + SiteID;//数据库对应表名 sbc.WriteToServer(dt); } } }

 

DataTable 批量插入SqlServer数据库 使用:SqlBulkCopy,布布扣,bubuko.com

DataTable 批量插入SqlServer数据库 使用:SqlBulkCopy

上一篇:PHP多次调用Mysql存储过程报错解决办法


下一篇:mysql replication配置