sql 斯卡拉火花创建-databases.sql

Posted 2021-05-13

CREATE DATABASE sparkdemo;
USE sparkdemo;

CREATE TABLE orders (
  order_id int,
  order_date string,
  order_customer_id int,
  order_status string
) ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
STORED AS TEXTFILE;

LOAD DATA LOCAL INPATH '/data/retail_db/orders' INTO TABLE orders;

CREATE TABLE order_items (
  order_item_id int,
  order_item_order_id int,
  order_item_product_id int,
  order_item_quantity smallint,
  order_item_subtotal float,
  order_item_product_price float
) ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
STORED AS TEXTFILE;

LOAD DATA LOCAL INPATH '/data/retail_db/order_items' INTO TABLE order_items;