2050 lines
70 KiB
C
2050 lines
70 KiB
C
/*
|
|
* Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
|
|
*
|
|
* 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 "functionMgt.h"
|
|
#include "parUtil.h"
|
|
#include "ttime.h"
|
|
|
|
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;
|
|
ESqlClause currClause;
|
|
SSelectStmt* pCurrStmt;
|
|
SCmdMsgInfo* pCmdMsg;
|
|
} STranslateContext;
|
|
|
|
static int32_t translateSubquery(STranslateContext* pCxt, SNode* pNode);
|
|
static int32_t translateQuery(STranslateContext* pCxt, SNode* pNode);
|
|
|
|
static bool afterGroupBy(ESqlClause clause) {
|
|
return clause > SQL_CLAUSE_GROUP_BY;
|
|
}
|
|
|
|
static bool beforeHaving(ESqlClause clause) {
|
|
return clause < SQL_CLAUSE_HAVING;
|
|
}
|
|
|
|
static EDealRes generateDealNodeErrMsg(STranslateContext* pCxt, int32_t errCode, ...) {
|
|
va_list vArgList;
|
|
va_start(vArgList, errCode);
|
|
generateSyntaxErrMsg(&pCxt->msgBuf, errCode, vArgList);
|
|
va_end(vArgList);
|
|
pCxt->errCode = errCode;
|
|
return DEAL_RES_ERROR;
|
|
}
|
|
|
|
static int32_t addNamespace(STranslateContext* pCxt, void* pTable) {
|
|
size_t currTotalLevel = taosArrayGetSize(pCxt->pNsLevel);
|
|
if (currTotalLevel > pCxt->currLevel) {
|
|
SArray* pTables = taosArrayGetP(pCxt->pNsLevel, pCxt->currLevel);
|
|
taosArrayPush(pTables, &pTable);
|
|
} else {
|
|
do {
|
|
SArray* pTables = taosArrayInit(TARRAY_MIN_SIZE, POINTER_BYTES);
|
|
if (pCxt->currLevel == currTotalLevel) {
|
|
taosArrayPush(pTables, &pTable);
|
|
}
|
|
taosArrayPush(pCxt->pNsLevel, &pTables);
|
|
++currTotalLevel;
|
|
} while (currTotalLevel <= pCxt->currLevel);
|
|
}
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static SName* toName(int32_t acctId, const SRealTableNode* pRealTable, SName* pName) {
|
|
pName->type = TSDB_TABLE_NAME_T;
|
|
pName->acctId = acctId;
|
|
strcpy(pName->dbname, pRealTable->table.dbName);
|
|
strcpy(pName->tname, pRealTable->table.tableName);
|
|
return pName;
|
|
}
|
|
|
|
static bool belongTable(const char* currentDb, const SColumnNode* pCol, const STableNode* pTable) {
|
|
int cmp = 0;
|
|
if ('\0' != pCol->dbName[0]) {
|
|
cmp = strcmp(pCol->dbName, pTable->dbName);
|
|
} else {
|
|
cmp = (QUERY_NODE_REAL_TABLE == nodeType(pTable) ? strcmp(currentDb, pTable->dbName) : 0);
|
|
}
|
|
if (0 == cmp) {
|
|
cmp = strcmp(pCol->tableAlias, pTable->tableAlias);
|
|
}
|
|
return (0 == cmp);
|
|
}
|
|
|
|
static SNodeList* getProjectList(SNode* pNode) {
|
|
if (QUERY_NODE_SELECT_STMT == nodeType(pNode)) {
|
|
return ((SSelectStmt*)pNode)->pProjectionList;
|
|
}
|
|
return NULL;
|
|
}
|
|
|
|
static void setColumnInfoBySchema(const SRealTableNode* pTable, const SSchema* pColSchema, bool isTag, SColumnNode* pCol) {
|
|
strcpy(pCol->dbName, pTable->table.dbName);
|
|
strcpy(pCol->tableAlias, pTable->table.tableAlias);
|
|
strcpy(pCol->tableName, pTable->table.tableName);
|
|
strcpy(pCol->colName, pColSchema->name);
|
|
if ('\0' == pCol->node.aliasName[0]) {
|
|
strcpy(pCol->node.aliasName, pColSchema->name);
|
|
}
|
|
pCol->tableId = pTable->pMeta->uid;
|
|
pCol->colId = pColSchema->colId;
|
|
pCol->colType = isTag ? COLUMN_TYPE_TAG : COLUMN_TYPE_COLUMN;
|
|
pCol->node.resType.type = pColSchema->type;
|
|
pCol->node.resType.bytes = pColSchema->bytes;
|
|
}
|
|
|
|
static void setColumnInfoByExpr(const STableNode* pTable, SExprNode* pExpr, SColumnNode* pCol) {
|
|
pCol->pProjectRef = (SNode*)pExpr;
|
|
nodesListAppend(pExpr->pAssociationList, (SNode*)pCol);
|
|
if (NULL != pTable) {
|
|
strcpy(pCol->tableAlias, pTable->tableAlias);
|
|
}
|
|
strcpy(pCol->colName, pExpr->aliasName);
|
|
pCol->node.resType = pExpr->resType;
|
|
}
|
|
|
|
static int32_t createColumnNodeByTable(STranslateContext* pCxt, const STableNode* pTable, SNodeList* pList) {
|
|
if (QUERY_NODE_REAL_TABLE == nodeType(pTable)) {
|
|
const STableMeta* pMeta = ((SRealTableNode*)pTable)->pMeta;
|
|
int32_t nums = pMeta->tableInfo.numOfColumns + ((TSDB_SUPER_TABLE == pMeta->tableType) ? pMeta->tableInfo.numOfTags : 0);
|
|
for (int32_t i = 0; i < nums; ++i) {
|
|
SColumnNode* pCol = (SColumnNode*)nodesMakeNode(QUERY_NODE_COLUMN);
|
|
if (NULL == pCol) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_OUT_OF_MEMORY);
|
|
}
|
|
setColumnInfoBySchema((SRealTableNode*)pTable, pMeta->schema + i, (i >= pMeta->tableInfo.numOfColumns), pCol);
|
|
nodesListAppend(pList, (SNode*)pCol);
|
|
}
|
|
} else {
|
|
SNodeList* pProjectList = getProjectList(((STempTableNode*)pTable)->pSubquery);
|
|
SNode* pNode;
|
|
FOREACH(pNode, pProjectList) {
|
|
SColumnNode* pCol = (SColumnNode*)nodesMakeNode(QUERY_NODE_COLUMN);
|
|
if (NULL == pCol) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_OUT_OF_MEMORY);
|
|
}
|
|
setColumnInfoByExpr(pTable, (SExprNode*)pNode, pCol);
|
|
nodesListAppend(pList, (SNode*)pCol);
|
|
}
|
|
}
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static bool findAndSetColumn(SColumnNode* pCol, const STableNode* pTable) {
|
|
bool found = false;
|
|
if (QUERY_NODE_REAL_TABLE == nodeType(pTable)) {
|
|
const STableMeta* pMeta = ((SRealTableNode*)pTable)->pMeta;
|
|
int32_t nums = pMeta->tableInfo.numOfTags + pMeta->tableInfo.numOfColumns;
|
|
for (int32_t i = 0; i < nums; ++i) {
|
|
if (0 == strcmp(pCol->colName, pMeta->schema[i].name)) {
|
|
setColumnInfoBySchema((SRealTableNode*)pTable, pMeta->schema + i, (i >= pMeta->tableInfo.numOfColumns), pCol);
|
|
found = true;
|
|
break;
|
|
}
|
|
}
|
|
} else {
|
|
SNodeList* pProjectList = getProjectList(((STempTableNode*)pTable)->pSubquery);
|
|
SNode* pNode;
|
|
FOREACH(pNode, pProjectList) {
|
|
SExprNode* pExpr = (SExprNode*)pNode;
|
|
if (0 == strcmp(pCol->colName, pExpr->aliasName)) {
|
|
setColumnInfoByExpr(pTable, pExpr, pCol);
|
|
found = true;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
return found;
|
|
}
|
|
|
|
static EDealRes translateColumnWithPrefix(STranslateContext* pCxt, SColumnNode* pCol) {
|
|
SArray* pTables = taosArrayGetP(pCxt->pNsLevel, pCxt->currLevel);
|
|
size_t nums = taosArrayGetSize(pTables);
|
|
bool foundTable = false;
|
|
for (size_t i = 0; i < nums; ++i) {
|
|
STableNode* pTable = taosArrayGetP(pTables, i);
|
|
if (belongTable(pCxt->pParseCxt->db, pCol, pTable)) {
|
|
foundTable = true;
|
|
if (findAndSetColumn(pCol, pTable)) {
|
|
break;
|
|
}
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_INVALID_COLUMN, pCol->colName);
|
|
}
|
|
}
|
|
if (!foundTable) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_TABLE_NOT_EXIST, pCol->tableAlias);
|
|
}
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static EDealRes translateColumnWithoutPrefix(STranslateContext* pCxt, SColumnNode* pCol) {
|
|
SArray* pTables = taosArrayGetP(pCxt->pNsLevel, pCxt->currLevel);
|
|
size_t nums = taosArrayGetSize(pTables);
|
|
bool found = false;
|
|
for (size_t i = 0; i < nums; ++i) {
|
|
STableNode* pTable = taosArrayGetP(pTables, i);
|
|
if (findAndSetColumn(pCol, pTable)) {
|
|
if (found) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_AMBIGUOUS_COLUMN, pCol->colName);
|
|
}
|
|
found = true;
|
|
}
|
|
}
|
|
if (!found) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_INVALID_COLUMN, pCol->colName);
|
|
}
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static bool translateColumnUseAlias(STranslateContext* pCxt, SColumnNode* pCol) {
|
|
SNodeList* pProjectionList = pCxt->pCurrStmt->pProjectionList;
|
|
SNode* pNode;
|
|
FOREACH(pNode, pProjectionList) {
|
|
SExprNode* pExpr = (SExprNode*)pNode;
|
|
if (0 == strcmp(pCol->colName, pExpr->aliasName)) {
|
|
setColumnInfoByExpr(NULL, pExpr, pCol);
|
|
return true;
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
static EDealRes translateColumn(STranslateContext* pCxt, SColumnNode* pCol) {
|
|
// count(*)/first(*)/last(*)
|
|
if (0 == strcmp(pCol->colName, "*")) {
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
if ('\0' != pCol->tableAlias[0]) {
|
|
return translateColumnWithPrefix(pCxt, pCol);
|
|
}
|
|
bool found = false;
|
|
if (SQL_CLAUSE_ORDER_BY == pCxt->currClause) {
|
|
found = translateColumnUseAlias(pCxt, pCol);
|
|
}
|
|
return found ? DEAL_RES_CONTINUE : translateColumnWithoutPrefix(pCxt, pCol);
|
|
}
|
|
|
|
static int32_t trimStringWithVarFormat(const char* src, int32_t len, bool format, char* dst) {
|
|
char* dstVal = dst;
|
|
if (format) {
|
|
varDataSetLen(dst, len);
|
|
dstVal = varDataVal(dst);
|
|
}
|
|
return trimString(src, len, dstVal, len);
|
|
}
|
|
|
|
static EDealRes translateValue(STranslateContext* pCxt, SValueNode* pVal) {
|
|
if (pVal->isDuration) {
|
|
if (parseAbsoluteDuration(pVal->literal, strlen(pVal->literal), &pVal->datum.i, &pVal->unit, pVal->node.resType.precision) != TSDB_CODE_SUCCESS) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_WRONG_VALUE_TYPE, pVal->literal);
|
|
}
|
|
} else {
|
|
switch (pVal->node.resType.type) {
|
|
case TSDB_DATA_TYPE_NULL:
|
|
break;
|
|
case TSDB_DATA_TYPE_BOOL:
|
|
pVal->datum.b = (0 == strcasecmp(pVal->literal, "true"));
|
|
break;
|
|
case TSDB_DATA_TYPE_TINYINT:
|
|
case TSDB_DATA_TYPE_SMALLINT:
|
|
case TSDB_DATA_TYPE_INT:
|
|
case TSDB_DATA_TYPE_BIGINT: {
|
|
char* endPtr = NULL;
|
|
pVal->datum.i = strtoll(pVal->literal, &endPtr, 10);
|
|
break;
|
|
}
|
|
case TSDB_DATA_TYPE_UTINYINT:
|
|
case TSDB_DATA_TYPE_USMALLINT:
|
|
case TSDB_DATA_TYPE_UINT:
|
|
case TSDB_DATA_TYPE_UBIGINT: {
|
|
char* endPtr = NULL;
|
|
pVal->datum.u = strtoull(pVal->literal, &endPtr, 10);
|
|
break;
|
|
}
|
|
case TSDB_DATA_TYPE_FLOAT:
|
|
case TSDB_DATA_TYPE_DOUBLE: {
|
|
char* endPtr = NULL;
|
|
pVal->datum.d = strtold(pVal->literal, &endPtr);
|
|
break;
|
|
}
|
|
case TSDB_DATA_TYPE_NCHAR:
|
|
case TSDB_DATA_TYPE_VARCHAR:
|
|
case TSDB_DATA_TYPE_VARBINARY: {
|
|
int32_t n = strlen(pVal->literal);
|
|
pVal->datum.p = calloc(1, n + VARSTR_HEADER_SIZE);
|
|
if (NULL == pVal->datum.p) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_OUT_OF_MEMORY);
|
|
}
|
|
trimStringWithVarFormat(pVal->literal, n, true, pVal->datum.p);
|
|
break;
|
|
}
|
|
case TSDB_DATA_TYPE_TIMESTAMP: {
|
|
int32_t n = strlen(pVal->literal);
|
|
char* tmp = calloc(1, n);
|
|
if (NULL == tmp) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_OUT_OF_MEMORY);
|
|
}
|
|
int32_t len = trimStringWithVarFormat(pVal->literal, n, false, tmp);
|
|
if (taosParseTime(tmp, &pVal->datum.i, len, pVal->node.resType.precision, tsDaylight) != TSDB_CODE_SUCCESS) {
|
|
tfree(tmp);
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_WRONG_VALUE_TYPE, pVal->literal);
|
|
}
|
|
tfree(tmp);
|
|
break;
|
|
}
|
|
case TSDB_DATA_TYPE_JSON:
|
|
case TSDB_DATA_TYPE_DECIMAL:
|
|
case TSDB_DATA_TYPE_BLOB:
|
|
// todo
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
pVal->translate = true;
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static EDealRes translateOperator(STranslateContext* pCxt, SOperatorNode* pOp) {
|
|
SDataType ldt = ((SExprNode*)(pOp->pLeft))->resType;
|
|
SDataType rdt = ((SExprNode*)(pOp->pRight))->resType;
|
|
if (nodesIsArithmeticOp(pOp)) {
|
|
if (TSDB_DATA_TYPE_JSON == ldt.type || TSDB_DATA_TYPE_BLOB == ldt.type ||
|
|
TSDB_DATA_TYPE_JSON == rdt.type || TSDB_DATA_TYPE_BLOB == rdt.type) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_WRONG_VALUE_TYPE, ((SExprNode*)(pOp->pRight))->aliasName);
|
|
}
|
|
pOp->node.resType.type = TSDB_DATA_TYPE_DOUBLE;
|
|
pOp->node.resType.bytes = tDataTypes[TSDB_DATA_TYPE_DOUBLE].bytes;
|
|
} else if (nodesIsComparisonOp(pOp)) {
|
|
if (TSDB_DATA_TYPE_JSON == ldt.type || TSDB_DATA_TYPE_BLOB == ldt.type ||
|
|
TSDB_DATA_TYPE_JSON == rdt.type || TSDB_DATA_TYPE_BLOB == rdt.type) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_WRONG_VALUE_TYPE, ((SExprNode*)(pOp->pRight))->aliasName);
|
|
}
|
|
pOp->node.resType.type = TSDB_DATA_TYPE_BOOL;
|
|
pOp->node.resType.bytes = tDataTypes[TSDB_DATA_TYPE_BOOL].bytes;
|
|
} else {
|
|
// todo json operator
|
|
}
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static EDealRes translateFunction(STranslateContext* pCxt, SFunctionNode* pFunc) {
|
|
if (TSDB_CODE_SUCCESS != fmGetFuncInfo(pFunc->functionName, &pFunc->funcId, &pFunc->funcType)) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_INVALID_FUNTION, pFunc->functionName);
|
|
}
|
|
int32_t code = fmGetFuncResultType(pFunc);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return generateDealNodeErrMsg(pCxt, code, pFunc->functionName);
|
|
}
|
|
if (fmIsAggFunc(pFunc->funcId) && beforeHaving(pCxt->currClause)) {
|
|
return generateDealNodeErrMsg(pCxt, TSDB_CODE_PAR_ILLEGAL_USE_AGG_FUNCTION);
|
|
}
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static EDealRes translateExprSubquery(STranslateContext* pCxt, SNode* pNode) {
|
|
return (TSDB_CODE_SUCCESS == translateSubquery(pCxt, pNode) ? DEAL_RES_CONTINUE : DEAL_RES_ERROR);
|
|
}
|
|
|
|
static EDealRes translateLogicCond(STranslateContext* pCxt, SLogicConditionNode* pCond) {
|
|
pCond->node.resType.type = TSDB_DATA_TYPE_BOOL;
|
|
pCond->node.resType.bytes = tDataTypes[TSDB_DATA_TYPE_BOOL].bytes;
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static EDealRes doTranslateExpr(SNode* pNode, void* pContext) {
|
|
STranslateContext* pCxt = (STranslateContext*)pContext;
|
|
switch (nodeType(pNode)) {
|
|
case QUERY_NODE_COLUMN:
|
|
return translateColumn(pCxt, (SColumnNode*)pNode);
|
|
case QUERY_NODE_VALUE:
|
|
return translateValue(pCxt, (SValueNode*)pNode);
|
|
case QUERY_NODE_OPERATOR:
|
|
return translateOperator(pCxt, (SOperatorNode*)pNode);
|
|
case QUERY_NODE_FUNCTION:
|
|
return translateFunction(pCxt, (SFunctionNode*)pNode);
|
|
case QUERY_NODE_LOGIC_CONDITION:
|
|
return translateLogicCond(pCxt, (SLogicConditionNode*)pNode);
|
|
case QUERY_NODE_TEMP_TABLE:
|
|
return translateExprSubquery(pCxt, ((STempTableNode*)pNode)->pSubquery);
|
|
default:
|
|
break;
|
|
}
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static int32_t translateExpr(STranslateContext* pCxt, SNode* pNode) {
|
|
nodesWalkNodePostOrder(pNode, doTranslateExpr, pCxt);
|
|
return pCxt->errCode;
|
|
}
|
|
|
|
static int32_t translateExprList(STranslateContext* pCxt, SNodeList* pList) {
|
|
nodesWalkListPostOrder(pList, doTranslateExpr, pCxt);
|
|
return pCxt->errCode;
|
|
}
|
|
|
|
static bool isAliasColumn(SColumnNode* pCol) {
|
|
return ('\0' == pCol->tableAlias[0]);
|
|
}
|
|
|
|
static bool isDistinctOrderBy(STranslateContext* pCxt) {
|
|
return (SQL_CLAUSE_ORDER_BY == pCxt->currClause && pCxt->pCurrStmt->isDistinct);
|
|
}
|
|
|
|
static SNodeList* getGroupByList(STranslateContext* pCxt) {
|
|
if (isDistinctOrderBy(pCxt)) {
|
|
return pCxt->pCurrStmt->pProjectionList;
|
|
}
|
|
return pCxt->pCurrStmt->pGroupByList;
|
|
}
|
|
|
|
static SNode* getGroupByNode(SNode* pNode) {
|
|
if (QUERY_NODE_GROUPING_SET == nodeType(pNode)) {
|
|
return nodesListGetNode(((SGroupingSetNode*)pNode)->pParameterList, 0);
|
|
}
|
|
return pNode;
|
|
}
|
|
|
|
static int32_t getGroupByErrorCode(STranslateContext* pCxt) {
|
|
if (isDistinctOrderBy(pCxt)) {
|
|
return TSDB_CODE_PAR_NOT_SELECTED_EXPRESSION;
|
|
}
|
|
return TSDB_CODE_PAR_GROUPBY_LACK_EXPRESSION;
|
|
}
|
|
|
|
static EDealRes doCheckExprForGroupBy(SNode* pNode, void* pContext) {
|
|
STranslateContext* pCxt = (STranslateContext*)pContext;
|
|
if (!nodesIsExprNode(pNode) || (QUERY_NODE_COLUMN == nodeType(pNode) && isAliasColumn((SColumnNode*)pNode))) {
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
if (QUERY_NODE_FUNCTION == nodeType(pNode) && fmIsAggFunc(((SFunctionNode*)pNode)->funcId) && !isDistinctOrderBy(pCxt)) {
|
|
return DEAL_RES_IGNORE_CHILD;
|
|
}
|
|
SNode* pGroupNode;
|
|
FOREACH(pGroupNode, getGroupByList(pCxt)) {
|
|
if (nodesEqualNode(getGroupByNode(pGroupNode), pNode)) {
|
|
return DEAL_RES_IGNORE_CHILD;
|
|
}
|
|
}
|
|
if (QUERY_NODE_COLUMN == nodeType(pNode) ||
|
|
(QUERY_NODE_FUNCTION == nodeType(pNode) && fmIsAggFunc(((SFunctionNode*)pNode)->funcId) && isDistinctOrderBy(pCxt))) {
|
|
return generateDealNodeErrMsg(pCxt, getGroupByErrorCode(pCxt));
|
|
}
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static int32_t checkExprForGroupBy(STranslateContext* pCxt, SNode* pNode) {
|
|
nodesWalkNode(pNode, doCheckExprForGroupBy, pCxt);
|
|
return pCxt->errCode;
|
|
}
|
|
|
|
static int32_t checkExprListForGroupBy(STranslateContext* pCxt, SNodeList* pList) {
|
|
if (NULL == getGroupByList(pCxt)) {
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
nodesWalkList(pList, doCheckExprForGroupBy, pCxt);
|
|
return pCxt->errCode;
|
|
}
|
|
|
|
typedef struct CheckAggColCoexistCxt {
|
|
STranslateContext* pTranslateCxt;
|
|
bool existAggFunc;
|
|
bool existCol;
|
|
} CheckAggColCoexistCxt;
|
|
|
|
static EDealRes doCheckAggColCoexist(SNode* pNode, void* pContext) {
|
|
CheckAggColCoexistCxt* pCxt = (CheckAggColCoexistCxt*)pContext;
|
|
if (QUERY_NODE_FUNCTION == nodeType(pNode) && fmIsAggFunc(((SFunctionNode*)pNode)->funcId)) {
|
|
pCxt->existAggFunc = true;
|
|
return DEAL_RES_IGNORE_CHILD;
|
|
}
|
|
if (QUERY_NODE_COLUMN == nodeType(pNode)) {
|
|
pCxt->existCol = true;
|
|
}
|
|
return DEAL_RES_CONTINUE;
|
|
}
|
|
|
|
static int32_t checkAggColCoexist(STranslateContext* pCxt, SSelectStmt* pSelect) {
|
|
if (NULL != pSelect->pGroupByList) {
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
CheckAggColCoexistCxt cxt = { .pTranslateCxt = pCxt, .existAggFunc = false, .existCol = false };
|
|
nodesWalkList(pSelect->pProjectionList, doCheckAggColCoexist, &cxt);
|
|
if (!pSelect->isDistinct) {
|
|
nodesWalkList(pSelect->pOrderByList, doCheckAggColCoexist, &cxt);
|
|
}
|
|
if (cxt.existAggFunc && cxt.existCol) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_NOT_SINGLE_GROUP);
|
|
}
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t setTableVgroupList(SParseContext* pCxt, SName* name, SRealTableNode* pRealTable) {
|
|
if (pCxt->topicQuery) {
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
if (TSDB_SUPER_TABLE == pRealTable->pMeta->tableType) {
|
|
SArray* vgroupList = NULL;
|
|
int32_t code = catalogGetTableDistVgInfo(pCxt->pCatalog, pCxt->pTransporter, &pCxt->mgmtEpSet, name, &vgroupList);
|
|
if (code != TSDB_CODE_SUCCESS) {
|
|
return code;
|
|
}
|
|
|
|
size_t vgroupNum = taosArrayGetSize(vgroupList);
|
|
pRealTable->pVgroupList = calloc(1, sizeof(SVgroupsInfo) + sizeof(SVgroupInfo) * vgroupNum);
|
|
if (NULL == pRealTable->pVgroupList) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pRealTable->pVgroupList->numOfVgroups = vgroupNum;
|
|
for (int32_t i = 0; i < vgroupNum; ++i) {
|
|
SVgroupInfo *vg = taosArrayGet(vgroupList, i);
|
|
pRealTable->pVgroupList->vgroups[i] = *vg;
|
|
}
|
|
|
|
taosArrayDestroy(vgroupList);
|
|
} else {
|
|
pRealTable->pVgroupList = calloc(1, sizeof(SVgroupsInfo) + sizeof(SVgroupInfo));
|
|
if (NULL == pRealTable->pVgroupList) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pRealTable->pVgroupList->numOfVgroups = 1;
|
|
int32_t code = catalogGetTableHashVgroup(pCxt->pCatalog, pCxt->pTransporter, &pCxt->mgmtEpSet, name, pRealTable->pVgroupList->vgroups);
|
|
if (code != TSDB_CODE_SUCCESS) {
|
|
return code;
|
|
}
|
|
}
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateTable(STranslateContext* pCxt, SNode* pTable) {
|
|
int32_t code = TSDB_CODE_SUCCESS;
|
|
switch (nodeType(pTable)) {
|
|
case QUERY_NODE_REAL_TABLE: {
|
|
SRealTableNode* pRealTable = (SRealTableNode*)pTable;
|
|
SName name;
|
|
code = catalogGetTableMeta(pCxt->pParseCxt->pCatalog, pCxt->pParseCxt->pTransporter, &(pCxt->pParseCxt->mgmtEpSet),
|
|
toName(pCxt->pParseCxt->acctId, pRealTable, &name), &(pRealTable->pMeta));
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_TABLE_NOT_EXIST, pRealTable->table.tableName);
|
|
}
|
|
code = setTableVgroupList(pCxt->pParseCxt, &name, pRealTable);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return code;
|
|
}
|
|
code = addNamespace(pCxt, pRealTable);
|
|
break;
|
|
}
|
|
case QUERY_NODE_TEMP_TABLE: {
|
|
STempTableNode* pTempTable = (STempTableNode*)pTable;
|
|
code = translateSubquery(pCxt, pTempTable->pSubquery);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = addNamespace(pCxt, pTempTable);
|
|
}
|
|
break;
|
|
}
|
|
case QUERY_NODE_JOIN_TABLE: {
|
|
SJoinTableNode* pJoinTable = (SJoinTableNode*)pTable;
|
|
code = translateTable(pCxt, pJoinTable->pLeft);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateTable(pCxt, pJoinTable->pRight);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateExpr(pCxt, pJoinTable->pOnCond);
|
|
}
|
|
break;
|
|
}
|
|
default:
|
|
break;
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t translateStar(STranslateContext* pCxt, SSelectStmt* pSelect, bool* pIsSelectStar) {
|
|
if (NULL == pSelect->pProjectionList) { // select * ...
|
|
SArray* pTables = taosArrayGetP(pCxt->pNsLevel, pCxt->currLevel);
|
|
size_t nums = taosArrayGetSize(pTables);
|
|
pSelect->pProjectionList = nodesMakeList();
|
|
if (NULL == pSelect->pProjectionList) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_OUT_OF_MEMORY);
|
|
}
|
|
for (size_t i = 0; i < nums; ++i) {
|
|
STableNode* pTable = taosArrayGetP(pTables, i);
|
|
int32_t code = createColumnNodeByTable(pCxt, pTable, pSelect->pProjectionList);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return code;
|
|
}
|
|
}
|
|
*pIsSelectStar = true;
|
|
} else {
|
|
// todo : t.*
|
|
}
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t getPositionValue(const SValueNode* pVal) {
|
|
switch (pVal->node.resType.type) {
|
|
case TSDB_DATA_TYPE_NULL:
|
|
case TSDB_DATA_TYPE_TIMESTAMP:
|
|
case TSDB_DATA_TYPE_NCHAR:
|
|
case TSDB_DATA_TYPE_VARCHAR:
|
|
case TSDB_DATA_TYPE_VARBINARY:
|
|
case TSDB_DATA_TYPE_JSON:
|
|
return -1;
|
|
case TSDB_DATA_TYPE_BOOL:
|
|
return (pVal->datum.b ? 1 : 0);
|
|
case TSDB_DATA_TYPE_TINYINT:
|
|
case TSDB_DATA_TYPE_SMALLINT:
|
|
case TSDB_DATA_TYPE_INT:
|
|
case TSDB_DATA_TYPE_BIGINT:
|
|
return pVal->datum.i;
|
|
case TSDB_DATA_TYPE_FLOAT:
|
|
case TSDB_DATA_TYPE_DOUBLE:
|
|
return pVal->datum.d;
|
|
case TSDB_DATA_TYPE_UTINYINT:
|
|
case TSDB_DATA_TYPE_USMALLINT:
|
|
case TSDB_DATA_TYPE_UINT:
|
|
case TSDB_DATA_TYPE_UBIGINT:
|
|
return pVal->datum.u;
|
|
default:
|
|
break;
|
|
}
|
|
return -1;
|
|
}
|
|
|
|
static int32_t translateOrderByPosition(STranslateContext* pCxt, SNodeList* pProjectionList, SNodeList* pOrderByList, bool* pOther) {
|
|
*pOther = false;
|
|
SNode* pNode;
|
|
FOREACH(pNode, pOrderByList) {
|
|
SNode* pExpr = ((SOrderByExprNode*)pNode)->pExpr;
|
|
if (QUERY_NODE_VALUE == nodeType(pExpr)) {
|
|
SValueNode* pVal = (SValueNode*)pExpr;
|
|
if (DEAL_RES_ERROR == translateValue(pCxt, pVal)) {
|
|
return pCxt->errCode;
|
|
}
|
|
int32_t pos = getPositionValue(pVal);
|
|
if (pos < 0) {
|
|
ERASE_NODE(pOrderByList);
|
|
continue;
|
|
} else if (0 == pos || pos > LIST_LENGTH(pProjectionList)) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_WRONG_NUMBER_OF_SELECT);
|
|
} else {
|
|
SColumnNode* pCol = (SColumnNode*)nodesMakeNode(QUERY_NODE_COLUMN);
|
|
if (NULL == pCol) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_OUT_OF_MEMORY);
|
|
}
|
|
setColumnInfoByExpr(NULL, (SExprNode*)nodesListGetNode(pProjectionList, pos - 1), pCol);
|
|
((SOrderByExprNode*)pNode)->pExpr = (SNode*)pCol;
|
|
nodesDestroyNode(pExpr);
|
|
}
|
|
} else {
|
|
*pOther = true;
|
|
}
|
|
}
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateOrderBy(STranslateContext* pCxt, SSelectStmt* pSelect) {
|
|
bool other;
|
|
int32_t code = translateOrderByPosition(pCxt, pSelect->pProjectionList, pSelect->pOrderByList, &other);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return code;
|
|
}
|
|
if (!other) {
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
pCxt->currClause = SQL_CLAUSE_ORDER_BY;
|
|
code = translateExprList(pCxt, pSelect->pOrderByList);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = checkExprListForGroupBy(pCxt, pSelect->pOrderByList);
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t translateSelectList(STranslateContext* pCxt, SSelectStmt* pSelect) {
|
|
bool isSelectStar = false;
|
|
int32_t code = translateStar(pCxt, pSelect, &isSelectStar);
|
|
if (TSDB_CODE_SUCCESS == code && !isSelectStar) {
|
|
pCxt->currClause = SQL_CLAUSE_SELECT;
|
|
code = translateExprList(pCxt, pSelect->pProjectionList);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = checkExprListForGroupBy(pCxt, pSelect->pProjectionList);
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t translateHaving(STranslateContext* pCxt, SSelectStmt* pSelect) {
|
|
if (NULL == pSelect->pGroupByList && NULL != pSelect->pHaving) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_GROUPBY_LACK_EXPRESSION);
|
|
}
|
|
pCxt->currClause = SQL_CLAUSE_HAVING;
|
|
int32_t code = translateExpr(pCxt, pSelect->pHaving);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = checkExprForGroupBy(pCxt, pSelect->pHaving);
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t translateGroupBy(STranslateContext* pCxt, SNodeList* pGroupByList) {
|
|
pCxt->currClause = SQL_CLAUSE_GROUP_BY;
|
|
return translateExprList(pCxt, pGroupByList);
|
|
}
|
|
|
|
static int32_t doTranslateWindow(STranslateContext* pCxt, SNode* pWindow) {
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateWindow(STranslateContext* pCxt, SNode* pWindow) {
|
|
pCxt->currClause = SQL_CLAUSE_WINDOW;
|
|
int32_t code = translateExpr(pCxt, pWindow);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = doTranslateWindow(pCxt, pWindow);
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t translatePartitionBy(STranslateContext* pCxt, SNodeList* pPartitionByList) {
|
|
pCxt->currClause = SQL_CLAUSE_PARTITION_BY;
|
|
return translateExprList(pCxt, pPartitionByList);
|
|
}
|
|
|
|
static int32_t translateWhere(STranslateContext* pCxt, SNode* pWhere) {
|
|
pCxt->currClause = SQL_CLAUSE_WHERE;
|
|
return translateExpr(pCxt, pWhere);
|
|
}
|
|
|
|
static int32_t translateFrom(STranslateContext* pCxt, SNode* pTable) {
|
|
pCxt->currClause = SQL_CLAUSE_FROM;
|
|
return translateTable(pCxt, pTable);
|
|
}
|
|
|
|
static int32_t translateSelect(STranslateContext* pCxt, SSelectStmt* pSelect) {
|
|
pCxt->pCurrStmt = pSelect;
|
|
int32_t code = translateFrom(pCxt, pSelect->pFromTable);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateWhere(pCxt, pSelect->pWhere);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translatePartitionBy(pCxt, pSelect->pPartitionByList);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateWindow(pCxt, pSelect->pWindow);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateGroupBy(pCxt, pSelect->pGroupByList);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateHaving(pCxt, pSelect);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateSelectList(pCxt, pSelect);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateOrderBy(pCxt, pSelect);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = checkAggColCoexist(pCxt, pSelect);
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static void buildCreateDbReq(STranslateContext* pCxt, SCreateDatabaseStmt* pStmt, SCreateDbReq* pReq) {
|
|
SName name = {0};
|
|
tNameSetDbName(&name, pCxt->pParseCxt->acctId, pStmt->dbName, strlen(pStmt->dbName));
|
|
tNameGetFullDbName(&name, pReq->db);
|
|
pReq->numOfVgroups = pStmt->pOptions->numOfVgroups;
|
|
pReq->cacheBlockSize = pStmt->pOptions->cacheBlockSize;
|
|
pReq->totalBlocks = pStmt->pOptions->numOfBlocks;
|
|
pReq->daysPerFile = pStmt->pOptions->daysPerFile;
|
|
pReq->daysToKeep0 = pStmt->pOptions->keep;
|
|
pReq->daysToKeep1 = -1;
|
|
pReq->daysToKeep2 = -1;
|
|
pReq->minRows = pStmt->pOptions->minRowsPerBlock;
|
|
pReq->maxRows = pStmt->pOptions->maxRowsPerBlock;
|
|
pReq->commitTime = -1;
|
|
pReq->fsyncPeriod = pStmt->pOptions->fsyncPeriod;
|
|
pReq->walLevel = pStmt->pOptions->walLevel;
|
|
pReq->precision = pStmt->pOptions->precision;
|
|
pReq->compression = pStmt->pOptions->compressionLevel;
|
|
pReq->replications = pStmt->pOptions->replica;
|
|
pReq->quorum = pStmt->pOptions->quorum;
|
|
pReq->update = -1;
|
|
pReq->cacheLastRow = pStmt->pOptions->cachelast;
|
|
pReq->ignoreExist = pStmt->ignoreExists;
|
|
pReq->streamMode = pStmt->pOptions->streamMode;
|
|
return;
|
|
}
|
|
|
|
static int32_t translateCreateDatabase(STranslateContext* pCxt, SCreateDatabaseStmt* pStmt) {
|
|
SCreateDbReq createReq = {0};
|
|
buildCreateDbReq(pCxt, pStmt, &createReq);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_CREATE_DB;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSCreateDbReq(NULL, 0, &createReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSCreateDbReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &createReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateDropDatabase(STranslateContext* pCxt, SDropDatabaseStmt* pStmt) {
|
|
SDropDbReq dropReq = {0};
|
|
SName name = {0};
|
|
tNameSetDbName(&name, pCxt->pParseCxt->acctId, pStmt->dbName, strlen(pStmt->dbName));
|
|
tNameGetFullDbName(&name, dropReq.db);
|
|
dropReq.ignoreNotExists = pStmt->ignoreNotExists;
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_DROP_DB;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSDropDbReq(NULL, 0, &dropReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSDropDbReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &dropReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static void buildAlterDbReq(STranslateContext* pCxt, SAlterDatabaseStmt* pStmt, SAlterDbReq* pReq) {
|
|
SName name = {0};
|
|
tNameSetDbName(&name, pCxt->pParseCxt->acctId, pStmt->dbName, strlen(pStmt->dbName));
|
|
tNameGetFullDbName(&name, pReq->db);
|
|
pReq->totalBlocks = pStmt->pOptions->numOfBlocks;
|
|
pReq->daysToKeep0 = pStmt->pOptions->keep;
|
|
pReq->daysToKeep1 = -1;
|
|
pReq->daysToKeep2 = -1;
|
|
pReq->fsyncPeriod = pStmt->pOptions->fsyncPeriod;
|
|
pReq->walLevel = pStmt->pOptions->walLevel;
|
|
pReq->quorum = pStmt->pOptions->quorum;
|
|
pReq->cacheLastRow = pStmt->pOptions->cachelast;
|
|
return;
|
|
}
|
|
|
|
static int32_t translateAlterDatabase(STranslateContext* pCxt, SAlterDatabaseStmt* pStmt) {
|
|
SAlterDbReq alterReq = {0};
|
|
buildAlterDbReq(pCxt, pStmt, &alterReq);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_ALTER_DB;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSAlterDbReq(NULL, 0, &alterReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSAlterDbReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &alterReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t calcTypeBytes(SDataType dt) {
|
|
if (TSDB_DATA_TYPE_BINARY == dt.type) {
|
|
return dt.bytes + VARSTR_HEADER_SIZE;
|
|
} else if (TSDB_DATA_TYPE_NCHAR == dt.type) {
|
|
return dt.bytes * TSDB_NCHAR_SIZE + VARSTR_HEADER_SIZE;
|
|
} else {
|
|
return dt.bytes;
|
|
}
|
|
}
|
|
|
|
static int32_t columnNodeToField(SNodeList* pList, SArray** pArray) {
|
|
*pArray = taosArrayInit(LIST_LENGTH(pList), sizeof(SField));
|
|
SNode* pNode;
|
|
FOREACH(pNode, pList) {
|
|
SColumnDefNode* pCol = (SColumnDefNode*)pNode;
|
|
SField field = { .type = pCol->dataType.type, .bytes = calcTypeBytes(pCol->dataType) };
|
|
strcpy(field.name, pCol->colName);
|
|
taosArrayPush(*pArray, &field);
|
|
}
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateCreateSuperTable(STranslateContext* pCxt, SCreateTableStmt* pStmt) {
|
|
SMCreateStbReq createReq = {0};
|
|
createReq.igExists = pStmt->ignoreExists;
|
|
columnNodeToField(pStmt->pCols, &createReq.pColumns);
|
|
columnNodeToField(pStmt->pTags, &createReq.pTags);
|
|
createReq.numOfColumns = LIST_LENGTH(pStmt->pCols);
|
|
createReq.numOfTags = LIST_LENGTH(pStmt->pTags);
|
|
|
|
SName tableName = { .type = TSDB_TABLE_NAME_T, .acctId = pCxt->pParseCxt->acctId };
|
|
strcpy(tableName.dbname, pStmt->dbName);
|
|
strcpy(tableName.tname, pStmt->tableName);
|
|
tNameExtractFullName(&tableName, createReq.name);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
tFreeSMCreateStbReq(&createReq);
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_CREATE_STB;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSMCreateStbReq(NULL, 0, &createReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
tFreeSMCreateStbReq(&createReq);
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSMCreateStbReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &createReq);
|
|
|
|
tFreeSMCreateStbReq(&createReq);
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t doTranslateDropSuperTable(STranslateContext* pCxt, const SName* pTableName, bool ignoreNotExists) {
|
|
SMDropStbReq dropReq = {0};
|
|
tNameExtractFullName(pTableName, dropReq.name);
|
|
dropReq.igNotExists = ignoreNotExists;
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_DROP_STB;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSMDropStbReq(NULL, 0, &dropReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSMDropStbReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &dropReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateDropTable(STranslateContext* pCxt, SDropTableStmt* pStmt) {
|
|
SDropTableClause* pClause = nodesListGetNode(pStmt->pTables, 0);
|
|
|
|
SName tableName = { .type = TSDB_TABLE_NAME_T, .acctId = pCxt->pParseCxt->acctId };
|
|
strcpy(tableName.dbname, pClause->dbName);
|
|
strcpy(tableName.tname, pClause->tableName);
|
|
STableMeta* pTableMeta = NULL;
|
|
int32_t code = catalogGetTableMeta(pCxt->pParseCxt->pCatalog, pCxt->pParseCxt->pTransporter, &(pCxt->pParseCxt->mgmtEpSet), &tableName, &pTableMeta);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
if (TSDB_SUPER_TABLE == pTableMeta->tableType) {
|
|
code = doTranslateDropSuperTable(pCxt, &tableName, pClause->ignoreNotExists);
|
|
} else {
|
|
// todo : drop normal table or child table
|
|
code = TSDB_CODE_FAILED;
|
|
}
|
|
}
|
|
tfree(pTableMeta);
|
|
|
|
return code;
|
|
}
|
|
|
|
static int32_t translateDropSuperTable(STranslateContext* pCxt, SDropSuperTableStmt* pStmt) {
|
|
SName tableName = { .type = TSDB_TABLE_NAME_T, .acctId = pCxt->pParseCxt->acctId };
|
|
strcpy(tableName.dbname, pStmt->dbName);
|
|
strcpy(tableName.tname, pStmt->tableName);
|
|
return doTranslateDropSuperTable(pCxt, &tableName, pStmt->ignoreNotExists);
|
|
}
|
|
|
|
static int32_t setAlterTableField(SAlterTableStmt* pStmt, SMAltertbReq* pAlterReq) {
|
|
pAlterReq->pFields = taosArrayInit(2, sizeof(TAOS_FIELD));
|
|
if (NULL == pAlterReq->pFields) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
|
|
switch (pStmt->alterType) {
|
|
case TSDB_ALTER_TABLE_ADD_TAG:
|
|
case TSDB_ALTER_TABLE_DROP_TAG:
|
|
case TSDB_ALTER_TABLE_ADD_COLUMN:
|
|
case TSDB_ALTER_TABLE_DROP_COLUMN:
|
|
case TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES:
|
|
case TSDB_ALTER_TABLE_UPDATE_TAG_BYTES: {
|
|
TAOS_FIELD field = { .type = pStmt->dataType.type, .bytes = pStmt->dataType.bytes };
|
|
strcpy(field.name, pStmt->colName);
|
|
taosArrayPush(pAlterReq->pFields, &field);
|
|
break;
|
|
}
|
|
case TSDB_ALTER_TABLE_UPDATE_TAG_NAME:
|
|
case TSDB_ALTER_TABLE_UPDATE_COLUMN_NAME: {
|
|
TAOS_FIELD oldField = {0};
|
|
strcpy(oldField.name, pStmt->colName);
|
|
taosArrayPush(pAlterReq->pFields, &oldField);
|
|
TAOS_FIELD newField = {0};
|
|
strcpy(oldField.name, pStmt->newColName);
|
|
taosArrayPush(pAlterReq->pFields, &newField);
|
|
break;
|
|
}
|
|
default:
|
|
break;
|
|
}
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateAlterTable(STranslateContext* pCxt, SAlterTableStmt* pStmt) {
|
|
SMAltertbReq alterReq = {0};
|
|
SName tableName = { .type = TSDB_TABLE_NAME_T, .acctId = pCxt->pParseCxt->acctId };
|
|
strcpy(tableName.dbname, pStmt->dbName);
|
|
strcpy(tableName.tname, pStmt->tableName);
|
|
tNameExtractFullName(&tableName, alterReq.name);
|
|
alterReq.alterType = pStmt->alterType;
|
|
alterReq.numOfFields = 1;
|
|
if (TSDB_ALTER_TABLE_UPDATE_OPTIONS == pStmt->alterType) {
|
|
// todo
|
|
} else {
|
|
if (TSDB_CODE_SUCCESS != setAlterTableField(pStmt, &alterReq)) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
}
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_ALTER_STB;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSMAlterStbReq(NULL, 0, &alterReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSMAlterStbReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &alterReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateUseDatabase(STranslateContext* pCxt, SUseDatabaseStmt* pStmt) {
|
|
SName name = {0};
|
|
tNameSetDbName(&name, pCxt->pParseCxt->acctId, pStmt->dbName, strlen(pStmt->dbName));
|
|
|
|
SUseDbReq usedbReq = {0};
|
|
tNameExtractFullName(&name, usedbReq.db);
|
|
|
|
catalogGetDBVgVersion(pCxt->pParseCxt->pCatalog, usedbReq.db, &usedbReq.vgVersion, &usedbReq.dbId, &usedbReq.numOfTable);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_USE_DB;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSUseDbReq(NULL, 0, &usedbReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSUseDbReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &usedbReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateCreateUser(STranslateContext* pCxt, SCreateUserStmt* pStmt) {
|
|
SCreateUserReq createReq = {0};
|
|
strcpy(createReq.user, pStmt->useName);
|
|
createReq.createType = 0;
|
|
createReq.superUser = 0;
|
|
strcpy(createReq.pass, pStmt->password);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_CREATE_USER;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSCreateUserReq(NULL, 0, &createReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSCreateUserReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &createReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateAlterUser(STranslateContext* pCxt, SAlterUserStmt* pStmt) {
|
|
SAlterUserReq alterReq = {0};
|
|
strcpy(alterReq.user, pStmt->useName);
|
|
alterReq.alterType = pStmt->alterType;
|
|
alterReq.superUser = 0;
|
|
strcpy(alterReq.pass, pStmt->password);
|
|
if (NULL != pCxt->pParseCxt->db) {
|
|
strcpy(alterReq.dbname, pCxt->pParseCxt->db);
|
|
}
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_ALTER_USER;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSAlterUserReq(NULL, 0, &alterReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSAlterUserReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &alterReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateDropUser(STranslateContext* pCxt, SDropUserStmt* pStmt) {
|
|
SDropUserReq dropReq = {0};
|
|
strcpy(dropReq.user, pStmt->useName);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_DROP_USER;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSDropUserReq(NULL, 0, &dropReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSDropUserReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &dropReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateCreateDnode(STranslateContext* pCxt, SCreateDnodeStmt* pStmt) {
|
|
SCreateDnodeReq createReq = {0};
|
|
strcpy(createReq.fqdn, pStmt->fqdn);
|
|
createReq.port = pStmt->port;
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_CREATE_DNODE;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSCreateDnodeReq(NULL, 0, &createReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSCreateDnodeReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &createReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateDropDnode(STranslateContext* pCxt, SDropDnodeStmt* pStmt) {
|
|
SDropDnodeReq dropReq = {0};
|
|
dropReq.dnodeId = pStmt->dnodeId;
|
|
strcpy(dropReq.fqdn, pStmt->fqdn);
|
|
dropReq.port = pStmt->port;
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_DROP_DNODE;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSDropDnodeReq(NULL, 0, &dropReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSDropDnodeReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &dropReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateAlterDnode(STranslateContext* pCxt, SAlterDnodeStmt* pStmt) {
|
|
SMCfgDnodeReq cfgReq = {0};
|
|
cfgReq.dnodeId = pStmt->dnodeId;
|
|
strcpy(cfgReq.config, pStmt->config);
|
|
strcpy(cfgReq.value, pStmt->value);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_CONFIG_DNODE;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSMCfgDnodeReq(NULL, 0, &cfgReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSMCfgDnodeReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &cfgReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t nodeTypeToShowType(ENodeType nt) {
|
|
switch (nt) {
|
|
case QUERY_NODE_SHOW_DATABASES_STMT:
|
|
return TSDB_MGMT_TABLE_DB;
|
|
case QUERY_NODE_SHOW_STABLES_STMT:
|
|
return TSDB_MGMT_TABLE_STB;
|
|
case QUERY_NODE_SHOW_USERS_STMT:
|
|
return TSDB_MGMT_TABLE_USER;
|
|
case QUERY_NODE_SHOW_DNODES_STMT:
|
|
return TSDB_MGMT_TABLE_DNODE;
|
|
case QUERY_NODE_SHOW_VGROUPS_STMT:
|
|
return TSDB_MGMT_TABLE_VGROUP;
|
|
case QUERY_NODE_SHOW_MNODES_STMT:
|
|
return TSDB_MGMT_TABLE_MNODE;
|
|
case QUERY_NODE_SHOW_QNODES_STMT:
|
|
return TSDB_MGMT_TABLE_QNODE;
|
|
default:
|
|
break;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static int32_t translateShow(STranslateContext* pCxt, SShowStmt* pStmt) {
|
|
SShowReq showReq = { .type = nodeTypeToShowType(nodeType(pStmt)) };
|
|
if ('\0' != pStmt->dbName[0]) {
|
|
SName name = {0};
|
|
tNameSetDbName(&name, pCxt->pParseCxt->acctId, pStmt->dbName, strlen(pStmt->dbName));
|
|
char dbFname[TSDB_DB_FNAME_LEN] = {0};
|
|
tNameGetFullDbName(&name, showReq.db);
|
|
}
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_SHOW;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSShowReq(NULL, 0, &showReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSShowReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &showReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateShowTables(STranslateContext* pCxt) {
|
|
SName name = {0};
|
|
SVShowTablesReq* pShowReq = calloc(1, sizeof(SVShowTablesReq));
|
|
if (pCxt->pParseCxt->db == NULL || strlen(pCxt->pParseCxt->db) == 0) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_TSC_INVALID_OPERATION, "db not specified");
|
|
}
|
|
|
|
tNameSetDbName(&name, pCxt->pParseCxt->acctId, pCxt->pParseCxt->db, strlen(pCxt->pParseCxt->db));
|
|
char dbFname[TSDB_DB_FNAME_LEN] = {0};
|
|
tNameGetFullDbName(&name, dbFname);
|
|
|
|
SArray* array = NULL;
|
|
int32_t code = catalogGetDBVgInfo(pCxt->pParseCxt->pCatalog, pCxt->pParseCxt->pTransporter, &pCxt->pParseCxt->mgmtEpSet, dbFname, false, &array);
|
|
if (code != TSDB_CODE_SUCCESS) {
|
|
return code;
|
|
}
|
|
SVgroupInfo* info = taosArrayGet(array, 0);
|
|
pShowReq->head.vgId = htonl(info->vgId);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = info->epSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_VND_SHOW_TABLES;
|
|
pCxt->pCmdMsg->msgLen = sizeof(SVShowTablesReq);
|
|
pCxt->pCmdMsg->pMsg = pShowReq;
|
|
pCxt->pCmdMsg->pExtension = array;
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateCreateSmaIndex(STranslateContext* pCxt, SCreateIndexStmt* pStmt) {
|
|
SVCreateTSmaReq createSmaReq = {0};
|
|
|
|
if (DEAL_RES_ERROR == translateValue(pCxt, (SValueNode*)pStmt->pOptions->pInterval) ||
|
|
(NULL != pStmt->pOptions->pOffset && DEAL_RES_ERROR == translateValue(pCxt, (SValueNode*)pStmt->pOptions->pOffset)) ||
|
|
(NULL != pStmt->pOptions->pSliding && DEAL_RES_ERROR == translateValue(pCxt, (SValueNode*)pStmt->pOptions->pSliding))) {
|
|
return pCxt->errCode;
|
|
}
|
|
|
|
createSmaReq.tSma.intervalUnit = ((SValueNode*)pStmt->pOptions->pInterval)->unit;
|
|
createSmaReq.tSma.slidingUnit = (NULL != pStmt->pOptions->pSliding ? ((SValueNode*)pStmt->pOptions->pSliding)->unit : 0);
|
|
strcpy(createSmaReq.tSma.indexName, pStmt->indexName);
|
|
|
|
SName name;
|
|
name.type = TSDB_TABLE_NAME_T;
|
|
name.acctId = pCxt->pParseCxt->acctId;
|
|
strcpy(name.dbname, pCxt->pParseCxt->db);
|
|
strcpy(name.tname, pStmt->tableName);
|
|
STableMeta* pMeta = NULL;
|
|
int32_t code = catalogGetTableMeta(pCxt->pParseCxt->pCatalog, pCxt->pParseCxt->pTransporter, &pCxt->pParseCxt->mgmtEpSet, &name, &pMeta);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return code;
|
|
}
|
|
|
|
createSmaReq.tSma.tableUid = pMeta->uid;
|
|
createSmaReq.tSma.interval = ((SValueNode*)pStmt->pOptions->pInterval)->datum.i;
|
|
createSmaReq.tSma.sliding = (NULL != pStmt->pOptions->pSliding ? ((SValueNode*)pStmt->pOptions->pSliding)->datum.i : 0);
|
|
code = nodesListToString(pStmt->pOptions->pFuncs, false, &createSmaReq.tSma.expr, &createSmaReq.tSma.exprLen);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return code;
|
|
}
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_VND_CREATE_SMA;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSVCreateTSmaReq(NULL, &createSmaReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
void* pBuf = pCxt->pCmdMsg->pMsg;
|
|
tSerializeSVCreateTSmaReq(&pBuf, &createSmaReq);
|
|
tdDestroyTSma(&createSmaReq.tSma);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateCreateIndex(STranslateContext* pCxt, SCreateIndexStmt* pStmt) {
|
|
if (INDEX_TYPE_SMA == pStmt->indexType) {
|
|
return translateCreateSmaIndex(pCxt, pStmt);
|
|
} else {
|
|
// todo fulltext index
|
|
return TSDB_CODE_FAILED;
|
|
}
|
|
}
|
|
|
|
static int32_t translateDropIndex(STranslateContext* pCxt, SDropIndexStmt* pStmt) {
|
|
SVDropTSmaReq dropSmaReq = {0};
|
|
strcpy(dropSmaReq.indexName, pStmt->indexName);
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_VND_DROP_SMA;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSVDropTSmaReq(NULL, &dropSmaReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
void* pBuf = pCxt->pCmdMsg->pMsg;
|
|
tSerializeSVDropTSmaReq(&pBuf, &dropSmaReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateCreateQnode(STranslateContext* pCxt, SCreateQnodeStmt* pStmt) {
|
|
SMCreateQnodeReq createReq = { .dnodeId = pStmt->dnodeId };
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_DND_CREATE_QNODE;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSMCreateDropQSBNodeReq(NULL, 0, &createReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSMCreateDropQSBNodeReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &createReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateDropQnode(STranslateContext* pCxt, SDropQnodeStmt* pStmt) {
|
|
SDDropQnodeReq dropReq = { .dnodeId = pStmt->dnodeId };
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_DND_DROP_QNODE;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSMCreateDropQSBNodeReq(NULL, 0, &dropReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSMCreateDropQSBNodeReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &dropReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateCreateTopic(STranslateContext* pCxt, SCreateTopicStmt* pStmt) {
|
|
SCMCreateTopicReq createReq = {0};
|
|
|
|
if (NULL != pStmt->pQuery) {
|
|
pCxt->pParseCxt->topicQuery = true;
|
|
int32_t code = translateQuery(pCxt, pStmt->pQuery);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = nodesNodeToString(pStmt->pQuery, false, &createReq.ast, NULL);
|
|
}
|
|
if (TSDB_CODE_SUCCESS != code ) {
|
|
return code;
|
|
}
|
|
} else {
|
|
strcpy(createReq.subscribeDbName, pStmt->subscribeDbName);
|
|
}
|
|
|
|
createReq.sql = strdup(pCxt->pParseCxt->pSql);
|
|
if (NULL == createReq.sql) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
|
|
SName name = { .type = TSDB_TABLE_NAME_T, .acctId = pCxt->pParseCxt->acctId };
|
|
strcpy(name.dbname, pCxt->pParseCxt->db);
|
|
strcpy(name.tname, pStmt->topicName);
|
|
tNameExtractFullName(&name, createReq.name);
|
|
createReq.igExists = pStmt->ignoreExists;
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_CREATE_TOPIC;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSCMCreateTopicReq(NULL, 0, &createReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSCMCreateTopicReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &createReq);
|
|
tFreeSCMCreateTopicReq(&createReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateDropTopic(STranslateContext* pCxt, SDropTopicStmt* pStmt) {
|
|
SMDropTopicReq dropReq = {0};
|
|
|
|
SName name = { .type = TSDB_TABLE_NAME_T, .acctId = pCxt->pParseCxt->acctId };
|
|
strcpy(name.dbname, pCxt->pParseCxt->db);
|
|
strcpy(name.tname, pStmt->topicName);
|
|
tNameExtractFullName(&name, dropReq.name);
|
|
dropReq.igNotExists = pStmt->ignoreNotExists;
|
|
|
|
pCxt->pCmdMsg = malloc(sizeof(SCmdMsgInfo));
|
|
if (NULL == pCxt->pCmdMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pCxt->pCmdMsg->epSet = pCxt->pParseCxt->mgmtEpSet;
|
|
pCxt->pCmdMsg->msgType = TDMT_MND_DROP_TOPIC;
|
|
pCxt->pCmdMsg->msgLen = tSerializeSMDropTopicReq(NULL, 0, &dropReq);
|
|
pCxt->pCmdMsg->pMsg = malloc(pCxt->pCmdMsg->msgLen);
|
|
if (NULL == pCxt->pCmdMsg->pMsg) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
tSerializeSMDropTopicReq(pCxt->pCmdMsg->pMsg, pCxt->pCmdMsg->msgLen, &dropReq);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateAlterLocal(STranslateContext* pCxt, SAlterLocalStmt* pStmt) {
|
|
// todo
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t translateQuery(STranslateContext* pCxt, SNode* pNode) {
|
|
int32_t code = TSDB_CODE_SUCCESS;
|
|
switch (nodeType(pNode)) {
|
|
case QUERY_NODE_SELECT_STMT:
|
|
code = translateSelect(pCxt, (SSelectStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_CREATE_DATABASE_STMT:
|
|
code = translateCreateDatabase(pCxt, (SCreateDatabaseStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_DROP_DATABASE_STMT:
|
|
code = translateDropDatabase(pCxt, (SDropDatabaseStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_ALTER_DATABASE_STMT:
|
|
code = translateAlterDatabase(pCxt, (SAlterDatabaseStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_CREATE_TABLE_STMT:
|
|
code = translateCreateSuperTable(pCxt, (SCreateTableStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_DROP_TABLE_STMT:
|
|
code = translateDropTable(pCxt, (SDropTableStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_DROP_SUPER_TABLE_STMT:
|
|
code = translateDropSuperTable(pCxt, (SDropSuperTableStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_ALTER_TABLE_STMT:
|
|
code = translateAlterTable(pCxt, (SAlterTableStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_CREATE_USER_STMT:
|
|
code = translateCreateUser(pCxt, (SCreateUserStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_ALTER_USER_STMT:
|
|
code = translateAlterUser(pCxt, (SAlterUserStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_DROP_USER_STMT:
|
|
code = translateDropUser(pCxt, (SDropUserStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_USE_DATABASE_STMT:
|
|
code = translateUseDatabase(pCxt, (SUseDatabaseStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_CREATE_DNODE_STMT:
|
|
code = translateCreateDnode(pCxt, (SCreateDnodeStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_DROP_DNODE_STMT:
|
|
code = translateDropDnode(pCxt, (SDropDnodeStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_ALTER_DNODE_STMT:
|
|
code = translateAlterDnode(pCxt, (SAlterDnodeStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_SHOW_DATABASES_STMT:
|
|
case QUERY_NODE_SHOW_STABLES_STMT:
|
|
case QUERY_NODE_SHOW_USERS_STMT:
|
|
case QUERY_NODE_SHOW_DNODES_STMT:
|
|
case QUERY_NODE_SHOW_VGROUPS_STMT:
|
|
case QUERY_NODE_SHOW_MNODES_STMT:
|
|
case QUERY_NODE_SHOW_QNODES_STMT:
|
|
code = translateShow(pCxt, (SShowStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_SHOW_TABLES_STMT:
|
|
code = translateShowTables(pCxt);
|
|
break;
|
|
case QUERY_NODE_CREATE_INDEX_STMT:
|
|
code = translateCreateIndex(pCxt, (SCreateIndexStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_DROP_INDEX_STMT:
|
|
code = translateDropIndex(pCxt, (SDropIndexStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_CREATE_QNODE_STMT:
|
|
code = translateCreateQnode(pCxt, (SCreateQnodeStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_DROP_QNODE_STMT:
|
|
code = translateDropQnode(pCxt, (SDropQnodeStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_CREATE_TOPIC_STMT:
|
|
code = translateCreateTopic(pCxt, (SCreateTopicStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_DROP_TOPIC_STMT:
|
|
code = translateDropTopic(pCxt, (SDropTopicStmt*)pNode);
|
|
break;
|
|
case QUERY_NODE_ALTER_LOCAL_STMT:
|
|
code = translateAlterLocal(pCxt, (SAlterLocalStmt*)pNode);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t translateSubquery(STranslateContext* pCxt, SNode* pNode) {
|
|
++(pCxt->currLevel);
|
|
ESqlClause currClause = pCxt->currClause;
|
|
SSelectStmt* pCurrStmt = pCxt->pCurrStmt;
|
|
int32_t code = translateQuery(pCxt, pNode);
|
|
--(pCxt->currLevel);
|
|
pCxt->currClause = currClause;
|
|
pCxt->pCurrStmt = pCurrStmt;
|
|
return code;
|
|
}
|
|
|
|
static int32_t setReslutSchema(STranslateContext* pCxt, SQuery* pQuery) {
|
|
if (QUERY_NODE_SELECT_STMT == nodeType(pQuery->pRoot)) {
|
|
SSelectStmt* pSelect = (SSelectStmt*)pQuery->pRoot;
|
|
pQuery->numOfResCols = LIST_LENGTH(pSelect->pProjectionList);
|
|
pQuery->pResSchema = calloc(pQuery->numOfResCols, sizeof(SSchema));
|
|
if (NULL == pQuery->pResSchema) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_OUT_OF_MEMORY);
|
|
}
|
|
SNode* pNode;
|
|
int32_t index = 0;
|
|
FOREACH(pNode, pSelect->pProjectionList) {
|
|
SExprNode* pExpr = (SExprNode*)pNode;
|
|
pQuery->pResSchema[index].type = pExpr->resType.type;
|
|
pQuery->pResSchema[index].bytes = pExpr->resType.bytes;
|
|
strcpy(pQuery->pResSchema[index].name, pExpr->aliasName);
|
|
index +=1;
|
|
}
|
|
}
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static void destroyTranslateContext(STranslateContext* pCxt) {
|
|
if (NULL != pCxt->pNsLevel) {
|
|
size_t size = taosArrayGetSize(pCxt->pNsLevel);
|
|
for (size_t i = 0; i < size; ++i) {
|
|
taosArrayDestroy(taosArrayGetP(pCxt->pNsLevel, i));
|
|
}
|
|
taosArrayDestroy(pCxt->pNsLevel);
|
|
}
|
|
|
|
if (NULL != pCxt->pCmdMsg) {
|
|
tfree(pCxt->pCmdMsg->pMsg);
|
|
tfree(pCxt->pCmdMsg);
|
|
}
|
|
}
|
|
|
|
typedef struct SVgroupTablesBatch {
|
|
SVCreateTbBatchReq req;
|
|
SVgroupInfo info;
|
|
} SVgroupTablesBatch;
|
|
|
|
static void toSchema(const SColumnDefNode* pCol, int32_t colId, SSchema* pSchema) {
|
|
pSchema->colId = colId;
|
|
pSchema->type = pCol->dataType.type;
|
|
pSchema->bytes = pCol->dataType.bytes;
|
|
strcpy(pSchema->name, pCol->colName);
|
|
}
|
|
|
|
static void destroyCreateTbReq(SVCreateTbReq* pReq) {
|
|
tfree(pReq->name);
|
|
tfree(pReq->ntbCfg.pSchema);
|
|
}
|
|
|
|
static int32_t buildNormalTableBatchReq(
|
|
const char* pTableName, const SNodeList* pColumns, const SVgroupInfo* pVgroupInfo, SVgroupTablesBatch* pBatch) {
|
|
SVCreateTbReq req = {0};
|
|
req.type = TD_NORMAL_TABLE;
|
|
req.name = strdup(pTableName);
|
|
req.ntbCfg.nCols = LIST_LENGTH(pColumns);
|
|
req.ntbCfg.pSchema = calloc(req.ntbCfg.nCols, sizeof(SSchema));
|
|
if (NULL == req.name || NULL == req.ntbCfg.pSchema) {
|
|
destroyCreateTbReq(&req);
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
SNode* pCol;
|
|
int32_t index = 0;
|
|
FOREACH(pCol, pColumns) {
|
|
toSchema((SColumnDefNode*)pCol, index + 1, req.ntbCfg.pSchema + index);
|
|
++index;
|
|
}
|
|
|
|
pBatch->info = *pVgroupInfo;
|
|
pBatch->req.pArray = taosArrayInit(1, sizeof(struct SVCreateTbReq));
|
|
if (NULL == pBatch->req.pArray) {
|
|
destroyCreateTbReq(&req);
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
taosArrayPush(pBatch->req.pArray, &req);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t serializeVgroupTablesBatch(SVgroupTablesBatch* pTbBatch, SArray* pBufArray) {
|
|
int tlen = sizeof(SMsgHead) + tSerializeSVCreateTbBatchReq(NULL, &(pTbBatch->req));
|
|
void* buf = malloc(tlen);
|
|
if (NULL == buf) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
((SMsgHead*)buf)->vgId = htonl(pTbBatch->info.vgId);
|
|
((SMsgHead*)buf)->contLen = htonl(tlen);
|
|
void* pBuf = POINTER_SHIFT(buf, sizeof(SMsgHead));
|
|
tSerializeSVCreateTbBatchReq(&pBuf, &(pTbBatch->req));
|
|
|
|
SVgDataBlocks* pVgData = calloc(1, sizeof(SVgDataBlocks));
|
|
if (NULL == pVgData) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pVgData->vg = pTbBatch->info;
|
|
pVgData->pData = buf;
|
|
pVgData->size = tlen;
|
|
pVgData->numOfTables = (int32_t) taosArrayGetSize(pTbBatch->req.pArray);
|
|
taosArrayPush(pBufArray, &pVgData);
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static void destroyCreateTbReqBatch(SVgroupTablesBatch* pTbBatch) {
|
|
size_t size = taosArrayGetSize(pTbBatch->req.pArray);
|
|
for(int32_t i = 0; i < size; ++i) {
|
|
SVCreateTbReq* pTableReq = taosArrayGet(pTbBatch->req.pArray, i);
|
|
tfree(pTableReq->name);
|
|
|
|
if (pTableReq->type == TSDB_NORMAL_TABLE) {
|
|
tfree(pTableReq->ntbCfg.pSchema);
|
|
} else if (pTableReq->type == TSDB_CHILD_TABLE) {
|
|
tfree(pTableReq->ctbCfg.pTag);
|
|
}
|
|
}
|
|
|
|
taosArrayDestroy(pTbBatch->req.pArray);
|
|
}
|
|
|
|
static int32_t getTableHashVgroup(SParseContext* pCxt, const char* pDbName, const char* pTableName, SVgroupInfo* pInfo) {
|
|
SName name = { .type = TSDB_TABLE_NAME_T, .acctId = pCxt->acctId };
|
|
strcpy(name.dbname, pDbName);
|
|
strcpy(name.tname, pTableName);
|
|
return catalogGetTableHashVgroup(pCxt->pCatalog, pCxt->pTransporter, &pCxt->mgmtEpSet, &name, pInfo);
|
|
}
|
|
|
|
static int32_t rewriteToVnodeModifOpStmt(SQuery* pQuery, SArray* pBufArray) {
|
|
SVnodeModifOpStmt* pNewStmt = nodesMakeNode(QUERY_NODE_VNODE_MODIF_STMT);
|
|
if (pNewStmt == NULL) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
pNewStmt->sqlNodeType = nodeType(pQuery->pRoot);
|
|
pNewStmt->pDataBlocks = pBufArray;
|
|
nodesDestroyNode(pQuery->pRoot);
|
|
pQuery->pRoot = (SNode*)pNewStmt;
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static void destroyCreateTbReqArray(SArray* pArray) {
|
|
size_t size = taosArrayGetSize(pArray);
|
|
for (size_t i = 0; i < size; ++i) {
|
|
SVgDataBlocks* pVg = taosArrayGetP(pArray, i);
|
|
tfree(pVg->pData);
|
|
tfree(pVg);
|
|
}
|
|
taosArrayDestroy(pArray);
|
|
}
|
|
|
|
static int32_t buildCreateTableDataBlock(const SCreateTableStmt* pStmt, const SVgroupInfo* pInfo, SArray** pBufArray) {
|
|
*pBufArray = taosArrayInit(1, POINTER_BYTES);
|
|
if (NULL == *pBufArray) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
|
|
SVgroupTablesBatch tbatch = {0};
|
|
int32_t code = buildNormalTableBatchReq(pStmt->tableName, pStmt->pCols, pInfo, &tbatch);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = serializeVgroupTablesBatch(&tbatch, *pBufArray);
|
|
}
|
|
|
|
destroyCreateTbReqBatch(&tbatch);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
destroyCreateTbReqArray(*pBufArray);
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t rewriteCreateTable(STranslateContext* pCxt, SQuery* pQuery) {
|
|
SCreateTableStmt* pStmt = (SCreateTableStmt*)pQuery->pRoot;
|
|
|
|
SVgroupInfo info = {0};
|
|
int32_t code = getTableHashVgroup(pCxt->pParseCxt, pStmt->dbName, pStmt->tableName, &info);
|
|
SArray* pBufArray = NULL;
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = buildCreateTableDataBlock(pStmt, &info, &pBufArray);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = rewriteToVnodeModifOpStmt(pQuery, pBufArray);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
destroyCreateTbReqArray(pBufArray);
|
|
}
|
|
}
|
|
|
|
return code;
|
|
}
|
|
|
|
static void addCreateTbReqIntoVgroup(SHashObj* pVgroupHashmap, const char* pTableName, SKVRow row, uint64_t suid, SVgroupInfo* pVgInfo) {
|
|
struct SVCreateTbReq req = {0};
|
|
req.type = TD_CHILD_TABLE;
|
|
req.name = strdup(pTableName);
|
|
req.ctbCfg.suid = suid;
|
|
req.ctbCfg.pTag = row;
|
|
|
|
SVgroupTablesBatch* pTableBatch = taosHashGet(pVgroupHashmap, &pVgInfo->vgId, sizeof(pVgInfo->vgId));
|
|
if (pTableBatch == NULL) {
|
|
SVgroupTablesBatch tBatch = {0};
|
|
tBatch.info = *pVgInfo;
|
|
|
|
tBatch.req.pArray = taosArrayInit(4, sizeof(struct SVCreateTbReq));
|
|
taosArrayPush(tBatch.req.pArray, &req);
|
|
|
|
taosHashPut(pVgroupHashmap, &pVgInfo->vgId, sizeof(pVgInfo->vgId), &tBatch, sizeof(tBatch));
|
|
} else { // add to the correct vgroup
|
|
taosArrayPush(pTableBatch->req.pArray, &req);
|
|
}
|
|
}
|
|
|
|
static void valueNodeToVariant(const SValueNode* pNode, SVariant* pVal) {
|
|
pVal->nType = pNode->node.resType.type;
|
|
pVal->nLen = pNode->node.resType.bytes;
|
|
switch (pNode->node.resType.type) {
|
|
case TSDB_DATA_TYPE_NULL:
|
|
break;
|
|
case TSDB_DATA_TYPE_BOOL:
|
|
pVal->i = pNode->datum.b;
|
|
break;
|
|
case TSDB_DATA_TYPE_TINYINT:
|
|
case TSDB_DATA_TYPE_SMALLINT:
|
|
case TSDB_DATA_TYPE_INT:
|
|
case TSDB_DATA_TYPE_BIGINT:
|
|
case TSDB_DATA_TYPE_TIMESTAMP:
|
|
pVal->i = pNode->datum.i;
|
|
break;
|
|
case TSDB_DATA_TYPE_UTINYINT:
|
|
case TSDB_DATA_TYPE_USMALLINT:
|
|
case TSDB_DATA_TYPE_UINT:
|
|
case TSDB_DATA_TYPE_UBIGINT:
|
|
pVal->u = pNode->datum.u;
|
|
break;
|
|
case TSDB_DATA_TYPE_FLOAT:
|
|
case TSDB_DATA_TYPE_DOUBLE:
|
|
pVal->d = pNode->datum.d;
|
|
break;
|
|
case TSDB_DATA_TYPE_NCHAR:
|
|
case TSDB_DATA_TYPE_VARCHAR:
|
|
case TSDB_DATA_TYPE_VARBINARY:
|
|
pVal->pz = pNode->datum.p;
|
|
break;
|
|
case TSDB_DATA_TYPE_JSON:
|
|
case TSDB_DATA_TYPE_DECIMAL:
|
|
case TSDB_DATA_TYPE_BLOB:
|
|
// todo
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
static int32_t addValToKVRow(STranslateContext* pCxt, SValueNode* pVal, const SSchema* pSchema, SKVRowBuilder* pBuilder) {
|
|
if (DEAL_RES_ERROR == translateValue(pCxt, pVal)) {
|
|
return pCxt->errCode;
|
|
}
|
|
SVariant var;
|
|
valueNodeToVariant(pVal, &var);
|
|
char tagVal[TSDB_MAX_TAGS_LEN] = {0};
|
|
int32_t code = taosVariantDump(&var, tagVal, pSchema->type, true);
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
tdAddColToKVRow(pBuilder, pSchema->colId, pSchema->type, tagVal);
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t buildKVRowForBindTags(STranslateContext* pCxt, SCreateSubTableClause* pStmt, STableMeta* pSuperTableMeta, SKVRowBuilder* pBuilder) {
|
|
int32_t numOfTags = getNumOfTags(pSuperTableMeta);
|
|
if (LIST_LENGTH(pStmt->pValsOfTags) != LIST_LENGTH(pStmt->pSpecificTags) || numOfTags < LIST_LENGTH(pStmt->pValsOfTags)) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_TAGS_NOT_MATCHED);
|
|
}
|
|
|
|
SSchema* pTagSchema = getTableTagSchema(pSuperTableMeta);
|
|
SNode* pTag, *pVal;
|
|
FORBOTH(pTag, pStmt->pSpecificTags, pVal, pStmt->pValsOfTags) {
|
|
SColumnNode* pCol = (SColumnNode*)pTag;
|
|
SSchema* pSchema = NULL;
|
|
for (int32_t i = 0; i < numOfTags; ++i) {
|
|
if (0 == strcmp(pCol->colName, pTagSchema[i].name)) {
|
|
pSchema = pTagSchema + i;
|
|
break;
|
|
}
|
|
}
|
|
if (NULL == pSchema) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_INVALID_TAG_NAME, pCol->colName);
|
|
}
|
|
int32_t code = addValToKVRow(pCxt, (SValueNode*)pVal, pSchema, pBuilder);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return code;
|
|
}
|
|
}
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t buildKVRowForAllTags(STranslateContext* pCxt, SCreateSubTableClause* pStmt, STableMeta* pSuperTableMeta, SKVRowBuilder* pBuilder) {
|
|
if (getNumOfTags(pSuperTableMeta) != LIST_LENGTH(pStmt->pValsOfTags)) {
|
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_TAGS_NOT_MATCHED);
|
|
}
|
|
|
|
SSchema* pTagSchema = getTableTagSchema(pSuperTableMeta);
|
|
SNode* pVal;
|
|
int32_t index = 0;
|
|
FOREACH(pVal, pStmt->pValsOfTags) {
|
|
int32_t code = addValToKVRow(pCxt, (SValueNode*)pVal, pTagSchema + index++, pBuilder);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
return code;
|
|
}
|
|
}
|
|
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t rewriteCreateSubTable(STranslateContext* pCxt, SCreateSubTableClause* pStmt, SHashObj* pVgroupHashmap) {
|
|
SName name = { .type = TSDB_TABLE_NAME_T, .acctId = pCxt->pParseCxt->acctId };
|
|
strcpy(name.dbname, pStmt->useDbName);
|
|
strcpy(name.tname, pStmt->useTableName);
|
|
STableMeta* pSuperTableMeta = NULL;
|
|
int32_t code = catalogGetTableMeta(pCxt->pParseCxt->pCatalog, pCxt->pParseCxt->pTransporter, &pCxt->pParseCxt->mgmtEpSet, &name, &pSuperTableMeta);
|
|
|
|
SKVRowBuilder kvRowBuilder = {0};
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = tdInitKVRowBuilder(&kvRowBuilder);
|
|
}
|
|
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
if (NULL != pStmt->pSpecificTags) {
|
|
code = buildKVRowForBindTags(pCxt, pStmt, pSuperTableMeta, &kvRowBuilder);
|
|
} else {
|
|
code = buildKVRowForAllTags(pCxt, pStmt, pSuperTableMeta, &kvRowBuilder);
|
|
}
|
|
}
|
|
|
|
SKVRow row = NULL;
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
row = tdGetKVRowFromBuilder(&kvRowBuilder);
|
|
if (NULL == row) {
|
|
code = TSDB_CODE_OUT_OF_MEMORY;
|
|
} else {
|
|
tdSortKVRowByColIdx(row);
|
|
}
|
|
}
|
|
|
|
SVgroupInfo info = {0};
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = getTableHashVgroup(pCxt->pParseCxt, pStmt->dbName, pStmt->tableName, &info);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
addCreateTbReqIntoVgroup(pVgroupHashmap, pStmt->tableName, row, pSuperTableMeta->uid, &info);
|
|
}
|
|
|
|
tfree(pSuperTableMeta);
|
|
tdDestroyKVRowBuilder(&kvRowBuilder);
|
|
return code;
|
|
}
|
|
|
|
static SArray* serializeVgroupsTablesBatch(SHashObj* pVgroupHashmap) {
|
|
SArray* pBufArray = taosArrayInit(taosHashGetSize(pVgroupHashmap), sizeof(void*));
|
|
if (NULL == pBufArray) {
|
|
return NULL;
|
|
}
|
|
|
|
int32_t code = TSDB_CODE_SUCCESS;
|
|
SVgroupTablesBatch* pTbBatch = NULL;
|
|
do {
|
|
pTbBatch = taosHashIterate(pVgroupHashmap, pTbBatch);
|
|
if (pTbBatch == NULL) {
|
|
break;
|
|
}
|
|
|
|
serializeVgroupTablesBatch(pTbBatch, pBufArray);
|
|
destroyCreateTbReqBatch(pTbBatch);
|
|
} while (true);
|
|
|
|
return pBufArray;
|
|
}
|
|
|
|
static int32_t rewriteCreateMultiTable(STranslateContext* pCxt, SQuery* pQuery) {
|
|
SCreateMultiTableStmt* pStmt = (SCreateMultiTableStmt*)pQuery->pRoot;
|
|
|
|
SHashObj* pVgroupHashmap = taosHashInit(4, taosGetDefaultHashFunction(TSDB_DATA_TYPE_INT), false, HASH_NO_LOCK);
|
|
if (NULL == pVgroupHashmap) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
|
|
int32_t code = TSDB_CODE_SUCCESS;
|
|
SNode* pNode;
|
|
FOREACH(pNode, pStmt->pSubTables) {
|
|
code = rewriteCreateSubTable(pCxt, (SCreateSubTableClause*)pNode, pVgroupHashmap);
|
|
if (TSDB_CODE_SUCCESS != code) {
|
|
taosHashCleanup(pVgroupHashmap);
|
|
return code;
|
|
}
|
|
}
|
|
|
|
SArray* pBufArray = serializeVgroupsTablesBatch(pVgroupHashmap);
|
|
taosHashCleanup(pVgroupHashmap);
|
|
if (NULL == pBufArray) {
|
|
return TSDB_CODE_OUT_OF_MEMORY;
|
|
}
|
|
|
|
return rewriteToVnodeModifOpStmt(pQuery, pBufArray);
|
|
}
|
|
|
|
static int32_t rewriteAlterTable(STranslateContext* pCxt, SQuery* pQuery) {
|
|
// todo
|
|
return TSDB_CODE_SUCCESS;
|
|
}
|
|
|
|
static int32_t rewriteQuery(STranslateContext* pCxt, SQuery* pQuery) {
|
|
int32_t code = TSDB_CODE_SUCCESS;
|
|
switch (nodeType(pQuery->pRoot)) {
|
|
case QUERY_NODE_CREATE_TABLE_STMT:
|
|
if (NULL == ((SCreateTableStmt*)pQuery->pRoot)->pTags) {
|
|
code = rewriteCreateTable(pCxt, pQuery);
|
|
}
|
|
break;
|
|
case QUERY_NODE_CREATE_MULTI_TABLE_STMT:
|
|
code = rewriteCreateMultiTable(pCxt, pQuery);
|
|
break;
|
|
case QUERY_NODE_ALTER_TABLE_STMT:
|
|
if (TSDB_ALTER_TABLE_UPDATE_TAG_VAL == ((SAlterTableStmt*)pQuery->pRoot)->alterType) {
|
|
code = rewriteAlterTable(pCxt, pQuery);
|
|
}
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
return code;
|
|
}
|
|
|
|
static int32_t setQuery(STranslateContext* pCxt, SQuery* pQuery) {
|
|
int32_t code = TSDB_CODE_SUCCESS;
|
|
switch (nodeType(pQuery->pRoot)) {
|
|
case QUERY_NODE_SELECT_STMT:
|
|
pQuery->haveResultSet = true;
|
|
pQuery->directRpc = false;
|
|
pQuery->msgType = TDMT_VND_QUERY;
|
|
code = setReslutSchema(pCxt, pQuery);
|
|
break;
|
|
case QUERY_NODE_VNODE_MODIF_STMT:
|
|
pQuery->haveResultSet = false;
|
|
pQuery->directRpc = false;
|
|
pQuery->msgType = TDMT_VND_CREATE_TABLE;
|
|
break;
|
|
default:
|
|
pQuery->haveResultSet = false;
|
|
pQuery->directRpc = true;
|
|
pQuery->pCmdMsg = pCxt->pCmdMsg;
|
|
pCxt->pCmdMsg = NULL;
|
|
pQuery->msgType = pQuery->pCmdMsg->msgType;
|
|
break;
|
|
}
|
|
return code;
|
|
}
|
|
|
|
int32_t doTranslate(SParseContext* pParseCxt, SQuery* pQuery) {
|
|
STranslateContext cxt = {
|
|
.pParseCxt = pParseCxt,
|
|
.errCode = TSDB_CODE_SUCCESS,
|
|
.msgBuf = { .buf = pParseCxt->pMsg, .len = pParseCxt->msgLen },
|
|
.pNsLevel = taosArrayInit(TARRAY_MIN_SIZE, POINTER_BYTES),
|
|
.currLevel = 0,
|
|
.currClause = 0
|
|
};
|
|
int32_t code = fmFuncMgtInit();
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = rewriteQuery(&cxt, pQuery);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = translateQuery(&cxt, pQuery->pRoot);
|
|
}
|
|
if (TSDB_CODE_SUCCESS == code) {
|
|
code = setQuery(&cxt, pQuery);
|
|
}
|
|
destroyTranslateContext(&cxt);
|
|
return code;
|
|
}
|