此页面由 Cloud Translation API 翻译。

配置 Cloud SQL for SQL Server 数据库

以下步骤介绍了如何为 SQL Server 配置 Cloud SQL for SQL Server 数据库，与 Datastream 搭配使用：

连接到您的 Cloud SQL 实例。为此，您可以使用 gcloud sql connect 命令（位于 Cloud Shell 提示符。
运行以下命令，在数据库上启用 CDC：
```
EXEC msdb.dbo.gcloudsql_cdc_enable_db 'DATABASE_NAME'
```
将 DATABASE_NAME 替换为您的源数据库的名称。

在需要捕获更改的表上启用 CDC：

USE [DATABASE_NAME]
EXEC sys.sp_cdc_enable_table
@source_schema = N'SCHEMA_NAME',
@source_name = N'TABLE_NAME',
@role_name = NULL
GO

启动 SQL Server Agent 并确保其始终运行。如果 SQL Server Agent 长时间保持关闭状态，日志可能会被截断，这会导致 Datastream 未读取的更改数据永久丢失。

如需了解如何运行 SQL Server 代理，请参阅启动、停止或重启 SQL Server Agent 实例。

注意：我们建议为 SQL Server Agent 服务设置自动重启，以防止代理长时间关闭。
启用快照隔离。

从 SQL Server 数据库回填数据时，请务必确保创建一致的快照如果您未应用本部分，在回填过程中对数据库进行更改可能会导致出现重复或错误的结果，尤其是没有主键的表。

启用快照隔离会在启动时创建数据库的临时视图回填流程中的各个部分这可以确保要复制的数据保持一致即使其他用户同时更改实时表格也是如此。启用快照隔离可能会对性能产生轻微的影响是可靠数据提取的关键。

如需启用快照隔离，请执行以下操作：
1. 使用 SQL Server 客户端连接到您的数据库。
2. 运行以下命令：
```
ALTER DATABASE DATABASE_NAME SET ALLOW_SNAPSHOT_ISOLATION ON;
```
将 DATABASE_NAME 替换为您的数据库的名称。
创建 Datastream 用户：
1. 在 Google Cloud 控制台中，转到 Cloud SQL 实例页面。
  
  转到“Cloud SQL 实例”
2. 创建登录信息。
3. 创建一个用户，并为其分配 db_owner 和 db_denydatawriter 角色：
```
CREATE USER USER_NAME FOR LOGIN YOUR_LOGIN;
```
```
EXEC sp_addrolemember 'db_owner', 'USER_NAME';
EXEC sp_addrolemember 'db_denydatawriter', 'USER_NAME';
```

使用事务日志 CDC 方法所需的其他步骤

只有在配置好与事务日志 CDC 方法搭配使用的 SQL Server 源数据库。

设置您希望所做更改在来源。
```
USE [DATABASE_NAME]
EXEC sys.sp_cdc_change_job @job_type = 'capture' , @pollinginterval = 86399
EXEC sp_cdc_stop_job 'capture'
EXEC sp_cdc_start_job 'capture'
```
“@pollinginterval”参数的单位为秒，该值为建议值。已设置为 86399。这意味着事务日志会将更改保留 86,399 秒（一天）。执行 sp_cdc_start_job 'capture 过程会启动设置。

设置日志截断保护。

为了确保 CDC 读取器有足够的时间来读取日志，同时允许您可以设置日志截断，以避免耗尽存储空间保护措施：

使用 SQL Server 客户端连接到数据库。

在数据库中创建虚拟表：

USE [DATABASE_NAME];
CREATE TABLE dbo.gcp_datastream_truncation_safeguard (
  [id] INT IDENTITY(1,1) PRIMARY KEY,
  CreatedDate DATETIME DEFAULT GETDATE(),
  [char_column] CHAR(8)
  );

创建一个存储过程，并在该时间段内运行活跃事务防止日志截断：

CREATE PROCEDURE [dbo].[DatastreamLogTruncationSafeguard] @transaction_logs_retention_time INT
AS
BEGIN
  -- Start a new transaction
  BEGIN TRANSACTION;
  INSERT INTO dbo.gcp_datastream_truncation_safeguard (char_column) VALUES ('a')

DECLARE @formatted_time VARCHAR(5)
SET @formatted_time = CONVERT(VARCHAR(5), DATEADD(MINUTE, @transaction_logs_retention_time, 0), 108);
  -- Wait for X minutes before ending the transaction
  WAITFOR DELAY @formatted_time;
  -- Commit the transaction
  COMMIT TRANSACTION;
END;

创建另一个存储过程。这一次，您将创建一个作业根据指定的频率：

CREATE PROCEDURE [dbo].[SetUpDatastreamJob] @transaction_logs_retention_time INT
AS
BEGIN
  DECLARE @database_name VARCHAR(MAX)
  SET @database_name =  (SELECT DB_NAME());;

  DECLARE @command_str VARCHAR(MAX);
  SET @command_str = CONCAT('Use ', @database_name,'; exec dbo.DatastreamLogTruncationSafeguard @transaction_logs_retention_time = ' + CAST(@transaction_logs_retention_time AS VARCHAR(10)));

  DECLARE @job_name VARCHAR(MAX);
SET @job_name =
  CONCAT(@database_name, '_', 'DatastreamLogTruncationSafeguardJob1')

    -- Add 3 schedules to the job to run again after specified time.
    IF
      NOT EXISTS(
        SELECT *
        FROM msdb.dbo.sysjobs
        WHERE name = @job_name
      )
        BEGIN
          EXEC
            msdb.dbo.sp_add_job
              @job_name
  = @job_name,
  @enabled = 1,
  @description = N'Execute the procedure to run an active transaction for x minutes.';

EXEC msdb.dbo.sp_add_jobstep @job_name = @job_name,
@step_name = N'Execute_DatastreamLogTruncationSafeguard',
@subsystem = N'TSQL',
@command = @command_str;

  -- Add a schedule that runs the stored procedure every given minutes starting now.
  DECLARE @schedule_name_1 VARCHAR(MAX);
  SET @schedule_name_1 = CONCAT(@database_name, '_', 'DatastreamEveryGivenMinutesFromNow')

  DECLARE @start_time_1 time;
  SET @start_time_1 = DATEADD(SECOND, 1, GETDATE());
  DECLARE @formatted_start_time_1 INT;
  SET @formatted_start_time_1 = CONVERT(INT, REPLACE(CONVERT(VARCHAR(8), @start_time_1, 114), ':' ,''));

  EXEC msdb.dbo.sp_add_schedule
  @schedule_name = @schedule_name_1,
  @freq_type = 4,  -- daily start
  @freq_subday_type = 4,  -- every X minutes daily
  @freq_interval = 1,
  @freq_subday_interval = @transaction_logs_retention_time,
  @active_start_time = @formatted_start_time_1;

  EXEC msdb.dbo.sp_attach_schedule
  @job_name = @job_name,
  @schedule_name = @schedule_name_1 ;

  -- Add a schedule that runs the stored procedure after every given minutes starting after some delay.
  DECLARE @schedule_name_2 VARCHAR(MAX);
  Set @schedule_name_2 = CONCAT(@database_name, '_', 'DatastreamEveryGivenMinutesAfterDelay');

  DECLARE @start_time_2 time;
  SET @start_time_2 = DATEADD(MINUTE, @transaction_logs_retention_time / 2, GETDATE());

  DECLARE @formatted_start_time_2 INT;
  SET @formatted_start_time_2 = CONVERT(INT, REPLACE(CONVERT(VARCHAR(8), @start_time_2, 114), ':' ,''));

  EXEC msdb.dbo.sp_add_schedule
  @schedule_name = @schedule_name_2,
  @freq_type = 4,  -- daily start
  @freq_subday_type = 4,  -- every x minutes daily
  @freq_interval = 1,
  @freq_subday_interval = @transaction_logs_retention_time,
  @active_start_time = @formatted_start_time_2;

  EXEC msdb.dbo.sp_attach_schedule
  @job_name = @job_name,
  @schedule_name = @schedule_name_2 ;

  -- Add a schedule that runs the stored procedure on the SQL Server Agent startup.
  DECLARE @schedule_name_agent_startup VARCHAR(MAX);
  Set @schedule_name_agent_startup = CONCAT(@database_name, '_', 'DatastreamSqlServerAgentStartupSchedule')

  EXEC msdb.dbo.sp_add_schedule
  @schedule_name = @schedule_name_agent_startup,
  @freq_type = 64,  -- start on SQL Server Agent startup
  @active_start_time = @formatted_start_time_1;

  EXEC msdb.dbo.sp_attach_schedule
  @job_name = @job_name,
  @schedule_name = @schedule_name_agent_startup ;

  EXEC msdb.dbo.sp_add_jobserver
  @job_name = @job_name,
  @server_name = @@servername ;
  END
END;

执行会创建 Datastream 作业的存储过程。
```
DECLARE @transaction_logs_retention_time INT = (INT)
EXEC [dbo].[SetUpDatastreamJob] @transaction_logs_retention_time
```
将 INT 替换为您要更改的分钟数并保留日志例如：
- 值 60 会将保留时间设置为 1 小时
- 值 24 * 60 会将保留时间设置为 1 天
- 值 3 * 24 * 60 会将保留时间设置为 3 天