diff --git a/metastore/scripts/upgrade/hive/hive-schema-3.0.0.hive.sql b/metastore/scripts/upgrade/hive/hive-schema-3.0.0.hive.sql index 71671c4..923f37d 100644 --- a/metastore/scripts/upgrade/hive/hive-schema-3.0.0.hive.sql +++ b/metastore/scripts/upgrade/hive/hive-schema-3.0.0.hive.sql @@ -1,7 +1,6 @@ -- HIVE system db -DROP DATABASE IF EXISTS SYS CASCADE; -CREATE DATABASE SYS; +CREATE DATABASE IF NOT EXISTS SYS; USE SYS; @@ -821,15 +820,6 @@ CREATE EXTERNAL TABLE IF NOT EXISTS `VERSION` ( `VER_ID` BIGINT, `SCHEMA_VERSION` string, `VERSION_COMMENT` string, - CONSTRAINT `SYS_PK_VERSION` PRIMARY KEY (`VER_ID`) DISABLE -); - -INSERT INTO `VERSION` VALUES (1, '3.0.0', 'Hive release version 3.0.0'); - -CREATE EXTERNAL TABLE IF NOT EXISTS `DB_VERSION` ( - `VER_ID` BIGINT, - `SCHEMA_VERSION` string, - `VERSION_COMMENT` string, CONSTRAINT `SYS_PK_DB_VERSION` PRIMARY KEY (`VER_ID`) DISABLE ) STORED BY 'org.apache.hive.storage.jdbc.JdbcStorageHandler' @@ -924,6 +914,8 @@ FROM \"KEY_CONSTRAINTS\"" ); +DROP VIEW IF EXISTS `TABLE_STATS_VIEW`; + CREATE VIEW `TABLE_STATS_VIEW` AS SELECT `TBL_ID`, @@ -935,6 +927,8 @@ SELECT max(CASE `PARAM_KEY` WHEN 'transient_lastDdlTime' THEN `PARAM_VALUE` END) AS TRANSIENT_LAST_DDL_TIME FROM `TABLE_PARAMS` GROUP BY `TBL_ID`; +DROP VIEW IF EXISTS `PARTITION_STATS_VIEW`; + CREATE VIEW `PARTITION_STATS_VIEW` AS SELECT `PART_ID`, @@ -1064,12 +1058,13 @@ LEFT OUTER JOIN \"WM_POOL\" ON \"WM_POOL\".\"POOL_ID\" = \"WM_MAPPING\".\"POOL_I " ); -DROP DATABASE IF EXISTS INFORMATION_SCHEMA CASCADE; -CREATE DATABASE INFORMATION_SCHEMA; +CREATE DATABASE IF NOT EXISTS INFORMATION_SCHEMA; USE INFORMATION_SCHEMA; -CREATE VIEW IF NOT EXISTS `SCHEMATA` +DROP VIEW IF EXISTS `SCHEMATA`; + +CREATE VIEW `SCHEMATA` ( `CATALOG_NAME`, `SCHEMA_NAME`, @@ -1097,7 +1092,9 @@ WHERE OR ((array_contains(current_groups(), P.`PRINCIPAL_NAME`) OR P.`PRINCIPAL_NAME` = 'public') AND P.`PRINCIPAL_TYPE`='GROUP')) AND current_authorizer() = P.`AUTHORIZER`; -CREATE VIEW IF NOT EXISTS `TABLES` +DROP VIEW IF EXISTS `TABLES`; + +CREATE VIEW `TABLES` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -1134,7 +1131,9 @@ WHERE OR ((array_contains(current_groups(), P.`PRINCIPAL_NAME`) OR P.`PRINCIPAL_NAME` = 'public') AND P.`PRINCIPAL_TYPE`='GROUP'))) AND P.`TBL_PRIV`='SELECT' AND P.`AUTHORIZER`=current_authorizer(); -CREATE VIEW IF NOT EXISTS `TABLE_PRIVILEGES` +DROP VIEW IF EXISTS `TABLE_PRIVILEGES`; + +CREATE VIEW `TABLE_PRIVILEGES` ( `GRANTOR`, `GRANTEE`, @@ -1168,7 +1167,9 @@ WHERE OR ((array_contains(current_groups(), P2.`PRINCIPAL_NAME`) OR P2.`PRINCIPAL_NAME` = 'public') AND P2.`PRINCIPAL_TYPE`='GROUP'))) AND P2.`TBL_PRIV`='SELECT' AND P.`AUTHORIZER` = current_authorizer() AND P2.`AUTHORIZER` = current_authorizer(); -CREATE VIEW IF NOT EXISTS `COLUMNS` +DROP VIEW IF EXISTS `COLUMNS`; + +CREATE VIEW `COLUMNS` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -1323,7 +1324,9 @@ WHERE OR ((array_contains(current_groups(), P.`PRINCIPAL_NAME`) OR P.`PRINCIPAL_NAME` = 'public') AND P.`PRINCIPAL_TYPE`='GROUP')) AND P.`TBL_COL_PRIV`='SELECT' AND P.`AUTHORIZER`=current_authorizer()); -CREATE VIEW IF NOT EXISTS `COLUMN_PRIVILEGES` +DROP VIEW IF EXISTS `COLUMN_PRIVILEGES`; + +CREATE VIEW `COLUMN_PRIVILEGES` ( `GRANTOR`, `GRANTEE`, @@ -1359,7 +1362,9 @@ WHERE OR ((array_contains(current_groups(), P2.`PRINCIPAL_NAME`) OR P2.`PRINCIPAL_NAME` = 'public') AND P2.`PRINCIPAL_TYPE`='GROUP')) AND P2.`TBL_PRIV`='SELECT' AND P.`AUTHORIZER`=current_authorizer() AND P2.`AUTHORIZER`=current_authorizer()); -CREATE VIEW IF NOT EXISTS `VIEWS` +DROP VIEW IF EXISTS `VIEWS`; + +CREATE VIEW `VIEWS` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, diff --git a/metastore/scripts/upgrade/hive/hive-schema-3.1.0.hive.sql b/metastore/scripts/upgrade/hive/hive-schema-3.1.0.hive.sql index 9bfe9c2..923f37d 100644 --- a/metastore/scripts/upgrade/hive/hive-schema-3.1.0.hive.sql +++ b/metastore/scripts/upgrade/hive/hive-schema-3.1.0.hive.sql @@ -1,7 +1,6 @@ -- HIVE system db -DROP DATABASE IF EXISTS SYS CASCADE; -CREATE DATABASE SYS; +CREATE DATABASE IF NOT EXISTS SYS; USE SYS; @@ -821,15 +820,6 @@ CREATE EXTERNAL TABLE IF NOT EXISTS `VERSION` ( `VER_ID` BIGINT, `SCHEMA_VERSION` string, `VERSION_COMMENT` string, - CONSTRAINT `SYS_PK_VERSION` PRIMARY KEY (`VER_ID`) DISABLE -); - -INSERT INTO `VERSION` VALUES (1, '3.1.0', 'Hive release version 3.1.0'); - -CREATE EXTERNAL TABLE IF NOT EXISTS `DB_VERSION` ( - `VER_ID` BIGINT, - `SCHEMA_VERSION` string, - `VERSION_COMMENT` string, CONSTRAINT `SYS_PK_DB_VERSION` PRIMARY KEY (`VER_ID`) DISABLE ) STORED BY 'org.apache.hive.storage.jdbc.JdbcStorageHandler' @@ -924,6 +914,8 @@ FROM \"KEY_CONSTRAINTS\"" ); +DROP VIEW IF EXISTS `TABLE_STATS_VIEW`; + CREATE VIEW `TABLE_STATS_VIEW` AS SELECT `TBL_ID`, @@ -935,6 +927,8 @@ SELECT max(CASE `PARAM_KEY` WHEN 'transient_lastDdlTime' THEN `PARAM_VALUE` END) AS TRANSIENT_LAST_DDL_TIME FROM `TABLE_PARAMS` GROUP BY `TBL_ID`; +DROP VIEW IF EXISTS `PARTITION_STATS_VIEW`; + CREATE VIEW `PARTITION_STATS_VIEW` AS SELECT `PART_ID`, @@ -1064,12 +1058,13 @@ LEFT OUTER JOIN \"WM_POOL\" ON \"WM_POOL\".\"POOL_ID\" = \"WM_MAPPING\".\"POOL_I " ); -DROP DATABASE IF EXISTS INFORMATION_SCHEMA CASCADE; -CREATE DATABASE INFORMATION_SCHEMA; +CREATE DATABASE IF NOT EXISTS INFORMATION_SCHEMA; USE INFORMATION_SCHEMA; -CREATE VIEW IF NOT EXISTS `SCHEMATA` +DROP VIEW IF EXISTS `SCHEMATA`; + +CREATE VIEW `SCHEMATA` ( `CATALOG_NAME`, `SCHEMA_NAME`, @@ -1097,7 +1092,9 @@ WHERE OR ((array_contains(current_groups(), P.`PRINCIPAL_NAME`) OR P.`PRINCIPAL_NAME` = 'public') AND P.`PRINCIPAL_TYPE`='GROUP')) AND current_authorizer() = P.`AUTHORIZER`; -CREATE VIEW IF NOT EXISTS `TABLES` +DROP VIEW IF EXISTS `TABLES`; + +CREATE VIEW `TABLES` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -1134,7 +1131,9 @@ WHERE OR ((array_contains(current_groups(), P.`PRINCIPAL_NAME`) OR P.`PRINCIPAL_NAME` = 'public') AND P.`PRINCIPAL_TYPE`='GROUP'))) AND P.`TBL_PRIV`='SELECT' AND P.`AUTHORIZER`=current_authorizer(); -CREATE VIEW IF NOT EXISTS `TABLE_PRIVILEGES` +DROP VIEW IF EXISTS `TABLE_PRIVILEGES`; + +CREATE VIEW `TABLE_PRIVILEGES` ( `GRANTOR`, `GRANTEE`, @@ -1168,7 +1167,9 @@ WHERE OR ((array_contains(current_groups(), P2.`PRINCIPAL_NAME`) OR P2.`PRINCIPAL_NAME` = 'public') AND P2.`PRINCIPAL_TYPE`='GROUP'))) AND P2.`TBL_PRIV`='SELECT' AND P.`AUTHORIZER` = current_authorizer() AND P2.`AUTHORIZER` = current_authorizer(); -CREATE VIEW IF NOT EXISTS `COLUMNS` +DROP VIEW IF EXISTS `COLUMNS`; + +CREATE VIEW `COLUMNS` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -1323,7 +1324,9 @@ WHERE OR ((array_contains(current_groups(), P.`PRINCIPAL_NAME`) OR P.`PRINCIPAL_NAME` = 'public') AND P.`PRINCIPAL_TYPE`='GROUP')) AND P.`TBL_COL_PRIV`='SELECT' AND P.`AUTHORIZER`=current_authorizer()); -CREATE VIEW IF NOT EXISTS `COLUMN_PRIVILEGES` +DROP VIEW IF EXISTS `COLUMN_PRIVILEGES`; + +CREATE VIEW `COLUMN_PRIVILEGES` ( `GRANTOR`, `GRANTEE`, @@ -1359,7 +1362,9 @@ WHERE OR ((array_contains(current_groups(), P2.`PRINCIPAL_NAME`) OR P2.`PRINCIPAL_NAME` = 'public') AND P2.`PRINCIPAL_TYPE`='GROUP')) AND P2.`TBL_PRIV`='SELECT' AND P.`AUTHORIZER`=current_authorizer() AND P2.`AUTHORIZER`=current_authorizer()); -CREATE VIEW IF NOT EXISTS `VIEWS` +DROP VIEW IF EXISTS `VIEWS`; + +CREATE VIEW `VIEWS` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, diff --git a/metastore/scripts/upgrade/hive/upgrade.order.hive b/metastore/scripts/upgrade/hive/upgrade.order.hive index e69de29..dd040af 100644 --- a/metastore/scripts/upgrade/hive/upgrade.order.hive +++ b/metastore/scripts/upgrade/hive/upgrade.order.hive @@ -0,0 +1 @@ +3.0.0-to-3.1.0 diff --git a/ql/src/test/results/clientpositive/llap/resourceplan.q.out b/ql/src/test/results/clientpositive/llap/resourceplan.q.out index 143b710..ce653bd 100644 --- a/ql/src/test/results/clientpositive/llap/resourceplan.q.out +++ b/ql/src/test/results/clientpositive/llap/resourceplan.q.out @@ -66,14 +66,10 @@ default srcpart hive_test_user USER DELETE true -1 hive_test_user default srcpart hive_test_user USER INSERT true -1 hive_test_user default srcpart hive_test_user USER SELECT true -1 hive_test_user default srcpart hive_test_user USER UPDATE true -1 hive_test_user -PREHOOK: query: DROP DATABASE IF EXISTS SYS CASCADE -PREHOOK: type: DROPDATABASE -POSTHOOK: query: DROP DATABASE IF EXISTS SYS CASCADE -POSTHOOK: type: DROPDATABASE -PREHOOK: query: CREATE DATABASE SYS +PREHOOK: query: CREATE DATABASE IF NOT EXISTS SYS PREHOOK: type: CREATEDATABASE PREHOOK: Output: database:SYS -POSTHOOK: query: CREATE DATABASE SYS +POSTHOOK: query: CREATE DATABASE IF NOT EXISTS SYS POSTHOOK: type: CREATEDATABASE POSTHOOK: Output: database:SYS PREHOOK: query: USE SYS @@ -1846,35 +1842,6 @@ PREHOOK: query: CREATE EXTERNAL TABLE IF NOT EXISTS `VERSION` ( `VER_ID` BIGINT, `SCHEMA_VERSION` string, `VERSION_COMMENT` string, - CONSTRAINT `SYS_PK_VERSION` PRIMARY KEY (`VER_ID`) DISABLE -) -PREHOOK: type: CREATETABLE -PREHOOK: Output: SYS@VERSION -PREHOOK: Output: database:sys -POSTHOOK: query: CREATE EXTERNAL TABLE IF NOT EXISTS `VERSION` ( - `VER_ID` BIGINT, - `SCHEMA_VERSION` string, - `VERSION_COMMENT` string, - CONSTRAINT `SYS_PK_VERSION` PRIMARY KEY (`VER_ID`) DISABLE -) -POSTHOOK: type: CREATETABLE -POSTHOOK: Output: SYS@VERSION -POSTHOOK: Output: database:sys -PREHOOK: query: INSERT INTO `VERSION` VALUES (1, '3.1.0', 'Hive release version 3.1.0') -PREHOOK: type: QUERY -PREHOOK: Input: _dummy_database@_dummy_table -PREHOOK: Output: sys@version -POSTHOOK: query: INSERT INTO `VERSION` VALUES (1, '3.1.0', 'Hive release version 3.1.0') -POSTHOOK: type: QUERY -POSTHOOK: Input: _dummy_database@_dummy_table -POSTHOOK: Output: sys@version -POSTHOOK: Lineage: version.schema_version SCRIPT [] -POSTHOOK: Lineage: version.ver_id SCRIPT [] -POSTHOOK: Lineage: version.version_comment SCRIPT [] -PREHOOK: query: CREATE EXTERNAL TABLE IF NOT EXISTS `DB_VERSION` ( - `VER_ID` BIGINT, - `SCHEMA_VERSION` string, - `VERSION_COMMENT` string, CONSTRAINT `SYS_PK_DB_VERSION` PRIMARY KEY (`VER_ID`) DISABLE ) STORED BY 'org.apache.hive.storage.jdbc.JdbcStorageHandler' @@ -1889,9 +1856,9 @@ FROM \"VERSION\"" ) PREHOOK: type: CREATETABLE -PREHOOK: Output: SYS@DB_VERSION +PREHOOK: Output: SYS@VERSION PREHOOK: Output: database:sys -POSTHOOK: query: CREATE EXTERNAL TABLE IF NOT EXISTS `DB_VERSION` ( +POSTHOOK: query: CREATE EXTERNAL TABLE IF NOT EXISTS `VERSION` ( `VER_ID` BIGINT, `SCHEMA_VERSION` string, `VERSION_COMMENT` string, @@ -1909,7 +1876,7 @@ FROM \"VERSION\"" ) POSTHOOK: type: CREATETABLE -POSTHOOK: Output: SYS@DB_VERSION +POSTHOOK: Output: SYS@VERSION POSTHOOK: Output: database:sys PREHOOK: query: CREATE EXTERNAL TABLE IF NOT EXISTS `FUNCS` ( `FUNC_ID` bigint, @@ -2053,6 +2020,10 @@ FROM POSTHOOK: type: CREATETABLE POSTHOOK: Output: SYS@KEY_CONSTRAINTS POSTHOOK: Output: database:sys +PREHOOK: query: DROP VIEW IF EXISTS `TABLE_STATS_VIEW` +PREHOOK: type: DROPVIEW +POSTHOOK: query: DROP VIEW IF EXISTS `TABLE_STATS_VIEW` +POSTHOOK: type: DROPVIEW PREHOOK: query: CREATE VIEW `TABLE_STATS_VIEW` AS SELECT `TBL_ID`, @@ -2088,6 +2059,10 @@ POSTHOOK: Lineage: TABLE_STATS_VIEW.raw_data_size EXPRESSION [(table_params)tabl POSTHOOK: Lineage: TABLE_STATS_VIEW.tbl_id SIMPLE [(table_params)table_params.FieldSchema(name:tbl_id, type:bigint, comment:from deserializer), ] POSTHOOK: Lineage: TABLE_STATS_VIEW.total_size EXPRESSION [(table_params)table_params.FieldSchema(name:param_key, type:string, comment:from deserializer), (table_params)table_params.FieldSchema(name:param_value, type:string, comment:from deserializer), ] POSTHOOK: Lineage: TABLE_STATS_VIEW.transient_last_ddl_time EXPRESSION [(table_params)table_params.FieldSchema(name:param_key, type:string, comment:from deserializer), (table_params)table_params.FieldSchema(name:param_value, type:string, comment:from deserializer), ] +PREHOOK: query: DROP VIEW IF EXISTS `PARTITION_STATS_VIEW` +PREHOOK: type: DROPVIEW +POSTHOOK: query: DROP VIEW IF EXISTS `PARTITION_STATS_VIEW` +POSTHOOK: type: DROPVIEW PREHOOK: query: CREATE VIEW `PARTITION_STATS_VIEW` AS SELECT `PART_ID`, @@ -2379,14 +2354,10 @@ LEFT OUTER JOIN \"WM_POOL\" ON \"WM_POOL\".\"POOL_ID\" = \"WM_MAPPING\".\"POOL_I POSTHOOK: type: CREATETABLE POSTHOOK: Output: SYS@WM_MAPPINGS POSTHOOK: Output: database:sys -PREHOOK: query: DROP DATABASE IF EXISTS INFORMATION_SCHEMA CASCADE -PREHOOK: type: DROPDATABASE -POSTHOOK: query: DROP DATABASE IF EXISTS INFORMATION_SCHEMA CASCADE -POSTHOOK: type: DROPDATABASE -PREHOOK: query: CREATE DATABASE INFORMATION_SCHEMA +PREHOOK: query: CREATE DATABASE IF NOT EXISTS INFORMATION_SCHEMA PREHOOK: type: CREATEDATABASE PREHOOK: Output: database:INFORMATION_SCHEMA -POSTHOOK: query: CREATE DATABASE INFORMATION_SCHEMA +POSTHOOK: query: CREATE DATABASE IF NOT EXISTS INFORMATION_SCHEMA POSTHOOK: type: CREATEDATABASE POSTHOOK: Output: database:INFORMATION_SCHEMA PREHOOK: query: USE INFORMATION_SCHEMA @@ -2395,7 +2366,11 @@ PREHOOK: Input: database:information_schema POSTHOOK: query: USE INFORMATION_SCHEMA POSTHOOK: type: SWITCHDATABASE POSTHOOK: Input: database:information_schema -PREHOOK: query: CREATE VIEW IF NOT EXISTS `SCHEMATA` +PREHOOK: query: DROP VIEW IF EXISTS `SCHEMATA` +PREHOOK: type: DROPVIEW +POSTHOOK: query: DROP VIEW IF EXISTS `SCHEMATA` +POSTHOOK: type: DROPVIEW +PREHOOK: query: CREATE VIEW `SCHEMATA` ( `CATALOG_NAME`, `SCHEMA_NAME`, @@ -2428,7 +2403,7 @@ PREHOOK: Input: sys@tbl_privs PREHOOK: Input: sys@tbls PREHOOK: Output: INFORMATION_SCHEMA@SCHEMATA PREHOOK: Output: database:information_schema -POSTHOOK: query: CREATE VIEW IF NOT EXISTS `SCHEMATA` +POSTHOOK: query: CREATE VIEW `SCHEMATA` ( `CATALOG_NAME`, `SCHEMA_NAME`, @@ -2468,7 +2443,11 @@ POSTHOOK: Lineage: SCHEMATA.default_character_set_schema EXPRESSION [] POSTHOOK: Lineage: SCHEMATA.schema_name SIMPLE [(dbs)d.FieldSchema(name:name, type:string, comment:from deserializer), ] #### A masked pattern was here #### POSTHOOK: Lineage: SCHEMATA.sql_path SIMPLE [(dbs)d.FieldSchema(name:db_location_uri, type:string, comment:from deserializer), ] -PREHOOK: query: CREATE VIEW IF NOT EXISTS `TABLES` +PREHOOK: query: DROP VIEW IF EXISTS `TABLES` +PREHOOK: type: DROPVIEW +POSTHOOK: query: DROP VIEW IF EXISTS `TABLES` +POSTHOOK: type: DROPVIEW +PREHOOK: query: CREATE VIEW `TABLES` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -2510,7 +2489,7 @@ PREHOOK: Input: sys@tbl_privs PREHOOK: Input: sys@tbls PREHOOK: Output: INFORMATION_SCHEMA@TABLES PREHOOK: Output: database:information_schema -POSTHOOK: query: CREATE VIEW IF NOT EXISTS `TABLES` +POSTHOOK: query: CREATE VIEW `TABLES` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -2564,7 +2543,11 @@ POSTHOOK: Lineage: TABLES.table_type EXPRESSION [(tbls)t.FieldSchema(name:view_o POSTHOOK: Lineage: TABLES.user_defined_type_catalog EXPRESSION [] POSTHOOK: Lineage: TABLES.user_defined_type_name EXPRESSION [] POSTHOOK: Lineage: TABLES.user_defined_type_schema EXPRESSION [] -PREHOOK: query: CREATE VIEW IF NOT EXISTS `TABLE_PRIVILEGES` +PREHOOK: query: DROP VIEW IF EXISTS `TABLE_PRIVILEGES` +PREHOOK: type: DROPVIEW +POSTHOOK: query: DROP VIEW IF EXISTS `TABLE_PRIVILEGES` +POSTHOOK: type: DROPVIEW +PREHOOK: query: CREATE VIEW `TABLE_PRIVILEGES` ( `GRANTOR`, `GRANTEE`, @@ -2603,7 +2586,7 @@ PREHOOK: Input: sys@tbl_privs PREHOOK: Input: sys@tbls PREHOOK: Output: INFORMATION_SCHEMA@TABLE_PRIVILEGES PREHOOK: Output: database:information_schema -POSTHOOK: query: CREATE VIEW IF NOT EXISTS `TABLE_PRIVILEGES` +POSTHOOK: query: CREATE VIEW `TABLE_PRIVILEGES` ( `GRANTOR`, `GRANTEE`, @@ -2650,7 +2633,11 @@ POSTHOOK: Lineage: TABLE_PRIVILEGES.table_catalog SIMPLE [] POSTHOOK: Lineage: TABLE_PRIVILEGES.table_name SIMPLE [(tbls)t.FieldSchema(name:tbl_name, type:string, comment:from deserializer), ] POSTHOOK: Lineage: TABLE_PRIVILEGES.table_schema SIMPLE [(dbs)d.FieldSchema(name:name, type:string, comment:from deserializer), ] POSTHOOK: Lineage: TABLE_PRIVILEGES.with_hierarchy SIMPLE [] -PREHOOK: query: CREATE VIEW IF NOT EXISTS `COLUMNS` +PREHOOK: query: DROP VIEW IF EXISTS `COLUMNS` +PREHOOK: type: DROPVIEW +POSTHOOK: query: DROP VIEW IF EXISTS `COLUMNS` +POSTHOOK: type: DROPVIEW +PREHOOK: query: CREATE VIEW `COLUMNS` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -2812,7 +2799,7 @@ PREHOOK: Input: sys@tbl_col_privs PREHOOK: Input: sys@tbls PREHOOK: Output: INFORMATION_SCHEMA@COLUMNS PREHOOK: Output: database:information_schema -POSTHOOK: query: CREATE VIEW IF NOT EXISTS `COLUMNS` +POSTHOOK: query: CREATE VIEW `COLUMNS` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -3021,7 +3008,11 @@ POSTHOOK: Lineage: COLUMNS.table_schema SIMPLE [(dbs)d.FieldSchema(name:name, ty POSTHOOK: Lineage: COLUMNS.udt_catalog EXPRESSION [] POSTHOOK: Lineage: COLUMNS.udt_name EXPRESSION [] POSTHOOK: Lineage: COLUMNS.udt_schema EXPRESSION [] -PREHOOK: query: CREATE VIEW IF NOT EXISTS `COLUMN_PRIVILEGES` +PREHOOK: query: DROP VIEW IF EXISTS `COLUMN_PRIVILEGES` +PREHOOK: type: DROPVIEW +POSTHOOK: query: DROP VIEW IF EXISTS `COLUMN_PRIVILEGES` +POSTHOOK: type: DROPVIEW +PREHOOK: query: CREATE VIEW `COLUMN_PRIVILEGES` ( `GRANTOR`, `GRANTEE`, @@ -3064,7 +3055,7 @@ PREHOOK: Input: sys@tbl_privs PREHOOK: Input: sys@tbls PREHOOK: Output: INFORMATION_SCHEMA@COLUMN_PRIVILEGES PREHOOK: Output: database:information_schema -POSTHOOK: query: CREATE VIEW IF NOT EXISTS `COLUMN_PRIVILEGES` +POSTHOOK: query: CREATE VIEW `COLUMN_PRIVILEGES` ( `GRANTOR`, `GRANTEE`, @@ -3115,7 +3106,11 @@ POSTHOOK: Lineage: COLUMN_PRIVILEGES.privilege_type SIMPLE [(tbl_col_privs)p.Fie POSTHOOK: Lineage: COLUMN_PRIVILEGES.table_catalog SIMPLE [] POSTHOOK: Lineage: COLUMN_PRIVILEGES.table_name SIMPLE [(tbls)t.FieldSchema(name:tbl_name, type:string, comment:from deserializer), ] POSTHOOK: Lineage: COLUMN_PRIVILEGES.table_schema SIMPLE [(dbs)d.FieldSchema(name:name, type:string, comment:from deserializer), ] -PREHOOK: query: CREATE VIEW IF NOT EXISTS `VIEWS` +PREHOOK: query: DROP VIEW IF EXISTS `VIEWS` +PREHOOK: type: DROPVIEW +POSTHOOK: query: DROP VIEW IF EXISTS `VIEWS` +POSTHOOK: type: DROPVIEW +PREHOOK: query: CREATE VIEW `VIEWS` ( `TABLE_CATALOG`, `TABLE_SCHEMA`, @@ -3157,7 +3152,7 @@ PREHOOK: Input: sys@tbl_privs PREHOOK: Input: sys@tbls PREHOOK: Output: INFORMATION_SCHEMA@VIEWS PREHOOK: Output: database:information_schema -POSTHOOK: query: CREATE VIEW IF NOT EXISTS `VIEWS` +POSTHOOK: query: CREATE VIEW `VIEWS` ( `TABLE_CATALOG`, `TABLE_SCHEMA`,