若选择了增量同步,可以指定增量同步过程中同步的SQL语句类型,当前可选的SQL语句类型包含:INSERT、UPDATE、DELETE,不支持DDL语句的迁移,如下图所示。 如上图所示,增量同步当前支持两种可选的迁移方案:物化视图日志(mlog)方案和归档日志方案(logminer)。
使用简介 远程登录到创建好的集群 ssh root@$public_ip 使用创建集群时输入的密码 登录ClickHouse客户端 su - clickhouse clickhouse-client -m -u admin --password 集群密码 clickhouse-client常用参数: -h 主机名 -d 数据库名 -m 客户端支持多行SQL输入以分号结尾,不指定该参数默认以回车作为SQL
flinksql 作业) flinkjar(flink 自定义作业) streamingjar(sparkstreaming jar作业) streamingscala(sparkstreaming scala作业) pipeline(可视化作业) shell(shell 作业) python(python 作业) sparksql sparkscala pyspark spark jdbc hsql
若选择了增量同步,可以指定增量同步过程中同步的SQL语句类型,当前可选的SQL语句类型包含:INSERT、UPDATE、DELETE、DDL;此外若选择了DDL语句的同步,可以额外指定是否过滤特殊的DDL同步,如DROP、和TRUNCATE语句,如下图所示。 传输对象包含两种选择类型: 整个实例 和 手动选择 。
同源异库 同源异库是指同一个数据源中的不同数据库,例如 MySQL 中的 数据库A 和 数据库B 之间的跨库查询。除了 MySQL,Sugar BI 中目前还支持 Presto 数据源中的跨 catalog、schema 的同源异库查询。
在调试中我们可以看到: 过滤条件作为参数被 POST 到后端(目前没有过滤条件,所以这里是空) 您输入的原始 SQL 语句 最终生成的在数据库中查询的 SQL 语句 SQL 查询的原始结果 Sugar BI进行转化操作后的中间结果 格式化为图表可以读取的数据 JSON 格式结果 如果都没有问题,点击刷新图表,就可以看到结果了: 图表的详细配置请参考「 图表制作概述 」。
mysql dbUser String 否 数据库访问账号 dts_trans dbPass String 否 数据库访问密码 dbPort Integer 否 数据库访问端口 3306 dbHost String 否 数据库ip或主机名 192.168.1.1 dbServer String 否 数据库ip或主机名.支持ip:端口,ip或域名与端口以英文冒号分隔,多个地址以英文逗号分隔 192.168.1.1
二、代码实现 调用Api要先获取access_token,获取的代码如下 static String getAccessToken() throws IOException { MediaType mediaType = MediaType.parse( application/x-www-form-urlencoded ); RequestBody body = RequestBody.create
二、代码实现 调用Api要先获取access_token,获取的代码如下 static String getAccessToken() throws IOException { MediaType mediaType = MediaType.parse( application/x-www-form-urlencoded ); RequestBody body = RequestBody.create
mysql dbUser String 否 数据库访问账号 dts_trans dbPass String 否 数据库访问密码 dbPass dbPort Integer 否 数据库访问端口 3306 dbHost String 否 数据库ip或主机名 192.168.1.1 instanceId String 否 实例ID rdsmfgdti3d53f5 field_whitelist String