Allow not delete triggers

lib/lhm.rb

@@ -55,7 +55,7 @@ def sync_table(table_name, sync_table, options = {}, &block)
  origin = Table.parse(table_name, connection)
  invoker = Invoker.new(origin, connection)
  block.call(invoker.migrator)
- options.merge!({disable_switcher: true})
+ options.merge!({disable_switcher: true, delete_trigger_after: false})
  invoker.run(options)
  ensure
  Lhm::Table.naming_strategy = nil

lib/lhm/entangler.rb

@@ -9,15 +9,16 @@ class Entangler
  include Command
  include SqlHelper
 
- attr_reader :connection
+ attr_reader :connection, :delete_trigger_after
 
  # Creates entanglement between two tables. All creates, updates and deletes
  # to origin will be repeated on the destination table.
- def initialize(migration, connection = nil)
+ def initialize(migration, connection = nil, delete_trigger_after = true)
  @intersection = migration.intersection
  @origin = migration.origin
  @destination = migration.destination
  @connection = connection
+ @delete_trigger_after = delete_trigger_after
  end
 
  def entangle
@@ -84,6 +85,7 @@ def before
  end
 
  def after
+ return unless @delete_trigger_after
  untangle.each do |stmt|
  @connection.execute(tagged(stmt))
  end

lib/lhm/invoker.rb

@@ -42,7 +42,7 @@ def run(options = {})
  set_session_lock_wait_timeouts
  migration = @migrator.run
 
- Entangler.new(migration, @connection).run do
+ Entangler.new(migration, @connection, options[:delete_trigger_after] && true).run do
  Chunker.new(migration, @connection, options).run
  if options[:disable_switcher]
  Lhm.logger.debug 'switcher is disabled'