SqlBulkCopy 快速插入数据到SqlServer 数据库

php中文网

发布时间：2016-06-07 15:33:57

1860人浏览过

来源于php中文网

原创

向SQL Server中导入大量数量可以用bulk insert，但是必须要求插入的文件在数据库机器上或者一个数据库可以访问的共享文件夹中（我不知道怎么设置共享文件夹，以使得SQL Server能访问到） SqlBulkCopy 是.net中的一个类，提供了导入大量数据的功能。

向sql server中导入大量数量可以用bulk insert，但是必须要求插入的文件在数据库机器上或者一个数据库可以访问的共享文件夹中（我不知道怎么设置共享文件夹，以使得sql server能访问到）

SqlBulkCopy 是.net中的一个类，提供了导入大量数据的功能。

基本用法如下：

using (SqlBulkCopy bc = new SqlBulkCopy(sqlConn, SqlBulkCopyOptions.TableLock | SqlBulkCopyOptions.UseInternalTransaction, null))
{
     bc.BulkCopyTimeout = 10 * 60;
     bc.BatchSize = 10000;
     bc.DestinationTableName = "dbo.Destination";
     bc.WriteToServer(reader); //reader 是一个继承自IDataReader的类的实例
}

自己可以写代码来实现继承自IDataReader的类。有n多成员要实现。。。

比如FieldCount， Read()， GetValue(int i)， Close()等

SmartB2B行业电子商务

SmartB2B 是一款基于PHP、MySQL、Smarty的B2B行业电子商务网站管理系统，系统提供了供求模型、企业模型、产品模型、人才招聘模型、资讯模型等模块，适用于想在行业里取得领先地位的企业快速假设B2B网站，可以运行于Linux与Windows等多重服务器环境，安装方便，使用灵活。系统使用当前流行的PHP语言开发，以MySQL为数据库，采用B/S架构，MVC模式开发。融入了模型化、模板

下载

下面是一个读文件的例子：

//返回记录的列数
        public int FieldCount  
        {
             get { return 3; }
        }

        //读记录，此方法会被自动调用
        public bool Read()
        {
            if (_Reader == null)
                _Reader = new StreamReader(_FilePath);

            string line = _Reader.ReadLine();
            
            if (line != null)
            {
                _CurrentQueryItem = GetRawData(line);
                _Count++;

                while (_CurrentQueryItem == null)//如果读出的是不满足条件的记录，则读下一条记录
                {
                    Read();
                }
                return true;
            }            
            return false;
        }

        //返回一条记录中第i 列（项）的值，此方法会被自动调用
    //SqlBulkCopy内部应该有一个循环，从0到FieldCount -1 ，再调用GetValue(int i)这个方法。我猜的。。。
        public object GetValue(int i)
        {
            if (_CurrentQueryItem == null)
                return null;

            switch (i)
            {
                //如果数据库中表的第一列是自增字段，则会忽略第一列，也就是说此方法被调用时，i只会从1开始，所以不需要case 0的情况。估计.net内部去取目的表的schema，自动判断哪些列是需要从外部导入的。有空再研究这个问题
                case 0:
                    return _CurrentQueryItem.Item1;
                case 1:
                    return _CurrentQueryItem.Item2;
                case 2:
                    return _CurrentQueryItem.Item3;
                default:
                    throw new IndexOutOfRangeException();
            }
        }

        //释放资源
        public void Close()
        {
            Dispose();
        }

        public void Dispose()
        {
            if (_Reader != null)
                _Reader.Close();
        }