(1 row)
select * from londiste.get_table_list('part1_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.tblmerge | t | | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.tblmerge | t | | | | |
(1 row)
select * from londiste.get_table_list('part2_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.tblmerge | t | | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.tblmerge | t | | | | |
(1 row)
select * from londiste.get_table_list('combined_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.tblmerge | t | ok | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.tblmerge | t | ok | | | |
(1 row)
select * from londiste.local_set_table_state('part1_set', 'public.tblmerge', null, 'in-copy');
(1 row)
select * from londiste.get_table_list('part1_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.tblmerge | t | in-copy | | | | lead
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.tblmerge | t | in-copy | | | | lead
(1 row)
select * from londiste.get_table_list('part2_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.tblmerge | t | in-copy | | | | wait-copy
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.tblmerge | t | in-copy | | | | wait-copy
(1 row)
select * from londiste.local_set_table_struct('part1_set', 'public.tblmerge', 'create index;');
(1 row)
select * from londiste.get_table_list('part1_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+---------------+-----------
- public.tblmerge | t | in-copy | | | create index; | lead
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+---------------+-----------
+ public.tblmerge | t | in-copy | | | create index; | lead
(1 row)
select * from londiste.get_table_list('part2_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-------------
- public.tblmerge | t | in-copy | | | | wait-replay
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-------------
+ public.tblmerge | t | in-copy | | | | wait-replay
(1 row)
select * from londiste.local_set_table_state('part1_set', 'public.tblmerge', null, 'in-copy');
(1 row)
select * from londiste.get_table_list('part1_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+---------------+-----------
- public.tblmerge | t | in-copy | | | create index; |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+---------------+-----------
+ public.tblmerge | t | in-copy | | | create index; |
(1 row)
select * from londiste.get_table_list('part2_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-------------
- public.tblmerge | t | catching-up | | | | wait-replay
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-------------
+ public.tblmerge | t | catching-up | | | | wait-replay
(1 row)
select * from londiste.local_set_table_struct('part1_set', 'public.tblmerge', null);
(1 row)
select * from londiste.get_table_list('part1_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.tblmerge | t | in-copy | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.tblmerge | t | in-copy | | | |
(1 row)
select * from londiste.get_table_list('part2_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-------------
- public.tblmerge | t | catching-up | | | | wait-replay
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-------------
+ public.tblmerge | t | catching-up | | | | wait-replay
(1 row)
select * from londiste.local_set_table_state('part1_set', 'public.tblmerge', null, 'catching-up');
(1 row)
select * from londiste.get_table_list('part1_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.tblmerge | t | catching-up | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.tblmerge | t | catching-up | | | |
(1 row)
select * from londiste.get_table_list('part2_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.tblmerge | t | catching-up | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.tblmerge | t | catching-up | | | |
(1 row)
insert into testdata (data) values ('test-data');
select * from londiste.get_table_list('aset');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.testdata | t | ok | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+-----------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.testdata | t | ok | | | |
(1 row)
+select * from londiste.local_show_missing('aset');
+ obj_kind | obj_name
+----------+-----------------------------
+ S | public.testdata_id_seq
+ S | public.testdata_nopk_id_seq
+ r | public.testdata_nopk
+(3 rows)
+
select * from londiste.local_remove_table('aset', 'public.testdata');
ret_code | ret_note
----------+--------------------------------
(1 row)
select * from londiste.get_table_list('aset');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
-------------+-------+-------------+-----------------+---------------+-------------+-----------
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+------------+-------+-------------+-----------------+-------------+-------------+-----------
(0 rows)
select ev_id, ev_type, ev_data, ev_extra1 from pgq.event_template;
3 | londiste.remove-table | public.testdata |
(3 rows)
+select * from londiste.local_show_missing('aset');
+ obj_kind | obj_name
+----------+-----------------------------
+ S | public.testdata_id_seq
+ S | public.testdata_nopk_id_seq
+ r | public.testdata
+ r | public.testdata_nopk
+(4 rows)
+
200 | Node "snode" initialized for queue "branch_set" with type "branch"
(1 row)
+select * from londiste.local_show_missing('branch_set');
+ obj_kind | obj_name
+----------+----------
+(0 rows)
+
select * from londiste.local_add_table('branch_set', 'public.slavedata');
ret_code | ret_note
----------+------------------------------------------------
(1 row)
select * from londiste.get_table_list('branch_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
-------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.slavedata | t | | | | |
- public.tmp | f | | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+------------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.slavedata | t | | | | |
+ public.tmp | f | | | | |
(2 rows)
select * from londiste.global_remove_table('branch_set', 'public.tmp');
(1 row)
select * from londiste.get_table_list('branch_set');
- table_name | local | merge_state | custom_snapshot | skip_truncate | dropped_ddl | copy_role
-------------------+-------+-------------+-----------------+---------------+-------------+-----------
- public.slavedata | f | | | | |
+ table_name | local | merge_state | custom_snapshot | table_attrs | dropped_ddl | copy_role
+------------------+-------+-------------+-----------------+-------------+-------------+-----------
+ public.slavedata | f | | | | |
+(1 row)
+
+select * from londiste.local_show_missing('branch_set');
+ obj_kind | obj_name
+----------+------------------
+ r | public.slavedata
(1 row)