提交 0a9d2a88 authored 作者: taojinlong's avatar taojinlong

fix: StarRocks、tidb 同步数据

上级 9f3ef8e1
...@@ -872,6 +872,8 @@ public class ExtractDataService { ...@@ -872,6 +872,8 @@ public class ExtractDataService {
case ds_doris: case ds_doris:
case mariadb: case mariadb:
case mysql: case mysql:
case TiDB:
case StarRocks:
MysqlConfiguration mysqlConfiguration = new Gson().fromJson(datasource.getConfiguration(), MysqlConfiguration.class); MysqlConfiguration mysqlConfiguration = new Gson().fromJson(datasource.getConfiguration(), MysqlConfiguration.class);
dataMeta = new DatabaseMeta("db", "MYSQL", "Native", mysqlConfiguration.getHost().trim(), mysqlConfiguration.getDataBase().trim(), mysqlConfiguration.getPort().toString(), mysqlConfiguration.getUsername(), mysqlConfiguration.getPassword()); dataMeta = new DatabaseMeta("db", "MYSQL", "Native", mysqlConfiguration.getHost().trim(), mysqlConfiguration.getDataBase().trim(), mysqlConfiguration.getPort().toString(), mysqlConfiguration.getUsername(), mysqlConfiguration.getPassword());
dataMeta.addExtraOption("MYSQL", "characterEncoding", "UTF-8"); dataMeta.addExtraOption("MYSQL", "characterEncoding", "UTF-8");
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论