MySQL离线同步

本文提供MySQL离线同步场景的实施思路、配置示例和验证方式，可作为实际项目配置参考。

实现在MySQL中结果表向目标表中离线同步数据

案例

MySQL中将t_source中的数据离线同步到t_target中

解决方案

CREATE TABLE from_table(
    username STRING,
    age INT
) WITH (
    'connector'='jdbc',
    'url'='jdbc:mysql://localhost:30306/isxcode_db',
    'driver'='com.mysql.cj.jdbc.Driver',
    'table-name'='t_source',
    'username'='root',
    'password'='root123',
    'scan.fetch-size'= '1'
);

CREATE TABLE target_table(
    username STRING,
    age INT
) WITH (
    'connector'='jdbc',
    'url'='jdbc:mysql://localhost:30306/isxcode_db',
    'driver'='com.mysql.cj.jdbc.Driver',
    'table-name'='t_target',
    'username'='root',
    'password'='root123',
    'sink.buffer-flush.max-rows'='1'); 

INSERT INTO target_table select * from from_table;