fix(数据集): 修复pg sql 数据集同步失败

This commit is contained in:
taojinlong 2024-04-06 20:31:29 +08:00
parent 468104cf02
commit 53d6946d02

View File

@ -1022,6 +1022,7 @@ public class ExtractDataService {
case pg:
PgConfiguration pgConfiguration = new Gson().fromJson(datasource.getConfiguration(), PgConfiguration.class);
dataMeta = new DatabaseMeta("db", "POSTGRESQL", "Native", pgConfiguration.getHost().trim(), pgConfiguration.getDataBase(), pgConfiguration.getPort().toString(), pgConfiguration.getUsername(), pgConfiguration.getPassword());
dataMeta.setPreferredSchemaName(pgConfiguration.getSchema());
transMeta.addDatabase(dataMeta);
inputSteps = inputStep(transMeta, selectSQL, pgConfiguration);
udjcStep = udjc(datasetTableFields, DatasourceTypes.pg, pgConfiguration, isSetKey);