66 lines
2 KiB
Ruby
66 lines
2 KiB
Ruby
require "cases/helper"
|
|
|
|
class MysqlConnectionTest < ActiveRecord::TestCase
|
|
def setup
|
|
super
|
|
@connection = ActiveRecord::Base.connection
|
|
end
|
|
|
|
def test_mysql_reconnect_attribute_after_connection_with_reconnect_true
|
|
run_without_connection do |orig_connection|
|
|
ActiveRecord::Base.establish_connection(orig_connection.merge({:reconnect => true}))
|
|
assert ActiveRecord::Base.connection.raw_connection.reconnect
|
|
end
|
|
end
|
|
|
|
def test_mysql_reconnect_attribute_after_connection_with_reconnect_false
|
|
run_without_connection do |orig_connection|
|
|
ActiveRecord::Base.establish_connection(orig_connection.merge({:reconnect => false}))
|
|
assert !ActiveRecord::Base.connection.raw_connection.reconnect
|
|
end
|
|
end
|
|
|
|
def test_no_automatic_reconnection_after_timeout
|
|
assert @connection.active?
|
|
@connection.update('set @@wait_timeout=1')
|
|
sleep 2
|
|
assert !@connection.active?
|
|
end
|
|
|
|
def test_successful_reconnection_after_timeout_with_manual_reconnect
|
|
assert @connection.active?
|
|
@connection.update('set @@wait_timeout=1')
|
|
sleep 2
|
|
@connection.reconnect!
|
|
assert @connection.active?
|
|
end
|
|
|
|
def test_successful_reconnection_after_timeout_with_verify
|
|
assert @connection.active?
|
|
@connection.update('set @@wait_timeout=1')
|
|
sleep 2
|
|
@connection.verify!
|
|
assert @connection.active?
|
|
end
|
|
|
|
# Test that MySQL allows multiple results for stored procedures
|
|
if Mysql.const_defined?(:CLIENT_MULTI_RESULTS)
|
|
def test_multi_results
|
|
rows = ActiveRecord::Base.connection.select_rows('CALL ten();')
|
|
assert_equal 10, rows[0][0].to_i, "ten() did not return 10 as expected: #{rows.inspect}"
|
|
assert @connection.active?, "Bad connection use by 'MysqlAdapter.select_rows'"
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def run_without_connection
|
|
original_connection = ActiveRecord::Base.remove_connection
|
|
begin
|
|
yield original_connection
|
|
ensure
|
|
ActiveRecord::Base.establish_connection(original_connection)
|
|
end
|
|
end
|
|
end
|