Flink CDC中flinksql写入到pg数据库嘛？

是的，Flink CDC支持将数据写入到PostgreSQL数据库。您可以使用Flink的Table/SQL API来实现这一功能。
以下是一个简单的示例，展示如何使用Flink SQL将数据写入到PostgreSQL数据库：

INSERT INTO postgresql_sink_table
SELECT * FROM stream_table;

在这个例子中，stream_table是源数据表，postgresql_sink_table是目标PostgreSQL表。该语句将会把流表中的数据插入到PostgreSQL表中。
需要注意的是，在使用Flink SQL写入PostgreSQL之前，需要先创建好目标表，并确保Flink能够访问PostgreSQL数据库。这通常需要提供正确的数据库连接信息（如URL、用户名和密码），并在Flink环境中安装必要的驱动程序。

是的，Flink CDC 可以通过 Flink SQL 将数据写入 PostgreSQL 数据库。具体来说，你可以使用 Flink JDBC connector 来连接到 PostgreSQL 数据库，并使用 INSERT INTO 语句将数据写入表中。
以下是一个示例代码，展示如何在 Flink SQL 中将数据写入 PostgreSQL 数据库：

CREATE TABLE my_table (
    id INT,
    value DOUBLE
) WITH (
    'connector' = 'jdbc',
    'url' = 'jdbc:postgresql://localhost:5432/mydatabase',
    'table-name' = 'mytable'
);

INSERT INTO my_table SELECT id, value FROM my_source_table;

在这个例子中，我们首先创建了一个名为 my_table 的表，并指定了它使用的数据库和表名。然后，我们使用 INSERT INTO 语句将 my_source_table 表中的数据写入到 my_table 表中。
注意，你需要确保你的 PostgreSQL 数据库已经正确配置了 Flink JDBC connector，以便能够接收来自 Flink CDC 的数据。此外，你还需要确保你的 Flink 配置文件中包含了正确的数据库连接信息，包括主机名、端口、用户名和密码等。
总之，Flink CDC 可以通过 Flink SQL 将数据写入 PostgreSQL 数据库，你可以使用 Flink JDBC connector 来连接到数据库，并使用 INSERT INTO 语句将数据写入表中。

是的，Flink CDC支持将数据通过Flink SQL写入到PostgreSQL数据库。在实际操作中，首先需要创建一个StreamTableEnvironment对象，然后通过设置AbstractJdbcCatalog对象来指定目标数据库的信息。接下来，你可以使用Flink SQL来编写具体的数据处理逻辑，最后将处理后的数据通过Flink CDC upsert到PostgreSQL数据库中。

值得注意的是，要实现PostgreSQL的CDC功能，你需要确保你的PostgreSQL数据库配置正确，包括WAL日志方式设置为logical。此外，Flink CDC可以保证全量快照数据的读取和变更数据的读取都能精确一次不漏，即使在发生故障的情况下也能保证数据的完整性。

写pg可以，写greenplum不行，通过jdbc连接器是可以的，建议用官方提供的jdbc- connector，此回答整理自钉群“Flink CDC 社区”