rsmaPersistenceRecovery.sim

system sh/stop_dnodes.sh
system sh/deploy.sh -n dnode1 -i 1
system sh/exec.sh -n dnode1 -s start
sleep 50
sql connect

#todo wait for streamState checkpoint
return 1

print =============== create database with retentions
sql create database d0 retentions 5s:7d,5m:21d,15m:365d;
sql use d0

print =============== create super table and register rsma
sql create table if not exists stb (ts timestamp, c1 int, c2 float) tags (city binary(20),district binary(20)) rollup(max) max_delay 5s,5s watermark 2s,3s;
sql create table if not exists stb1 (ts timestamp, c1 int, c2 float) tags (city binary(20),district binary(20)) rollup(max) max_delay 5s,5s watermark 2s,3s;

sql show stables
if $rows != 2 then
  return -1
endi

print =============== create child table
sql create table ct1 using stb tags("BeiJing", "ChaoYang") ct_1 using stb1 tags("BeiJing", "ChaoYang");

sql show tables
if $rows != 2 then
  return -1
endi

print =============== insert data and trigger rollup
sql insert into ct1 values(now, 10, 10.0);
sql insert into ct1 values(now+1s, 1, 1.0);
sql insert into ct1 values(now+2s, 100, 100.0);
sql insert into ct_1 values(now, 10, 10.0);
sql insert into ct_1 values(now+1s, 1, 1.0);
sql insert into ct_1 values(now+2s, 100, 100.0);

print =============== wait maxdelay 5+2 seconds for results
sleep 7000

print =============== select * from retention level 2 from memory
sql select * from ct1;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 2 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 2 file result $data01 != 100 or 10
  return -1
  endi
endi

sql select * from ct_1;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 2 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 2 file result $data01 != 100 or 10
  return -1
  endi
endi

print =============== select * from retention level 1 from memory
sql select * from ct1 where ts > now-8d;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 1 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 1 file result $data01 != 100 or 10
  return -1
  endi
endi

sql select * from ct_1 where ts > now-8d;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 1 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 1 file result $data01 != 100 or 10
  return -1
  endi
endi

print =============== select * from retention level 0 from memory
sql select * from ct1 where ts > now-3d;
print $data00 $data01 $data02
print $data10 $data11 $data12
print $data20 $data21 $data22

if $rows < 1 then
  print retention level 0 file rows $rows < 1
  return -1
endi

if $data01 != 10 then
  print retention level 0 file result $data01 != 10
  return -1
endi

sql select * from ct_1 where ts > now-3d;
print $data00 $data01 $data02
print $data10 $data11 $data12
print $data20 $data21 $data22

if $rows < 1 then
  print retention level 0 file rows $rows < 1
  return -1
endi

if $data01 != 10 then
  print retention level 0 file result $data01 != 10
  return -1
endi

#===================================================================
system sh/exec.sh -n dnode1 -s stop -x SIGINT
system sh/exec.sh -n dnode1 -s start
print =============== wait maxdelay 5+2 seconds for results after reboot
sleep 7000

print =============== select * from retention level 2 from memory after reboot
sql select * from ct1;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 2 file rows $rows > 2
  return -1
endi


if $data01 != 100 then
  if $data01 != 10 then
    print retention level 2 file result $data01 != 100 or 10
  return -1
  endi
endi

sql select * from ct_1;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 2 file rows $rows > 2
  return -1
endi


if $data01 != 100 then
  if $data01 != 10 then
    print retention level 2 file result $data01 != 100 or 10
  return -1
  endi
endi

print =============== select * from retention level 1 from memory after reboot
sql select * from ct1 where ts > now-8d;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 1 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 1 file result $data01 != 100 or 10
  return -1
  endi
endi

sql select * from ct_1 where ts > now-8d;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 1 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 1 file result $data01 != 100 or 10
  return -1
  endi
endi

print =============== select * from retention level 0 from memory after reboot
sql select * from ct1 where ts > now-3d;
print $data00 $data01 $data02
print $data10 $data11 $data12
print $data20 $data21 $data22

if $rows < 1 then
  print retention level 0 file rows $rows < 1
  return -1
endi

if $data01 != 10 then
  print retention level 0 file result $data01 != 10
  return -1
endi

sql select * from ct_1 where ts > now-3d;
print $data00 $data01 $data02
print $data10 $data11 $data12
print $data20 $data21 $data22

if $rows < 1 then
  print retention level 0 file rows $rows < 1
  return -1
endi

if $data01 != 10 then
  print retention level 0 file result $data01 != 10
  return -1
endi


#==================== flush database to trigger commit data to file
sql flush database d0;
system sh/exec.sh -n dnode1 -s stop -x SIGINT
system sh/exec.sh -n dnode1 -s start

print =============== select * from retention level 2 from file
sql select * from ct1;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 2 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 2 file result $data01 != 100 or 10
  return -1
  endi
endi

sql select * from ct_1;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 2 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 2 file result $data01 != 100 or 10
  return -1
  endi
endi

print =============== select * from retention level 1 from file
sql select * from ct1 where ts > now-8d;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 1 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 1 file result $data01 != 100 or 10
  return -1
  endi
endi

sql select * from ct_1 where ts > now-8d;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 1 file rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 1 file result $data01 != 100 or 10
  return -1
  endi
endi

print =============== select * from retention level 0 from file
sql select * from ct1 where ts > now-3d;
print $data00 $data01 $data02
print $data10 $data11 $data12
print $data20 $data21 $data22
if $rows < 1 then
  print retention level 0 file rows $rows < 1
  return -1
endi

if $data01 != 10 then
  print retention level 0 file result $data01 != 10
  return -1
endi

sql select * from ct_1 where ts > now-3d;
print $data00 $data01 $data02
print $data10 $data11 $data12
print $data20 $data21 $data22
if $rows < 1 then
  print retention level 0 file rows $rows < 1
  return -1
endi

if $data01 != 10 then
  print retention level 0 file result $data01 != 10
  return -1
endi

print =============== insert after rsma qtaskinfo recovery
sql insert into ct1 values(now, 50, 500.0);
sql insert into ct1 values(now+1s, 40, 40.0);
sql insert into ct_1 values(now, 50, 500.0);
sql insert into ct_1 values(now+1s, 40, 40.0);

print =============== wait maxdelay 5+2 seconds for results
sleep 7000

print =============== select * from retention level 2 from file and memory after rsma qtaskinfo recovery
sql select * from ct1;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 2 file/mem rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 2 file/mem result $data01 != 100 or 10
  return -1
  endi
endi

if $data02 != 500.00000 then
  if $data02 != 100.00000 then
    if $data02 != 10.00000 then
    print retention level 1 file/mem result $data02 != 500.00000 or 100.00000 or 10.00000
    return -1
    endi
  endi
endi

sql select * from ct_1;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 2 file/mem rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 2 file/mem result $data01 != 100 or 10
  return -1
  endi
endi

if $data02 != 500.00000 then
  if $data02 != 100.00000 then
    if $data02 != 10.00000 then
    print retention level 1 file/mem result $data02 != 500.00000 or 100.00000 or 10.00000
    return -1
    endi
  endi
endi

print =============== select * from retention level 1 from file and memory after rsma qtaskinfo recovery
sql select * from ct1 where ts > now-8d;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 1 file/mem rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 1 file/mem result $data01 != 100 or 10
  return -1
  endi
endi

if $data02 != 500.00000 then
  if $data02 != 100.00000 then
    if $data02 != 10.00000 then
    print retention level 1 file/mem result $data02 != 500.00000 or 100.00000 or 10.00000
    return -1
    endi
  endi
endi

sql select * from ct_1 where ts > now-8d;
print $data00 $data01 $data02
print $data10 $data11 $data12
if $rows > 2 then
  print retention level 1 file/mem rows $rows > 2
  return -1
endi

if $data01 != 100 then
  if $data01 != 10 then
    print retention level 1 file/mem result $data01 != 100 or 10
  return -1
  endi
endi

if $data02 != 500.00000 then
  if $data02 != 100.00000 then
    if $data02 != 10.00000 then
    print retention level 1 file/mem result $data02 != 500.00000 or 100.00000 or 10.00000
    return -1
    endi
  endi
endi


print =============== select * from retention level 0 from file and memory after rsma qtaskinfo recovery
sql select * from ct1 where ts > now-3d;
print $data00 $data01 $data02
print $data10 $data11 $data12
print $data20 $data21 $data22
print $data30 $data31 $data32
print $data40 $data41 $data42

if $rows < 1 then
  print retention level 0 file/mem rows $rows < 1
  return -1
endi

if $data01 != 10 then
  print retention level 0 file/mem result $data01 != 10
  return -1
endi

if $data11 != 1 then
  print retention level 0 file/mem result $data11 != 1
  return -1
endi

if $data21 != 100 then
  print retention level 0 file/mem result $data21 != 100
  return -1
endi

if $data31 != 50 then
  print retention level 0 file/mem result $data31 != 50
  return -1
endi

if $data32 != 500.00000 then
  print retention level 0 file/mem result $data32 != 500.00000
  return -1
endi


if $data41 != 40 then
  print retention level 0 file/mem result $data41 != 40
  return -1
endi

if $data42 != 40.00000 then
  print retention level 0 file/mem result $data42 != 40.00000
  return -1
endi

sql select * from ct_1 where ts > now-3d;
print $data00 $data01 $data02
print $data10 $data11 $data12
print $data20 $data21 $data22
print $data30 $data31 $data32
print $data40 $data41 $data42

if $rows < 1 then
  print retention level 0 file/mem rows $rows < 1
  return -1
endi

if $data01 != 10 then
  print retention level 0 file/mem result $data01 != 10
  return -1
endi

if $data11 != 1 then
  print retention level 0 file/mem result $data11 != 1
  return -1
endi

if $data21 != 100 then
  print retention level 0 file/mem result $data21 != 100
  return -1
endi

if $data31 != 50 then
  print retention level 0 file/mem result $data31 != 50
  return -1
endi

if $data32 != 500.00000 then
  print retention level 0 file/mem result $data32 != 500.00000
  return -1
endi


if $data41 != 40 then
  print retention level 0 file/mem result $data41 != 40
  return -1
endi

if $data42 != 40.00000 then
  print retention level 0 file/mem result $data42 != 40.00000
  return -1
endi

print =============== drop stb1
sql drop table stb1;
sql flush database d0;

print =============== select * from retention level 0 from file and memory after rsma qtaskinfo recovery
sql_error select * from ct_1 where ts > now-3d;
sql_error select * from ct_1 where ts > now-8d;
sql_error select * from ct_1;

system sh/exec.sh -n dnode1 -s stop -x SIGINT