OceanBase（MySQL 模式）

TapData Cloud 为您提供了云端服务，适合需要快速部署、低前期投资场景，帮助您更好地专注于业务发展而非基础设施管理，注册账号即可领取免费的 Agent 实例，欢迎试用。TapData Enterprise 可部署在您的本地数据中心，适合对数据敏感性或网络隔离有严格要求的场景，可服务于构建实时数仓，实现实时数据交换，数据迁移等场景。TapData Community 是一个开源的数据集成平台，提供基础的数据同步和转换功能，可通过 Docker 一键部署，帮助您快速探索和实施数据集成项目。随着项目或企业发展，您可以平滑升级至 TapData Cloud 或 TapData Enterprise，以获得更多高级功能或服务支持。

OceanBase 是蚂蚁集团自研的原生分布式关系型数据库，兼容 MySQL 与 Oracle 双语法，具备高可用、高性能与强一致特性。Tapdata 支持将 OceanBase 作为源库或目标库接入，帮助您构建多源汇聚、实时写入的数据流转链路，实现异构系统间的数据同步与整合。

支持版本与架构

• 版本：OceanBase 4.0 及以上
• 架构：单节点或集群架构

支持数据类型

类别	数据类型
字符串	CHAR、VARCHAR、TINYTEXT、TEXT、MEDIUMTEXT、LONGTEXT、BINARY、VARBINARY
整数	TINYINT、SMALLINT、MEDIUMINT、INT、BIGINT
数值	DECIMAL、FLOAT、DOUBLE
日期/时间	DATE、TIME、DATETIME、TIMESTAMP、YEAR
枚举/集合	ENUM、SET
JSON	JSON
二进制	TINYBLOB、BLOB、MEDIUMBLOB、LONGBLOB
位类型	BIT
空间地理类型	POINT、LINESTRING、POLYGON、GEOMETRY、MULTIPOINT、MULTILINESTRING、MULTIPOLYGON、GEOMCOLLECTION

支持同步的操作

• DML：INSERT、UPDATE、DELETE

  提示

  将 OceanBase 作为同步的目标时，您还可以通过任务节点的高级配置，选择写入策略：插入冲突场景下，可选择转为更新或丢弃；更新失败场景下，可选择转为插入或仅打印日志。

• DDL：ADD COLUMN、CHANGE COLUMN、DROP COLUMN、RENAME COLUMN

准备工作

作为源库

1. 确保 TapData Agent 所属的网络已加入 OceanBase 的租户白名单中，且内网可互通。

2. 以 root 身份登录到租户，执行下述格式的命令，创建用于数据同步的用户。

   CREATE USER 'username' IDENTIFIED BY 'password';
   • username：用户名。
   • password：密码。

3. 执行下述格式的命令，为刚创建的用户授予库级别读取权限，您也可以基于业务需求自定义更精细化的权限控制。

   -- 授予指定库的读权限
   GRANT SELECT ON database_name.* TO 'username' IDENTIFIED BY 'password';
   • database_name：数据库名称。
   • username：用户名。

4. 为保障读取 OceanBase 数据库的增量数据，您还需要跟随教程，完成 OceanBase Binlog 服务部署。

   提示

   OceanBase Binlog 服务主要由 OBProxy 和 obbinlog（原 oblogproxy）构成，前者负责客户端连接接入，后者负责拉取增量日志并生成 Binlog。更多详情可参考见 Binlog 服务介绍。

作为目标库

1. 确保 TapData Agent 所属的网络已加入 OceanBase 的租户白名单中，且内网可互通。

2. 以 root 身份登录到租户，执行下述格式的命令，创建用于数据同步的用户。

   CREATE USER 'username' IDENTIFIED BY 'password';
   • username：用户名。
   • password：密码。

3. 执行下述格式的命令，为刚创建的用户授予库级别所有权限，您也可以基于业务需求自定义更精细化的权限控制。

   -- 授予指定库的所有权限
   GRANT ALL ON database_name.* TO username;
   • database_name：数据库名称。
   • username：用户名。

连接 OceanBase（MySQL 模式）

1. 登录 TapData 平台。

2. 在左侧导航栏，单击连接管理。

3. 单击页面右侧的创建。

4. 在弹出的对话框中，搜索并选择 OceanBase。

5. 在跳转到的页面，根据下述说明填写 OceanBase 的连接信息。

   

   • 连接信息设置
     • 连接名称：填写具有业务含义的名称，便于后续识别与管理。
     • 连接类型：支持将 OceanBase 作为源或目标库。
     • 地址：数据库主机地址，支持 IP 或域名。通常为 OBProxy 的部署地址。
     • 端口：数据库访问端口，默认为 2881。
     • 租户：OceanBase 中的逻辑租户（类似传统数据库的实例），此处请填写租户名。
     • 数据库：数据库名称，即一个连接对应一个数据库，如有多个数据库则需创建多个数据连接。
     • 账号：租户下的数据库用户名。
     • 密码：上述账号对应的登录密码。
     • 连接参数：可选项，填写 JDBC 连接参数（如编码、SSL 配置等），默认为空。
     • RPC 端口：OBProxy 的服务端口，用于访问 OceanBase，默认为 2882。
     • 日志代理端口：用于增量同步的日志代理服务端口（Binlog 服务端口），默认为 2983。
     • 时区：默认为 UTC（0 时区）。若源库或目标库时区不同，请设置为一致的时区。该配置将影响无时区字段（如 DATETIME），但不影响 TIMESTAMP、DATE、TIME 等字段。
   • 高级设置
     • 使用共享挖掘：挖掘源库的增量日志，可为多个任务共享源库的增量日志，避免重复读取，从而最大程度上减轻增量同步对源库的压力，开启该功能后还需要选择一个外存用来存储增量日志信息。
     • Agent 设置：默认为平台自动分配，您也可以手动指定 Agent。
     • 模型加载时间：如果数据源中的模型数量少于10000个，则每小时更新一次模型信息。但如果模型数量超过10000个，则刷新将在您指定的时间每天进行。
     • 开启心跳表：当连接类型选择为源头和目标、源头时，支持打开该开关，任务引用并该数据源并启动后，由 TapData 在源库中创建一个名为 _tapdata_heartbeat_table 的心跳表并每隔 10 秒更新一次其中的数据（数据库账号需具备相关权限），用于数据源连接与任务的健康度监测。

6. 单击连接测试，测试通过后单击保存。

   提示

   如提示连接测试失败，请根据页面提示进行修复。

节点高级特性

在配置数据复制或转换任务时，若将 OceanBase（MySQL 模式） 作为源节点，Tapdata 提供了内置的高级特性选项，以提升性能并适应更复杂的业务场景。

单表并发读（默认关闭）：启用后，Tapdata 会根据数据分区对单表进行拆分，并发启动多个读取线程，同时读取不同分区的数据，从而显著提升全量读取的性能。该功能适用于大表场景，建议在数据库资源充足时开启。

• 默认单表分片数：16
• 默认并发读取线程数：8

上述参数均可在界面中进行调整。