提交 5e4f374c 编写于 作者: S slzhou

fix: add test cases

上级 807b1bbc
...@@ -6612,7 +6612,8 @@ static int32_t validateMaxQueryTimeRange(SSqlObj* pSql, SQueryInfo* pQueryInfo) ...@@ -6612,7 +6612,8 @@ static int32_t validateMaxQueryTimeRange(SSqlObj* pSql, SQueryInfo* pQueryInfo)
STableMetaInfo* pTableMetaInfo = tscGetMetaInfo(pQueryInfo, 0); STableMetaInfo* pTableMetaInfo = tscGetMetaInfo(pQueryInfo, 0);
STableComInfo tinfo = tscGetTableInfo(pTableMetaInfo->pTableMeta); STableComInfo tinfo = tscGetTableInfo(pTableMetaInfo->pTableMeta);
int64_t maxTimeRange = convertTimePrecision(tsMaxQueryTimeRange * 1000, TSDB_TIME_PRECISION_MILLI, tinfo.precision); int64_t maxTimeRange = convertTimePrecision(tsMaxQueryTimeRange * 1000, TSDB_TIME_PRECISION_MILLI, tinfo.precision);
if (pQueryInfo->window.ekey - pQueryInfo->window.skey > maxTimeRange) { uint64_t queryTimeRange = pQueryInfo->window.ekey - pQueryInfo->window.skey;
if (queryTimeRange > maxTimeRange) {
return TSDB_CODE_TSC_EXCEED_QUERY_TIME_RANGE; return TSDB_CODE_TSC_EXCEED_QUERY_TIME_RANGE;
} }
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
......
...@@ -135,8 +135,8 @@ bool tsWriteBatchThreadLocal = false; // if thread local enable, each thre ...@@ -135,8 +135,8 @@ bool tsWriteBatchThreadLocal = false; // if thread local enable, each thre
int32_t tsWriteBatchSize = 0; // suggest: 64 - 512, default 0, 0 means disable batching. int32_t tsWriteBatchSize = 0; // suggest: 64 - 512, default 0, 0 means disable batching.
int32_t tsWriteBatchTimeout = 10; // suggest: 2 - 100 (unit: milliseconds) int32_t tsWriteBatchTimeout = 10; // suggest: 2 - 100 (unit: milliseconds)
// max query time range // max query time range in seconds
// if less than zero, no limits // if less than zero, no limits on query time range
int32_t tsMaxQueryTimeRange = -1; int32_t tsMaxQueryTimeRange = -1;
// the maximum allowed query buffer size during query processing for each data node. // the maximum allowed query buffer size during query processing for each data node.
......
...@@ -573,6 +573,7 @@ ...@@ -573,6 +573,7 @@
10,,script,./test.sh -f general/compute/scalar_pow.sim 10,,script,./test.sh -f general/compute/scalar_pow.sim
9,,docs-examples-test,./test_go.sh 9,,docs-examples-test,./test_go.sh
9,,script,./test.sh -f general/parser/alter1.sim 9,,script,./test.sh -f general/parser/alter1.sim
9,,script,./test.sh -c 'maxQueryTimeRange 3' -f general/parser/max_query_time_range.sim
9,,script,./test.sh -f general/db/delete.sim 9,,script,./test.sh -f general/db/delete.sim
9,,pytest,python3 test.py -f tools/taosdemoTestLimitOffset.py 9,,pytest,python3 test.py -f tools/taosdemoTestLimitOffset.py
9,,develop-test,python3 ./test.py -f 5-taos-tools/taosbenchmark/custom_col_tag.py 9,,develop-test,python3 ./test.py -f 5-taos-tools/taosbenchmark/custom_col_tag.py
......
system sh/stop_dnodes.sh
system sh/deploy.sh -n dnode1 -i 1
system sh/cfg.sh -n dnode1 -c walLevel -v 1
system sh/exec.sh -n dnode1 -s start
sleep 2000
sql connect
print =============== step1
$db = querytimerange
$ts = 1679399468000
sql drop database $db -x step1
step1:
sql create database $db
sql use $db
sql create table t (ts timestamp, f int)
sql insert into t values ( $ts , 1)( $ts + 1s , 2)( $ts + 2s , 3)( $ts + 3s, 4)( $ts + 4s, 5)
sql select * from t where ts >= $ts and ts <= $ts + 3000
sql select * from t where ts > $ts and ts <= $ts + 3001
sql select * from t where ts > $ts and ts < $ts + 3000
sql select * from t where ts > $ts and ts <= $ts + 3000
sql select * from t where ts >= $ts and ts < $ts + 3000
sql select * from t where ts > $ts and ts < $ts + 2000
sql select * from t where ts = $ts + 200
sql select * from t where ts = $ts
sql select * from t where ts > $ts and ts <= $ts + 3001
sql select * from (select * from t where ts > $ts and ts <= $ts + 3001) where ts = $ts + 200
sql_error select * from t
sql_error select * from t where ts > $ts
sql_error select * from t where ts < $ts
sql_error select * from t where ts >= $ts and ts <= $ts + 3001
sql_error select * from t where ts >= $ts and ts <= $ts + 4000
sql_error select * from ( select * from t ) where ts >= $ts and ts <= $ts + 2000
sql_error select * from ( select * from t where ts > $ts and ts < $ts + 3000) where ts > $ts
sql_error select * from ( select * from t where ts > $ts and ts < $ts + 4000) where ts > $ts
print =============== clear
#sql drop database $db
#sql show databases
#if $rows != 0 then
# return -1
#endi
#system sh/exec.sh -n dnode1 -s stop -x SIGINT
...@@ -16,12 +16,15 @@ VALGRIND=0 ...@@ -16,12 +16,15 @@ VALGRIND=0
UNIQUE=0 UNIQUE=0
UNAME_BIN=`which uname` UNAME_BIN=`which uname`
OS_TYPE=`$UNAME_BIN` OS_TYPE=`$UNAME_BIN`
while getopts "f:avu" arg while getopts "f:c:avu" arg
do do
case $arg in case $arg in
f) f)
FILE_NAME=$OPTARG FILE_NAME=$OPTARG
;; ;;
c)
CFG_STR=$OPTARG
;;
a) a)
ASYNC=1 ASYNC=1
;; ;;
...@@ -126,6 +129,7 @@ echo "wal 0" >> $TAOS_CFG ...@@ -126,6 +129,7 @@ echo "wal 0" >> $TAOS_CFG
echo "asyncLog 0" >> $TAOS_CFG echo "asyncLog 0" >> $TAOS_CFG
echo "locale en_US.UTF-8" >> $TAOS_CFG echo "locale en_US.UTF-8" >> $TAOS_CFG
echo "enableCoreFile 1" >> $TAOS_CFG echo "enableCoreFile 1" >> $TAOS_CFG
echo $CFG_STR >> $TAOS_CFG
echo " " >> $TAOS_CFG echo " " >> $TAOS_CFG
ulimit -n 600000 ulimit -n 600000
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册