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);

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM