#!/bin/sh source ./replinit.sh TABLEID=$1 TABLENAME=$2 $SLONIK << _END_ # # Define cluster namespace and node connection @R_161_4045@ion # cluster name = $CLUSTER; node $MASTERNODE admin conninfo = 'dbname=$MASTER_DB host=$MASTER_IP port=5432 user=$REPLUSER password=$REPLPWD'; node $SLAVENODE admin conninfo = 'dbname=$SLAVE_DB host=$SLAVE_IP port=5432 user=$REPLUSER password=$REPLPWD'; create set (id=999,origin=$MASTERNODE,comment='add $TABLENAME table'); set add table (set id=999,id=$TABLEID,fully qualified name ='public.$TABLENAME',comment='Table $TABLENAME '); # SUBSCRIBE SET (ID = 999,PROVIDER = $MASTERNODE,RECEIVER =$SLAVENODE,forward=no); echo 'wait 1 ...'; SYNC (ID=$MASTERNODE); echo 'wait 2 ...'; WAIT FOR EVENT (ORIGIN = ALL,CONFIRMED = ALL,WAIT ON=$MASTERNODE,TIMEOUT=0); #SLEEP(seconds =2); echo 'MERGE SET ...'; MERGE SET ( ID = $SETID,ADD ID = 999,ORIGIN = $MASTERNODE ); echo '$TABLENAME table added'; #DROP SET (id=999,origin=$MASTERNODE); _END_
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。