3.5. 设置 Db2 以运行 Debezium 连接器

流程

1. 使用 Db2 提供的 bldrtn 命令编译 Db2 服务器主机上的 Debezium 管理 UDF：

   cd $HOME/asncdctools/src

   Copy to Clipboard Toggle word wrap

   ./bldrtn asncdc

   Copy to Clipboard Toggle word wrap

2. 启动数据库（如果还没有运行）。将 DB_NAME 替换为您希望 Debezium 连接到的数据库的名称。

   db2 start db DB_NAME

   Copy to Clipboard Toggle word wrap

3. 确保 JDBC 可以读取 Db2 元数据目录：

   cd $HOME/sqllib/bnd

   Copy to Clipboard Toggle word wrap

   db2 bind db2schema.bnd blocking all grant public sqlerror continue

   Copy to Clipboard Toggle word wrap

4. 确保数据库最近备份。ASN 代理必须具有从中读取的最新起点。如果您需要执行备份，请运行以下命令，它会修剪数据，以便只有最新版本可用。如果您不不需要保留旧版本的数据，请为备份位置指定 dev/null。

   1. 备份数据库。将 DB_NAME 和 BACK_UP_LOCATION 替换为适当的值：

      db2 backup db DB_NAME to BACK_UP_LOCATION

      Copy to Clipboard Toggle word wrap

   2. 重启数据库：

      db2 restart db DB_NAME

      Copy to Clipboard Toggle word wrap

5. 连接到数据库，以安装 Debezium 管理 UDF。假设您以 db2instl 用户身份登录，因此应在 db2inst1 用户上安装 UDF。

   db2 connect to DB_NAME

   Copy to Clipboard Toggle word wrap

6. 复制 Debezium 管理 UDF 并为它们设置权限：

   cp $HOME/asncdctools/src/asncdc $HOME/sqllib/function

   Copy to Clipboard Toggle word wrap

   chmod 777 $HOME/sqllib/function

   Copy to Clipboard Toggle word wrap

7. 启用用于启动和停止 ASN 捕获代理的 Debezium UDF：

   db2 -tvmf $HOME/asncdctools/src/asncdc_UDF.sql

   Copy to Clipboard Toggle word wrap

8. 创建 ASN 控制表：

   $ db2 -tvmf $HOME/asncdctools/src/asncdctables.sql

   Copy to Clipboard Toggle word wrap

9. 启用 Debezium UDF 来添加表来捕获模式并从捕获模式中删除表：

   $ db2 -tvmf $HOME/asncdctools/src/asncdcaddremove.sql

   Copy to Clipboard Toggle word wrap

   设置 Db2 服务器后，使用 UDF 使用 SQL 命令控制 Db2 复制(ASN)。有些 UDF 期望一个返回值，在这种情况下，您可以使用 SQL VALUE 语句来调用它们。对于其他 UDF，请使用 SQL CALL 语句。

10. 启动 ASN 代理：

    VALUES ASNCDC.ASNCDCSERVICES('start','asncdc');

    Copy to Clipboard Toggle word wrap

    以上语句返回以下结果之一：

    • asncap 已在运行

    • start --> <COMMAND>

      在这种情况下，在终端窗口中输入指定的 <COMMAND >，如下例所示：

      /database/config/db2inst1/sqllib/bin/asncap capture_schema=asncdc capture_server=SAMPLE &

      Copy to Clipboard Toggle word wrap

11. 将表置于捕获模式。对您要放入捕获的每个表调用以下语句：将 MYSCHEMA 替换为包含您要放入捕获模式的表的 schema 名称。同样，将 MYTABLE 替换为要放入捕获模式的表名称：

    CALL ASNCDC.ADDTABLE('MYSCHEMA', 'MYTABLE');

    Copy to Clipboard Toggle word wrap

12. 重新初始化 ASN 服务：

    VALUES ASNCDC.ASNCDCSERVICES('reinit','asncdc');

    Copy to Clipboard Toggle word wrap