fix: postgres money bug

jarad0628 · jarad0628 · commit 80cc2aeeec2b · 2026-01-21T14:37:42.000+08:00
(cherry picked from commit dae5e3c)
diff --git a/connectors-common/postgres-core/src/main/java/io/tapdata/connector/postgres/PostgresTest.java b/connectors-common/postgres-core/src/main/java/io/tapdata/connector/postgres/PostgresTest.java
@@ -185,7 +185,7 @@ public Boolean testWalMinerPgto() {
         }
     }
 
-    private static final String WALMINER_PACKAGE_NAME = "walminer_x86_64_v4.11.2";
+    private static final String WALMINER_PACKAGE_NAME = "walminer_x86_64_v4.12.2";
 
     private boolean deployPgto() {
         String toolPath = FileUtil.paths("run-resources", "pg-db", "walminer");
diff --git a/connectors-common/postgres-core/src/main/resources/walminer/walminer_x86_64_v4.12.2.tar.gz b/connectors-common/postgres-core/src/main/resources/walminer/walminer_x86_64_v4.12.2.tar.gz
diff --git a/connectors/postgres-connector/src/main/java/io/tapdata/connector/postgres/PostgresConnector.java b/connectors/postgres-connector/src/main/java/io/tapdata/connector/postgres/PostgresConnector.java
@@ -985,6 +985,13 @@ private Map<String, Object> filterTimeForPG(ResultSet resultSet, Map<String, Str
                     } else {
                         dataMap.put(colName, null);
                     }
+                } else if (dataType.equals("money")) {
+                    String money = resultSet.getString(colName);
+                    if ("null".equals(money)) {
+                        dataMap.put(colName, null);
+                    } else {
+                        dataMap.put(colName, new BigDecimal(money.substring(1).replace(",", "")));
+                    }
                 } else {
                     dataMap.put(colName, processData(resultSet.getObject(colName), dataType));
                 }

Original file line number	Diff line number	Diff line change
`@@ -185,7 +185,7 @@ public Boolean testWalMinerPgto() {`
`185`	`185`	`}`
`186`	`186`	`}`
`187`	`187`
`188`		`- private static final String WALMINER_PACKAGE_NAME = "walminer_x86_64_v4.11.2";`
	`188`	`+ private static final String WALMINER_PACKAGE_NAME = "walminer_x86_64_v4.12.2";`
`189`	`189`
`190`	`190`	`private boolean deployPgto() {`
`191`	`191`	`String toolPath = FileUtil.paths("run-resources", "pg-db", "walminer");`
Original file line number	Diff line number	Diff line change
`@@ -985,6 +985,13 @@ private Map<String, Object> filterTimeForPG(ResultSet resultSet, Map<String, Str`
`985`	`985`	`} else {`
`986`	`986`	`dataMap.put(colName, null);`
`987`	`987`	`}`
	`988`	`+ } else if (dataType.equals("money")) {`
	`989`	`+ String money = resultSet.getString(colName);`
	`990`	`+ if ("null".equals(money)) {`
	`991`	`+ dataMap.put(colName, null);`
	`992`	`+ } else {`
	`993`	`+ dataMap.put(colName, new BigDecimal(money.substring(1).replace(",", "")));`
	`994`	`+ }`
`988`	`995`	`} else {`
`989`	`996`	`dataMap.put(colName, processData(resultSet.getObject(colName), dataType));`
`990`	`997`	`}`