当前位置:Gxlcms > mssql > SQLServer中数据行批量插入脚本的存储实现

SQLServer中数据行批量插入脚本的存储实现

时间:2021-07-01 10:21:17 帮助过:61人阅读

无意中看到朋友写的一篇文章“将表里的数据批量生成INSERT语句的存储过程的实现”。我仔细看文中的两个存储代码,自我感觉两个都不太满意,都是生成的单行模式的插入,数据行稍微大些性能会受影响的。所在公司本来就存在第二个版本的类似实现,但是是基于多行模式的,还是需要手工添加UNAION ALL来满足多行模式的插入。看到这篇博文和基于公司数据行批量脚本的存储的缺点,这次改写和增强该存储的功能。

   本存储运行于SQL Server 2005或以上版本,T-SQL代码如下:

  1. IF OBJECT_ID(N'dbo.usp_GetInsertSQL', 'P') IS NOT NULL
  2. BEGIN
  3. DROP PROCEDURE dbo.usp_GetInsertSQL;
  4. END
  5. GO
  6. --==================================
  7. -- 功能: 获取数据表记录插入的SQL脚本
  8. -- 说明: 具体实现阐述
  9. -- 作者: XXX
  10. -- 创建: yyyy-MM-dd
  11. -- 修改: yyyy-MM-dd XXX 修改内容描述
  12. --==================================
  13. CREATE PROCEDURE dbo.usp_GetInsertSQL
  14. (
  15. @chvnTable NVARCHAR(), -- 数据表名称(建议只使用表名称,不要带有分隔符[])
  16. @chvnWhere NVARCHAR() = N'', -- where查询条件(不带WHERE关键字)
  17. @bitIsSingleRow BIT = -- 是否单行模式,默认为单行模式(单行模式为单行INSERT INTO VALUES格式;非单行模式(多行模式)为多行INSERT INTO SELECT格式)
  18. )
  19. --$Encode$--
  20. AS
  21. BEGIN
  22. SET NOCOUNT ON;
  23. SET @bitIsSingleRow = ISNULL(@bitIsSingleRow, );
  24. DECLARE
  25. @intTableID AS INT,
  26. @chvnSchemaTableName NVARCHAR();/*格式:[schema].[table]--++++++(各部分对应字符数)*/
  27. SELECT
  28. @intTableID = ,
  29. @chvnSchemaTableName = N'';
  30. SELECT
  31. @intTableID = object_id
  32. ,@chvnSchemaTableName = QUOTENAME(SCHEMA_NAME(schema_id)) + N'.' + QUOTENAME(@chvnTable) /*组合架构名称和表名称的连接*/
  33. FROM sys.objects
  34. WHERE name = @chvnTable
  35. AND type = 'U';
  36. DECLARE
  37. @chvnColumnNames NVARCHAR(), -- 字段列名集,多个以逗号','分隔,格式如:[column_name],[column_name],...
  38. @chvnColumnValues AS NVARCHAR(MAX); -- 字段列值集,多个以逗号','分隔
  39. DECLARE
  40. @chvnTSQL AS NVARCHAR(MAX), -- TSQL脚本变量
  41. @chvnInsertIntoBoday AS NVARCHAR(); -- InsertInto主体变量
  42. SELECT
  43. @chvnTSQL = N'',
  44. @chvnInsertIntoBoday = N'';
  45. SELECT
  46. @chvnColumnNames = ISNULL(@chvnColumnNames + N',', N'') + QUOTENAME(T.column_name)
  47. ,@chvnColumnValues = ISNULL(@chvnColumnValues + N' + '','' + ', N'') + CAST(T.column_value AS NVARCHAR())
  48. FROM (SELECT
  49. name AS column_name /*字段列名*/
  50. /*字段列值*/
  51. ,column_value = CASE
  52. WHEN system_type_id IN (, , , , , , , , , , ) /*数字数据类型:整数数据类型(bit、tinyint、smallint、int、bigint),带精度和小数的数据类型(decimal、numeric)和货币数据类型(monery和smallmoney*/
  53. THEN 'CASE WHEN '+ name + ' IS NULL THEN ''NULL'' ELSE CAST(' + name + ' AS VARCHAR) END'
  54. WHEN system_type_id IN (, , , , ) /*日期和时间数据类型:datetime、smalldatetime(兼容sql server 新增 date、datetime和time)*/
  55. THEN 'CASE WHEN '+ name + ' IS NULL THEN ''NULL'' ELSE '''''''' + REPLACE(CONVERT(VARCHAR(), ' + name + ', ), '' ::.'', '''') + '''''''' END'
  56. WHEN system_type_id IN () /*字符串数据类型:varchar*/
  57. THEN 'CASE WHEN '+ name + ' IS NULL THEN ''NULL'' ELSE '''''''' + REPLACE(' + name + ', '''''''', '''''''''''') + '''''''' END'
  58. WHEN system_type_id IN () /*Unicode字符串数据类型:nvarchar*/
  59. THEN 'CASE WHEN '+ name + ' IS NULL THEN ''NULL'' ELSE ''N'''''' + REPLACE(' + name + ', '''''''','''''''''''') + '''''''' END'
  60. WHEN system_type_id IN () /*字符串数据类型:char*/
  61. THEN 'CASE WHEN '+ name + ' IS NULL THEN ''NULL'' ELSE '''''''' + CAST(REPLACE(' + name + ', '''''''' ,'''''''''''') AS CHAR(' + CAST(max_length AS VARCHAR) + ')) + '''''''' END'
  62. WHEN system_type_id IN () /*nicode字符串数据类型:nchar*/
  63. THEN 'CASE WHEN '+ name + ' IS NULL THEN ''NULL'' ELSE ''N'''''' + CAST(REPLACE(' + name + ', '''''''' ,'''''''''''') AS CHAR(' + CAST(max_length AS VARCHAR) + ')) + '''''''' END'
  64. ELSE '''NULL''' END
  65. FROM sys.columns
  66. WHERE object_id = @intTableID
  67. ) AS T;
  68. SET @chvnInsertIntoBoday = N'''INSERT INTO '+ @chvnSchemaTableName + N' (' + @chvnColumnNames + N')''';
  69. -- 方式一、代码格式使用了GOTO和Label
  70. --BEGIN
  71. -- IF @bitIsSingleRow = /*多行模式*/
  72. -- BEGIN
  73. -- SET @chvnTSQL = N'SELECT ''SELECT '' + ' + @chvnColumnValues + ' AS RowData, ROW_NUMBER() OVER(ORDER BY (SELECT NULL)) AS RowNum FROM ' + @chvnSchemaTableName
  74. -- -- 此处不能使用GOTO WhereCondition;,因为之后的代码不会被执行
  75. -- IF @chvnWhere > ''
  76. -- BEGIN
  77. -- SET @chvnTSQL = @chvnTSQL + ' WHERE ' + @chvnWhere;
  78. -- END
  79. -- -- 处理多行模式,需要使用ROW_NUMBER窗口函数
  80. -- SET @chvnTSQL = N'SELECT CASE WHEN T.rownum = THEN REPLICATE(N'' '', LEN(N''UNION ALL '') + ) + T.RowData ELSE N''UNION ALL '' + T.RowData END' +
  81. -- N' FROM (' + @chvnTSQL + N') AS T';
  82. -- SET @chvnTSQL = N'SELECT '+ @chvnInsertIntoBoday + N';' +
  83. -- @chvnTSQL;
  84. -- GOTO MultiRow;
  85. -- END
  86. -- ELSE IF @bitIsSingleRow = /*当行模式*/
  87. -- BEGIN
  88. -- SET @chvnTSQL = N'SELECT ' + @chvnInsertIntoBoday +
  89. -- N' + ''VALUES('' + ' + @chvnColumnValues + ' + '');'' FROM ' + @chvnSchemaTableName;
  90. -- GOTO WhereCondition;
  91. -- END
  92. -- -- where查询条件
  93. -- WhereCondition:
  94. -- IF @chvnWhere > ''
  95. -- BEGIN
  96. -- SET @chvnTSQL = @chvnTSQL + ' WHERE ' + @chvnWhere;
  97. -- END
  98. -- MultiRow:/*多行模式GOTO的Label空标记*/
  99. --END
  100. -- 方式二、存在部分代码的冗余
  101. BEGIN
  102. IF @bitIsSingleRow = /*多行模式*/
  103. BEGIN
  104. SET @chvnTSQL = N'SELECT ''SELECT '' + ' + @chvnColumnValues + ' AS RowData, ROW_NUMBER() OVER(ORDER BY (SELECT NULL)) AS RowNum FROM ' + @chvnSchemaTableName
  105. IF @chvnWhere > ''
  106. BEGIN
  107. SET @chvnTSQL = @chvnTSQL + ' WHERE ' + @chvnWhere;
  108. END
  109. -- 多行模式特殊代码,需要使用ROW_NUMBER窗口函数
  110. SET @chvnTSQL = N'SELECT CASE WHEN T.rownum = THEN REPLICATE(N'' '', LEN(N''UNION ALL '') + ) + T.RowData ELSE N''UNION ALL '' + T.RowData END' +
  111. N' FROM (' + @chvnTSQL + N') AS T';
  112. SET @chvnTSQL = N'SELECT '+ @chvnInsertIntoBoday + N';' +
  113. @chvnTSQL;
  114. END
  115. ELSE IF @bitIsSingleRow = /*单行模式*/
  116. BEGIN
  117. SET @chvnTSQL = N'SELECT ' + @chvnInsertIntoBoday +
  118. N' + ''VALUES('' + ' + @chvnColumnValues + ' + '');'' FROM ' + @chvnSchemaTableName;
  119. IF @chvnWhere > ''
  120. BEGIN
  121. SET @chvnTSQL = @chvnTSQL + ' WHERE ' + @chvnWhere;
  122. END
  123. END
  124. END
  125. PRINT @chvnTSQL;
  126. EXEC(@chvnTSQL);
  127. END
  128. GO

    为了测试以上存储的效果,下面准备一个有数据的数据表,T-SQL代码如下:

  1. IF OBJECT_ID(N'dbo.UserLoginInfo', N'U') IS NOT NULL
  2. BEGIN
  3. DROP TABLE dbo.UserLoginInfo;
  4. END
  5. GO
  6. -- create testing table UserLoginInfo
  7. CREATE TABLE dbo.UserLoginInfo (
  8. ID INT IDENTITY(, ) PRIMARY KEY,
  9. Name VARCHAR() NOT NULL,
  10. LoginTime DATETIME NOT NULL
  11. );
  12. GO
  13. -- insert testing data
  14. INSERT dbo.UserLoginInfo (Name, LoginTime) VALUES
  15. ('zhang', '-- ::')
  16. ,('li', '-- ::')
  17. ,('wang', '-- ::')
  18. ,('zhang', '-- ::')
  19. ,('li', '-- ::')
  20. ,('wang', '-- ::')
  21. ,('zhang', '-- ::')
  22. ,('li', '-- ::')
  23. ,('wang', '-- ::')
  24. ,('zhang', '-- ::')
  25. ,('li', '-- ::')
  26. ,('wang', '-- ::')
  27. ,('zhang', '-- ::')
  28. ,('li', '-- ::')
  29. ,('li', '-- ::')
  30. ,('li', '-- ::')
  31. ,('li', '-- ::')
  32. ,('li', '-- ::')
  33. ,('li', '-- ::')
  34. ,('li', '-- ::')
  35. ,('li', '-- ::')
  36. ,('wang', '-- ::')
  37. ,('zhang', '-- ::')
  38. ,('li', '-- ::')
  39. ,('wang', '-- ::')
  40. ,('zhang', '-- ::')
  41. ,('li', '-- ::')
  42. ,('wang', '-- ::')
  43. ,('zhang', '-- ::')
  44. ,('li', '-- ::')
  45. ,('wang', '-- ::');
  46. GO
  47. 先测试单行模式的效果,相应的T-SQL代码如下:
  48. EXEC dbo.usp_GetInsertSQL
  49. @chvnTable = N'UserLoginInfo', -- nvarchar()
  50. @chvnWhere = N'', -- nvarchar()
  51. @bitIsSingleRow = ; -- bit
  52. GO

执行后的查询结果如下:

 

 再测试多行模式的效果,相应的T-SQL代码如下:

  1. EXEC dbo.usp_GetInsertSQL
  2. @chvnTable = N'UserLoginInfo', -- nvarchar()
  3. @chvnWhere = N'', -- nvarchar()
  4. @bitIsSingleRow = ; -- bit
  5. GO

执行后的查询效果如下:

 

注意:多行模式,还需要将以上的两个结果前后合并在一个文件就可以啦。

以上内容是小编给大家分享的SQL Server中数据行批量插入脚本的存储实现,希望大家喜欢。

您可能感兴趣的文章:

  • SQLServer 批量插入数据的两种方法
  • SQL批量插入数据几种方案的性能详细对比
  • 用SQL批量插入数据的代码
  • 用SQL批量插入数据的存储过程
  • sql server中批量插入与更新两种解决方案分享(存储过程)
  • sql server中批量插入与更新两种解决方案分享(asp.net)
  • mssql2008 自定义表类型实现(批量插入或者修改)
  • 关于sql server批量插入和更新的两种解决方案
  • sql下三种批量插入数据的方法
  • 用一条mysql语句插入多条数据
  • C#实现SQL批量插入数据到表的方法
  • CI框架AR操作(数组形式)实现插入多条sql数据的方法
  • SQL Server使用一个语句块批量插入多条记录的三种方法

人气教程排行