From 8ea19a61d97ad5b941807f99675941cee9fe08e3 Mon Sep 17 00:00:00 2001 From: Shkin1 <240493030@qq.com> Date: Thu, 28 Jul 2022 15:14:18 +0800 Subject: [PATCH 01/17] =?UTF-8?q?add:=20statement=E3=80=81query=E3=80=81ta?= =?UTF-8?q?blesource=E3=80=81expr?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .idea/misc.xml | 5 + .../common/contants/ParserConstant.java | 29 +++++ .../com/hathor/exception/ParserException.java | 37 ++++++ hathor-core/hathor-core.iml | 6 + hathor-core/pom.xml | 16 +++ .../analyse/atree/TableLineageTreeBuild.java | 71 +++++++++++ .../expr/SQLAggregateExprProcessor.java | 36 ++++++ .../expr/SQLAllColumnExprProcessor.java | 33 +++++ .../expr/SQLBinaryOpExprProcessor.java | 32 +++++ .../process/expr/SQLCaseExprProcessor.java | 60 +++++++++ .../process/expr/SQLCastExprProcessor.java | 31 +++++ .../process/expr/SQLCharExprProcessor.java | 37 ++++++ ...prProcessor.java => SQLExprProcessor.java} | 2 +- .../expr/SQLIdentifierExprProcessor.java | 32 +++++ .../expr/SQLMethodInvokeExprProcessor.java | 47 +++++++ .../expr/SQLPropertyExprProcessor.java | 32 +++++ .../expr/pg/PGTypeCastExprProcessor.java | 39 ++++++ .../AbstractSQLSelectQueryProcessor.java | 61 ++++++++++ .../selectquery/SQLSelectQueryProcessor.java | 32 +++++ .../odps/OdpsSelectQueryBlockProcessor.java | 35 ++++++ .../pg/PGSelectQueryBlockProcessor.java | 115 ++++++++++++++++++ .../statement/AbstractStatementProcessor.java | 68 +++++++++++ .../SQLCreateViewStatementProcessor.java | 41 +++++++ .../HiveCreateTableStatementProcessor.java | 49 ++++++++ .../pg/PGInsertStatementProcessor.java | 42 +++++++ .../SQLExprTableSourceProcessor.java | 55 +++++++++ .../SQLJoinTableSourceProcessor.java | 57 +++++++++ .../SQLSubqueryTableSourceProcessor.java | 35 ++++++ .../SQLUnionQueryTableSourceProcessor.java | 95 +++++++++++++++ .../register/AntlrProcessorRegister.java | 17 +++ .../register/DruidProcessorRegister.java | 93 ++++++++++++++ 31 files changed, 1339 insertions(+), 1 deletion(-) create mode 100644 hathor-common/src/main/java/com/hathor/common/contants/ParserConstant.java create mode 100644 hathor-common/src/main/java/com/hathor/exception/ParserException.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/analyse/atree/TableLineageTreeBuild.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLAggregateExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLAllColumnExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLBinaryOpExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLCaseExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLCastExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLCharExprProcessor.java rename hathor-core/src/main/java/com/hathor/core/engine/process/expr/{SqlExprProcessor.java => SQLExprProcessor.java} (94%) create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLIdentifierExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLMethodInvokeExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/SQLPropertyExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/expr/pg/PGTypeCastExprProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/selectquery/AbstractSQLSelectQueryProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/selectquery/SQLSelectQueryProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/selectquery/odps/OdpsSelectQueryBlockProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/selectquery/pg/PGSelectQueryBlockProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/statement/AbstractStatementProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/statement/SQLCreateViewStatementProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/statement/hive/HiveCreateTableStatementProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/statement/pg/PGInsertStatementProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/tablesource/SQLExprTableSourceProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/tablesource/SQLJoinTableSourceProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/tablesource/SQLSubqueryTableSourceProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/process/tablesource/SQLUnionQueryTableSourceProcessor.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/register/AntlrProcessorRegister.java create mode 100644 hathor-core/src/main/java/com/hathor/core/engine/register/DruidProcessorRegister.java diff --git a/.idea/misc.xml b/.idea/misc.xml index 8572330..b9cd0a0 100644 --- a/.idea/misc.xml +++ b/.idea/misc.xml @@ -1,5 +1,10 @@ + + + + +