【spark】Spark SQL:INSERT INTO语句语法

Spark SQL:INSERT INTO语句语法

您可以

INSERT

像通常那样使用语句:

INSERTINTO hello (someId,name)VALUES(1,"hello")

在Spark 2.0(Python)环境中测试它以及与Mysql数据库的连接会引发错误:

File "/home/yawn/spark-2.0.0-bin-hadoop2.7/python/lib/pyspark.zip/pyspark/sql/utils.py", line 73, in deco
pyspark.sql.utils.ParseException: 
u'\nmismatched input \'someId\' expecting {\'(\', \'SELECT\', \'FROM\', \'VALUES\', \'TABLE\', \'INSERT\', \'MAP\', \'REDUCE\'}(line 1, pos 19)\n\n== SQL ==\nINSERT INTO hello (someId,name) VALUES (1,"hello")\n-------------------^^^\n'

但是,如果我删除显式列定义,它将按预期工作:

INSERTINTO hello VALUES(1,"hello");