class WithTransactionalLock::MySqlHelper

Public Class Methods

cleanup(klass = ActiveRecord::Base) click to toggle source
# File lib/with_transactional_lock/my_sql_helper.rb, line 3
def self.cleanup(klass = ActiveRecord::Base)
  klass.connection_pool.with_connection do |conn|
    target_count = conn.select_value('select count(1) from transactional_advisory_locks')
    count = 0
    count += conn.delete('delete from transactional_advisory_locks limit 1000') until count >= target_count
  end
end