How to write JSON column type to Postgres with PySpark?

Question

I have a Postgresql table that has a column with data type JSONB.

How do I insert DataFrame to the Postgresql table via JDBC?

If I have a UDF to convert the the body column to the JSONB Postgresql data type, what is the corresponding pyspark.sql.types should I use?

Postgresql Table with a JSONB column:

CREATE TABLE dummy (
  id bigint,
  body JSONB
);

Thanks!

Answer 1

原来，如果我将其设置"stringtype":"unspecified"为JDBC的属性，Postgres将自动转换：

    属性= {
        “用户”：“ ***”，
        “密码”：“ ***”，
        “ stringtype”：“未指定”
    }
    df.write.jdbc（URL = URL，table =“ dummy”，properties = properties）