lib/rubyrep/replication_extenders/postgresql_replication.rb in rubyrep-1.1.1 vs lib/rubyrep/replication_extenders/postgresql_replication.rb in rubyrep-1.1.2

@@ -8,10 +8,10 @@
       # Returns the key clause that is used in the trigger function.
       # * +trigger_var+: should be either 'NEW' or 'OLD'
       # * +params+: the parameter hash as described in #create_rep_trigger
       def key_clause(trigger_var, params)
         params[:keys].
-          map { |key| "'#{key}#{params[:key_sep]}' || #{trigger_var}.#{key}"}.
+          map { |key| "'#{key}#{params[:key_sep]}' || #{trigger_var}.#{quote_column_name(key)}"}.
           join(" || '#{params[:key_sep]}' || ")
       end
       private :key_clause
 
       # Returns the schema prefix (including dot) that will be used by the