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