基于C语言的XuguTSDB分布式时序数据库设计源码

/* * Copyright (c) 2019 TAOS Data, Inc. <[email protected]> * * This program is free software: you can use, redistribute, and/or modify * it under the terms of the GNU Affero General Public License, version 3 * or later ("AGPL"), as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>. */ #include "parInt.h" #include "catalog.h" #include "cmdnodes.h" #include "filter.h" #include "functionMgt.h" #include "parUtil.h" #include "scalar.h" #include "systable.h" #include "tglobal.h" #include "ttime.h" #define generateDealNodeErrMsg(pCxt, code, ...) \ (pCxt->errCode = generateSyntaxErrMsg(&pCxt->msgBuf, code, ##__VA_ARGS__), DEAL_RES_ERROR) #define SYSTABLE_SHOW_TYPE_OFFSET QUERY_NODE_SHOW_DNODES_STMT typedef struct SRewriteTbNameContext { int32_t errCode; char* pTbName; } SRewriteTbNameContext; typedef struct STranslateContext { SParseContext* pParseCxt; int32_t errCode; SMsgBuf msgBuf; SArray* pNsLevel; // element is SArray*, the element of this subarray is STableNode* int32_t currLevel; int32_t levelNo; ESqlClause currClause; SNode* pCurrStmt; SCmdMsgInfo* pCmdMsg; SHashObj* pDbs; SHashObj* pTables; SHashObj* pTargetTables; SExplainOptions* pExplainOpt; SParseMetaCache* pMetaCache; bool createStream; bool stableQuery; bool showRewrite; SNode* pPrevRoot; SNode* pPostRoot; } STranslateContext; typedef struct SBuildTopicContext { bool colExists; bool colNotFound; STableMeta* pMeta; SNodeList* pTags; } SBuildTopicContext; typedef struct SFullDatabaseName { char fullDbName[TSDB_DB_FNAME_LEN]; } SFullDatabaseName; typedef struct SSysTableShowAdapter { ENodeType showType; const char* pDbName; const char* pTableName; int32_t numOfShowCols; const char* pShowCols[2]; } SSysTableShowAdapter; // clang-format off static const SSysTableShowAdapter sysTableShowAdapter[] = { { .showType = QUERY_NODE_SHOW_DNODES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_DNODES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_MNODES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_MNODES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_MODULES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_MODULES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_QNODES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_QNODES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_SNODES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_SNODES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_BNODES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_BNODES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_CLUSTER_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_CLUSTER, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_DATABASES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_DATABASES, .numOfShowCols = 1, .pShowCols = {"name"} }, { .showType = QUERY_NODE_SHOW_FUNCTIONS_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_FUNCTIONS, .numOfShowCols = 1, .pShowCols = {"name"} }, { .showType = QUERY_NODE_SHOW_INDEXES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_INDEXES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_STABLES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_STABLES, .numOfShowCols = 1, .pShowCols = {"stable_name"} }, { .showType = QUERY_NODE_SHOW_STREAMS_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_STREAMS, .numOfShowCols = 1, .pShowCols = {"stream_name"} }, { .showType = QUERY_NODE_SHOW_TABLES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_TABLES, .numOfShowCols = 1, .pShowCols = {"table_name"} }, { .showType = QUERY_NODE_SHOW_TAGS_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_TAGS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_USERS_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_USERS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_LICENCES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_LICENCES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_VGROUPS_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_VGROUPS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_TOPICS_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_TOPICS, .numOfShowCols = 1, .pShowCols = {"topic_name"} }, { .showType = QUERY_NODE_SHOW_CONSUMERS_STMT, .pDbName = TSDB_PERFORMANCE_SCHEMA_DB, .pTableName = TSDB_PERFS_TABLE_CONSUMERS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_CONNECTIONS_STMT, .pDbName = TSDB_PERFORMANCE_SCHEMA_DB, .pTableName = TSDB_PERFS_TABLE_CONNECTIONS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_QUERIES_STMT, .pDbName = TSDB_PERFORMANCE_SCHEMA_DB, .pTableName = TSDB_PERFS_TABLE_QUERIES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_APPS_STMT, .pDbName = TSDB_PERFORMANCE_SCHEMA_DB, .pTableName = TSDB_PERFS_TABLE_APPS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_VARIABLES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_CONFIGS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_DNODE_VARIABLES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_DNODE_VARIABLES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_TRANSACTIONS_STMT, .pDbName = TSDB_PERFORMANCE_SCHEMA_DB, .pTableName = TSDB_PERFS_TABLE_TRANS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_SUBSCRIPTIONS_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_SUBSCRIPTIONS, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_VNODES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_VNODES, .numOfShowCols = 1, .pShowCols = {"*"} }, { .showType = QUERY_NODE_SHOW_USER_PRIVILEGES_STMT, .pDbName = TSDB_INFORMATION_SCHEMA_DB, .pTableName = TSDB_INS_TABLE_USER_PRIVILEGES, .numOfShowCols = 1, .pShowCols = {"*"} }, }; // clang-format on static int32_t translateSubquery(STranslateContext* pCxt, SNode* pNode); static int32_t translateQuery(STranslateContext* pCxt, SNode* pNode); static EDealRes translateValue(STranslateContext* pCxt, SValueNode* pVal); static int32_t createSimpleSelectStmtFromProjList(