用SqlBulkCopy批量插入数据到SqlServer数据库表中

首先创建一个数据库连接类：SQLHelper

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data.SqlClient;

using System.Data;

namespace insetData

{

   public  class SQLHelper

    {

       public static readonly string Strconn = "Data Source=LocalHost;database=CardID;uid=sa;pwd=123";

        /// <summary>

        /// 创建SqlConnection对象

        /// </summary>

        /// <returns></returns>

        public static SqlConnection sqlConn()

        {

            return new SqlConnection(Strconn);

        }

        /// <summary>

        /// SQLServer批量插入数据功能

        /// 这是SQLServer特有的功能，故不再上层抽象类中编写

        /// </summary>

        /// <param name="dt">数据表</param>

        /// <param name="tableName">表名称</param>

        public static void BulkInsert(SqlConnection conn, DataTable dt, string tableName)

        {

            if (string.IsNullOrEmpty(tableName))

            {

                throw new ArgumentNullException("请指定需要插入的数据表");

            }

            var count = dt.Rows.Count;

            if (count == )

            {

                return;

            }

            if (conn.State == ConnectionState.Closed)

            {

                conn.Open();

            }

            //SqlBulkCopy用其他源的数据有效批量加载 SQL Server 表

            using (SqlBulkCopy copy = new SqlBulkCopy(conn))

            {

                copy.BatchSize = dt.Rows.Count;//每一批次中的行数。在每一批次结束时，将该批次中的行发送到服务器。 

                copy.DestinationTableName = tableName;//指定目标表

                copy.WriteToServer(dt);//将dt中的所有行复制到SqlBulkCopy对象的DestinationTableName指定的目标表中

                conn.Close();

                conn.Dispose();

            }

        }

        /// <summary>

        /// 创建数据表

        /// </summary>

        /// <param name="columns"></param>

        public static DataTable CreateTable(IList<string> columns)

        {

            var dt = new DataTable();

            foreach (var c in columns)

            {

                dt.Columns.Add(c);

            }

            return dt;

        }

        /// <summary>

        /// 批量插入数据

        /// </summary>

        /// <param name="tableName">数据表</param>

        /// <param name="columns">字段</param>

        /// <param name="dataList">数据列表</param>

        /// <param name="action">具体操作</param>

        public static void CreateInner<T>(SqlConnection conn, string tableName, IList<string> columns, IList<T> dataList, Action<DataRowWaper, T, int> action)

        {

            if (string.IsNullOrEmpty(tableName))

            {

               throw new ArgumentNullException("需要指定操作的数据表");

            }

            if (columns == null || columns.Count == )

            {

                throw new ArgumentNullException("数据表列不能为空");

            }

            var dt = CreateTable(columns);

            if (action != null)

            {

                for (var i = ; i < dataList.Count; i++)

                {

                    var wapper = new DataRowWaper(dt.NewRow());

                    action(wapper, dataList[i], i);

                    dt.Rows.Add(wapper.Row);

                }

            }

            BulkInsert(conn, dt, tableName);

        }

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data.SqlClient;

using System.Data;

namespace insetData

{

   public  class SQLHelper

    {

       public static readonly string Strconn = "Data Source=LocalHost;database=CardID;uid=sa;pwd=123";

        /// <summary>

        /// 创建SqlConnection对象

        /// </summary>

        /// <returns></returns>

        public static SqlConnection sqlConn()

        {

            return new SqlConnection(Strconn);

        }

        /// <summary>

        /// SQLServer批量插入数据功能

        /// 这是SQLServer特有的功能，故不再上层抽象类中编写

        /// </summary>

        /// <param name="dt">数据表</param>

        /// <param name="tableName">表名称</param>

        public static void BulkInsert(SqlConnection conn, DataTable dt, string tableName)

        {

            if (string.IsNullOrEmpty(tableName))

            {

                throw new ArgumentNullException("请指定需要插入的数据表");

            }

            var count = dt.Rows.Count;

            if (count == 0)

            {

                return;

            }

            if (conn.State == ConnectionState.Closed)

            {

                conn.Open();

            }

            //SqlBulkCopy用其他源的数据有效批量加载 SQL Server 表

            using (SqlBulkCopy copy = new SqlBulkCopy(conn))

            {

                copy.BatchSize = dt.Rows.Count;//每一批次中的行数。在每一批次结束时，将该批次中的行发送到服务器。 

                copy.DestinationTableName = tableName;//指定目标表

                copy.WriteToServer(dt);//将dt中的所有行复制到SqlBulkCopy对象的DestinationTableName指定的目标表中

                conn.Close();

                conn.Dispose();

            }

        }

        /// <summary>

        /// 创建数据表

        /// </summary>

        /// <param name="columns"></param>

        public static DataTable CreateTable(IList<string> columns)

        {

            var dt = new DataTable();

            foreach (var c in columns)

            {

                dt.Columns.Add(c);

            }

            return dt;

        }

        /// <summary>

        /// 批量插入数据

        /// </summary>

        /// <param name="tableName">数据表</param>

        /// <param name="columns">字段</param>

        /// <param name="dataList">数据列表</param>

        /// <param name="action">具体操作</param>

        public static void CreateInner<T>(SqlConnection conn, string tableName, IList<string> columns, IList<T> dataList, Action<DataRowWaper, T, int> action)

        {

            if (string.IsNullOrEmpty(tableName))

            {

               throw new ArgumentNullException("需要指定操作的数据表");

            }

            if (columns == null || columns.Count == 0)

            {

                throw new ArgumentNullException("数据表列不能为空");

            }

            var dt = CreateTable(columns);

            if (action != null)

            {

                for (var i = 0; i < dataList.Count; i++)

                {

                    var wapper = new DataRowWaper(dt.NewRow());

                    action(wapper, dataList[i], i);

                    dt.Rows.Add(wapper.Row);

                }

            }

            BulkInsert(conn, dt, tableName);

        }

    }

}

其次创建DataRowWaper类

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

namespace insetData

{

  public  class DataRowWaper

    {

        private DataRow row = null;

        public DataRowWaper(DataRow row)

        {

            this.row = row;

        }

        public DataRow Row

        {

            get

            {

                return this.row;

            }

        }

        public object this[DataColumn column]

        {

            get

            {

                return this.row[column];

            }

            set

            {

                this.row[column] = value;

            }

        }

        public object this[int columnIndex]

        {

            get

            {

                return this.row[columnIndex];

            }

            set

            {

                this.row[columnIndex] = value;

            }

        }

        public object this[string columnName]

        {

            get

            {

                return this.row[columnName];

            }

            set

            {

                this.row[columnName] = value;

            }

        }

        public void SetValue(string key, object value)

        {

            this.row[key] = value;

        }

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

namespace insetData

{

  public  class DataRowWaper

    {

        private DataRow row = null;

        public DataRowWaper(DataRow row)

        {

            this.row = row;

        }

        public DataRow Row

        {

            get

            {

                return this.row;

            }

        }

        public object this[DataColumn column]

        {

            get

            {

                return this.row[column];

            }

            set

            {

                this.row[column] = value;

            }

        }

        public object this[int columnIndex]

        {

            get

            {

                return this.row[columnIndex];

            }

            set

            {

                this.row[columnIndex] = value;

            }

        }

        public object this[string columnName]

        {

            get

            {

                return this.row[columnName];

            }

            set

            {

                this.row[columnName] = value;

            }

        }

        public void SetValue(string key, object value)

        {

            this.row[key] = value;

        }

    }

}

映射到数据库对象表信息People

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

namespace insetData

{

   public class People

    {

       public int id { get; set;}

       public string uname { get; set; }

       public string era { get; set; }

       public string amount { get; set; }

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

namespace insetData

{

   public class People

    {

       public int id { get; set;}

       public string uname { get; set; }

       public string era { get; set; }

       public string amount { get; set; }

    }

}

批量操作数据

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Diagnostics;

using System.Data.SqlClient;

namespace insetData

{

    class Program

    {

        static void Main(string[] args)

        {

            //构造的数据源

            List<People> list = new List<People>() 

            {

                new People(){ uname="张亮",era="中年",amount=""},

                new People(){ uname="天天",era="年轻",amount=""},

                new People(){ uname="kimi",era="年轻",amount=""}

             };

            //列名称

            var lists = new[] { "id", "uname", "era", "amount" };

            ////构建DataTable

            //DataTable dt = new DataTable();

            //foreach (var item in lists)

            //{

            //    dt.Columns.Add(item, item.GetType());

            //}

            //for (int i = 0; i < list.Count; i++)

            //{

            //    DataRow newRow = dt.NewRow();

            //   newRow["uname"] = list[i].uname;

            //    newRow["era"] = list[i].era;

            //    newRow["amount"] = list[i].amount;

            //   dt.Rows.Add(newRow);

            //}

            ////批量插入

            //SQLHelper.BulkInsert(SQLHelper.sqlConn(), dt, "Tb_People");

            //上面这段代码是直接构造的DataTable

            SQLHelper.CreateInner<People>(SQLHelper.sqlConn(), "Tb_People", lists, list,

               (curow, People, i) =>

               {

                   curow["id"] = People.id;

                   curow["uname"] = People.uname;

                   curow["era"] = People.era;

                   curow["amount"] = People.amount;

               }

               );

        }

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Diagnostics;

using System.Data.SqlClient;

namespace insetData

{

    class Program

    {

        static void Main(string[] args)

        {

            //构造的数据源

            List<People> list = new List<People>() 

            {

                new People(){ uname="张亮",era="中年",amount="100000"},

                new People(){ uname="天天",era="年轻",amount="233233"},

                new People(){ uname="kimi",era="年轻",amount="455631"}

             };

            //列名称

            var lists = new[] { "id", "uname", "era", "amount" };

            ////构建DataTable

            //DataTable dt = new DataTable();

            //foreach (var item in lists)

            //{

            //    dt.Columns.Add(item, item.GetType());

            //}

            //for (int i = 0; i < list.Count; i++)

            //{

            //    DataRow newRow = dt.NewRow();

            //   newRow["uname"] = list[i].uname;

            //    newRow["era"] = list[i].era;

            //    newRow["amount"] = list[i].amount;

            //   dt.Rows.Add(newRow);

            //}

            ////批量插入

            //SQLHelper.BulkInsert(SQLHelper.sqlConn(), dt, "Tb_People");

            //上面这段代码是直接构造的DataTable

            SQLHelper.CreateInner<People>(SQLHelper.sqlConn(), "Tb_People", lists, list,

               (curow, People, i) =>

               {

                   curow["id"] = People.id;

                   curow["uname"] = People.uname;

                   curow["era"] = People.era;

                   curow["amount"] = People.amount;

               }

               );

        }

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Diagnostics;

using System.Data.SqlClient;

namespace insetData

{

    class Program

    {

        static void Main(string[] args)

        {

            //构造的数据源

            List<People> list = new List<People>() 

            {

                new People(){ uname="张亮",era="中年",amount="100000"},

                new People(){ uname="天天",era="年轻",amount="233233"},

                new People(){ uname="kimi",era="年轻",amount="455631"}

             };

            //列名称

            var lists = new[] { "id", "uname", "era", "amount" };

            ////构建DataTable

            //DataTable dt = new DataTable();

            //foreach (var item in lists)

            //{

            //    dt.Columns.Add(item, item.GetType());

            //}

            //for (int i = 0; i < list.Count; i++)

            //{

            //    DataRow newRow = dt.NewRow();

            //   newRow["uname"] = list[i].uname;

            //    newRow["era"] = list[i].era;

            //    newRow["amount"] = list[i].amount;

            //   dt.Rows.Add(newRow);

            //}

            ////批量插入

            //SQLHelper.BulkInsert(SQLHelper.sqlConn(), dt, "Tb_People");

            //上面这段代码是直接构造的DataTable

            SQLHelper.CreateInner<People>(SQLHelper.sqlConn(), "Tb_People", lists, list,

               (curow, People, i) =>

               {

                   curow["id"] = People.id;

                   curow["uname"] = People.uname;

                   curow["era"] = People.era;

                   curow["amount"] = People.amount;

               }

               );

        }

    }

}

用SqlBulkCopy批量插入数据到SqlServer数据库表中的更多相关文章

&period;Net批量插入数据到SQLServer数据库,System&period;Data&period;SqlClient&period;SqlBulkCopy类批量插入大数据到数据库
批量的的数据导入数据库中,尽量少的访问数据库,高性能的对数据库进行存储. 采用SqlBulkCopy来处理存储数据.SqlBulkCopy存储大批量的数据非常的高效,将内存中的数据表直接的一次性的存储 ...
C&num;批量插入数据到Sqlserver中的四种方式
我的新书ASP.NET MVC企业级实战预计明年2月份出版,感谢大家关注! 本篇,我将来讲解一下在Sqlserver中批量插入数据. 先创建一个用来测试的数据库和表,为了让插入数据更快,表中主键采用的 ...
C&num;批量插入数据到Sqlserver中的三种方式
本篇,我将来讲解一下在Sqlserver中批量插入数据. 先创建一个用来测试的数据库和表,为了让插入数据更快,表中主键采用的是GUID,表中没有创建任何索引.GUID必然是比自增长要快的,因为你生成 ...
C&num;&lowbar;批量插入数据到Sqlserver中的四种方式
先创建一个用来测试的数据库和表,为了让插入数据更快,表中主键采用的是GUID,表中没有创建任何索引.GUID必然是比自增长要快的,因为你生成一个GUID算法所花的时间肯定比你从数据表中重新查询上一条记 ...
C&num; 之批量插入数据到 SQLServer 中
创建一个用来测试的数据库和表,为了让插入数据更快,表中主键采用的是GUID,表中没有创建任何索引.GUID必然是比自增长要快.而如果存在索引的情况下,每次插入记录都会进行索引重建,这是非常耗性能的.如 ...
C&num;批量插入数据到Sqlserver中的四种方式 - 转
先创建一个用来测试的数据库和表,为了让插入数据更快,表中主键采用的是GUID,表中没有创建任何索引.GUID必然是比自增长要快的,因为你生成一个GUID算法所花的时间肯定比你从数据表中重新查询上一条记 ...
【转载】C&num;批量插入数据到Sqlserver中的三种方式
引用:https://m.jb51.net/show/99543 这篇文章主要为大家详细介绍了C#批量插入数据到Sqlserver中的三种方式,具有一定的参考价值,感兴趣的小伙伴们可以参考一下本篇, ...
sql 中的Bulk和C&num; 中的SqlBulkCopy批量插入数据（回顾 and 粗谈）
通常,我们会对于一个文本文件数据导入到数据库中,不多说,上代码. 首先,表结构如下. 其次,在我当前D盘中有个文本文件名为2.txt的文件. 在数据库中,可以这样通过一句代码插入. Bulk in ...
SqlBulkCopy批量插入数据时，不执行触发器和约束的解决方法
原文:SqlBulkCopy批量插入数据时,不执行触发器和约束的解决方法在new SqlBulkCopy对象的时候,设置一下SqlBulkCopyOptions选项即可,按位或运算 SqlBulkC ...

随机推荐

Backbone源码解析（五）：Route和History（路由）模块
今天是四月十二号,距离上次写博已经将近二十天了.一直忙于工作,回家被看书的时间占用了.连续两个礼拜被频繁的足球篮球以及各种体育运动弄的精疲力竭,所以很少抽时间来写技术博客.今天抽出时间把backbon ...
img会在特定的情况下主动的第二次调用MVC的action
当img的src为空,或者不是合法路径的时候,会连续调用MVC的action两次,第二次所传的值为src的值,这常常会导致程序报错. 这不是MVC的issue,而是浏览器的行为,当response f ...
统一回复《怎么学JavaScript？》
作者:小不了链接:https://zhuanlan.zhihu.com/p/23265155来源:知乎著作权归作者所有.商业转载请联系作者获得授权,非商业转载请注明出处. 鉴于时不时,有同学私信问我( ...
js 判断微信浏览器
上周接到个需求,需求是这样的:用户扫一扫二维码会产生一个链接,该链接会向后端发送个请求,返回一个 apk 的下载地址,用户点击下载按钮可以下载此 apk.然后就发生了问题,经过测试,发现用微信扫一扫打 ...
sublimeText插件推荐
工欲善其事必先利其器.sublimeText是前端开发工程师的一把利器,它的优点包含: 随时保留文件的修改 Goto Anything,智能搜索; 简单全面的插件体系; 代码地图; 快速启动 ... ...
Oracle的AUTOTRACE功能
ORACLE9i在使用autotrace之前,需要作一些初始设置: 1.用sys用户运行脚本utlxplan.sql创建PLAN_TABLE表脚本目录:(UNIX:$ORACLE_HOME/rdbm ...
常用开源GIS项目
常用开源GIS项目常用开源桌面GIS软件 QGIS 始于2002年5月,算得上是开源GIS平台中的后起之秀.界面友好,分析功能可与GRASS GIS相媲美.主页:http://www.qgi ...
dict&period;get(&&num;39&semi;key&&num;39&semi;)和dict[&&num;39&semi;key&&num;39&semi;]的区别
dict['key']只能获取存在的值,如果不存在会触发KeyError dict.get('key', default=None)如果不存在,返回一个默认值
Java：网络编程
一.因特网地址 InetAddress类:实现主机名和因特网地址之间的转换. InetAddress address=InetAddress.getByName(String);返回一个InetAdd ...
Blockly编程：用Scratch制作游戏愤怒的小牛（小鸟）
愤怒的小鸟曾经很热门,网上还说他是程序员最喜欢玩的游戏.最先我是WIKIOI的评测页面看到他的,后来在2014年全国信息学奥林匹克联赛第一天第三题飞扬的小鸟也看到了它.因此,突然想做一个类似愤怒的小鸟 ...