DataX 官方 postgresqlreader 期望 connection.querySql 为 List<String>; 老代码塞了单个 string,DataX ReaderSplitUtil.doSplit 读成 List 时 ClassCastException。querySql 模式从未被激活使用所以没暴露;本轮 启用 cert_birthday 脱敏踩到。改为 split(';') 与 mysql_reader 一致。 Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
@@ -61,7 +61,7 @@ class PostgreSQLReader(Reader):
if query_sql:
connection = {
DS_POSTGRE_SQL_JDBC_URL: jdbc_url.split(','),
- POSTGRE_SQL_READER_PARAMETER_QUERY_SQL: query_sql
+ POSTGRE_SQL_READER_PARAMETER_QUERY_SQL: query_sql.split(';')
}
else: