From 2e051081ff61d3516b7282ed2a5ccbe710c5ce39 Mon Sep 17 00:00:00 2001 From: liuwenjie <1518386192@qq.com> Date: Wed, 21 Sep 2022 11:17:30 +0800 Subject: [PATCH] [hotfix-#1272][chunjun-connector-pgwal]fix pgwal does not support uppercase schema or uppercase table --- .../com/dtstack/chunjun/connector/pgwal/util/PGUtil.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/chunjun-connectors/chunjun-connector-pgwal/src/main/java/com/dtstack/chunjun/connector/pgwal/util/PGUtil.java b/chunjun-connectors/chunjun-connector-pgwal/src/main/java/com/dtstack/chunjun/connector/pgwal/util/PGUtil.java index 35b0d3b5e9..7565c319a9 100644 --- a/chunjun-connectors/chunjun-connector-pgwal/src/main/java/com/dtstack/chunjun/connector/pgwal/util/PGUtil.java +++ b/chunjun-connectors/chunjun-connector-pgwal/src/main/java/com/dtstack/chunjun/connector/pgwal/util/PGUtil.java @@ -19,6 +19,7 @@ import com.dtstack.chunjun.constants.ConstantValue; import com.dtstack.chunjun.util.ClassUtil; +import com.dtstack.chunjun.util.DtStringUtil; import com.dtstack.chunjun.util.ExceptionUtil; import com.dtstack.chunjun.util.TelnetUtil; @@ -178,8 +179,13 @@ public static ReplicationSlotInfoWrapper checkPostgres( String.format(QUERY_TABLE_REPLICA_IDENTITY, tables[0], tables[1])); resultSet.next(); if (!"f".equals(resultSet.getString(1))) { + String quoteTable = + DtStringUtil.addQuoteForStr(tables[0]) + + "." + + DtStringUtil.addQuoteForStr(tables[1]); LOG.warn("update {} replica identity, set to full", table); - conn.createStatement().execute(String.format(UPDATE_REPLICA_IDENTITY, table)); + conn.createStatement() + .execute(String.format(UPDATE_REPLICA_IDENTITY, quoteTable)); } }