Flink用jdbc catalog连接postgresql时,pg的schema里有横线该怎么处理呢?
以下为热心网友提供的参考意见
在Flink SQL中通过 JDBC Catalog连接PostgreSQL数据库时遇到 schema 中包含反斜杠字符 \-
的问题,可以通过以下方式进行处理:
-
使用双引号包围 schema 名称以转义其中的特殊字符。例如,在查询语句中应该这样写:
select * from "enjoy-audit".au_tt_audit_rectifying;
注意这里必须使用双引号包围 schema 和 table 名称,不能只包围表名的一部分。
-
在 PostgreSQL 数据库中修改 schema 名称,移除反斜杠字符。虽然这不是一个理想的解决方案,但在某些情况下可能会有所帮助。但是请注意,这可能会涉及到更复杂的变更管理和兼容性测试过程,并且不适用于所有的应用场景。
本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/19689.html