sql >> Databáze >  >> RDS >> PostgreSQL

Spark Dataframes UPSERT to Postgres Table

Není podporováno. DataFrameWriter může buď připojit nebo přepsat existující tabulku. Pokud vaše aplikace vyžaduje složitější logiku, budete se s tím muset vypořádat ručně.

Jednou z možností je použít akci (foreach , foreachPartition ) se standardním připojením JDBC. Dalším je zapsat do dočasného a zbytek zpracovat přímo v databázi.

Viz také SPARK-19335 (Spark by měl podporovat provádění efektivního Upsert DataFrame prostřednictvím JDBC ) a související návrhy.



  1. Jak používat regexp ve sqlite

  2. Oracle Database Testing Challenge – Porovnejte data schématu

  3. Základní monitorování PostgreSQL – část 1

  4. Skrytá vylepšení výkonu a správy v SQL Server 2012 / 2014