Merge pull request #8808 from taosdata/xiaoping/test_case

[TS-717]<test>: add test case for cachelast

tests/pytest/import_merge/import_update_1.py

@@ -422,7 +422,7 @@ class TDTestCase:
             tdSql.execute('''insert into table_1 values(%d, %d, %d, %d, %d, false, 'binary%s', 'nchar%s', %f, %f, %d)''' 
                         % (self.ts + i, random.randint(-2147483647, 2147483647), 
                         random.randint(-9223372036854775807, 9223372036854775807), random.randint(-32767, 32767),
-                        random.randint(-127, 127), random.randint(-100, 100), random.randint(-10000, 10000), 
+                        random.randint(-127, 127), random.randint(-99, 99), random.randint(-9999, 9999), 
                         random.uniform(-100000,100000), random.uniform(-1000000000,1000000000), self.ts + i))
 
         tdLog.info("========== regular_table ==========") 

tests/pytest/query/select_last_crash.py

@@ -16,7 +16,8 @@ import taos
 from util.log import *
 from util.cases import *
 from util.sql import *
-
+from util.dnodes import *
+import random
 
 class TDTestCase:
     def init(self, conn, logSql):
@@ -41,6 +42,32 @@ class TDTestCase:
 
         tdSql.query("select last(*) from st")
         tdSql.checkRows(1)
+
+        # TS-717
+        tdLog.info("case for TS-717")
+        cachelast_values = [0, 1, 3]
+
+        for value in cachelast_values:
+            tdLog.info("case for cachelast value: %d" % value)
+            tdSql.execute("drop database if exists db")
+            tdLog.sleep(1)
+            tdSql.execute("create database db cachelast %d" % value)
+            tdSql.execute("use db")
+            tdSql.execute("create table stb(ts timestamp, c1 int, c2 binary(20), c3 binary(5)) tags(t1 int)")
+
+            sql = "insert into t1 using stb tags(1) (ts, c1, c2) values"
+            for i in range(self.rowNum):
+                sql += "(%d, %d, 'test')" % (self.ts + i, random.randint(1,100))
+            tdSql.execute(sql)
+
+            tdSql.query("select * from stb")
+            tdSql.checkRows(self.rowNum)
+
+            tdDnodes.stop(1)
+            tdDnodes.start(1)
+
+            tdSql.query("select * from stb")
+            tdSql.checkRows(self.rowNum)
         
     def stop(self):
         tdSql.close()