ogg 12.3 for sqlserver 2016/2014 CDC模式配置

本文主要講述ogg 12.3 經過CDC抽取mssqlserver 2016 enterprise的過程，以sqlserver爲目標端投遞配置相對簡單，因此在此不在贅述。

針對之前的mssqlserver，是直接解析日誌的模式，因此配置略有不一樣。

配置步驟概述

1.         解壓ogg 12.3 for sqlserver軟件，執行create subdirs，編輯mgr並啓動。

2.         數據庫安裝配置，並打補丁

3.         create schema ogg

4.         建立測試表

5.         建立globals文件

6.         建立同步用戶

7.         確保sqlagent能正常啓動

8.         在源端DB上啓用CDC

9.         建立ODBC

10.      add trandata

11.     建立清理歷史變動數據的job

12.     創建抽取進程

13.     測試

 

 

安裝過程

 

OGG軟件及sqlserver 2016安裝步驟在此省略。

 

 

補丁下載安裝

安裝完成sqlserver 2016 ent版本以後，還須要打補丁：

https://support.microsoft.com/en-us/help/3166120/fix-could-not-find-stored-procedure-sys-sp-cdc-parse-captured-column-l

 

源庫上建立OGG schema

用於存放配置表，其中cdc schema由啓用CDC步驟的存儲過程建立。

語法：

USE [sourcedb]

GO

CREATE SCHEMA [ogg] AUTHORIZATION [dbo]

GO

 

建立測試表

use sourcedb;

create table dbo.test1 (id int primary key, name varchar(50));

create table dbo.test2( id int, name varchar(50), age int);

 

use targetdb;

 

create table dbo.test1 (id int primary key, name varchar(50));

create table dbo.test2( id int, name varchar(50), age int);

 

 

建立Globals文件

在OGG目錄下，新建globals文件，內容以下

ggschema ogg

 

建立OGG同步用戶

建立訪問DB的用戶並賦權srcogg, tgtogg

 

目標端用戶

 

啓動sqlagent

agent用於啓動CDC對應的job, 因此必需要啓動agent才能正常同步。

 

 

源庫上啓用cdc

use sourcedb

EXECUTE sys.sp_cdc_enable_db

建立ODBC

若是須要遠程捕獲sqlserver，則只要配置經過odbc能遠程訪問DB便可實現。

 

 

 

OGG trandata

GGSCI>dblogin sourcedb srcdb, userid srcogg, password srcogg

GGSCI>add trandata dbo.test1

GGSCI>add trandata dbo.test2

 

執行完成以後，能夠看到多了一張配置表

ogg.OracleGGTranTables由OGG 第一次add trandata自動建立。

 

 

建立OGG clean job

須要先刪除DB自帶的clean job

EXECUTE sys.sp_cdc_drop_job 'cleanup'

 

而後在OGG安裝目錄下，進入命令行，執行以下語句，其中(local)是默認的sqlserver實例

ogg_cdc_cleanup_setup.bat createjob srcogg srcogg sourcedb (local) ogg

其中： srcogg爲用戶名及密碼，source爲源DB的名稱，(local)爲sqlserver實例, ogg爲對應的schema。

 

此時，會再增長兩張配置表:

and add a new job

 

配置抽取進程

GGSCI (DESKTOP-V8IQDQP) 6> view param exsrc

extract exsrc

 

sourcedb srcdb, userid srcogg, password srcogg

exttrail ./dirdat/aa

 

table dbo.*;

 

 

add extract exsrc, tranlog, begin now

add exttrail ./dirdat/aa, extract exsrc

 

 

測試

 

insert into dbo.test1 values(1, 'bc是中kos');

 

 

 

能夠看到正常捕獲數據。