配置DRS同步任务

EXEC sys.sp_cdc_enable_db;

如果当前Azure SQL Database不支持开启CDC，则如下所示开启库级别CDC失败，随后异常，执行后续SQL，升级Azure SQL Database后开启库级CDC。

需要执行如下sql查询源端数据库的服务层级，并将结果记录下来，以便后期恢复数据库服务层级。

• 不支持开启CDC的级别有：Basic、Standard S0、Standard S1 和 Standard S2。
• 不同版本的Azure SQL Database计费不同，用户需根据自身需要选择。

SELECT 
    database_name = DB_NAME(),
    edition,
    service_objective
FROM sys.database_service_objectives;

随后依次执行如下SQL，开启源端数据库服务层级。

（SQL5.b.i、5.b.ii、5.b.iii为非必须，若开启库级CDC失败，可执行SQL5.b.i、5.b.ii、5.b.iii为并刷新数据库后重新开启）：

1. 将数据库升级到支持CDC的Azure SQL Database层级Premium层级

   ALTER DATABASE [smsa_mig]
   MODIFY (EDITION = 'Premium', SERVICE_OBJECTIVE = 'P1');

2. 禁用数据库级别的DDL触发器

   DISABLE TRIGGER ALL ON DATABASE

3. 关闭库级CDC

   EXECsys.sp_cdc_disable_db;

4. 开启库级CDC

   EXEC sys.sp_cdc_enable_db;

   

   源端库开启CDC成功后可再次查看源端数据库服务层级，已提升至Premium

   

BEGIN TRY
    DECLARE @source_name VARCHAR(400);
    DECLARE @sql VARCHAR(1000);
    DECLARE @dbname VARCHAR(100);
    DECLARE @schemaname VARCHAR(100), @enable BIT;

    SET @dbname = 'smsa_migration';  -- 确保数据库名正确
    SET @schemaname = 'SalesLT';     -- 修改为实际需要处理的 Schema（例如 SalesLT 或 dbo）
    SET @enable = 1;                 -- 1 启用 CDC，0 禁用 CDC

    DECLARE the_cursor CURSOR FAST_FORWARD FOR
    SELECT table_name
    FROM INFORMATION_SCHEMA.TABLES 
    WHERE TABLE_CATALOG = @dbname 
      AND TABLE_SCHEMA = @schemaname 
      AND TABLE_NAME != 'systranschemas'
      AND TABLE_TYPE = 'BASE TABLE';  -- 关键修正：仅选择基表，排除视图

    OPEN the_cursor;
    FETCH NEXT FROM the_cursor INTO @source_name;

    WHILE @@FETCH_STATUS = 0
    BEGIN
        IF @enable = 1
        BEGIN
            SET @sql = 
                'USE ' + @dbname + '; ' +
                'EXEC sys.sp_cdc_enable_table ' +
                '@source_schema = N''' + @schemaname + ''', ' +  -- Schema 名称
                '@source_name = N''' + @source_name + ''', ' +    -- 表名称
                '@role_name = NULL;';  -- 根据需求设置角色名，NULL 表示不限制访问
        END
        ELSE
        BEGIN
            SET @sql = 
                'USE ' + @dbname + '; ' +
                'EXEC sys.sp_cdc_disable_table ' +
                '@source_schema = N''' + @schemaname + ''', ' +  -- Schema 名称
                '@source_name = N''' + @source_name + ''', ' +    -- 表名称
                '@capture_instance = ''all'';';  -- 禁用所有实例
        END

        PRINT @sql;  -- 调试输出生成的 SQL
        EXEC(@sql);
        FETCH NEXT FROM the_cursor INTO @source_name;
    END

    CLOSE the_cursor;
    DEALLOCATE the_cursor;
    SELECT 'Successful';
END TRY
BEGIN CATCH
    IF CURSOR_STATUS('global', 'the_cursor') >= 0
    BEGIN
        CLOSE the_cursor;
        DEALLOCATE the_cursor;
    END

    SELECT
        ERROR_NUMBER() AS ErrorNumber,
        ERROR_MESSAGE() AS ErrorMessage;
END CATCH

select name, is_tracked_by_cdc from sys.tables where is_tracked_by_cdc = '1';