Merge pull request #6345 from taosdata/hotfix/TD-4494
[TD-4494]add keep value check
This commit is contained in:
commit
e2b8212029
|
@ -5648,11 +5648,17 @@ static int32_t setKeepOption(SSqlCmd* pCmd, SCreateDbMsg* pMsg, SCreateDbInfo* p
|
||||||
tVariantListItem* p0 = taosArrayGet(pKeep, 0);
|
tVariantListItem* p0 = taosArrayGet(pKeep, 0);
|
||||||
switch (s) {
|
switch (s) {
|
||||||
case 1: {
|
case 1: {
|
||||||
|
if ((int32_t)p0->pVar.i64 <= 0) {
|
||||||
|
return invalidSqlErrMsg(tscGetErrorMsgPayload(pCmd), msg);
|
||||||
|
}
|
||||||
pMsg->daysToKeep = htonl((int32_t)p0->pVar.i64);
|
pMsg->daysToKeep = htonl((int32_t)p0->pVar.i64);
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
case 2: {
|
case 2: {
|
||||||
tVariantListItem* p1 = taosArrayGet(pKeep, 1);
|
tVariantListItem* p1 = taosArrayGet(pKeep, 1);
|
||||||
|
if ((int32_t)p0->pVar.i64 <= 0 || (int32_t)p1->pVar.i64 <= 0) {
|
||||||
|
return invalidSqlErrMsg(tscGetErrorMsgPayload(pCmd), msg);
|
||||||
|
}
|
||||||
pMsg->daysToKeep = htonl((int32_t)p0->pVar.i64);
|
pMsg->daysToKeep = htonl((int32_t)p0->pVar.i64);
|
||||||
pMsg->daysToKeep1 = htonl((int32_t)p1->pVar.i64);
|
pMsg->daysToKeep1 = htonl((int32_t)p1->pVar.i64);
|
||||||
break;
|
break;
|
||||||
|
@ -5661,6 +5667,10 @@ static int32_t setKeepOption(SSqlCmd* pCmd, SCreateDbMsg* pMsg, SCreateDbInfo* p
|
||||||
tVariantListItem* p1 = taosArrayGet(pKeep, 1);
|
tVariantListItem* p1 = taosArrayGet(pKeep, 1);
|
||||||
tVariantListItem* p2 = taosArrayGet(pKeep, 2);
|
tVariantListItem* p2 = taosArrayGet(pKeep, 2);
|
||||||
|
|
||||||
|
if ((int32_t)p0->pVar.i64 <= 0 || (int32_t)p1->pVar.i64 <= 0 || (int32_t)p2->pVar.i64 <= 0) {
|
||||||
|
return invalidSqlErrMsg(tscGetErrorMsgPayload(pCmd), msg);
|
||||||
|
}
|
||||||
|
|
||||||
pMsg->daysToKeep = htonl((int32_t)p0->pVar.i64);
|
pMsg->daysToKeep = htonl((int32_t)p0->pVar.i64);
|
||||||
pMsg->daysToKeep1 = htonl((int32_t)p1->pVar.i64);
|
pMsg->daysToKeep1 = htonl((int32_t)p1->pVar.i64);
|
||||||
pMsg->daysToKeep2 = htonl((int32_t)p2->pVar.i64);
|
pMsg->daysToKeep2 = htonl((int32_t)p2->pVar.i64);
|
||||||
|
|
|
@ -129,8 +129,8 @@ sql alter database db keep 20
|
||||||
sql_error alter database db keep 10
|
sql_error alter database db keep 10
|
||||||
sql_error alter database db keep 9
|
sql_error alter database db keep 9
|
||||||
sql_error alter database db keep 1
|
sql_error alter database db keep 1
|
||||||
sql alter database db keep 0
|
sql_error alter database db keep 0
|
||||||
sql alter database db keep -1
|
sql_error alter database db keep -1
|
||||||
sql_error alter database db keep 365001
|
sql_error alter database db keep 365001
|
||||||
|
|
||||||
print ============== step cache
|
print ============== step cache
|
||||||
|
|
|
@ -385,8 +385,8 @@ sql alter database db keep 20
|
||||||
sql_error alter database db keep 10
|
sql_error alter database db keep 10
|
||||||
sql_error alter database db keep 9
|
sql_error alter database db keep 9
|
||||||
sql_error alter database db keep 1
|
sql_error alter database db keep 1
|
||||||
sql alter database db keep 0
|
sql_error alter database db keep 0
|
||||||
sql alter database db keep -1
|
sql_error alter database db keep -1
|
||||||
sql_error alter database db keep 365001
|
sql_error alter database db keep 365001
|
||||||
|
|
||||||
sql_error alter topic db keep 40
|
sql_error alter topic db keep 40
|
||||||
|
|
Loading…
Reference in New Issue