zoukankan      html  css  js  c++  java
  • 表数据的批量插入

          当一个表要插入数据库时,手动编写sql插入语句是不太现实的,效率也比较低。

          我用的是SqlBulkCopy

    View Code
            public void ExecuteTransactionScopeInsertEx(DataTable dt, string tableName)
            {
                using (SqlBulkCopy sbc = new SqlBulkCopy(Common.ConnStr, SqlBulkCopyOptions.UseInternalTransaction))
                {
                    //服务器上目标表的名称   
                    sbc.DestinationTableName = tableName;
                    sbc.BatchSize = dt.Rows.Count;
                    sbc.BulkCopyTimeout = 600;
    
                    for (int i = 0, l = dt.Columns.Count; i < l; i++)
                    {
                        //列映射定义数据源中的列和目标表中的列之间的关系   
                        sbc.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
                    }
    
                    sbc.WriteToServer(dt);
                }
            }

          如果表的列名与数据库的列名不能一一对应,则需重载上述方法

    View Code
            public void ExecuteTransactionScopeInsertEx(DataTable dt, string tableName, string[] dbComlunName)
            {
                using (SqlBulkCopy sbc = new SqlBulkCopy(Common.ConnStr, SqlBulkCopyOptions.UseInternalTransaction))
                {
                    //服务器上目标表的名称   
                    sbc.DestinationTableName = tableName;
                    sbc.BatchSize = dt.Rows.Count;
                    sbc.BulkCopyTimeout = 600;
    
                    for (int i = 0, l = dt.Columns.Count; i < l; i++)
                    {
                        //列映射定义数据源中的列和目标表中的列之间的关系   
                        sbc.ColumnMappings.Add(dt.Columns[i].ColumnName, dbComlunName[i]);
                    }
    
                    sbc.WriteToServer(dt);
                }
            }

          如果需要自己指定控件的哪些列对应数据库的哪些列,则又需要重载

    View Code
            public void ExecuteTransactionScopeInsertEx(DataTable dt, string tableName, string[] displayName, string[] dbComlunName)
            {
                using (SqlBulkCopy sbc = new SqlBulkCopy(Common.ConnStr, SqlBulkCopyOptions.UseInternalTransaction))
                {
                    //服务器上目标表的名称   
                    sbc.DestinationTableName = tableName;
                    sbc.BatchSize = dt.Rows.Count;
                    sbc.BulkCopyTimeout = 600;
    
                    for (int i = 0, l = dt.Columns.Count; i < l; i++)
                    {
                        //列映射定义数据源中的列和目标表中的列之间的关系   
                        sbc.ColumnMappings.Add(displayName[i], dbComlunName[i]);
                    }
    
                    sbc.WriteToServer(dt);
                }
            }

          这样子基本可以解决表的批量插入了。不过如果是修改而不是插入呢。我的做法是先将该表原来需要修改的数据全删除,再执行本方法。

          至于有更好的方法,我暂时还没有想到。。。还有这三个重载的方法如果归并为一个方法我也暂时没有想到很好的方法。。。

  • 相关阅读:
    Java秒杀系统实战系列~整合RabbitMQ实现消息异步发送
    Java秒杀系统实战系列~分布式唯一ID生成订单编号
    Java秒杀系统实战系列~商品秒杀代码实战
    Java秒杀系统实战系列~整合Shiro实现用户登录认证
    Java秒杀系统实战系列~待秒杀商品列表与详情功能开发
    Java秒杀系统实战系列~整体业务流程介绍与数据库设计
    Java秒杀系统实战系列~构建SpringBoot多模块项目
    重磅发布- Java秒杀系统的设计与实战视频教程(SpringBoot版)
    ct
    mysql 分区表
  • 原文地址:https://www.cnblogs.com/hambert/p/3065229.html
Copyright © 2011-2022 走看看