fix: pgto money bug

Author: jarad0628

connectors-common/postgres-core/src/main/java/io/tapdata/connector/postgres/PostgresTest.java

@@ -245,7 +245,7 @@ private boolean deployPgto() {
             process = processBuilder.start();
             process.waitFor(60, TimeUnit.SECONDS);
             new File(FileUtil.paths(toolPath, ctlDir)).mkdir();
-            processBuilder.command("/bin/sh", "-c", String.format("walminer pgto -i -c %s -s '%s' -e %s -t 4 --source-connstr1='host=%s port=%s username=%s dbanme=%s password=%s'", toolDir.getAbsolutePath() + "/" + ctlDir, slotName, ((PostgresConfig) commonDbConfig).getPgtoPort(), commonDbConfig.getHost(), commonDbConfig.getPort(), commonDbConfig.getUser(), commonDbConfig.getDatabase(), commonDbConfig.getPassword()));
+            processBuilder.command("/bin/sh", "-c", String.format("walminer pgto init -c %s -s '%s' -e %s -t 4 --source-connstr1='host=%s port=%s username=%s dbanme=%s password=%s'", toolDir.getAbsolutePath() + "/" + ctlDir, slotName, ((PostgresConfig) commonDbConfig).getPgtoPort(), commonDbConfig.getHost(), commonDbConfig.getPort(), commonDbConfig.getUser(), commonDbConfig.getDatabase(), commonDbConfig.getPassword()));
             process = processBuilder.start();
             process.waitFor(60, TimeUnit.SECONDS);
             try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
@@ -256,7 +256,7 @@ private boolean deployPgto() {
             }
             int exitCode = process.waitFor();
             System.out.println("exit code: " + exitCode);
-            processBuilder.command("/bin/sh", "-c", String.format("walminer pgto -m -c %s", toolDir.getAbsolutePath() + "/" + ctlDir));
+            processBuilder.command("/bin/sh", "-c", String.format("walminer pgto run -m -c %s", toolDir.getAbsolutePath() + "/" + ctlDir));
             processBuilder.redirectOutput(ProcessBuilder.Redirect.INHERIT);
             process = processBuilder.start();
             process.waitFor(60, TimeUnit.SECONDS);

connectors-common/postgres-core/src/main/java/io/tapdata/connector/postgres/cdc/AbstractWalLogMiner.java

@@ -176,6 +176,7 @@ protected void parseKeyAndValue(String tableName, Map.Entry<String, Object> stri
             case "integer":
             case "bigint":
             case "numeric":
+            case "money":
             case "real":
             case "double precision":
                 stringObjectEntry.setValue(new BigDecimal((String) value));