From d3a9429c3b5ad4c69bbdec2e305b824d511d80ea Mon Sep 17 00:00:00 2001
From: slzhou <shenglian_zhou@163.com>
Date: Fri, 4 Aug 2023 14:17:18 +0800
Subject: [PATCH] fix: add test case

---
 tests/parallel_test/cases.task      |  1 +
 tests/script/tsim/query/join_pk.sim | 42 +++++++++++++++++++++++++++++
 2 files changed, 43 insertions(+)
 create mode 100644 tests/script/tsim/query/join_pk.sim

diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task
index 89572d1c06..1883a50e59 100644
--- a/tests/parallel_test/cases.task
+++ b/tests/parallel_test/cases.task
@@ -954,6 +954,7 @@
 ,,n,script,./test.sh -f tsim/query/udfpy.sim
 ,,y,script,./test.sh -f tsim/query/udf_with_const.sim
 ,,y,script,./test.sh -f tsim/query/join_interval.sim
+,,y,script,./test.sh -f tsim/query/join_pk.sim
 ,,y,script,./test.sh -f tsim/query/unionall_as_table.sim
 ,,y,script,./test.sh -f tsim/query/multi_order_by.sim
 ,,y,script,./test.sh -f tsim/query/sys_tbname.sim
diff --git a/tests/script/tsim/query/join_pk.sim b/tests/script/tsim/query/join_pk.sim
new file mode 100644
index 0000000000..66bb20da24
--- /dev/null
+++ b/tests/script/tsim/query/join_pk.sim
@@ -0,0 +1,42 @@
+system sh/stop_dnodes.sh
+system sh/deploy.sh -n dnode1 -i 1
+system sh/exec.sh -n dnode1 -s start
+sql connect
+
+sql create database test;
+sql use test;
+sql create table st(ts timestamp, f int) tags(t int);
+sql insert into ct1 using st tags(1) values(now, 0)(now+1s, 1)
+sql insert into ct2 using st tags(2) values(now+2s, 2)(now+3s, 3)
+sql select * from (select _wstart - 1s as ts, count(*) as num1 from st interval(1s)) as t1 inner join (select _wstart as ts, count(*) as num2 from st interval(1s)) as t2 on t1.ts = t2.ts
+
+if $rows != 3 then
+  return -1
+endi
+if $data01 != 1 then 
+  return -1
+endi
+if $data11 != 1 then
+  return -1
+endi
+
+if $data21 != 1 then 
+  return -1
+endi
+if $data03 != 1 then
+  return -1
+endi
+
+if $data13 != 1 then 
+  return -1
+endi
+if $data23 != 1 then
+  return -1
+endi
+sql select * from (select _wstart - 1d as ts, count(*) as num1 from st interval(1s)) as t1 inner join (select _wstart as ts, count(*) as num2 from st interval(1s)) as t2 on t1.ts = t2.ts
+
+sql select * from (select _wstart + 1a as ts, count(*) as num1 from st interval(1s)) as t1 inner join (select _wstart as ts, count(*) as num2 from st interval(1s)) as t2 on t1.ts = t2.ts
+
+sql_error select * from (select _wstart *  3 as ts, count(*) as num1 from st interval(1s)) as t1 inner join (select _wstart as ts, count(*) as num2 from st interval(1s)) as t2 on t1.ts = t2.ts
+#system sh/exec.sh -n dnode1 -s stop -x SIGINT
+