SQL Server 批量插入数据的方法

ycycoco

在SQL Server 中插入一条数据使用Insert语句，但是如果想要批量插入一堆数据的话，循环使用Insert不仅效率低，而且会导致SQL一系统性能问题。下面介绍SQL Server支持的两种批量数据插入方法：Bulk和表值参数(Table-Valued Parameters)。

• bulk方法 主要思想是通过在客户端把数据都缓存在Table中，然后利用SqlBulkCopy一次性把Table中的数据插入到数据库。
  

　　代码如下：
                     public static void BulkToDB(DataTable dt)  //将DataTable 数据批量插入到数据表

　　{  
    SqlConnection sqlConn = new SqlConnection(  
　　ConfigurationManager.ConnectionStrings["ConnStr"].ConnectionString);  
    SqlBulkCopy bulkCopy = new SqlBulkCopy(sqlConn);  

　　bulkCopy.DestinationTableName = "BulkTestTable";  //数据表名字

    bulkCopy.BatchSize = dt.Rows.Count;  
                   for (int i = 0; i < dt.Columns.Count; i++)//插入的数据列名和数据库表字段映射
                    {
                        bulkCopy.ColumnMappings.Add(dt.Columns.ToString(), dt.Columns.ToString());
                    }
　　try   {  
        sqlConn.Open();  
　　        if (dt != null && dt.Rows.Count != 0)  
             bulkCopy.WriteToServer(dt);  
　　}  catch (Exception ex)   {  
            throw ex;  
　　}  
finally  
　　{  
          sqlConn.Close();  
　　          if (bulkCopy != null)  
              bulkCopy.Close();  
　　}  
                            }

• 表值参数(Table-Valued Parameters)。表值参数是SQL Server 2008新特性，简称TVPs
  

　　代码如下：
public static void TableValuedToDB(DataTable dt)  //将DataTable 数据批量插入到数据表
　　{  
      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();  
    }  
　　}
　　
　　
　　这两种方法可以批量将数据插入SQlSERVER ,后者的速度比前者快些。