xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

chore: allow source table with primary key

This commit is contained in:
kailixu 2024-04-03 09:39:58 +08:00
parent cc660de9d0
commit 62ab1b1c41
1 changed files with 0 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/libs/parser/src/parTranslater.c
View File

@ -5088,7 +5088,6 @@ static int32_t translateInsertProject(STranslateContext* pCxt, SInsertStmt* pIns
SNode* pPrimaryKeyExpr = NULL; SNode* pPrimaryKeyExpr = NULL;
SNode* pBoundCol = NULL; SNode* pBoundCol = NULL;
SNode* pProj = NULL; SNode* pProj = NULL;
int16_t numOfSourcePKs = 0;
int16_t numOfTargetPKs = 0; int16_t numOfTargetPKs = 0;
int16_t numOfBoundPKs = 0; int16_t numOfBoundPKs = 0;
FORBOTH(pBoundCol, pInsert->pCols, pProj, pProjects) { FORBOTH(pBoundCol, pInsert->pCols, pProj, pProjects) {
@ -5107,7 +5106,6 @@ static int32_t translateInsertProject(STranslateContext* pCxt, SInsertStmt* pIns
if (PRIMARYKEY_TIMESTAMP_COL_ID == pCol->colId) { if (PRIMARYKEY_TIMESTAMP_COL_ID == pCol->colId) {
pPrimaryKeyExpr = (SNode*)pExpr; pPrimaryKeyExpr = (SNode*)pExpr;
numOfTargetPKs = pCol->numOfPKs; numOfTargetPKs = pCol->numOfPKs;
numOfSourcePKs = ((SColumnNode*)pProj)->numOfPKs;
} }
if (pCol->isPk) ++numOfBoundPKs; if (pCol->isPk) ++numOfBoundPKs;
} }
@ -5121,12 +5119,6 @@ static int32_t translateInsertProject(STranslateContext* pCxt, SInsertStmt* pIns
return generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_SYNTAX_ERROR, "Primary key column should not be none"); return generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_SYNTAX_ERROR, "Primary key column should not be none");
} }
if (numOfTargetPKs < numOfSourcePKs) {
return generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_SYNTAX_ERROR,
"Target table has less primary keys:%" PRIi16 " than source:%" PRIi16,
numOfTargetPKs, numOfSourcePKs);
}
return addOrderByPrimaryKeyToQuery(pCxt, pPrimaryKeyExpr, pInsert->pQuery); return addOrderByPrimaryKeyToQuery(pCxt, pPrimaryKeyExpr, pInsert->pQuery);
} }