File: londiste_subscriber.sql

package info (click to toggle)
londiste-sql 3.8-6
  • links: PTS, VCS
  • area: main
  • in suites: sid, trixie
  • size: 560 kB
  • sloc: sql: 2,742; python: 309; makefile: 18; sh: 1
file content (36 lines) | stat: -rw-r--r-- 1,355 bytes parent folder | download | duplicates (5)
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

set client_min_messages = 'warning';
\set VERBOSITY 'terse'

--
-- tables
--
create table slavedata (
    id serial primary key,
    data text
);

select current_database();

select * from pgq_node.register_location('branch_set', 'snode', 'dbname=db', false);
select * from pgq_node.register_location('branch_set', 'pnode', 'dbname=db2', false);
select * from pgq_node.create_node('branch_set', 'branch', 'snode', 'londiste_branch', 'pnode', 100, null::text);

select * from londiste.local_show_missing('branch_set');

select * from londiste.local_add_table('branch_set', 'public.slavedata');
select * from londiste.global_add_table('branch_set', 'public.slavedata');
select * from londiste.local_add_table('branch_set', 'public.slavedata');
select * from londiste.global_add_table('branch_set', 'public.tmp');
select * from londiste.get_table_list('branch_set');

select * from londiste.local_set_table_state('branch_set', 'public.slavedata', null, 'in-copy');
select * from londiste.get_table_list('branch_set');

select * from londiste.global_remove_table('branch_set', 'public.tmp');
select * from londiste.local_remove_table('branch_set', 'public.slavedata');
select * from londiste.local_remove_table('branch_set', 'public.slavedata');
select * from londiste.get_table_list('branch_set');

select * from londiste.local_show_missing('branch_set');