From a5501f30461b19be30f15a47c3fa82f8f6f3cec9 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Tue, 29 Oct 2024 10:07:08 +0800
Subject: [PATCH] test: add test cases.

---
 tests/script/tsim/stream/snodeCheck.sim | 64 +++++++++++++++++++++++++
 1 file changed, 64 insertions(+)
 create mode 100644 tests/script/tsim/stream/snodeCheck.sim

diff --git a/tests/script/tsim/stream/snodeCheck.sim b/tests/script/tsim/stream/snodeCheck.sim
new file mode 100644
index 0000000000..f4ab8c8124
--- /dev/null
+++ b/tests/script/tsim/stream/snodeCheck.sim
@@ -0,0 +1,64 @@
+system sh/stop_dnodes.sh
+system sh/deploy.sh -n dnode1 -i 1
+system sh/deploy.sh -n dnode2 -i 2
+system sh/deploy.sh -n dnode3 -i 3
+
+system sh/cfg.sh -n dnode1 -c supportVnodes -v 4
+system sh/cfg.sh -n dnode2 -c supportVnodes -v 4
+system sh/cfg.sh -n dnode3 -c supportVnodes -v 4
+
+print ========== step1
+system sh/exec.sh -n dnode1 -s start
+sql connect
+
+print ========== step2
+sql create dnode $hostname port 7200
+system sh/exec.sh -n dnode2 -s start
+
+sql create dnode $hostname port 7300
+system sh/exec.sh -n dnode3 -s start
+
+$x = 0
+step2:
+	$x = $x + 1
+	sleep 1000
+	if $x == 10 then
+	  print ====> dnode not ready!
+		return -1
+	endi
+sql select * from information_schema.ins_dnodes
+print ===> $data00 $data01 $data02 $data03 $data04 $data05
+print ===> $data10 $data11 $data12 $data13 $data14 $data15
+if $rows != 3 then
+  return -1
+endi
+if $data(1)[4] != ready then
+  goto step2
+endi
+if $data(2)[4] != ready then
+  goto step2
+endi
+
+print ========== step3
+sql drop database if exists test;
+sql create database if not exists test vgroups 4 replica 3 precision "ms" ;
+sql use test;
+
+sql create table test.test (ts timestamp, c1 int) tags (t1 int) ;
+
+print create stream without snode existing
+sql_error create stream stream_t1 trigger at_once into str_dst as select count(*) from test interval(20s);
+
+print create snode
+sql create snode on dnode 1;
+
+sql create stream stream_t1 trigger at_once into str_dst as select count(*) from test interval(20s);
+
+print drop snode and then create stream
+sql drop snode on dnode 1;
+
+sql_error create stream stream_t2 trigger at_once into str_dst as select count(*) from test interval(20s);
+
+system sh/exec.sh -n dnode1 -s stop  -x SIGINT
+system sh/exec.sh -n dnode2 -s stop  -x SIGINT
+system sh/exec.sh -n dnode3 -s stop  -x SIGINT