mixed_blocks.sim 3.1 KB
Newer Older
S
slguan 已提交
1
system sh/stop_dnodes.sh
S
slguan 已提交
2 3

system sh/deploy.sh -n dnode1 -i 1
S
slguan 已提交
4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144
system sh/cfg.sh -n dnode1 -c commitLog -v 0
system sh/exec.sh -n dnode1 -s start

sleep 3000
sql connect

$dbPrefix = mb_db
$tbPrefix = mb_tb
$stbPrefix = mb_stb
$tbNum = 10
$ts0 = 1537146000000
$delta = 1000
print ========== mixed_blocks.sim
$i = 0
$db = $dbPrefix . $i
$stb = $stbPrefix . $i

sql drop database if exists $db
$paramRows = 200
$rowNum = $paramRows * 4
$rowNum = $rowNum / 5
sql create database $db rows $paramRows tables 4
print ====== create tables
sql use $db
sql create table $stb (ts timestamp, c1 int, c2 bigint, c3 float, c4 double, c5 bool, c6 binary(10), c7 nchar(10)) tags(t1 int)

$i = 0
$ts = $ts0
$tb1 = $tbPrefix . 1
$tb2 = $tbPrefix . 2
sql create table $tb1 using $stb tags( 1 )
sql create table $tb2 using $stb tags( 2 )

$tb1 = $tbPrefix . 1
$tb2 = $tbPrefix . 2
$x = 0
print rowNum = $rowNum
while $x < $rowNum
  $xs = $x * $delta
  $ts = $ts0 + $xs
  $c = $x / 10
  $c = $c * 10
  $c = $x - $c
  $binary = 'binary . $c
  $binary = $binary . '
  $nchar = 'nchar . $c
  $nchar = $nchar . '
  $c = 0 - $x
  sql insert into $tb1 values ( $ts , $x , $x , $x , $x , true, $binary , $nchar ) 
  sql insert into $tb2 values ( $ts , $c , $c , $c , $c , true, $binary , $nchar ) 
  $x = $x + 1
endw 
print ====== tables created
sql show databases

print ================== restart server to commit data into disk
system sh/exec.sh -n dnode1 -s stop -x SIGINT
sleep 2000
system sh/exec.sh -n dnode1 -s start
print ================== server restart completed

$rowNum = $rowNum * 2
while $x < $rowNum
  $xs = $x * $delta
  $ts = $ts0 + $xs
  $c = $x / 10
  $c = $c * 10
  $c = $x - $c
  $binary = 'binary . $c
  $binary = $binary . '
  $nchar = 'nchar . $c
  $nchar = $nchar . '
  $c = 0 - $x
  sql insert into $tb1 values ( $ts , $x , $x , $x , $x , true, $binary , $nchar ) 
  sql insert into $tb2 values ( $ts , $c , $c , $c , $c , true, $binary , $nchar ) 
  $x = $x + 1
endw 

#### query a STable and using where clause to filter out all the data from tb2 and make the query only return first/last of tb1
sql select first(ts,c1), last(ts,c1), spread(c1) from $stb where c1 > 0 group by t1
if $rows != 1 then
  return -1
endi
if $data00 != @18-09-17 09:00:01.000@ then
  return -1
endi
if $data01 != 1 then
  return -1
endi
if $data02 != @18-09-17 09:05:19.000@ then
  return -1
endi
if $data03 != 319 then
  return -1
endi
if $data04 != 318.000000000 then
  return -1
endi
if $data05 != 1 then
  return -1
endi

sql select max(c1), min(c1), sum(c1), avg(c1), count(c1) from $stb where c1 > 0 group by t1
if $rows != 1 then
  return -1
endi
if $data00 != 319 then
  return -1
endi
if $data01 != 1 then
  return -1
endi
if $data02 != 51040 then
  return -1
endi
if $data03 != 160.000000000 then
  return -1
endi
if $data04 != 319 then
  return -1
endi
if $data05 != 1 then
  return -1
endi

sql select first(ts,c1), last(ts,c1) from $tb1 where c1 > 0
if $rows != 1 then
  return -1
endi
if $data00 != @18-09-17 09:00:01.000@ then
  return -1
endi
if $data01 != 1 then
  return -1
endi
if $data02 != @18-09-17 09:05:19.000@ then
  return -1
endi
if $data03 != 319 then
  return -1
endi