最新下载
热门教程
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
IBatis.Net如何使用SqlBulkCopy大批量导入数据
时间:2022-06-25 06:01:26 编辑:袖梨 来源:一聚教程网
SQLBulkCopy是继承SQLClient空间下的一个特殊类,它可以帮助我们以映射的方式把DataTable和DataReader数据大批量导入到数据库对应表中
代码如下 | 复制代码 |
public void Inert2DBBySqlBulkCopy(DataTable data, string tableName) { BaseDao basdd = new BaseDao(); using (SqlConnection conn = new SqlConnection(basdd.SqlNormMap.DataSource.ConnectionString)) { if (conn.State != ConnectionState.Open) conn.Open(); using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(conn)) { sqlBulkCopy.ColumnMappings.Add(0, "CarModelID"); sqlBulkCopy.ColumnMappings.Add(1, "TranConfID"); sqlBulkCopy.ColumnMappings.Add(2, "TranValue"); sqlBulkCopy.ColumnMappings.Add(3, "CreatorID"); sqlBulkCopy.ColumnMappings.Add(4, "Creator"); sqlBulkCopy.ColumnMappings.Add(5, "OptDataType"); sqlBulkCopy.BatchSize = data.Rows.Count; sqlBulkCopy.BulkCopyTimeout = 30; sqlBulkCopy.DestinationTableName = tableName; sqlBulkCopy.WriteToServer(data); } if (conn.State != ConnectionState.Closed) conn.Close(); } } |
其中要注意都是:
Table表中的字段名称,字段顺序,字段类型 必须和插入的sqlBulkCopy.ColumnMappings.Add的插入顺序是一模一样的,如下图,自定义一个Class
代码如下 | 复制代码 |
public class JJJModel { public int? CarModelID { get; set; } public int TranConfID { get; set; } public string TranValue { get; set; } public int CreatorID { get; set; } public string Creator { get; set; } public int OptDataType { get; set; } } |
插入的时候的代码
代码如下 | 复制代码 |
//匹配款式Id和配置ID 拼成二维表数据 for (int i = 0; i < listCarModelID.Count(); i++) { msindex = i; for (int j = 0; j < listTranF.Count(); j++) { JJJModel jj = new JJJModel(); jj.CarModelID = Convert.ToInt32(listCarModelID[i]); //款型ID jj.TranConfID = Convert.ToInt32(listTranF[j].ToString()); //配置ID jj.TranValue = dtCMTranConf.Rows[i][j + 2].ToString().ToUpper();//值 jj.CreatorID = UserId; jj.Creator = UserName; jj.OptDataType = CarConst.OptDataType20; listTranExcel.Add(jj); } } |
异常信息:楼主刚开始写的时候也是按照上边开发,百万数据数据也是轻轻松松分分钟搞定的。可是后来,产品有提到一个要求,就是要大批量更新数据,而且也是速度很快的时间内完成。
解决SQLBulkCopy批量更新问题:
于是就想先删除 那些要插入的数据,再批量插入要更新的数据,于是乎就捋起胳膊大干一场,当然删除和批量插入肯定是同一张表(Table_A),也肯定是在同一个事务中,后来,后来竟然插入不成功,
就一直在sqlBulkCopy.WriteToServer(data);这句代码里边一直转悠,一直到sql连接超时结束调试程序。我就郁了个闷的,同样的代码怎么会出现这个问题。
后来仔细查看对比一下,原来问题是由于对同一个表(Table_A) 先删除,再批量插入的时候 都是在同一个事务中 ,因为删除的时候 就把表给lock了,当然只能插入失败了.
那怎么办呢,于是楼主就扔然 还让先删除,再插入 在同一个事务中,只是在数据做了个操作,建立一个同样和目标表(Table_A)一样的临时表(Table_Temp),在执行事务开始时候,
先把要插入的数据插入到临时表Table_Temp,然后执行存储过程,再存储过程中 删除目标表(Table_A)中的存在于临时表(Table_Temp)里边的ID条件数据.
然后再用Insert Into 目标表(Table_A) select from 临时表(Table_Temp) 的方法把临时表的数据插入到目标表(Table_A)中.这样就妥妥的完成了。
PS:存储过程中写个事务,完成不完成都要把临时表(Table_Temp)的数据清空哦 ,这个可不能忘记了
相关文章
- 光遇12.23每日任务怎么做 光遇12月23日每日任务做法攻略 12-23
- 光遇12.23大蜡烛在哪里 光遇12月23日大蜡烛位置攻略 12-23
- 光遇12.23免费魔法有什么 光遇12月23日免费魔法收集攻略 12-23
- 《流放之路2》寻找熔炉任务攻略分享 12-23
- 《流放之路2》德雷文打法技巧分享 12-23
- 《流放之路2》永恒裁判者德雷文具体位置介绍 12-23