JDBC-Sink

启动类

【防循环复制】txnTable

• 功能：事务表方案，防循环复制使用的表

• 默认值：drc_txn

• 值的选择范围：string

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【防循环复制】txnDb

• 功能：事务表方案，防循环复制使用的表所在的库

• 默认值：test

• 值的选择范围：string

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【连接信息】jdbcUrl

• 功能：目标库连接串

• 默认值：无，必填

• 值的选择范围：string

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【连接信息】username

• 功能：目标库用户名

• 默认值：无，必填

• 值的选择范围：string

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【连接信息】password

• 功能：目标库密码

• 默认值：无，必填

• 值的选择范围：string

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【调试】printSql

• 功能：是否打印执行 SQL

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【线程】workerNum

• 功能：工作线程

• 默认值：16

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【调试】slowSqlThreshold

• 功能：慢 SQL 阈值，控制打印执行 SQL

• 默认值：15ms

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【连接信息】timezone

• 功能：时区

• 默认值：+08:00

• 值的选择范围：时区

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【过滤】notWriteColumn

• 功能：无需写入的列

• 默认值：无

• 值的选择范围：string

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【防循环复制】localRegionNo

• 功能：写入的 regionNo

• 默认值：无

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【反向防回放】transactionIdIsLong

• 功能：transactionId 是否需要转化为 long 写入。反向防回放使用，作用是兼容之前已存在的事务表

• 默认值：false

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【写入】useTargetIndex

• 功能：使用目标端的 index 进行数据同步

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【OceanBase 数据库分区写入】sysUsername

• 功能：sys 租户账号，三段式，OceanBase 数据库分区写入时使用

• 默认值：无

• 值的选择范围：string

• 支持的版本：OMS 社区版 V4.0.0-CE 及之后版本

【OceanBase 数据库分区写入】sysPassword

• 功能：sys 租户密码，OceanBase 数据库分区写入时使用

• 默认值：无

• 值的选择范围：string

• 支持的版本：OMS 社区版 V4.0.0-CE 及之后版本

【OceanBase 数据库分区写入】sysInstance

• 功能：sys 租户的连接信息

• 默认值：无

• 值的选择范围：string

• 支持的版本：OMS 社区版 V4.0.0-CE 及之后版本

【OceanBase 数据库分区写入】tenant

• 功能：用户写入租户

• 默认值：无

• 值的选择范围：string

• 支持的版本：OMS 社区版 V4.0.0-CE 及之后版本

【OceanBase 数据库分区写入】enablePartitionBucket

• 功能：是否开启分区写入能力

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V4.0.0-CE 及之后版本

【特殊场景】ignoreRedunantColumnsReplicate

• 功能：是否允许源端和目标端的字段数量不一致

• 默认值：false

  MySQL 数据库和 OMS 社区版之间的全量迁移和增量同步过程中，如果报错源端表字段在目标端中不存在，您可以设置参数 ignoreRedunantColumnsReplicate 为 true。

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V4.1.1-CE 及之后版本

【外键】disableForeignKeyCheck

• 功能：禁用外键检查

• 默认值：true

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【错误处理】maxRetryTimes

• 功能：Sink 写入失败重试的最大参数

• 默认值：1000

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【错误处理】retryIntervalTime

• 功能：重试时间间隔

• 默认值：3s

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【调试】dryRun

• 功能：空跑，不执行 SQL

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【SQL 操作】updateSetAllColumns

• 功能：对于 update，是否全列设置

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【错误处理】skipErrorCode

• 功能：Sink 写入，忽略的 errorcode，为 JSON 数组

• 默认值：无

• 值的选择范围：错误码

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【错误处理】skipErrorMessage

• 功能：Sink 写入，忽略的 errormessage，为 JSON 数组

• 默认值：无

• 值的选择范围：错误内容

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【调试】conflictPrintSize

• 功能：单 Key 冲突队列长度超过多大会进行打印

• 默认值：256

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【无主键表】enableNoUniqueConstraintTableReplicate

• 功能：迁移 MySQL 数据库的至 OceanBase 数据库 MySQL 兼容模式，或迁移 OceanBase 数据库 MySQL 兼容模式的数据至 MySQL 数据库时，是否允许迁移无主键表

• 默认值：false

  即使该值被设置为 true，如果不是 MySQL 数据库和 OceanBase 数据库 MySQL 兼容模式之间的数据迁移任务，也会被自动设置为 false。

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V4.0.0-CE 及之后版本

【无主键表】serialNoUniqueConstraintTable

• 功能：事务冲突矩阵是否串行执行无主键表

• 默认值：

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【事务表】transactionTableClearTime

• 功能：事务表每天的清理时间

• 默认值：02:00:00

• 值的选择范围：time

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【事务表】transactionTableReserveDays

• 功能：事务表保留的天数

• 默认值：7

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【特定场景】serialExecuteTable

• 功能：需要串行执行的表，使用英文逗号（,）分隔

• 默认值：空

• 值的选择范围：string

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【特定场景】useSSL

• 功能：是否使用 SSL 进行链接

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【写入查询】dependTargetSchema

• 功能：是否依赖目标端的 Schema 写目标端

• 默认值：true

  如果取值为 false，则不会查询目标端。在目标端为 OceanBase 数据库的某些情况下，您需要关闭该参数。例如，迁移 OceanBase 数据库 V3.x 的大量表数据至 OceanBase 数据库 V4.x，由于很多查询是每一张表都需要查询一次，导致创建数据迁移任务失败。

  说明

  dependTargetSchema 为 false 时，如果源端和目标端的表结构不一致，该参数可能导致未知问题。例如，主键不同时可能会产生数据问题。

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【特殊场景】forceUpdateTimeField

• 功能：update 是否强制更新 time 类型

• 默认值：true

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【写入模式】writeMode

• 功能：目标端的写入模式，包括批量写入和非批量写入

• 默认值：batch（批量写入）

• 值的选择范围：batch 或 noBatch

• 支持的版本：OMS 社区版 V3.2.2-CE 及之后版本

datasource.variables

OceanBase 社区版支持 Session 级别的变量：datasource.variables.xxx，xxx 表示可以使数据执行 Session 变量的配置。

例如，datasource.variables._FORCE_PARALLEL_DDL_DOP 表示通过 Session 变量来指定并行度，您可以设置具体的并行数值。_FORCE_PARALLEL_DDL_DOP 详情请参见 并行执行分类与优化。

loadSysmetaFromCache

• 功能：缓存系统视图

• 默认值：true

  • true：表示从本地 Cache 加载。

    注意

    当您在 OMS 社区版管理数据源页面，单击 缓存系统视图，并且该运维任务执行成功，loadSysmetaFromCache 设置为 true 才生效。

  • false：表示从数据库中直接加载。

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V4.2.5-CE 及之后版本

insertMode

• 功能：插入数据的模式

• 默认值：INSERT

• 值的选择范围：

  • INSERT：表示写入时按照 INSERT INTO 语法

  • REPLACE：表示写入时按照 REPLACE INTO 语法

  • INSERT_IGNORE：表示写入时按照 INSERT IGNORE INTO 语法

• 支持的版本：OMS 社区版 V4.2.7-CE 及之后版本

geomExchangeLonLat

• 功能：经纬度调换开关

  该参数仅对 MySQL Sink 有效，并且仅适用于源端为 OceanBase 数据库 MySQL 兼容模式的场景。

• 默认值：true

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V4.2.7-CE 及之后版本

postgisGeometryBinaryConvert

• 功能：表示对 PostGIS 的增量数据进行一次转换

  该参数仅对 OBMySQL Sink 有效，并且仅适用于源端为 PostgreSQL 数据库的场景。

• 默认值：true

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V4.2.7-CE 及之后版本