Mysql
 sql >> Datenbank >  >> RDS >> Mysql

Ignoriert die Ignorieroption der Pyspark DataFrameWriter jdbc-Funktion die gesamte Transaktion oder nur beleidigende Zeilen?

mode("ingore") ist nur NOOP, wenn die Tabelle (oder eine andere Senke) bereits vorhanden ist und Schreibmodi nicht kombiniert werden können. Wenn Sie nach etwas wie INSERT IGNORE suchen oder INSERT INTO ... WHERE NOT EXISTS ... Sie müssen dies manuell tun, zum Beispiel mit mapPartitions .