Flink用jdbc catalog连接postgresql时pg的schema里有横线该怎么处理？

在 PostgreSQL 中，带有横线的 schema 名称被视为非法的。因此，当你尝试使用 JDBC Catalog 连接 PostgreSQL 并引用这样的 schema 时，Flink 可能会抛出异常。

为了解决这个问题，你需要确保你的 schema 名称不包含横线或其他非法字符。如果 schema 名称已经存在且包含横线，你可能需要联系数据库管理员将其更改为合法的名称。

此外，你还可以尝试使用反引号（`）将 schema 名称括起来。在某些情况下，这可以帮助绕过某些关键字或特殊字符的问题。例如，你可以像这样引用 schema：

CREATE CATALOG mycat WITH (
  ...
  'default-database' = '`my-schema`',
  ...
);

请注意，这种方法可能不适用于所有数据库和所有情况，因此最好还是避免使用非法的 schema 名称。

在Flink SQL中通过 JDBC Catalog连接PostgreSQL数据库时遇到 schema 中包含反斜杠字符 \- 的问题，可以通过以下方式进行处理：

1. 使用双引号包围 schema 名称以转义其中的特殊字符。例如，在查询语句中应该这样写：

   select * from "enjoy-audit".au_tt_audit_rectifying;
   

   注意这里必须使用双引号包围 schema 和 table 名称，不能只包围表名的一部分。

2. 在 PostgreSQL 数据库中修改 schema 名称，移除反斜杠字符。虽然这不是一个理想的解决方案，但在某些情况下可能会有所帮助。但是请注意，这可能会涉及到更复杂的变更管理和兼容性测试过程，并且不适用于所有的应用场景。