def switch_trigger_mode(database, table, exclude_rr_activity)
options = session.configuration.options
if session.send(database).replication_trigger_exists? "#{options[:rep_prefix]}_#{table}", table
params = {
:trigger_name => "#{options[:rep_prefix]}_#{table}",
:table => table,
:keys => session.send(database).primary_key_names(table),
:log_table => "#{options[:rep_prefix]}_pending_changes",
:activity_table => "#{options[:rep_prefix]}_running_flags",
:key_sep => options[:key_sep],
:exclude_rr_activity => exclude_rr_activity,
}
session.send(database).create_or_replace_replication_trigger_function(params)
end
end