MaterializedMySQL引擎 完整同步示例 sql CREATE TABLE mysqlsync.fulltable ENGINE MaterializedMySQL('A.A.A.A:3306', 'sales', 'products', 'sync', 'productsmv', 'MergeTree() order by id'); 这会完整同步MySQL server,其ip地址为 A.A.A.A 上的sales库中products表到云数据库ClickHouse中的sync库的productsmv表。 增量同步示例 sql CREATE TABLE mysqlsync.updateddata ENGINE MaterializedMySQL('A.A.A.A:3306', 'sales', 'products', 'sync', 'productupdates', 'MergeTree() order by id', 1); 该表仅同步products表中新增或修改过的数据。第6个参数 1表示启用增量同步。 只同步部分列示例 sql CREATE TABLE mysqlsync.productnames ENGINE MaterializedMySQL('A.A.A.A:3306', 'sales', 'products', 'sync', 'productnames', 'MergeTree() order by id', 0, ['name', 'description']); 这里只同步products表的name和description两列。第7个参数定义同步的列。 设置同步周期示例 sql CREATE TABLE mysqlsync.orders ENGINE MaterializedMySQL('A.A.A.A:3306', 'store', 'orders', 'sync', 'ordersmv', 'MergeTree() order by id', 0, [], 3600); 这里通过第8个参数将同步周期设置为3600秒,即每小时同步一次。