Merge pull request #8965 from dataease/pr@dev@fixpg

fix(数据集): 修复pg sql 数据集同步失败
This commit is contained in:
taojinlong 2024-04-06 20:33:14 +08:00 committed by GitHub
commit 3b635ef5f6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

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);