[BugFix][Postgres][#1463] The cast is bad, only when 'rowConverter' instance of the 'JdbcColumnConverter' should cast. (#1464)

FlechazoW · web-flow · commit 1d87b291d902 · 2023-01-05T16:23:48.000+08:00
diff --git a/chunjun-connectors/chunjun-connector-postgresql/src/main/java/com/dtstack/chunjun/connector/postgresql/sink/PostgresOutputFormat.java b/chunjun-connectors/chunjun-connector-postgresql/src/main/java/com/dtstack/chunjun/connector/postgresql/sink/PostgresOutputFormat.java
@@ -88,10 +88,12 @@ protected void openInternal(int taskNumber, int numTasks) {
                 LOG.info("write sql:{}", copySql);
             }
             checkUpsert();
-            if (jdbcDialect.dialectName().equals("PostgreSQL")) {
-                ((PostgresqlColumnConverter) rowConverter).setConnection((BaseConnection) dbConn);
+            if (rowConverter instanceof JdbcColumnConverter) {
+                if (jdbcDialect.dialectName().equals("PostgresSQL")) {
+                    ((PostgresqlColumnConverter) rowConverter).setConnection((BaseConnection) dbConn);
+                }
+                ((PostgresqlColumnConverter) rowConverter).setFieldTypeList(columnTypeList);
             }
-            ((PostgresqlColumnConverter) rowConverter).setFieldTypeList(columnTypeList);
         } catch (SQLException sqe) {
             throw new IllegalArgumentException("checkUpsert() failed.", sqe);
         }

Original file line number	Diff line number	Diff line change
`@@ -88,10 +88,12 @@ protected void openInternal(int taskNumber, int numTasks) {`
`88`	`88`	`LOG.info("write sql:{}", copySql);`
`89`	`89`	`}`
`90`	`90`	`checkUpsert();`
`91`		`- if (jdbcDialect.dialectName().equals("PostgreSQL")) {`
`92`		`- ((PostgresqlColumnConverter) rowConverter).setConnection((BaseConnection) dbConn);`
	`91`	`+ if (rowConverter instanceof JdbcColumnConverter) {`
	`92`	`+ if (jdbcDialect.dialectName().equals("PostgresSQL")) {`
	`93`	`+ ((PostgresqlColumnConverter) rowConverter).setConnection((BaseConnection) dbConn);`
	`94`	`+ }`
	`95`	`+ ((PostgresqlColumnConverter) rowConverter).setFieldTypeList(columnTypeList);`
`93`	`96`	`}`
`94`		`- ((PostgresqlColumnConverter) rowConverter).setFieldTypeList(columnTypeList);`
`95`	`97`	`} catch (SQLException sqe) {`
`96`	`98`	`throw new IllegalArgumentException("checkUpsert() failed.", sqe);`
`97`	`99`	`}`