SQL批量插入表类 SqlBulkInsert

ado.net已经有了sqlBulkCopy, 但是那个用xml格式，网络传输数据量太大。

自己实现了一个，传输尽量少的字节。 性能没对比过，有需要的自己拿去测试。

  1 using System.Data.SqlClient;
  2
  3 namespace RaywindStudio.DAL {
  4
  5     /// <summary>
  6     /// MSSQL批量插入表
  7     /// </summary>
  8     public static class SqlBulkInsert {
  9
 10         private static bool initsql = false;
 11
 12         /// <summary>
 13         /// SQL批量插入表 过程
 14         /// </summary>
 15         /// <param name="tableName">表名</param>
 16         /// <param name="fields">字段，逗号分隔</param>
 17         /// <param name="Values">字段值，逗号分隔</param>
 18         /// <param name="RowSplit">Values行间分隔符</param>
 19         /// <param name="RowCount">Values行数</param>
 20         /// <param name="conn">Sql Connection</param>
 21         /// <returns></returns>
 22         public static bool BulkInsert(string tableName, string fields, string Values, string RowSplit, int RowCount,
 23             SqlConnection conn) {
 24             initSql(conn);
 25             string ret= SqlAdo.ExecuteScalar("EXEC [dbo].[pSqlBulkInsert]"
 26                 + " @tableName=N‘" + tableName
 27                 + "‘,@fields=N‘" + fields
 28                 + "‘,@values=N‘" + Values
 29                 + "‘,@split=N‘" + RowSplit
 30                 + "‘,@rowCount=" + RowCount.ToString(), conn).ToString();
 31             return ret == "0";
 32         }
 33         private static void initSql(SqlConnection sqlconn) {
 34             if (!initsql) {
 35                 SqlAdo.ExecuteNonQuery(
 36                 @"IF not EXISTS (SELECT * FROM dbo.SysObjects
 37                             WHERE ID = object_id(N‘[fGetArrayStr]‘)
 38                                 and OBJECTPROPERTY(ID,‘IsScalarFunction‘)=1)
 39                             begin
 40                             exec(
 41                                 ‘CREATE function fGetArrayStr
 42                                 (
 43                                     @str nvarchar(max), --字符串
 44                                     @split nvarchar(10), --分隔符
 45                                     @index int --取第几个元素
 46                                     )
 47                                 returns nvarchar(4000)
 48                                 as
 49                                 begin
 50                                     declare @location int
 51                                     declare @start int
 52                                     declare @next int
 53                                     declare @seed int
 54                                     set @str=ltrim(rtrim(@str))
 55                                     set @start=1
 56                                     set @next=1
 57                                     set @seed=len(@split)
 58                                     set @location=charindex(@split,@str)
 59                                     while @location<>0 and @index>@next
 60                                     begin
 61                                     set @[email protected][email protected]
 62                                     set @location=charindex(@split,@str,@start)
 63                                     set @[email protected]+1
 64                                     end
 65                                     if @location =0 set @location =len(@str)+1
 66                                 return substring(@str,@start,@[email protected])
 67                                 end‘)
 68                             end", sqlconn);
 69
 70                 SqlAdo.ExecuteNonQuery(
 71                     @"IF not EXISTS (SELECT * FROM dbo.SysObjects
 72                         WHERE ID = object_id(N‘[pSqlBulkInsert]‘)
 73                             and OBJECTPROPERTY(ID,‘IsProcedure‘)=1)
 74                             begin
 75                             exec(
 76                                 ‘Create proc pSqlBulkInsert
 77                                 @tableName nvarchar(50),
 78                                 @fields nvarchar(500),
 79                                 @values nvarchar(max),
 80                                 @split nvarchar(5),
 81                                 @rowCount int
 82                                 as
 83                                 declare @next int =1
 84                                 declare @sql nvarchar(500)=N‘ Insert Into ‘[email protected] +N‘(‘[email protected] +N‘) Values(‘
 85                                 declare @sqlTmp nvarchar(4000)
 86                                 Begin tran
 87                                     while @next<[email protected]
 88                                     begin
 89                                     set @[email protected]+dbo.fGetArrayStr(@values,@split,@next)+N‘)‘
 90                                     Exec(@sqlTmp)
 91                                     if(@@error<>0)
 92                                         begin
 93                                             rollback
 94                                             return -1
 95                                         end
 96                                         set @[email protected]+1
 97                                     end
 98                                 commit
 99                                 return 0", sqlconn);
100
101                 initsql = true;
102             }
103         }
104     }
105 }