1、创建数据库
建一个数据库exchange_platform。
DROP DATABASE IF EXISTS exchange_platform CASCADE;
CREATE DATABASE IF NOT EXISTS exchange_platform;

2、删除数据库
DROP DATABASE IF EXISTS exchange_platform;

3、修改 DBPROPERTIES
ALTER DATABASE exchange_platform
SET DBPROPERTIES ('date'= '2015-12');

4、修改数据库owner
ALTER DATABASE exchange_platform
SET OWNER USER alice;
数据库owner可以是Inceptor的用户也可以是角色。

5、创建表
5.1、通过定义列建表
-- 将表建在当前数据库中：
DROP TABLE IF EXISTS user_info_tab;
CREATE TABLE user_info_tab (
  name STRING,
  acc_num STRING,
  password STRING,
  citizen_id STRING,
  bank_acc STRING,
  reg_date DATE,
  acc_level STRING
);

-- 将表建在指定数据库中：
DROP TABLE IF EXISTS exchange_platform.user_info;
CREATE TABLE exchange_platform.user_info (
  name STRING,
  acc_num STRING,
  password STRING,
  citizen_id STRING,
  bank_acc STRING,
  reg_date DATE,
  acc_level STRING
);

-- 建HDFS外表：
DROP TABLE IF EXISTS user_info_tab;
CREATE EXTERNAL TABLE user_info_tab (
  name STRING,
  acc_num STRING,
  password STRING,
  citizen_id STRING,
  bank_acc STRING,
  reg_date DATE,
  acc_level STRING
);
LOAD DATA LOCAL INPATH '/LOCALWORKSPACE/manual-ut/manual_data/manual_crud_tmp/user_info.txt'
OVERWRITE INTO TABLE user_info_tab;

5.2、通过拷贝表定义建表
DROP TABLE IF EXISTS exchange_platform.user_info;
CREATE TABLE IF NOT EXISTS exchange_platform.user_info
LIKE user_info;

5.3、CTAS
--用user_info表做为例子，user_info中含有帐户密码，身份证号码和银行帐户等会影响帐户安全的信息，现在用 CTAS 建一张不包含这些信息的表。
DROP TABLE IF EXISTS nonsecure_user_info ;
CREATE TABLE nonsecure_user_info
AS SELECT name, acc_num, reg_date, acc_level
FROM user_info;

6、删除表
DROP TABLE [IF EXISTS] ;

7、修改表
7.1 重命名
ALTER TABLE RENAME TO ;

7.2 修改或添加TBLPROPERTIES
-- 我们可以用这个语句给表添加和修改自定义的表属性。
ALTER TABLE SET TBLPROPERTIES ('' = '' … );

7.3 修改或添加SERDEPROPERTIES
ALTER TABLE SET SERDEPROPERTIES ('' = '' … );

7.4 修改外表目录
ALTER TABLE SET LOCATION '';
-- 将外表指向的HDFS目录改为 。注意，执行该操作的用户必须是 的owner

8、清空表
-- TRUNCATE TABLE 清空表或者分区中的数据，但不删除表或分区的元数据。这个操作只能用于托管表，不能用于外表。
8.1 清空表中数据
TRUNCATE TABLE user_info;

8.2 清空指定表中指定分区的数据
TRUNCATE TABLE user_info_part PARTITION (acc_level='A');

9、增加替换列
9.1 增加列
-- 可以将新的列加入表中，位置在所有列之后，分区之前。
DROP TABLE IF EXISTS test_change;
CREATE TABLE test_change (a INT, b INT, c INT);
-- 在表test_change中添加一个新列d，类型为INT
ALTER TABLE test_change ADD COLUMNS(d INT);

9.2 替换列
DROP TABLE IF EXISTS test_change;
CREATE TABLE test_change (a INT, b INT, c INT);
-- 将test_change中的列由(a INT, b INT, c INT)替换为(a int, b int)起到将列c删除的效果
ALTER TABLE test_change
REPLACE COLUMNS (a INT, b INT);

10、视图
10.1创建视图
DROP VIEW IF EXISTS non_secure_info;
CREATE VIEW non_secure_info AS SELECT name, reg_date, acc_level FROM user_info;
-- 注意:不支持CREATE VIEW AS SELECT … UNION SELECT

10.2 删除视图
DROP VIEW [IF EXISTS] ;

11、导入数据
-- 将本地数据导入一张表
LOAD DATA LOCAL INPATH '/LOCALWORKSPACE/manualut/manual_data/manual_crud_tmp/user_info_table.txt'
INTO TABLE user_info2;

-- 将本地数据导入一张表下的分区
LOAD DATA LOCAL INPATH '/LOCALWORKSPACE/manualut/manual_data/manual_crud_tmp/user_info_table_A.txt'
INTO TABLE partition_user_info
PARTITION (acc_level = 'A');

-- 将HDFS上的数据导入一张表
LOAD DATA INPATH '/manual_crud_hdfs/user_info3/test'
INTO TABLE user_info2;

12、向表中插入数据
-- 一些常见的DML如 UPDATE, DELETE和 INSERT … VALUES只能对ORC事务表、Hyperbase内存表、ES 表使用。
-- 而INSERT … SELECT、SELECT则可以作用于任意类型的表
12.1 向表中插入数据并覆盖原数据
INSERT OVERWRITE TABLE user_info2 SELECT * FROM user_info;

12.2 多次插入
-- 使用一个数据源可以将多个查询结果插入不同表中。语法
FROM user_info 
INSERT INTO TABLE user_name SELECT name n 
INSERT OVERWRITE TABLE user_name_num SELECT name, acc_num ac  
INSERT INTO TABLE user_name_level SELECT name, acc_level;

13、向文件系统中插入数据
-- 写入文件系统使用INSERT语句，但是不同于将数据INSERT进表中有INTO和OVERWRITE两种选项，将数据写入文件系统必须INSERT OVERWRITE。
13.1 将user_info中的内容写入本地某目录下。
INSERT OVERWRITE LOCAL DIRECTORY '/LOCALWORKSPACE/manual-ut/manual_data/user_info2/'
ROW FORMAT DELIMITED FIELDS TERMINATED BY'|'
SELECT * FROM user_info;

13.2 将user_info中的内容写入HDFS上的目录下
INSERT OVERWRITE DIRECTORY '/manual_crud_hdfs/user_info2/'
ROW FORMAT DELIMITED FIELDS TERMINATED BY'|'
SELECT * FROM user_info;

13.3 多插入
--在Inceptor中还可以用一个SQL语句将从一个数据源中检索出来的多个结果插入不同文件和表中。
FROM user_info
INSERT OVERWRITE LOCAL DIRECTORY '/LOCALWORKSPACE/manual-ut/manual_data/user_info4/'SELECT name a
INSERT OVERWRITE DIRECTORY '/manual_crud_hdfs/user_info5/'SELECT password b
INSERT INTO TABLE new_user SELECT name c
INSERT OVERWRITE TABLE user_name SELECT name d;

14、TEXT表
DROP TABLE IF EXISTS employee;
CREATE EXTERNAL TABLE employee (id INT, name STRING)
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
LOCATION '/manual_crud_tmp/employee';
SELECT * FROM employee;

15、CSV表
DROP TABLE IF EXISTS csv_table;
CREATE EXTERNAL TABLE csv_table
(
  col1 STRING,
  col2 STRING,
  col3 STRING
)
STORED AS CSVFILE;
LOAD DATA LOCAL INPATH '/LOCALWORKSPACE/manual-ut/manual_data/manual_crud_tmp/csv1.txt'
OVERWRITE INTO TABLE csv_table;

16、ORC表
SET transaction.type=inceptor;
-- 创建非分区ORC表。
DROP TABLE IF EXISTS ta;
CREATE TABLE ta (name STRING, age INT)
CLUSTERED BY (age) INTO 2 BUCKETS
STORED AS ORC TBLPROPERTIES ("transactional"="true");
-- 创建非分区ORC表。
DROP TABLE IF EXISTS tg;
CREATE TABLE tg (name STRING, gpa DOUBLE) CLUSTERED BY (name) INTO 4 BUCKETS STORED AS ORC
TBLPROPERTIES ("transactional"="true");
-- 创建单值分区ORC表。
DROP TABLE IF EXISTS test;
CREATE TABLE test (a INT, b STRING, c DOUBLE) PARTITIONED BY (date STRING) CLUSTERED BY (c) INTO 8
BUCKETS STORED AS ORC TBLPROPERTIES ("transactional"="true");
-- 创建范围分区ORC表。
DROP TABLE IF EXISTS t5;
CREATE TABLE t5(id INT, value INT) PARTITIONED BY RANGE(amount INT) (
PARTITION less1 VALUES LESS THAN (1),
PARTITION less10 VALUES LESS THAN (10),
PARTITION less100 VALUES LESS THAN (100) )
CLUSTERED BY (id) INTO 5 BUCKETS STORED AS ORC TBLPROPERTIES ("transactional"="true");
-- 桶的个数对事务处理的性能有关键性的影响，我们建议您设置合理的个数，
-- 一般是CPU个数的倍数，并且每个桶平均的大小控制不要超过200MB或者一百万行记录。

17、Holodesk表
--Holodesk普通建表
DROP TABLE IF EXISTS holodeskEmployee;
CREATE TABLE holodeskEmployee(
  ID INT,
  Region STRING,
  Sex VARCHAR(4),
  Department STRING,
  Salary DECIMAL
) STORED AS HOLODESK;