insérerDans

Insère le contenu du DataFrame dans la table spécifiée. Exige que le schéma du DataFrame soit identique au schéma de la table.

Syntaxe

insertInto(tableName, overwrite=None)

parameter

parameter	Type	Description
tableName	str	Le nom de la table cible.
overwrite	bool, facultatif	Si True, écrase les données existantes. Désactivé par default.

parameter	Type	Description
tableName	str	Le nom de la table cible.
overwrite	bool, facultatif	Si True, écrase les données existantes. Désactivé par default.

Renvoie

Aucun

Notes

Contrairement à DataFrameWriter.saveAsTable, DataFrameWriter.insertInto ignore les noms de colonne et utilise la résolution basée sur la position.

Exemples

Insérer des données dans une table à l'aide de la résolution basée sur la position, en ignorant les noms de colonne.

Python

spark.sql("DROP TABLE IF EXISTS tblA")
df = spark.createDataFrame([
    (100, "Alice"), (120, "Alice"), (140, "Bob")],
    schema=["age", "name"]
)
df.write.saveAsTable("tblA")

df.selectExpr("age AS col1", "name AS col2").write.insertInto("tblA")
spark.read.table("tblA").sort("age").show()
# +---+------------+
# |age|        name|
# +---+------------+
# |100|Alice|
# |100|Alice|
# |120|Alice|
# |120|Alice|
# |140| Bob|
# |140| Bob|
# +---+------------+

spark.sql("DROP TABLE tblA")