ClickHouse

必须先选择 MySQL 的表后,再选择 ClickHouse 插件,再选择 ClickHouse 库表的时候,如果ClickHouse表字段和MySQL表字段一致的情况下会自动填充

 

ClickHouse 对应用MySQL里的存储类型

括号里的代表是ClickHouse里的存储类型

TINYINT ( Int8 | UInt8 ) , SMALLINT ( Int16 | UInt16 ) , MEDIUMINT ( Int32 | UInt32 ), INT ( Int32 | UInt32 ) , BIGINT ( Int64 | UInt64 )

FLOAT ( Float64 ) , DOUBLE ( Float64 ) ,REAL ( Float64 )

DECIMAL , NUMERIC( Float64 )

DATE ( Date )

TIME ( String )

YEAR ( Int16 )

DATETIME , TIMESTAMP ( DateTime )

CHAR , VARCHAR ( String )

TEXT , TINYTEXT , MEDIUMINTTEXT , LONGTEXT ( String )

BLOB, TINYBLOB , MEDIUMINTBLOB , LONGBLOB ( String )

ENUM ( String )

SET ( String )

BIT ( Int64 )

BOOL ( Int8 )

连接配置

eg : tcp://127.0.0.1:9000?Database=test&username=&compress=true

自动过滤规则

假如同一个主键的数据,在同一批次刷数据,会自动过滤多余操作

 

1. 假如 id = 1 这条数据,连接有 insert ,delete ,update 操作

则只会执行最后的 update 操作,不会执行前面insert 及 delete操作

 

2. 假如 id = 1 这条数据,连接有 insert ,delete ,insert ,delete 顺序操作

则只会执行最后的 delete 操作一次,不会执行 insert

 

update 操作是转换成 delete 再 insert 两次操作

备注

必须只能选择一个字段为主键

不支持批量设置表

ClickHouse 18+ 版本

不支持 NULL 值字段

BatchSize参数代表累积多少条数据刷一次数据到ClickHouse,假如一直没有数据从 MySQL 过来,则默认5秒超时,也会进行刷一次