C# 快速插入大量数据到数据库中

有时需要通过C#一次性插入或更新大量数据到SQL Server中，使用insert into/update这种方式就会变得异常缓慢，这个时候可以使用到表值参数来一次性插入或更新大量数据。需要注意，UpdateSale方法table参数的结构需要和表自定义类型结构、数据库表结构一样，比如下面的Type_SaleUpdate表自定义类型有id、Name、CreateDate三个字段，那么传进来的table参数也要有这三个字段，总之table参数的结构要和表自定义类型、数据库表一样。下面是具体代码：

 

public static void UpdateSale(DataTable table)
{
　　if (table.Rows.Count <= 0)
　　return;
　　List<string> sqlList = new List<string>()
　　{
　　　　"if exists(select * from sys.objects where name = 'DownLoad_SaleInsertProc') drop proc DownLoad_SaleInsertProc",  //判断存储过程是否存在，存在即删除
　　　　"if exists(select * from sys.types where name = 'Type_SaleInsert') drop type Type_SaleInsert",                    //判断表自定义类型是否存在，存在即删除
　　　　"if exists(select * from sys.objects where name = 'DownLoad_SaleUpdateProc') drop proc DownLoad_SaleUpdateProc",
　　　　"if exists(select * from sys.types where name = 'Type_SaleUpdate') drop type Type_SaleUpdate",

　　　　@"create type Type_SaleUpdate as table(       //创建表自定义类型
　　　　Id uniqueidentifier not null,
　　　　Name nvarchar(20) not null,
　　　　CreateDate datetime )",

　　　　@"create proc DownLoad_SaleUpdateProc(@Table Type_SaleUpdate readonly)   //创建存储过程，使用表值参数更新表数据
　　　　as
　　　　begin
　　　　update Sale set
　　　　id=b.id,Name =b.Name,CreateDate =b.CreateDate from Sale a
　　　　left join @Tableb on b.id = a.id where b.id is not null
　　　　end;",

　　　　@"create type Type_SaleInsert as table(   //创建表自定义类型
　　　　Id uniqueidentifier not null,
　　　　Name nvarchar(20) not null,
　　　　CreateDate datetime )",

　　　　@"create proc DownLoad_SaleInsertProc(@Table Type_SaleInsert readonly)  //创建存储过程，使用表值参数插入数据
　　　　as
　　　　begin
　　　　insert into Sale select distinct a.* from @Table a
　　　　where (select count(1) from Sale b where a.id = b.id) = 0
　　　　end;"
　　};
　　SqlParameter[] sqlsUpdate = new SqlParameter[] {new SqlParameter("@Table", SqlDbType.Structured){ TypeName = "Type_SaleUpdate",Value = table}};  //设置表值参数的值，以及表值参数的数据类型
　　SqlParameter[] sqlsInsert = new SqlParameter[] {new SqlParameter("@Table", SqlDbType.Structured){ TypeName = "Type_SaleInsert",Value = table}};
　　UserData.ExecuteNonQueryProc("", sqlList);   //执行建表，创建存储过程等SQL语句
　　UserData.ExecuteNonQueryProc("", "DownLoad_SaleUpdateProc", sqlsUpdate);   //使用存储过程更新数据
　　UserData.ExecuteNonQueryProc("", "DownLoad_SaleInsertProc", sqlsInsert);    //使用存储过程插入数据
}