blob: 4d61757ba203e9a7b6c4dd4534ac661fce4a97e7 (
plain)
1
2
3
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
|
#! /bin/bash
. ../testlib.sh
../zstop.sh
v='-v'
# bulkloader method
meth=0
db_list="hsrc hdst"
kdb_list=`echo $db_list | sed 's/ /,/g'`
#( cd ../..; make -s install )
echo " * create configs * "
# create ticker conf
cat > conf/pgqd.ini <<EOF
[pgqd]
database_list = $kdb_list
logfile = log/pgqd.log
pidfile = pid/pgqd.pid
EOF
# londiste3 configs
for db in $db_list; do
cat > conf/londiste_$db.ini <<EOF
[londiste3]
job_name = londiste_$db
db = dbname=$db
queue_name = replika
logfile = log/%(job_name)s.log
pidfile = pid/%(job_name)s.pid
EOF
done
for db in $db_list; do
cleardb $db
done
clearlogs
set -e
msg "Basic config"
run cat conf/pgqd.ini
run cat conf/londiste_hsrc.ini
msg "Install londiste3 and initialize nodes"
run londiste3 $v conf/londiste_hsrc.ini create-root hsrc 'dbname=hsrc'
run londiste3 $v conf/londiste_hdst.ini create-leaf hdst 'dbname=hdst' --provider='dbname=hsrc'
for db in $db_list; do
run_sql $db "update pgq.queue set queue_ticker_idle_period='5 secs'"
done
msg "Run ticker"
run pgqd -d conf/pgqd.ini
run sleep 5
msg "See topology"
run londiste3 $v conf/londiste_hsrc.ini status
msg "Run londiste3 daemon for each node"
for db in $db_list; do
run londiste3 $v -d conf/londiste_$db.ini worker
done
msg "Create table on root node and fill couple of rows"
run_sql hsrc "create table mytable (id int4 primary key, data text, tstamp timestamptz default now())"
for n in 1 2 3; do
run_sql hsrc "insert into mytable values ($n, 'row$n')"
done
msg "Register table on root node"
run londiste3 $v conf/londiste_hsrc.ini add-table mytable
msg "Create queue replika on hdst"
run_sql hdst "select pgq.create_queue('replika')"
msg "Register table on other node with creation, qtable->replika handler"
run londiste3 $v conf/londiste_hdst.ini add-table mytable --handler=qsplitter --handler-arg="queue=replika"
msg "Wait until table is in sync"
cnt=0
while test $cnt -ne 1; do
sleep 3
cnt=`psql -A -t -d hdst -c "select count(*) from londiste.table_info where merge_state = 'ok'"`
echo " cnt=$cnt"
done
msg "Do some updates"
run_sql hsrc "insert into mytable values (5, 'row5')"
run_sql hsrc "update mytable set data = 'row5x' where id = 5"
run_sql hsrc "insert into mytable values (6, 'row6')"
run_sql hsrc "delete from mytable where id = 6"
run_sql hsrc "insert into mytable values (7, 'row7')"
run_sql hsrc "update mytable set data = 'row7x' where id = 7"
run_sql hsrc "delete from mytable where id = 7"
run_sql hsrc "delete from mytable where id = 1"
run_sql hsrc "update mytable set data = 'row2x' where id = 2"
run sleep 5
msg "Check status"
run londiste3 $v conf/londiste_hsrc.ini status
run sleep 5
tbl=$(psql hdst -qAtc "select * from pgq.current_event_table('replika');")
msg "Check queue 'replika' form table $tbl"
run_sql hdst "select * from $tbl"
#run_sql hdst 'select * from mytable order by id'
../zcheck.sh
|
