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

[td-4780]<fix>: disable the update of fsync and wal parameters after the database created.

This commit is contained in:
Haojun Liao 2021-07-13 10:27:36 +08:00
parent 128c1bc5c3
commit 2c30118c13
3 changed files with 713 additions and 727 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -7809,11 +7809,9 @@ 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) {
@ -7831,16 +7829,6 @@ static STableMeta* extractTempTableMetaFromSubquery(SQueryInfo* pUpstream) {
info->rowSize += meta->schema[n].bytes; info->rowSize += meta->schema[n].bytes;
n += 1; 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;
}
}
} }
return meta; return meta;

3
src/query/inc/sql.y
View File

@ -303,10 +303,11 @@ alter_db_optr(Y) ::= alter_db_optr(Z) quorum(X). { Y = Z; Y.quorum = strtol
alter_db_optr(Y) ::= alter_db_optr(Z) keep(X). { Y = Z; Y.keep = X; } alter_db_optr(Y) ::= alter_db_optr(Z) keep(X). { Y = Z; Y.keep = X; }
alter_db_optr(Y) ::= alter_db_optr(Z) blocks(X). { Y = Z; Y.numOfBlocks = strtol(X.z, NULL, 10); } alter_db_optr(Y) ::= alter_db_optr(Z) blocks(X). { Y = Z; Y.numOfBlocks = strtol(X.z, NULL, 10); }
alter_db_optr(Y) ::= alter_db_optr(Z) comp(X). { Y = Z; Y.compressionLevel = strtol(X.z, NULL, 10); } alter_db_optr(Y) ::= alter_db_optr(Z) comp(X). { Y = Z; Y.compressionLevel = strtol(X.z, NULL, 10); }
alter_db_optr(Y) ::= alter_db_optr(Z) fsync(X). { Y = Z; Y.fsyncPeriod = strtol(X.z, NULL, 10); }
alter_db_optr(Y) ::= alter_db_optr(Z) update(X). { Y = Z; Y.update = strtol(X.z, NULL, 10); } alter_db_optr(Y) ::= alter_db_optr(Z) update(X). { Y = Z; Y.update = strtol(X.z, NULL, 10); }
alter_db_optr(Y) ::= alter_db_optr(Z) cachelast(X). { Y = Z; Y.cachelast = strtol(X.z, NULL, 10); } alter_db_optr(Y) ::= alter_db_optr(Z) cachelast(X). { Y = Z; Y.cachelast = strtol(X.z, NULL, 10); }
// dynamically update the following two parameters are not allowed.
//alter_db_optr(Y) ::= alter_db_optr(Z) fsync(X). { Y = Z; Y.fsyncPeriod = strtol(X.z, NULL, 10); }
//alter_db_optr(Y) ::= alter_db_optr(Z) wal(X). { Y = Z; Y.walLevel = strtol(X.z, NULL, 10); } not support yet //alter_db_optr(Y) ::= alter_db_optr(Z) wal(X). { Y = Z; Y.walLevel = strtol(X.z, NULL, 10); } not support yet
%type alter_topic_optr {SCreateDbInfo} %type alter_topic_optr {SCreateDbInfo}

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

File diff suppressed because it is too large Load Diff