require 'cases/helper' require 'models/topic' module ActiveRecord class BindParameterTest < ActiveRecord::TestCase fixtures :topics class LogListener attr_accessor :calls def initialize @calls = [] end def call(*args) calls << args end end def setup super @connection = ActiveRecord::Base.connection @listener = LogListener.new @pk = Topic.columns.find { |c| c.primary } ActiveSupport::Notifications.subscribe('sql.active_record', @listener) end def teardown ActiveSupport::Notifications.unsubscribe(@listener) end def test_binds_are_logged return skip_bind_parameter_test unless supports_statement_cache? sub = @connection.substitute_at(@pk, 0) binds = [[@pk, 1]] sql = "select * from topics where id = #{sub}" @connection.exec_query(sql, 'SQL', binds) message = @listener.calls.find { |args| args[4][:sql] == sql } assert_equal binds, message[4][:binds] end def test_find_one_uses_binds return skip_bind_parameter_test unless supports_statement_cache? Topic.find(1) binds = [[@pk, 1]] message = @listener.calls.find { |args| args[4][:binds] == binds } assert message, 'expected a message with binds' end def test_logs_bind_vars return skip_bind_parameter_test unless supports_statement_cache? pk = Topic.columns.find { |x| x.primary } payload = { :name => 'SQL', :sql => 'select * from topics where id = ?', :binds => [[pk, 10]] } event = ActiveSupport::Notifications::Event.new( 'foo', Time.now, Time.now, 123, payload) logger = Class.new(ActiveRecord::LogSubscriber) { attr_reader :debugs def initialize super @debugs = [] end def debug str @debugs << str end }.new logger.sql event assert_match([[pk.name, 10]].inspect, logger.debugs.first) end private def skip_bind_parameter_test skip('prepared statement caching is not supported') end def supports_statement_cache? @connection.supports_statement_cache? end end end