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 connect to DB_NAME
   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 用户身份登录，因此 UDF 应在 db2inst1 用户上安装。

   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. 从 SQL 客户端启动 ASN 代理：

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

    Copy to Clipboard Toggle word wrap

    或者在 shell 中：

    db2 "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 替换为包含您要放入捕获模式的模式的名称。同样，将 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