commit
0399398036
|
@ -986,14 +986,16 @@ static int32_t tscCheckIfCreateTable(char **sqlstr, SSqlObj *pSql) {
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
int validateTableName(char *tblName, int len) {
|
int validateTableName(char *tblName, int len, SSQLToken* psTblToken) {
|
||||||
char buf[TSDB_TABLE_ID_LEN] = {0};
|
char buf[TSDB_TABLE_ID_LEN] = {0};
|
||||||
tstrncpy(buf, tblName, sizeof(buf));
|
tstrncpy(buf, tblName, sizeof(buf));
|
||||||
|
|
||||||
SSQLToken token = {.n = len, .type = TK_ID, .z = buf};
|
psTblToken->n = len;
|
||||||
tSQLGetToken(buf, &token.type);
|
psTblToken->type = TK_ID;
|
||||||
|
psTblToken->z = buf;
|
||||||
|
tSQLGetToken(buf, &psTblToken->type);
|
||||||
|
|
||||||
return tscValidateName(&token);
|
return tscValidateName(psTblToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int32_t validateDataSource(SSqlCmd *pCmd, int8_t type, const char *sql) {
|
static int32_t validateDataSource(SSqlCmd *pCmd, int8_t type, const char *sql) {
|
||||||
|
@ -1077,14 +1079,14 @@ int tsParseInsertSql(SSqlObj *pSql) {
|
||||||
}
|
}
|
||||||
|
|
||||||
pCmd->curSql = sToken.z;
|
pCmd->curSql = sToken.z;
|
||||||
|
SSQLToken sTblToken;
|
||||||
// Check if the table name available or not
|
// Check if the table name available or not
|
||||||
if (validateTableName(sToken.z, sToken.n) != TSDB_CODE_SUCCESS) {
|
if (validateTableName(sToken.z, sToken.n, &sTblToken) != TSDB_CODE_SUCCESS) {
|
||||||
code = tscInvalidSQLErrMsg(pCmd->payload, "table name invalid", sToken.z);
|
code = tscInvalidSQLErrMsg(pCmd->payload, "table name invalid", sToken.z);
|
||||||
goto _error;
|
goto _error;
|
||||||
}
|
}
|
||||||
|
|
||||||
if ((code = tscSetTableFullName(pTableMetaInfo, &sToken, pSql)) != TSDB_CODE_SUCCESS) {
|
if ((code = tscSetTableFullName(pTableMetaInfo, &sTblToken, pSql)) != TSDB_CODE_SUCCESS) {
|
||||||
goto _error;
|
goto _error;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue