提交 77cf9cec 编写于 作者: P Ping Xiao

[TD-2310]<test> add test case for stream dest table

上级 d3ed3cda
...@@ -88,6 +88,10 @@ class TDTestCase: ...@@ -88,6 +88,10 @@ class TDTestCase:
except Exception as e: except Exception as e:
tdLog.info(repr(e)) tdLog.info(repr(e))
tdSql.query("show streams")
tdSql.checkRows(1)
tdSql.checkData(0, 2, 's0')
tdLog.info("===== step8 =====") tdLog.info("===== step8 =====")
tdSql.query( tdSql.query(
"select count(*), count(col1), count(col2) from stb0 interval(1d)") "select count(*), count(col1), count(col2) from stb0 interval(1d)")
...@@ -142,6 +146,12 @@ class TDTestCase: ...@@ -142,6 +146,12 @@ class TDTestCase:
except Exception as e: except Exception as e:
tdLog.info(repr(e)) tdLog.info(repr(e))
tdSql.query("show streams")
tdSql.checkRows(2)
tdSql.checkData(0, 2, 's1')
tdSql.checkData(1, 2, 's0')
def stop(self): def stop(self):
tdSql.close() tdSql.close()
tdLog.success("%s successfully executed" % __file__) tdLog.success("%s successfully executed" % __file__)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册