| create database if not exists multi_catalog; |
| use multi_catalog; |
| |
| CREATE TABLE text_table_normal_skip_header ( |
| id INT, |
| name STRING |
| ) |
| ROW FORMAT DELIMITED |
| FIELDS TERMINATED BY '\t' |
| STORED AS TEXTFILE |
| LOCATION '/user/doris/preinstalled_data/text/text_table_normal_skip_header' |
| TBLPROPERTIES ("skip.header.line.count"="2"); |
| |
| CREATE TABLE text_table_compressed_skip_header ( |
| id INT, |
| name STRING |
| ) |
| ROW FORMAT DELIMITED |
| FIELDS TERMINATED BY '\t' |
| STORED AS TEXTFILE |
| LOCATION '/user/doris/preinstalled_data/text/text_table_compressed_skip_header' |
| TBLPROPERTIES ("skip.header.line.count"="5"); |
| |
| CREATE TABLE csv_json_table_simple ( |
| id STRING, |
| status_json STRING |
| ) |
| ROW FORMAT SERDE |
| 'org.apache.hadoop.hive.serde2.OpenCSVSerde' |
| STORED AS TEXTFILE |
| LOCATION '/user/doris/preinstalled_data/csv/csv_json_table_simple'; |
| |
| CREATE TABLE open_csv_table_null_format ( |
| id INT, |
| name STRING |
| ) |
| ROW FORMAT SERDE |
| 'org.apache.hadoop.hive.serde2.OpenCSVSerde' |
| STORED AS TEXTFILE |
| LOCATION '/user/doris/preinstalled_data/csv/open_csv_table_null_format'; |
| |
| CREATE TABLE open_csv_complex_type ( |
| id INT, |
| arr_col ARRAY<INT>, |
| map_col MAP<STRING, INT>, |
| struct_col STRUCT<name:STRING, age:INT> |
| ) |
| ROW FORMAT SERDE |
| 'org.apache.hadoop.hive.serde2.OpenCSVSerde' |
| WITH SERDEPROPERTIES ( |
| "separatorChar" = ",", |
| "quoteChar" = "\"", |
| "escapeChar" = "\\" |
| ) |
| STORED AS TEXTFILE |
| LOCATION '/user/doris/preinstalled_data/csv/open_csv_complex_type'; |
| |
| create database if not exists openx_json; |
| use openx_json; |
| |
| CREATE TABLE IF NOT EXISTS json_table ( |
| id INT, |
| name STRING, |
| numbers ARRAY<INT>, |
| scores MAP<STRING, INT>, |
| details STRUCT<a:INT, b:STRING, c:BIGINT> |
| ) |
| ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe' |
| LOCATION '/user/doris/preinstalled_data/json/openx_json/json_table'; |
| |
| |
| CREATE TABLE IF NOT EXISTS json_table_ignore_malformed ( |
| id INT, |
| name STRING, |
| numbers ARRAY<INT>, |
| scores MAP<STRING, INT>, |
| details STRUCT<a:INT, b:STRING, c:BIGINT> |
| ) |
| ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe' |
| WITH SERDEPROPERTIES ("ignore.malformed.json" = "true" ) |
| LOCATION '/user/doris/preinstalled_data/json/openx_json/json_table'; |
| |
| |
| CREATE TABLE json_data_arrays_tb ( |
| name string, age int) |
| ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe' |
| LOCATION '/user/doris/preinstalled_data/json/openx_json/json_data_arrays_tb'; |
| |
| |
| CREATE TABLE IF NOT EXISTS scalar_to_array_tb( |
| id INT, |
| name STRING, |
| tags ARRAY<STRING> |
| )ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe' |
| LOCATION '/user/doris/preinstalled_data/json/openx_json/scalar_to_array_tb'; |
| |
| |
| CREATE TABLE IF NOT EXISTS json_one_column_table ( |
| name STRING, |
| id INT, |
| numbers ARRAY<INT>, |
| scores MAP<STRING, INT>, |
| details STRUCT<a:INT, b:STRING, c:BIGINT> |
| ) |
| ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe' |
| LOCATION '/user/doris/preinstalled_data/json/openx_json/json_one_column_table'; |
| |
| msck repair table json_table; |
| msck repair table json_table_ignore_malformed; |
| msck repair table json_data_arrays_tb; |
| msck repair table scalar_to_array_tb; |
| msck repair table json_one_column_table; |