sparksql insert 语句注意事项
我们在使用mysql进行插入操作时,可以使用如下语法:
INSERT INTO 表名 (列1,列2,列3...)VALUES(值1,值2,值3...)
列的数量是可变的,是可以指定的。
但使用spqrksql进行插入操作时,不能指定任意数量的列,必须插入包含全部列的记录,sparksql官网中(https://spark.apache.org/docs/latest/sql-ref-syntax-dml-insert-into.html)insert into例子如下:
CREATE TABLE students (name VARCHAR(64), address VARCHAR(64)) USING PARQUET PARTITIONED BY (student_id INT); INSERT INTO students VALUES ('Amy Smith', '123 Park Ave, San Jose', 111111); INSERT INTO students VALUES ('Bob Brown', '456 Taylor St, Cupertino', 222222), ('Cathy Johnson', '789 Race Ave, Palo Alto', 333333);