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

[td-225]disable alter wal level after create databases.

This commit is contained in:
Haojun Liao 2021-07-12 13:47:07 +08:00
parent cdc85ae820
commit 128c1bc5c3
2 changed files with 736 additions and 721 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/client/src/tscSQLParser.c
View File

@ -7809,19 +7809,37 @@ static STableMeta* extractTempTableMetaFromSubquery(SQueryInfo* pUpstream) {
meta->tableType = TSDB_TEMP_TABLE; meta->tableType = TSDB_TEMP_TABLE;
STableComInfo *info = &meta->tableInfo; STableComInfo *info = &meta->tableInfo;
info->numOfColumns = numOfColumns;
// todo : row size, numOfTags, numOfCols, tag info
// info->numOfColumns = numOfColumns;
info->precision = pUpstreamTableMetaInfo->pTableMeta->tableInfo.precision; info->precision = pUpstreamTableMetaInfo->pTableMeta->tableInfo.precision;
info->numOfTags = 0; // info->numOfTags = 0;
int32_t n = 0; int32_t n = 0;
for(int32_t i = 0; i < numOfColumns; ++i) { for(int32_t i = 0; i < numOfColumns; ++i) {
SInternalField* pField = tscFieldInfoGetInternalField(&pUpstream->fieldsInfo, i); SInternalField* pField = tscFieldInfoGetInternalField(&pUpstream->fieldsInfo, i);
if (pField->visible) { if (!pField->visible) {
meta->schema[n].bytes = pField->field.bytes; continue;
meta->schema[n].type = pField->field.type; }
meta->schema[n].colId = pField->pExpr->base.resColId;
tstrncpy(meta->schema[n].name, pField->pExpr->base.aliasName, TSDB_COL_NAME_LEN); meta->schema[n].bytes = pField->field.bytes;
n += 1; meta->schema[n].type = pField->field.type;
SExprInfo* pExpr = pField->pExpr;
meta->schema[n].colId = pExpr->base.resColId;
tstrncpy(meta->schema[n].name, pField->pExpr->base.aliasName, TSDB_COL_NAME_LEN);
info->rowSize += meta->schema[n].bytes;
n += 1;
if (pExpr->pExpr != NULL) {
info->numOfColumns += 1;
} else {
if (TSDB_COL_IS_TAG(pExpr->base.colInfo.flag)) {
info->numOfTags += 1;
} else {
info->numOfColumns += 1;
}
} }
} }

1423
src/query/src/sql.c
View File

File diff suppressed because it is too large Load Diff