C#使用SqlBulkCopy批量复制数据到数据表

2019-12-26 11:58:20丽君
易采站长站为您分析C#使用SqlBulkCopy批量复制数据到数据表的方法,较为详细的讲述了SqlBulkCopy批量复制数据到数据表的原理与实现技巧,需要的朋友可以参考下    

本文实例讲述了C#使用SqlBulkCopy批量复制数据到数据表的方法。。具体实现方法如下:

使用 SqlBulkCopy 类只能向 SQL Server 表写入数据。但是,数据源不限于 SQL Server;可以使用任何数据源,只要数据可加载到 DataTable 实例或可使用 IDataReader 实例读取数据

1.使用Datatable作为数据源的方式:

下面的代码使用到了ColumnMappings,因为目标表和数据源Datatable的结构不一致,需要这么一个映射来指定对应关系

 

复制代码 public string SaveJHCData(LzShopBasicData[] datas)
{
    var result = new AResult();
    SqlConnection con = new SqlConnection(System.Configuration.ConfigurationManager.ConnectionStrings["**"].ConnectionString);
    con.Open();
    foreach (var item in datas)
    {

 

 Logger.Info("数据更新处理,店铺名称:" + item.ShopName + "数据日期" + item.SellDate);
 try
 {
     using (TransactionScope scope = new TransactionScope())
     {

  DataTable JHCOrderItemsdt = SaveJHCOrderItemsData(item);
  SqlBulkCopy JHCOrderItemscopy = new SqlBulkCopy(con);
  JHCOrderItemscopy.ColumnMappings.Add("orderId", "orderId");
  JHCOrderItemscopy.ColumnMappings.Add("auctionId", "auctionId");
  JHCOrderItemscopy.ColumnMappings.Add("itemTitle", "itemTitle");
  JHCOrderItemscopy.ColumnMappings.Add("tradeAmt", "tradeAmt");
  JHCOrderItemscopy.ColumnMappings.Add("alipayNum", "alipayNum");
  JHCOrderItemscopy.ColumnMappings.Add("tradeTime", "tradeTime");
  JHCOrderItemscopy.ColumnMappings.Add("uv", "uv");
  JHCOrderItemscopy.ColumnMappings.Add("srcId", "srcId");
  JHCOrderItemscopy.ColumnMappings.Add("srcName", "srcName");
  JHCOrderItemscopy.ColumnMappings.Add("DataType", "DataType");