From df96178394c52cd2dfca717e4c9eb1d18167d274 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Fri, 11 Apr 2008 13:54:09 +0000 Subject: [PATCH] fix root notifications --- sql/londiste/expected/londiste_provider.out | 9 +++++++++ sql/londiste/functions/londiste.root_notify_change.sql | 2 +- sql/londiste/sql/londiste_provider.sql | 3 +++ 3 files changed, 13 insertions(+), 1 deletion(-) diff --git a/sql/londiste/expected/londiste_provider.out b/sql/londiste/expected/londiste_provider.out index 7829fa7d..52f12e88 100644 --- a/sql/londiste/expected/londiste_provider.out +++ b/sql/londiste/expected/londiste_provider.out @@ -41,6 +41,7 @@ select * from londiste.node_add_table('aset', 'public.testdata'); 200 | Table added: public.testdata (1 row) +insert into testdata (data) values ('test-data'); select * from londiste.node_get_table_list('aset'); table_name | merge_state | custom_snapshot | skip_truncate -----------------+-------------+-----------------+--------------- @@ -64,3 +65,11 @@ select * from londiste.node_get_table_list('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 | add-table | public.testdata | + 2 | I | (id,data) values ('1','test-data') | public.testdata + 3 | remove-table | public.testdata | +(3 rows) + diff --git a/sql/londiste/functions/londiste.root_notify_change.sql b/sql/londiste/functions/londiste.root_notify_change.sql index 0f79cc22..03183c16 100644 --- a/sql/londiste/functions/londiste.root_notify_change.sql +++ b/sql/londiste/functions/londiste.root_notify_change.sql @@ -20,7 +20,7 @@ begin raise exception 'only root node can send events'; end if; - perform pgq.insert_event(que, i_ev_data, i_ev_data); + perform pgq.insert_event(que, i_ev_type, i_ev_data); return 1; end; diff --git a/sql/londiste/sql/londiste_provider.sql b/sql/londiste/sql/londiste_provider.sql index fa173910..b86223f4 100644 --- a/sql/londiste/sql/londiste_provider.sql +++ b/sql/londiste/sql/londiste_provider.sql @@ -21,8 +21,11 @@ select * from pgq_set.create_node('aset', 'root', 'rnode', 'londiste_root', null select * from londiste.node_add_table('aset', 'public.testdata_nopk'); select * from londiste.node_add_table('aset', 'public.testdata'); +insert into testdata (data) values ('test-data'); select * from londiste.node_get_table_list('aset'); select * from londiste.node_remove_table('aset', 'public.testdata'); select * from londiste.node_remove_table('aset', 'public.testdata'); select * from londiste.node_get_table_list('aset'); +select ev_id, ev_type, ev_data, ev_extra1 from pgq.event_template; + -- 2.39.5