postgresql 无法使用JDBC在Postgres中插入数据

mm5n2pyu  于 2023-06-22  发布在  PostgreSQL
关注(0)|答案(1)|浏览(168)

我正在尝试使用PySpark和JDBC将数据插入PostgreSQL数据库。但是,在数据插入过程中,它意外地尝试重新创建表并生成以下输出。

org.postgresql.util.PSQLException: ERROR: relation "account" already exists

我正在尝试使用下面的代码片段在Postgres中写入数据。

def postgres_writes(url, driver, username, password, table_name, df):
df.write \
  .format("jdbc") \
  .option("url", url) \
  .option("dbtable", table_name) \
  .option("user", username) \
  .option("password", password) \
  .option("driver", driver) \
  .mode("append") \
  .save()

我想在现有表中追加数据。

ttp71kqs

ttp71kqs1#

请确保您传递的是适当的jdbcurl。根据Postgres文档Documentation Link,您可以使用以下JDBC URL的表单

jdbc:postgresql:database
jdbc:postgresql:/
jdbc:postgresql://host/database
jdbc:postgresql://host/
jdbc:postgresql://host:port/database
jdbc:postgresql://host:port/

同时尝试重新创建表并尝试再次加载数据。Spark会话级别可能存在一些问题。

相关问题