diff --git a/lib/active_record/connection_adapters/makara_abstract_adapter.rb b/lib/active_record/connection_adapters/makara_abstract_adapter.rb index 6e180160..9d4c463c 100644 --- a/lib/active_record/connection_adapters/makara_abstract_adapter.rb +++ b/lib/active_record/connection_adapters/makara_abstract_adapter.rb @@ -110,7 +110,7 @@ def custom_error_message?(connection, message) send_to_all :connect, :reconnect!, :verify!, :clear_cache!, :reset! control_method :close, :steal!, :expire, :lease, :in_use?, :owner, :schema_cache, :pool=, :pool, - :schema_cache=, :lock, :seconds_idle + :schema_cache=, :lock, :seconds_idle, :== SQL_MASTER_MATCHERS = [/\A\s*select.+for update\Z/i, /select.+lock in share mode\Z/i, /\A\s*select.+(nextval|currval|lastval|get_lock|release_lock|pg_advisory_lock|pg_advisory_unlock)\(/i].map(&:freeze).freeze @@ -307,6 +307,10 @@ def pool=(*args) def pool(*args) @pool end + + def ==(*args) + @proxy.object_id == args[0].object_id + end end end end