fix: postgres money bug

jarad0628 · jarad0628 · commit be447b5fc131 · 2026-01-21T14:45:59.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
@@ -966,6 +966,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
`@@ -966,6 +966,13 @@ private Map<String, Object> filterTimeForPG(ResultSet resultSet, Map<String, Str`
`966`	`966`	`} else {`
`967`	`967`	`dataMap.put(colName, null);`
`968`	`968`	`}`
	`969`	`+ } else if (dataType.equals("money")) {`
	`970`	`+ String money = resultSet.getString(colName);`
	`971`	`+ if ("null".equals(money)) {`
	`972`	`+ dataMap.put(colName, null);`
	`973`	`+ } else {`
	`974`	`+ dataMap.put(colName, new BigDecimal(money.substring(1).replace(",", "")));`
	`975`	`+ }`
`969`	`976`	`} else {`
`970`	`977`	`dataMap.put(colName, processData(resultSet.getObject(colName), dataType));`
`971`	`978`	`}`