summaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorMarko Kreen2013-02-20 18:36:27 +0000
committerMarko Kreen2013-02-20 18:36:27 +0000
commit2172e11bbc680b150429c6becb45696149fbeb71 (patch)
treebcc3a6f44ee9814104247463b87dea5be92145ef /sql
parent1e5cce43e847c7b154c1ef9ce3ea57ec0850e224 (diff)
parent391fcb198ed0f8daefa96931b8154f9036d453ee (diff)
Merge remote-tracking branch 'petr/master'
Diffstat (limited to 'sql')
-rw-r--r--sql/londiste/functions/londiste.create_trigger.sql4
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/londiste/functions/londiste.create_trigger.sql b/sql/londiste/functions/londiste.create_trigger.sql
index 9dbf4cab..dc2aac18 100644
--- a/sql/londiste/functions/londiste.create_trigger.sql
+++ b/sql/londiste/functions/londiste.create_trigger.sql
@@ -106,7 +106,7 @@ begin
trigger_name := '_londiste_' || i_queue_name;
lg_func := 'pgq.logutriga';
lg_event := '';
- lg_args := array[i_queue_name];
+ lg_args := array[quote_literal(i_queue_name)];
lg_pos := 'after';
if array_lower(_args, 1) is not null then
@@ -230,7 +230,7 @@ begin
where tgrelid = londiste.find_table_oid(i_dest_table)
and tgname = trunctrg_name;
if not found then
- _extra_args := i_queue_name || _extra_args;
+ _extra_args := quote_literal(i_queue_name) || _extra_args;
sql := 'create trigger ' || quote_ident(trunctrg_name)
|| ' after truncate on ' || londiste.quote_fqname(i_dest_table)
|| ' for each statement execute procedure pgq.sqltriga('