随着国家对自主可控的日益重视，目前在各个行业和区域中面临越来越多的国产化，采用有自主知识产权的国产数据库正在成为主流。长期以来，作为拥有纯国产自研背景的 TapData，自是非常重视对于更多国产信创数据库的数据连接器支持，旗下产品已陆续与**阿里云、华为云、麒麟软件、优炫数据库、Apache Doris、人大金仓、OceanBase **等国产数据库及操作系统完成产品生态集成认证或产品兼容互认证。
本专题将以 TapData 正在支持的各国产信创数据源为原点，提供详细的数据库同步、迁移教程，为有需求的用户提供更灵活的工具选择。本文将介绍的 TapData 数据源为——PolarDB。
国产化浪潮之下，基础软件自主可控迫在眉睫，越来越多的国内企业开始从 Oracle、MySQL 这一类海外数据库向国产数据库迁移，TapData 的能力恰好满足企业快速、无痛实现迁移的需求，有效推动信创行业国产化建设更进一步。信创领域和基础软件设施的自主可控作为国家重点关注领域，全面国产化替代的进程仍在全速前进中。
同为国产基础软硬件生态的积极建设者，TapData 一直以来都在坚持拓展并持续深化与更多国产信创数据库的生态与战略伙伴关系，以期推动更多行业数据管理解决方案及创新应用的落地，提供更加广泛的基础设施选择及技术服务保障，从而为加速国产软硬件产品的应用普及与协同发展贡献力量。纯国产自研的背景更是为 TapData 的这一发展目标添翼。目前，TapData 已成功实现对主流国产数据库的广泛支持，以 PolarDB 为例：
云原生数据库 PolarDB 是阿里云自研产品，在存储计算分离架构下，利用了软硬件结合的优势，为用户提供秒级弹性、高性能、海量存储、安全可靠的数据库服务。100% 兼容 MySQL 和 PostgreSQL 生态，支持分布式扩展，高度兼容 Oracle 语法。版本包括云原生数据库 PolarDB MySQL 版、云原生数据库 PolarDB PostgreSQL 版和云原生数据库 PolarDB 分布式等。PolarDB 在全球范围内拥有超过 10,000 名企业级用户，部署实例超百万核 CPU，三年间增长率高达 400%，成为最受欢迎的国产数据库之一。
此外，作为 2024年8月墨天轮中国数据库流行度排行榜上的 Top2 以及 7月榜首，PolarDB 在云原生领域具有显著优势，用户量庞大，增长迅速，是国产数据库中的佼佼者。其创新设计的“分布式共享内存和存储”多主数据库架构，性能达到了业界同类数据库的3倍，并且已实现大规模商用，充分验证了其在实际业务场景中的卓越表现。那么，如何高效实现 PolarDB 的数据同步？
一、PolarDB 数据迁移与同步方案
更多详情，参见《PolarDB 产品文档-操作指南》：https://help.aliyun.com/zh/polardb/user-guide
云原生数据库 PolarDB 提供了多种数据迁移与同步方案，可满足不同上云、迁云以及业务同步等需求，支持在不影响业务的情况下平滑实现引擎间的数据迁移与同步，以 PolarDB MySQL 版本为例：
① 使用阿里云数据传输服务（DTS）
DTS（Data Transmission Service）是阿里云提供的数据传输服务，适用于 PolarDB 的迁移与同步场景，支持RDBMS、NoSQL、OLAP等数据源间的数据交互。
PolarDB 的数据迁移
- 使用场景：
- 从 RDS 迁移至 PolarDB
- PolarDB 间的数据迁移
- 从其他数据库迁移至 PolarDB
- 从 PolarDB 迁移至其他数据库
**PolarDB 的实时同步 **
- 使用场景：
- PolarDB 间的数据同步
- PolarDB 与其它数据库的数据同步
支持的数据库
当源为 PolarDB MySQL 版时，DTS 对源库与目标库的支持情况如下：
- 源库：PolarDB MySQL 版所有版本
- 目标库：包含 PolarDB MySQL、自建MySQL、RDS MySQL、云原生数据仓库 AnalyticDB MySQL 版、云原生数据仓库 AnalyticDB PostgreSQL 版、ClickHouse 等在内的 10+ 数据目标
② 使用实时数据同步工具 TapData
TapData 是一个以低延迟数据移动为核心优势构建的现代数据平台，可用于实现核心数据系统之间的实时同步、实时交换及实时处理。
PolarDB 的数据迁移
- 使用场景：
- 从其他数据库迁移至 PolarDB
- PolarDB 间的数据迁移
- 从 PolarDB 迁移至其他数据库
PolarDB 的实时同步
- 使用场景：
- PolarDB 间的数据同步
- PolarDB 与其它数据库的数据同步
支持的数据库
当源为 PolarDB MySQL 版时，TapData 对源库与目标库的支持情况如下：
- 源库：PolarDB MySQL 5.6、5.7、8.0
- 目标库：包含 PolarDB MySQL、MySQL、RDS MySQL、ClickHouse、Elasticsearch、Kafka 等在内的 60+ 数据目标
二、TapData 高效同步教程：以 PolarDB MySQL → RDS MySQL 为例
更多详情，参见《TapData 帮助文档-连接数据源-云数据库 PolarDB MySQL》：
https://docs.tapdata.net/prerequisites/cloud-databases/polardb-mysql
完成 TapData Agent 部署后，即可跟随以下教程在 TapData 中添加 PolarDB MySQL 数据连接（支持版本：PolarDB MySQL 5.6、5.7、8.0），后续可将其作为源或目标库来构建数据管道。这里我们将以 PolarDB MySQL 为数据源，RDS MySQL 为数据目标进行模拟演示。（*涉及工具版本为 TapData 本地部署版）
版本指路：
点击登录 TapData Cloud
申请试用 TapData 本地部署版
① 前提条件（作为源）
开启 Binlog
- 必须开启 MySQL 的 binlog ，Tapdata 才能正常完成同步工作。
- 级连删除（CASCADE DELETE），这类由数据库产生的删除不会记录在binlog内，所以不被支持。 修改 $MYSQL_HOME/mysql.cnf, 例如:
server_id = 223344 log_bin = mysql-bin expire_logs_days = 1 binlog_format = row binlog_row_image = full
配置解释：
- server-id: 对于 MySQL 中的每个服务器和复制客户端必须是唯一的
- binlog_format：必须设置为 row 或者 ROW
- binlog_row_image：必须设置为 full
- expire_logs_days：二进制日志文件保留的天数，到期会自动删除
- log_bin：binlog 序列文件的基本名称
重启 MySQL
/etc/inint.d/mysqld restart
验证 binlog 已启用，请在 mysql shell 执行以下命令
show variables like 'binlog_format';
输出的结果中，format value 应该是"ROW"
验证 binlog_row_image 参数的值是否为full:
show variables like 'binlog_row_image';
输出结果中，binlog_row_image value应该是"FULL"
创建MySQL账号
MySQL 以后，对密码加密的方式不同，请注意使用对应版本的方式，设置密码，否则会导致无法进行增量同步 使用以下命令，确认 supplemental logging 是否开启
3.3.1 5.x版本
create user 'username'@'localhost' identified by 'password';
3.3.2 8.x版本
// 创建用户 create user 'username'@'localhost' identified with mysql_native_password by 'password'; // 修改密码 alter user 'username'@'localhost' identified with mysql_native_password by 'password';
给 TapData 账号授权
对于某个数据库赋予select权限
GRANT SELECT, SHOW VIEW, CREATE ROUTINE, LOCK TABLES ON <DATABASE_NAME>.<TABLE_NAME> TO 'tapdata' IDENTIFIED BY 'password';
对于全局的权限
GRANT RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'tapdata' IDENTIFIED BY 'password';
约束说明
当从 MySQL 同步到其他异构数据库时，如果源 MySQL 存在表级联设置，因该级联触发产生的数据更新和删除不会传递到目标。如需要在目标端构建级联处理能力，可以视目标情况，通过触发器等手段来实现该类型的数据同步。
② 创建 PolarDB MySQL 的连接
- 进入 TapData 控制台，在左侧导航栏，单击连接管理。
- 单击页面右侧的创建，在弹框中，搜索并选择 PolarDB。
- 在跳转到的页面，根据下述说明填写 PolarDB 连接信息：
- 单击连接测试，测试通过后单击保存：
*提示：如提示连接测试失败，请根据页面提示进行修复。
③ 创建 RDS MySQL 的连接
- 参照 PolarDB 连接创建流程，完成 RDS MySQL 连接配置信息填写，添加数据目标：
- 测试 RDS MySQL 的连接：
④ 创建数据复制/开发任务
- 左侧导航栏点击数据复制，并点击右侧创建：
- 进入 DAG 页面，构建数据复制任务，通过拖拉拽的方式添加源与目标节点，并连接源与目标
- 单击源与目标节点，即可按需对二者进行设置：
- 保存任务
⑤ 任务启动与监控
- 启动任务，任务全量同步正常运行：
- 增量同步开启
以上，便是借助 TapData 快速实现 PolarDB MySQL 到 RDS MySQL 的全、增量同步的模拟教程。
后续，我们还将陆续输出 GaussDB、人大金仓Kingbase、神州通用、南大通用、OpenGauss、瀚高、 TDengine、TDSQL、VastBase 等热门国产数据源的连接教程，欢迎关注 TapData 官方公众号，了解更多。
< 上一篇 OceanBase
【推荐阅读】
- 如何高效整合分散数据，构建统一的实时数据平台？
- 流式处理 vs 批处理，新数据时代的数据处理技术该如何选择？
- TapData 医疗美容行业数字化白皮书上线
- 战略资讯 | TapData 牵手思想科技，开启数据管理新篇章！
