码迷,mamicode.com
首页 > 数据库 > 详细

批量插入数据到sqlserver

时间:2015-06-01 14:36:54      阅读:211      评论:0      收藏:0      [点我收藏+]

标签:

 第一种方法:
Insert
部分数据还ok 批量数据性能问题。
第二种方法:
sqlbulkcopy 方法 主要思想 是在客户端将数据缓存到datatable里面,然后用sqlbulkcopy 一次性将数据插入到数据库表中
方法如下:

            System.Data.SqlClient.SqlBulkCopy bcp = new System.Data.SqlClient.SqlBulkCopy(connectionString);
            //指定目标数据库的表名
            bcp.DestinationTableName = "resulttable";
            //建立数据源表字段和目标表中的列之间的映射
            bcp.ColumnMappings.Add("sheetname", "sheetname");
            bcp.ColumnMappings.Add("meters", "公里标");
            bcp.ColumnMappings.Add("twista", "twista");
            //写入数据库表 dt 是数据源DataTable
            bcp.WriteToServer(dt);
            //关闭SqlBulkCopy实例

            bcp.Close(); 
如果主键冲突会回滚插入操作,所以要么保证无冲突要么建临时表! 
第三种方法:
表值参数 tvps 需要先在sql上建立表值参数

--Create DataBase
create database BulkTestDB;
go
use BulkTestDB;
go
--Create Table
Create table BulkTestTable(
Id int primary key,
UserName nvarchar(32),
Pwd varchar(16))
go
--Create Table Valued
CREATE TYPE BulkUdt AS TABLE
  (Id int,
   UserName nvarchar(32),

   Pwd varchar(16)) 

public static void TableValuedToDB(DataTable dt)
{
    SqlConnection sqlConn = new SqlConnection(
      ConfigurationManager.ConnectionStrings["ConnStr"].ConnectionString);
    const string TSqlStatement =
     "insert into BulkTestTable (Id,UserName,Pwd)" +
     " SELECT nc.Id, nc.UserName,nc.Pwd" +
     " FROM @NewBulkTestTvp AS nc";
    SqlCommand cmd = new SqlCommand(TSqlStatement, sqlConn);
    SqlParameter catParam = cmd.Parameters.AddWithValue("@NewBulkTestTvp", dt);
    catParam.SqlDbType = SqlDbType.Structured;
    //表值参数的名字叫BulkUdt,在上面的建立测试环境的SQL中有。
    catParam.TypeName = "dbo.BulkUdt";
    try
    {
      sqlConn.Open();
      if (dt != null && dt.Rows.Count != 0)
      {
          cmd.ExecuteNonQuery();
      }
    }
    catch (Exception ex)
    {
      throw ex;
    }
    finally
    {
      sqlConn.Close();
    }
}


datatable序列化成json
调用jsonnet库
jsondata = JsonConvert.SerializeObject(dt, new DataTableConverter());

批量插入数据到sqlserver

标签:

原文地址:http://www.cnblogs.com/smallxin/p/4543824.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!