--
create table testdata (
id serial primary key,
- data text
+ txt text
);
create table testdata_nopk (
id serial,
- data text
+ txt text
);
select current_database();
current_database
200 | Table added: public.testdata
(1 row)
-insert into testdata (data) values ('test-data');
+insert into testdata (txt) values ('test-data');
select * from londiste.get_table_list('aset');
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;
- ev_id | ev_type | ev_data | ev_extra1
--------+-----------------------+------------------------------------+-----------------
- 1 | londiste.add-table | public.testdata |
- 2 | I | (id,data) values ('1','test-data') | public.testdata
- 3 | londiste.remove-table | public.testdata |
+ ev_id | ev_type | ev_data | ev_extra1
+-------+-----------------------+-----------------------------------+-----------------
+ 1 | londiste.add-table | public.testdata |
+ 2 | I | (id,txt) values ('1','test-data') | public.testdata
+ 3 | londiste.remove-table | public.testdata |
(3 rows)
select * from londiste.local_show_missing('aset');
----------+------------+-------
(0 rows)
-select ev_id, ev_type, ev_data, ev_extra1 from pgq.event_template;
- ev_id | ev_type | ev_data | ev_extra1
--------+-----------------------+------------------------------------+------------------
- 1 | londiste.add-table | public.testdata |
- 2 | I | (id,data) values ('1','test-data') | public.testdata
- 3 | londiste.remove-table | public.testdata |
- 4 | EXECUTE | drop all | DDL-root.sql
- 5 | EXECUTE | drop all | DDL-root.sql
- 1 | londiste.update-seq | 30001 | public.masterseq
- 2 | londiste.remove-seq | public.masterseq |
-(7 rows)
+select ev_id, ev_type, ev_data, ev_extra1 from pgq.event_template where ev_type like '%seq%';
+ ev_id | ev_type | ev_data | ev_extra1
+-------+---------------------+------------------+------------------
+ 1 | londiste.update-seq | 30001 | public.masterseq
+ 2 | londiste.remove-seq | public.masterseq |
+(2 rows)
-- subscriber
select * from pgq_node.register_location('seqbranch', 'subnode', 'dbname=db', false);
--
create table testdata (
id serial primary key,
- data text
+ txt text
);
create table testdata_nopk (
id serial,
- data text
+ txt text
);
select current_database();
select * from londiste.local_add_table('aset', 'public.testdata_nopk');
select * from londiste.local_add_table('aset', 'public.testdata');
-insert into testdata (data) values ('test-data');
+insert into testdata (txt) values ('test-data');
select * from londiste.get_table_list('aset');
select * from londiste.local_show_missing('aset');
select * from londiste.local_remove_table('aset', 'public.testdata');
select * from londiste.get_seq_list('seqroot');
-select ev_id, ev_type, ev_data, ev_extra1 from pgq.event_template;
+select ev_id, ev_type, ev_data, ev_extra1 from pgq.event_template where ev_type like '%seq%';
-- subscriber
select * from pgq_node.register_location('seqbranch', 'subnode', 'dbname=db', false);