PostgreSQL
 sql >> Base de Dados >  >> RDS >> PostgreSQL

Spark Dataframes UPSERT para tabela Postgres


Não é suportado. DataFrameWriter pode anexar ou substituir a tabela existente. Se seu aplicativo requer uma lógica mais complexa, você terá que lidar com isso manualmente.

Uma opção é usar uma ação (foreach , foreachPartition ) com conexão JDBC padrão. Outra é escrever em um temporário e manipular o resto diretamente no banco de dados.

Veja também SPARK-19335 (Spark deve suportar fazer um DataFrame Upsert eficiente via JDBC ) e propostas relacionadas.