SqlBulkCopy 高效、大数据量复制数据
2015-08-11 17:45
183 查看
SqlBulkCopy存储大批量的数据非常的高效,就像这个方法的名字一样,可以将内存中的数据表直接的一次性的存储到数据库中,而不需要一次一次的向数据库Insert数据。初次实验,百万级别的数据表,也只需几秒时间内就可以完全的存入数据库中,其速度,比传统的Insert方法不止快很多倍。
SqlBulkCopy 使用示例:
SqlBulkCopy 使用示例:
public void SqlBulkCopyDomo() { Dal.DalSql dal = new Dal.DalSql(); //获取源数据 string gongPanSql = @" select a,b,c,d from T where 条件过滤"; DataTable dtGongPan = dal.QueryByFind(gongPanSql).Tables[0];//sql帮助类 //数据复制 using (SqlConnection conn = new SqlConnection(SqlConnString)) { // Open the connection. conn.Open(); using (SqlBulkCopy bulkCopy = new SqlBulkCopy(conn)) { // 设置目标表名称 bulkCopy.DestinationTableName = "HouseBase"; bulkCopy.BulkCopyTimeout = 3600;//超时时间设置 bulkCopy.BatchSize = 1000;//分批提交记录数,可不设 // 列名映射 bulkCopy.ColumnMappings.Add("源数据列", "目标表对应列名称"); bulkCopy.ColumnMappings.Add("a", "HouseCode"); bulkCopy.ColumnMappings.Add("b", "CommName"); bulkCopy.ColumnMappings.Add("c", "FenQiName"); bulkCopy.ColumnMappings.Add("d", "Seat"); //复制数据 bulkCopy.WriteToServer(dtGongPan); } } }
相关文章推荐
- [AIR] AS3读取txt文档
- Exception in thread "main" com.sun.xml.internal.ws.client.ClientTransportException: HTTP transport e
- Container with most water
- main函数中通过使用Person类和AddressBook类,创建对象、调用方法,实现以下8个功能
- Ubuntu下编译运行Kamailio
- AIX开启telnet服务
- 十八款Hadoop工具帮你驯服大数据
- spark implementation hadoop setup,cleanup
- POJ 3068 "Shortest" pair of paths(最小费用最大流-mcmf)
- Webmin version 1.760 is now available, but you are running version 1.730.
- 2015 HUAS Summer Trainning #5~A
- Installation error: INSTALL_FAILED_INSUFFICIENT_STORAGE的报错的解决方法
- Leetcode -- Container With Most Water
- Leetcode#11||Container With Most Water
- 172 Factorial Trailing Zeroes
- HDU 1532 Drainage Ditches
- SmtpClient发邮件时为什么用MailMessage.From而不用MailMessage.Sender
- MDK __main过程分析
- 树形DP - hdu5293 Tree chain problem
- HDU - 4630 No Pain No Game (线段树 + 离线处理)