sql >> Database teknologi >  >> RDS >> PostgreSQL

Spark Dataframes UPSERT til Postgres Table

Det er ikke understøttet. DataFrameWriter kan enten tilføje til eller overskrive eksisterende tabel. Hvis din ansøgning kræver mere kompleks logik, bliver du nødt til at håndtere dette manuelt.

En mulighed er at bruge en handling (foreach , foreachPartition ) med standard JDBC-forbindelse. En anden er at skrive til en midlertidig og håndtere resten direkte i databasen.

Se også SPARK-19335 (Spark bør understøtte at lave en effektiv DataFrame Upsert via JDBC ) og relaterede forslag.



  1. Beregn alder baseret på fødselsdato

  2. ORA-01438:værdi større end den specificerede præcision tilladt for denne kolonne, når der indsættes 3

  3. MySQL:hvordan man får forskellen mellem to tidsstempler på sekunder

  4. Hvordan opretter man en Oracle-sekvens, der starter med maks. værdi fra en tabel?