Sha256: de676141d7d1667ec3668ee690a55b04cb5bb7216321436381625c7492967ef3
Contents?: true
Size: 1.58 KB
Versions: 28
Compression:
Stored size: 1.58 KB
Contents
require 'active_record/connection_adapters/statement_pool'
module ArJdbc
module Abstract
module StatementCache
# This works a little differently than the AR implementation in that
# we are storing an actual PreparedStatement object instead of just
# the name of the prepared statement
class StatementPool < ActiveRecord::ConnectionAdapters::StatementPool
private
def dealloc(statement)
statement.close
end
end
def initialize(*args) # (connection, logger, config)
super
# Only say we support the statement cache if we are using prepared statements
# and have a max number of statements defined
statement_limit = self.class.type_cast_config_to_integer(config[:statement_limit])
@jdbc_statement_cache_enabled = prepared_statements && (statement_limit.nil? || statement_limit > 0)
@statements = StatementPool.new(statement_limit) # AR (5.0) expects this to be stored as @statements
end
# Clears the prepared statements cache.
def clear_cache!
@statements.clear
end
def delete_cached_statement(sql)
@statements.delete(sql_key(sql))
end
def fetch_cached_statement(sql)
@statements[sql_key(sql)] ||= @connection.prepare_statement(sql)
end
def supports_statement_cache?
@jdbc_statement_cache_enabled
end
private
# This should be overridden by the adapter if the sql itself
# is not enough to make the key unique
def sql_key(sql)
sql
end
end
end
end
Version data entries
28 entries across 28 versions & 2 rubygems