迁移SQL Server数据库建议您使用阿里云数据传输服务DTS，详情请参见DTS数据迁移方案概览。

除了DTS，您也可以使用其他工具迁移数据库，本文以本地SQL Server数据库到阿里云云数据库SQL Server 2012的数据全量迁移为例，介绍了如何通过使用SQL Server Management Studio（SSMS）和大容量复制程序实用工具（BCP）来迁移SQL Server数据库。

适用场景

  • SQL Server数据库的结构迁移。
  • 数据的全量迁移，不支持数据的增量迁移。
  • 本地数据库到本地数据库、本地数据库到阿里云云数据库SQL Server和阿里云云数据库SQL Server间的数据全量迁移。

背景信息

SSMS 是用于管理SQL Server基础架构的集成环境，提供用于配置、监视和管理SQL Server实例的工具。 此外，它还提供了用于部署、监视和升级数据层组件（如应用程序使用的数据库和数据仓库）的工具以生成查询和脚本。

BCP 可以在SQL Server实例和用户指定格式的数据文件间大容量复制数据，您可以通过BCP实用工具将大量新行导入SQL Server表，或将表数据导出到数据文件。

所以，本文直接使用SSMS的功能来生成源端数据库对象结构的创建脚本，然后在目标数据库中去执行，进行数据库结构的迁移；再配合使用BCP命令行来进行数据库数据的导出和导入操作，进行数据的全量迁移。下面将介绍如何将本地SQL Server 2012数据库AdventureWorks2012的数据全量迁移到阿里云云数据库SQL Server 2012。

前提条件

目标数据库主机需要有充足的存储空间来存放导入的数据和因此而带来的日志文件增长，两者加起来的空间增长大概是源端数据库大小的2-3倍（如果数据库是Full模式）。如果目标数据库是在本地自建环境，请确保宿主机有足够的存储空间；如果是阿里云云数据库SQL Server，请确保已经购买了充足的存储空间。

注意事项

  • 在创建目标数据库时，要确保目标数据库和源端数据库排序规则的一致性，否则很可能会导致全量数据迁移失败。
  • 为防止数据全量迁移过程报错，需要在目标数据库中禁用外键、索引和触发器，然后再启用，以此来避免错误发生和提高数据导入效率。
  • BCP导入计算列或时间戳（timestamp）列时，会忽略它们的列值，SQL Server将自动分配该列的值。

操作步骤

视频介绍

0.7 倍 1.0 倍 1.2 倍 1.5 倍 2.0 倍

文本介绍

  • 打开SSMS客户端。
  • 分别连接源数据库AdventureWorks2012和阿里云云数据库SQL Server。
  • 执行如下代码，在源数据库创建具有读写权限的用户。代码中的testdbo是指用户名称，XXXXXXXX是该用户的登录密码，在执行代码前请将这两个参数改成您想要的用户名和密码。若您的数据库中已存在具有读写权限的用户，请跳过此步骤。

1. 1. USE MASTER
   2. GO
   3. CREATE LOGIN testdbo
   4. WITH PASSWORD = N'XXXXXXXX',CHECK_POLICY = OFF
   5. GO
   6. USE AdventureWorks2012
   7. GO

   9. CREATE USER testdbo FOR LOGIN testdbo;

   11. EXEC sys.sp_addrolemember 'db_owner','testdbo'
   12. GO
  • 禁用掉TCP/IP协议，以断开源数据库的所有客户端连接，以确保源端数据迁移前后的一致性。
  • 重启SQL Server服务。

注意：禁用掉TCP/IP协议后，远端应用程序将无法通过TCP/IP端口来访问本地实例，在使用BCP进行数据导出时，必须在该实例所在的物理机上进行。

  • 执行如下命令，在阿里云云数据库SQL Server 2012的实例上创建数据库。

1. 1. create database db01 DEFAULT CHARACTER SET gbk COLLATE gbk_chinese_ci;
  • 执行如下代码，分别查看源端数据库和目标数据库的排序规则。

1. 1. -- Check Collation name
   2. SELECT name,collation_name
   3. FROM sys.databases
   4. WHERE name = 'adventureworks2012'
  • 若结果显示的排序规则不同，在目标数据库执行如下代码，将SQL_Latin1_General_CP1_CI_AS替换成跟跟源端数据库一致的排序规则。若排序规则一致，请跳过此步骤。

1. 1. -- change the collate if need.
   2. USE master;
   3. GO
   4. ALTER DATABASE adventureworks2012
   5. COLLATE SQL_Latin1_General_CP1_CI_AS;
   6. GO
  • 在目标数据库中执行如下代码，创建与步骤3中一致的源端数据库用户。

1. 1. USE MASTER
   2. GO
   3. CREATE LOGIN testdbo
   4. WITH PASSWORD = N'XXXXXXXX',CHECK_POLICY = OFF
   5. GO
   6. USE AdventureWorks2012
   7. GO

   9. CREATE USER testdbo FOR LOGIN testdbo;

   11. EXEC sys.sp_addrolemember 'db_owner','testdbo'
   12. GO

  • 在源端数据库生成对象信息创建脚本。操作步骤如下：

  • 单击源数据库中的Databases。

  • 右击AdventureWorks2012。
  • 选择Tasks > Generate Scripts，如下图所示。

生成脚本

  • 进入生成脚本的界面后，单击 Next。
  • 选中Select specific database objects，选择除Users以外所有的迁移对象，然后单击Next。如下图所示。

选择迁移对象

  • 在Set Scripting Options页面，单击Advanced，然后进行如下设置：

  • 单击Script for Server Version，将其值设成与目标数据库一致的数据库版本，本示例中使用的是SQL Server 2012.

  • 单击Script for the database engine edition，将其值设成 Microsoft SQL Server Enterprise Edition。
  • 将Script Object-Level Permissions、Script Owner 和 Script USE DATAABASE的值设成True。
  • 单击Types of data to script，将其值设成Schema only。

注意：该选项不能设成Schema and data，否则会生成schema文件和INSERT语句文件，造成效率低下。


1. -

建议将Table/View Options中的所有选项值都设置成True。

详情如下图所示：

脚本高级设置

  • 单击OK。导出的脚本文件会放在页面上显示的File name中所示的位置。

  • 单击Next、Next、Finish，完成脚本生成工作。

  • 在目标数据库中执行在上一步中创建的脚本文件。

  • 当创建对象信息的脚本文件执行完毕后，执行如下代码，并将参数@is_disable BIT的值设成1，以禁用外键约束、索引和触发器。

说明：表外键约束的存在会导致数据导入失败，而表索引和触发器的存在会导致数据导入效率降低，所以需要将其禁用。


1. 1. USE [adventureworks2012]
   2. GO

   4. --public variables: need init by users.
   5. DECLARE
   6. @is_disable BIT = 1    -- 1: disalbe indexes, foreign keys and triggers;
   7. -- 0: enable indexes, foreign keys and triggers;
   8. ;

   10. --================ Private variables
   11. DECLARE
   12. @sql NVARCHAR(MAX)
   13. , @sql_index NVARCHAR(MAX)
   14. , @tb_schema SYSNAME
   15. , @tb_object_name SYSNAME
   16. , @tr_schema SYSNAME
   17. , @tr_object_name SYSNAME
   18. , @ix_name SYSNAME
   19. ;

   21. --================= Disable/Enable indexes on all tables
   22. DECLARE
   23. cur_indexes CURSOR LOCAL STATIC FORWARD_ONLY READ_ONLY
   24. FOR
   25. SELECT
   26. ix_name = ix.name
   27. , tb_schema = SCHEMA_NAME(obj.schema_id)
   28. , tb_object_name = obj.name
   29. FROM sys.indexes as ix
   30. INNER JOIN sys.objects as obj
   31. ON ix.object_id = obj.object_id
   32. WHERE ix.type >= 2
   33. AND obj.is_ms_shipped = 0
   34. AND ix.is_disabled = (1 - @is_disable)

   36. OPEN cur_indexes;
   37. FETCH NEXT FROM cur_indexes INTO @ix_name, @tb_schema, @tb_object_name;

   39. WHILE @@FETCH_STATUS = 0
   40. BEGIN
   41. SET
   42. @sql_index = N'ALTER INDEX ' + QUOTENAME(@ix_name)
   43. + N' ON ' + QUOTENAME(@tb_schema) + N'.' + QUOTENAME(@tb_object_name)
   44. + CASE @is_disable
   45. WHEN 1 THEN N' DISABLE;'
   46. WHEN 0 THEN N' REBUILD; '
   47. ELSE N''
   48. END;
   49. RAISERROR(N'%s', 10, 1, @sql_index) WITH NOWAIT;
   50. EXEC sys.sp_executesql @sql_index
   51. FETCH NEXT FROM cur_indexes INTO @ix_name, @tb_schema, @tb_object_name;
   52. END

   54. CLOSE cur_indexes;
   55. DEALLOCATE cur_indexes;

   57. --================= Disable/Enable foreign keys on all tables
   58. --disable
   59. IF @is_disable = 1
   60. BEGIN
   61. SELECT
   62. @sql = N'
   63. RAISERROR(N''ALTER TABLE ? NOCHECK CONSTRAINT ALL;'', 10, 1) WITH NOWAIT
   64. ALTER TABLE ? NOCHECK CONSTRAINT ALL;'
   65. ;
   66. END
   67. ELSE    --enable
   68. BEGIN
   69. SELECT
   70. @sql = N'
   71. RAISERROR(N''ALTER TABLE ? WITH CHECK CHECK CONSTRAINT ALL;'', 10, 1) WITH NOWAIT
   72. ALTER TABLE ? WITH CHECK CHECK CONSTRAINT ALL;'
   73. ;
   74. END

   76. EXEC sys.sp_MSforeachtable @sql

   78. --================= Disable/Enable triggers on all tables

   80. DECLARE
   81. cur_triggers CURSOR LOCAL STATIC FORWARD_ONLY READ_ONLY
   82. FOR
   83. SELECT
   84. tb_schema = SCHEMA_NAME(tb.schema_id)
   85. ,tb_object_name = tb.name
   86. ,tr_schema = SCHEMA_NAME(obj.schema_id)
   87. ,tr_object_name = obj.name
   88. FROM sys.objects as obj
   89. INNER JOIN sys.tables as tb
   90. ON obj.parent_object_id = tb.object_id
   91. INNER JOIN sys.triggers as tr
   92. ON obj.object_id = tr.object_id
   93. WHERE obj.type = 'TR'
   94. AND obj.is_ms_shipped = 0
   95. AND tr.is_disabled =  (1 - @is_disable)
   96. ORDER BY tb_schema, tb_object_name

   98. OPEN cur_triggers;
   99. FETCH NEXT FROM cur_triggers INTO @tb_schema, @tb_object_name, @tr_schema, @tr_object_name;

   101. WHILE @@FETCH_STATUS = 0
   102. BEGIN
   103. SET @sql = CASE @is_disable
   104. WHEN 1 THEN N'DISABLE TRIGGER '
   105. WHEN 0 THEN N'ENABLE TRIGGER '
   106. ELSE N''
   107. END
   108. + QUOTENAME(@tr_schema) + N'.' + QUOTENAME(@tr_object_name)
   109. + N' ON '
   110. + QUOTENAME(@tb_schema) + N'.' + QUOTENAME(@tb_object_name)
   111. ;
   112. RAISERROR(N'%s', 10, 1, @sql) WITH NOWAIT;
   113. EXEC sys.sp_executesql @sql;
   114. FETCH NEXT FROM cur_triggers INTO @tb_schema, @tb_object_name, @tr_schema, @tr_object_name;
   115. END

   117. CLOSE cur_triggers;
   118. DEALLOCATE cur_triggers;
   119. GO
  • 在源端数据库和目标数据库中分别执行如下代码，查询数据库的对象汇总信息。

1. 1. USE AdventureWorks2012
   2. GO
   3. ;WITH objs
   4. AS(
   5. -- check objects
   6. SELECT
   7. database_name = LOWER(DB_NAME())
   8. , object_type = type
   9. , objet_desc = type_desc
   10. , object_count = COUNT(1)
   11. FROM sys.all_objects WITH(NOLOCK)
   12. WHERE is_ms_shipped = 0
   13. GROUP BY type,type_desc
   14. UNION ALL

   16. --check indexes
   17. SELECT
   18. database_name = LOWER(DB_NAME())
   19. , object_type = CAST(ix.type AS VARCHAR)
   20. , objet_desc = ix.type_desc
   21. , object_count = COUNT(1)
   22. FROM sys.indexes as ix
   23. INNER JOIN sys.objects as obj
   24. ON ix.object_id = obj.object_id
   25. WHERE obj.is_ms_shipped = 0
   26. GROUP BY ix.type,ix.type_desc
   27. )
   28. SELECT * FROM objs
   29. ORDER BY object_type
  • 查询结果返回后，对比源端数据库和目标数据库的对象信息。若结果显示一致，则说明所有对象信息已经从源数据库迁移到了目标数据库。

注意：

  • 为方便对比和避免人眼观察带来的人为错误，建议您使用对比工具来对比对象汇总信息。本文推荐您使用Araxis Merge 2001 v6.0 Professional。
  • 阿里云云数据库SQL Server数据库的名称仅支持小写字母，而源数据库名称可能含有大写字母，在使用工具进行对比时，请将其设置为忽略字母大小写的检查。若您使用的是Araxis Merge 2001 v6.0 Professional，可以通过选择View > Options，然后再选中Ignore differences in character case来设置。

  • 在源端数据库上执行如下脚本，执行前请按实际情况修改如下参数：

  • source_User：源数据库中的登录用户名。

  • source_Password：登录源数据库的用户名所对应的密码。
  • destination_Instance：将 XXXX 改成目标数据库的实例名称。
  • destination_Database：目标端的数据库名称。若为空，则表示与源端数据库保持一致。
  • destination_User：目标数据库中登录的用户名，与源端数据库一致。
  • destination_Password：登录目标数据库中的用户名所对应的密码。

1. 1. USE AdventureWorks2012
   2. GO

   4. -- declare public variables, need to init by user
   5. DECLARE
   6. @source_Instance sysname
   7. , @source_Database sysname
   8. , @source_User sysname
   9. , @source_Passwd sysname

   11. , @destination_Instance sysname
   12. , @destination_Database sysname
   13. , @destination_User sysname
   14. , @destination_Passwd sysname

   16. , @batch_Size int

   18. , @transfer_table_list nvarchar(max)
   19. ;

   21. -- Public variables init.
   22. SELECT
   23. @source_Instance = @@SERVERNAME                -- Source Instance Name
   24. , @source_Database = DB_NAME()                    -- Source Database is current database.
   25. , @source_User = 'XXX'                            -- Source Instance Connect User Name
   26. , @source_Passwd = N'XXX'                -- Source Instance User Password

   28. , @destination_Instance = N'XXXX.sqlserver.rds.aliyuncs.com,3433'    -- Destination Instance Name
   29. , @destination_Database = N''                        -- Destination Database name: NULL/empty: Keep the same as source db
   30. , @destination_User = 'XXX'                        -- Destination Instance User Name
   31. , @destination_Passwd = N'XXX'            -- Destination Instance User Password

   33. , @transfer_table_list = N''                                --NULL/empty: ALL Tables are needed to be transfered.
   34. , @batch_Size = 50000                                    -- BCP IN Batch Size, by default, it is 50000. Must between 1 and 50000.
   35. ;

   37. -- Private variables, there is no need to init.
   38. DECLARE
   39. @transfer_table_list_xml xml
   40. , @timestamp char(14)
   41. ;

   43. -- correct the variables init by user.
   44. SELECT
   45. @source_Instance = RTRIM( LTRIM(@source_Instance) )
   46. , @source_User = RTRIM( LTRIM( @source_User ) )
   47. , @source_Passwd = RTRIM( LTRIM( @source_Passwd ) )

   49. , @destination_Instance = RTRIM( LTRIM( @destination_Instance ) )
   50. , @destination_Database =  CASE
   51. WHEN ISNULL(@destination_Database, N'') = N'' THEN @source_Database
   52. ELSE @destination_Database
   53. END
   54. , @destination_User = RTRIM( LTRIM( @destination_User ) )
   55. , @destination_Passwd = RTRIM( LTRIM( @destination_Passwd ) )

   57. , @batch_Size = CASE
   58. WHEN (@batch_Size>0 AND @batch_Size<=50000) THEN @batch_Size
   59. ELSE 50000
   60. END
   61. , @transfer_table_list_xml = '<V><![CDATA[' + REPLACE(
   62. REPLACE(
   63. REPLACE(
   64. @transfer_table_list,CHAR(10),']]></V><V><![CDATA['
   65. ),',',']]></V><V><![CDATA['
   66. ),CHAR(13),']]></V><V><![CDATA['
   67. ) + ']]></V>'
   68. , @timestamp =
   69. REPLACE(
   70. REPLACE(
   71. REPLACE(
   72. CONVERT(CHAR(19), GETDATE(), 120), N'-', '')
   73. , N':', N'')
   74. , CHAR(32), N'')
   75. ;

   77. IF OBJECT_ID('tempdb..#tb_list', 'U') IS NOT NULL
   78. DROP TABLE #tb_list
   79. CREATE TABLE #tb_list(
   80. RowID INT IDENTITY(1, 1) NOT NULL PRIMARY KEY
   81. ,Table_name SYSNAME NOT NULL
   82. )

   84. IF ISNULL(@transfer_table_list, '') = ''
   85. BEGIN
   86. INSERT INTO #tb_list
   87. SELECT name
   88. FROM sys.tables AS tb
   89. WHERE tb.is_ms_shipped = 0
   90. END
   91. ELSE
   92. BEGIN
   93. INSERT INTO #tb_list
   94. SELECT table_name = T.C.value('(./text())[1]','sysname')
   95. FROM @transfer_table_list_xml.nodes('./V') AS T(C)
   96. WHERE T.C.value('(./text())[1]','sysname') IS NOT NULL
   97. END
   98. ;

   100. SELECT
   101. BCP_OUT = N'BCP ' + @source_Database + '.' + sch.name + '.' + tb.name
   102. + N' Out '
   103. + QUOTENAME( REPLACE(@source_Instance, N'\', N'_')+ '.' + @source_Database + '.' + sch.name + '.' + tb.name, '"')
   104. + N' /N /U ' + @source_User +N' /P ' + @source_Passwd +N' /S ' + @source_Instance
   105. + N' >> BCPOUT_' + @timestamp +N'.txt'
   106. ,BCP_IN = N'BCP ' + @destination_Database + '.' + sch.name + '.' + tb.name
   107. + N' In '
   108. + QUOTENAME( REPLACE(@source_Instance, N'\', N'_')+ '.' + @source_Database + '.' + sch.name + '.' + tb.name, '"')
   109. + N' /N /E /q /k /U ' + @destination_User + N' /P ' + @destination_Passwd + N' /b '
   110. + CAST(@batch_Size as varchar) + N' /S ' + @destination_Instance
   111. + N' >> BCPIN_' + @timestamp + N'.txt'
   112. --,*
   113. FROM sys.tables as tb
   114. LEFT JOIN sys.schemas as sch
   115. ON tb.schema_id = sch.schema_id
   116. WHERE tb.is_ms_shipped = 0
   117. AND tb.name IN (SELECT Table_name FROM #tb_list)
  • 分别将生成的BCP_OUT和BCP_IN文件保存至本地。
  • 运行本地保存的BCP_OUT.bat文件，生成源数据库的数据导出文件。
  • BCP_OUT.bat文件运行结束后，双击其日志文件BCPOUT_YYYYMMDDHHMMSS.txt（YYYYMMDDHHMMSS为文件生成时间），查看数据导出过程是否全部成功。
  • 运行本地保存的BCP_IN.bat文件，将从源数据库中导出的文件从本地导入到远端目标数据库中。

说明：由于目标数据库是在阿里云上，由于网络原因，BCP_IN.bat文件的运行时间会比BCP_OUT.bat文件的运行时间长。

  • BCP_IN.bat文件运行结束后，双击其日志文件BCPOUT_YYYYMMDDHHMMSS.txt，查看数据导入过程是否全部成功。
  • 若确保数据已经全部从源端数据库导入到目标数据库中，删除磁盘上BCP在步骤 17中导出的中间临时文件，如下图所示。

BCP导出文件

  • 分别在源端数据库和目标数据库中执行如下代码，查询源端数据库和目标数据库中的表记录总数。

1. 1. USE AdventureWorks2012
   2. GO
   3. SELECT
   4. schema_name = SCHEMA_NAME(tb.schema_id)
   5. ,table_name = OBJECT_NAME(tb.object_id)
   6. ,row_count = SUM(CASE WHEN ps.index_id < 2 THEN ps.row_count ELSE 0 END)
   7. FROM sys.dm_db_partition_stats as ps WITH(NOLOCK)
   8. INNER JOIN sys.tables as tb WITH(NOLOCK)
   9. ON ps.object_id = tb.object_id
   10. WHERE tb.is_ms_shipped = 0
   11. GROUP BY tb.object_id,tb.schema_id
   12. ORDER BY schema_name,table_name
  • 使用对比工具对比源端数据库和目标数据库中的表记录总数。若数据一致，则说明源数据库的所有数据已经全部导入目标数据库中。
  • 执行如下代码，并将参数@is_disable BIT的值设成0，启用外键约束、索引和触发器，完成数据库迁移。

1. 1. USE [adventureworks2012]
   2. GO

   4. --public variables: need init by users.
   5. DECLARE
   6. @is_disable BIT = 0    -- 1: disalbe indexes, foreign keys and triggers;
   7. -- 0: enable indexes, foreign keys and triggers;
   8. ;

   10. --================ Private variables
   11. DECLARE
   12. @sql NVARCHAR(MAX)
   13. , @sql_index NVARCHAR(MAX)
   14. , @tb_schema SYSNAME
   15. , @tb_object_name SYSNAME
   16. , @tr_schema SYSNAME
   17. , @tr_object_name SYSNAME
   18. , @ix_name SYSNAME
   19. ;

   21. --================= Disable/Enable indexes on all tables
   22. DECLARE
   23. cur_indexes CURSOR LOCAL STATIC FORWARD_ONLY READ_ONLY
   24. FOR
   25. SELECT
   26. ix_name = ix.name
   27. , tb_schema = SCHEMA_NAME(obj.schema_id)
   28. , tb_object_name = obj.name
   29. FROM sys.indexes as ix
   30. INNER JOIN sys.objects as obj
   31. ON ix.object_id = obj.object_id
   32. WHERE ix.type >= 2
   33. AND obj.is_ms_shipped = 0
   34. AND ix.is_disabled = (1 - @is_disable)

   36. OPEN cur_indexes;
   37. FETCH NEXT FROM cur_indexes INTO @ix_name, @tb_schema, @tb_object_name;

   39. WHILE @@FETCH_STATUS = 0
   40. BEGIN
   41. SET
   42. @sql_index = N'ALTER INDEX ' + QUOTENAME(@ix_name)
   43. + N' ON ' + QUOTENAME(@tb_schema) + N'.' + QUOTENAME(@tb_object_name)
   44. + CASE @is_disable
   45. WHEN 1 THEN N' DISABLE;'
   46. WHEN 0 THEN N' REBUILD; '
   47. ELSE N''
   48. END;
   49. RAISERROR(N'%s', 10, 1, @sql_index) WITH NOWAIT;
   50. EXEC sys.sp_executesql @sql_index
   51. FETCH NEXT FROM cur_indexes INTO @ix_name, @tb_schema, @tb_object_name;
   52. END

   54. CLOSE cur_indexes;
   55. DEALLOCATE cur_indexes;

   57. --================= Disable/Enable foreign keys on all tables
   58. --disable
   59. IF @is_disable = 1
   60. BEGIN
   61. SELECT
   62. @sql = N'
   63. RAISERROR(N''ALTER TABLE ? NOCHECK CONSTRAINT ALL;'', 10, 1) WITH NOWAIT
   64. ALTER TABLE ? NOCHECK CONSTRAINT ALL;'
   65. ;
   66. END
   67. ELSE    --enable
   68. BEGIN
   69. SELECT
   70. @sql = N'
   71. RAISERROR(N''ALTER TABLE ? WITH CHECK CHECK CONSTRAINT ALL;'', 10, 1) WITH NOWAIT
   72. ALTER TABLE ? WITH CHECK CHECK CONSTRAINT ALL;'
   73. ;
   74. END

   76. EXEC sys.sp_MSforeachtable @sql

   78. --================= Disable/Enable triggers on all tables

   80. DECLARE
   81. cur_triggers CURSOR LOCAL STATIC FORWARD_ONLY READ_ONLY
   82. FOR
   83. SELECT
   84. tb_schema = SCHEMA_NAME(tb.schema_id)
   85. ,tb_object_name = tb.name
   86. ,tr_schema = SCHEMA_NAME(obj.schema_id)
   87. ,tr_object_name = obj.name
   88. FROM sys.objects as obj
   89. INNER JOIN sys.tables as tb
   90. ON obj.parent_object_id = tb.object_id
   91. INNER JOIN sys.triggers as tr
   92. ON obj.object_id = tr.object_id
   93. WHERE obj.type = 'TR'
   94. AND obj.is_ms_shipped = 0
   95. AND tr.is_disabled =  (1 - @is_disable)
   96. ORDER BY tb_schema, tb_object_name

   98. OPEN cur_triggers;
   99. FETCH NEXT FROM cur_triggers INTO @tb_schema, @tb_object_name, @tr_schema, @tr_object_name;

   101. WHILE @@FETCH_STATUS = 0
   102. BEGIN
   103. SET @sql = CASE @is_disable
   104. WHEN 1 THEN N'DISABLE TRIGGER '
   105. WHEN 0 THEN N'ENABLE TRIGGER '
   106. ELSE N''
   107. END
   108. + QUOTENAME(@tr_schema) + N'.' + QUOTENAME(@tr_object_name)
   109. + N' ON '
   110. + QUOTENAME(@tb_schema) + N'.' + QUOTENAME(@tb_object_name)
   111. ;
   112. RAISERROR(N'%s', 10, 1, @sql) WITH NOWAIT;
   113. EXEC sys.sp_executesql @sql;
   114. FETCH NEXT FROM cur_triggers INTO @tb_schema, @tb_object_name, @tr_schema, @tr_object_name;
   115. END

   117. CLOSE cur_triggers;
   118. DEALLOCATE cur_triggers;
   119. GO