15 changed files with 123 additions and 0 deletions
@ -0,0 +1,22 @@
@@ -0,0 +1,22 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
create set (ID=@temp, ORIGIN=@master, comment='add one table to replication'); |
||||
|
||||
SYNC (ID=@master); |
||||
WAIT FOR EVENT (ORIGIN=ALL, CONFIRMED=ALL, WAIT ON=@master, TIMEOUT=0); |
||||
|
||||
#output from sql/create_slonik_set_incremental.sql here |
||||
# |
||||
|
||||
|
||||
SUBSCRIBE SET (ID=@temp, PROVIDER=@master, RECEIVER=@slave1, FORWARD=YES); |
||||
#SUBSCRIBE SET (ID=@temp, PROVIDER=@master, RECEIVER=@slave2, FORWARD=YES); |
||||
|
||||
SYNC (ID=@master); |
||||
WAIT FOR EVENT (ORIGIN=ALL, CONFIRMED=ALL, WAIT ON=@master, TIMEOUT=0); |
||||
|
||||
MERGE SET (ID=@main, ADD ID=@temp, ORIGIN=@master ); |
||||
SYNC (ID=@master); |
||||
WAIT FOR EVENT (ORIGIN=ALL, CONFIRMED=ALL, WAIT ON=@master, TIMEOUT=0); |
||||
|
||||
@ -0,0 +1,15 @@
@@ -0,0 +1,15 @@
|
||||
|
||||
define master 1; |
||||
define slave1 2; |
||||
|
||||
define cluster slony; |
||||
define db [somedb]; |
||||
|
||||
define main 1; |
||||
define temp 9999; |
||||
|
||||
cluster name = @cluster; |
||||
|
||||
node 1 admin conninfo = 'dbname=[somedb] user=slony host=[master_db host] port=5432'; |
||||
node 2 admin conninfo = 'dbname=[somedb] user=slony host=[slave_db host] port=5432'; |
||||
|
||||
@ -0,0 +1,5 @@
@@ -0,0 +1,5 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
create set (ID=@main, ORIGIN=@master, comment='master_db host'); |
||||
|
||||
@ -0,0 +1,5 @@
@@ -0,0 +1,5 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
store node (ID=@slave1, comment = '[slave db host]', EVENT NODE=@master); |
||||
|
||||
@ -0,0 +1,8 @@
@@ -0,0 +1,8 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
DROP SET (ID=@temp, ORIGIN=@master); |
||||
|
||||
SYNC (ID=@master); |
||||
WAIT FOR EVENT (ORIGIN=ALL, CONFIRMED=ALL, WAIT ON=@master, TIMEOUT = 0); |
||||
|
||||
@ -0,0 +1,6 @@
@@ -0,0 +1,6 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
#DROP NODE (ID=@slave1, EVENT NODE=@master); |
||||
#DROP NODE (ID=@slave2, EVENT NODE=@master); |
||||
|
||||
@ -0,0 +1,5 @@
@@ -0,0 +1,5 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
#EXECUTE SCRIPT (SET ID=@main, FILENAME = 'HH-6059-data.sql', EVENT NODE=@master); |
||||
|
||||
@ -0,0 +1,3 @@
@@ -0,0 +1,3 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
@ -0,0 +1,5 @@
@@ -0,0 +1,5 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
INIT CLUSTER (ID=@master, comment = 'Master Node'); |
||||
|
||||
@ -0,0 +1,10 @@
@@ -0,0 +1,10 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
#SET DROP TABLE (origin=@master, id=SOME_TAB_NUMBER); |
||||
#SET DROP SEQUENCE (origin=@master, id=SOME_SEQ_NUMBER); |
||||
|
||||
|
||||
SYNC (ID=@master); |
||||
WAIT FOR EVENT (ORIGIN=ALL, CONFIRMED=ALL, WAIT ON=@master, TIMEOUT = 0); |
||||
|
||||
@ -0,0 +1,12 @@
@@ -0,0 +1,12 @@
|
||||
|
||||
syslog 0 |
||||
log_level 2 |
||||
log_timestamp 1 |
||||
|
||||
cluster_name slony |
||||
conn_info 'dbname=[somedb] user=slony port=5432' |
||||
|
||||
vac_frequency 0 |
||||
desired_sync_time 60000 |
||||
sync_group_maxsize 1000 |
||||
|
||||
@ -0,0 +1,6 @@
@@ -0,0 +1,6 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
store path (server = 1, client = 2, conninfo='dbname=[somedb] user=slony host=[master_db host] port=5432'); |
||||
store path (server = 2, client = 1, conninfo='dbname=[somedb] user=slony host=[slave_db host] port=5432'); |
||||
|
||||
@ -0,0 +1,9 @@
@@ -0,0 +1,9 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
#SUBSCRIBE SET (ID=@main, PROVIDER=@master, RECEIVER=@slave1, FORWARD=YES); |
||||
SUBSCRIBE SET (ID=@main, PROVIDER=@master, RECEIVER=@slave2, FORWARD=YES); |
||||
|
||||
SYNC (ID=@master); |
||||
WAIT FOR EVENT (ORIGIN=ALL, CONFIRMED=ALL, WAIT ON=@master, TIMEOUT = 0); |
||||
|
||||
@ -0,0 +1,7 @@
@@ -0,0 +1,7 @@
|
||||
|
||||
include <cluster_config.slonik>; |
||||
|
||||
#LOCK SET (ID=@main, ORIGIN=@master); |
||||
#MOVE SET (ID=@main, OLD ORIGIN=@master, NEW ORIGIN=@slave1); |
||||
#MOVE SET (ID=@main, OLD ORIGIN=@master, NEW ORIGIN=@slave2); |
||||
|
||||
Loading…
Reference in new issue