ADO.net--SqlBulkCopy批量插入数据

通常状况下,咱们在向数据库中插入数据时用Insert语句,可是当数据量很大的时候,这种状况就比较缓慢了,这个时候就须要SqlBulkCopy这个类。web

SqlBulkCopy自己经常使用的函数有这么几个数据库

DestinationTableName-----服务器目标表上的名称,也就是你要向哪一个表插入大量的数据,这个就设置为那个表名c#

ColumnMappings-----字段映射,由于是要在本地创建一个Table,而后将整个Table一次性的加入到数据库中,所以须要将本地的Table的字段和数据库表中的字段作好映射关系数组

WriteToServer-----这个就是写入数据库了,不须要多说服务器

导入的数据是传智播客免费视频上提供的手机号码归属地的信息,插入数据库看了一下,一共有258113条数据,用时大概6秒吧。app

private void btnDR_Click(object sender, RoutedEventArgs e)
        {
            OpenFileDialog ofd = new OpenFileDialog();
            ofd.Filter = "文本文件|*.txt";
            if(ofd.ShowDialog()!=true)
            {
                return;
            }
            DateTime time = DateTime.Now;//计时,看看花了多长时间
            
            DataTable table = new DataTable();//本地建立一个临时表
            //给临时表添加列名
            table.Columns.Add("HD");
            table.Columns.Add("DQ");
            table.Columns.Add("LX");
            using(StreamReader streamReader=new StreamReader(ofd.FileName,Encoding.Default))//读取文件
            {
                while(!streamReader.EndOfStream)
                {
                    string[] stringStream = streamReader.ReadLine().Split('\t');//按行读取,经过\t进行分割,获得数组
                    string HD = stringStream[0].Trim('"');
                    string DQ = stringStream[1].Trim('"');
                    string LX = stringStream[2].Trim('"');
                    //将数据插入到本地建立的临时表里
                    DataRow row = table.NewRow();
                    row["HD"] = HD;
                    row["DQ"] = DQ;
                    row["LX"] = LX;
                    table.Rows.Add(row);
                }
            }
            //这部分就是从本地导入到数据库中
            using(SqlConnection conn=new SqlConnection("Data Source=.;Initial Catalog=imageprocess;Integrated Security=True"))
            {
                conn.Open();
                using(SqlBulkCopy bulkCopy=new SqlBulkCopy(conn))
                {
                    bulkCopy.DestinationTableName = "T_HM";
                    bulkCopy.ColumnMappings.Add("HD", "HD");//前面的参数是本地的临时Table列名,后面的参数是数据库的列名。两个名称不须要相同,我写相同,是为了方便
                    bulkCopy.ColumnMappings.Add("DQ", "DQ");
                    bulkCopy.ColumnMappings.Add("LX", "LX");
                    bulkCopy.WriteToServer(table);
                }
            }
            TimeSpan TS = DateTime.Now - time;
            MessageBox.Show(TS.ToString());           
        }
相关文章
相关标签/搜索