Flink sink 到 pg json格式的数据怎么写入呀？

Flink 可以使用 JdbcOutputFormat 连接器将数据写入 PostgreSQL。JdbcOutputFormat 有一个 json 方法，可以将数据写入 PostgreSQL 的 JSON 表。例如，以下代码使用 JdbcOutputFormat 将 JSON 格式的数据写入 PostgreSQL 的表 users:

val jdbcSink = new JdbcOutputFormat()
jdbcSink.setDriverName("org.postgresql.Driver")
jdbcSink.setDBUrl("jdbc:postgresql://localhost:5432/test")
jdbcSink.setUsername("flink")
jdbcSink.setPassword("flink")
jdbcSink.setTableName("users")
jdbcSink.setPreparedStatement("insert into users (name, age, birthdate) values (?, ?, ?)")

val data = Seq(
("John", 20, "1990-01-01"),
("Jane", 21, "1991-01-01")
)

data.foreach(row => jdbcSink.writeRecord(row))
当我们运行这个代码后，会在 test 数据库中创建一个名为 users 的表，表中的数据会以 JSON 格式存储。