如何使用jdbc pyspark python在现有表中添加新列?

Question

是否可以将新列添加到现有表而不覆盖它?如果表中有col1，我要添加col2。因此，在。save()之后，col1和col2将同时存在，而不仅仅是覆盖col2。

提前谢谢你。

Answer 1

参见alter syntax

https://spark.apache.org/docs/latest/sql-ref-syntax-ddl-alter-table.html

使用spark.sql(query)

f。e.ALTER TABLE yourtable ADD columns (LastName string, DOB timestamp);