test/cases/mirroring_test.rb @@ -15,17 +15,19 @@ module ActiveRecord mode = config[:mode] ? config[:mode].to_s.upcase : 'ADO' username = config[:username] ? config[:username].to_s : 'sa' password = config[:password] ? config[:password].to_s : '' + mirror_url = nil if mode == "ODBC" raise ArgumentError, "Missing DSN. Argument ':dsn' must be set in order for this adapter to work." unless config.has_key?(:dsn) dsn = config[:dsn] driver_url = "DBI:ODBC:#{dsn}" + mirror_url = "DBI:ODBC:#{config[:dsn_mirror]}" if config[:dsn_mirror] else raise ArgumentError, "Missing Database. Argument ':database' must be set in order for this adapter to work." unless config.has_key?(:database) database = config[:database] host = config[:host] ? config[:host].to_s : 'localhost' driver_url = "DBI:ADO:Provider=SQLOLEDB;Data Source=#{host};Initial Catalog=#{database};User ID=#{username};Password=#{password};" end - ConnectionAdapters::SQLServerAdapter.new(logger, [driver_url, username, password]) + ConnectionAdapters::SQLServerAdapter.new(logger, [driver_url, username, password], (mirror_url ? [driver_url, mirror_url] : nil) ) end protected @@ -183,8 +185,10 @@ module ActiveRecord end - def initialize(logger, connection_options) + def initialize(logger, connection_options, mirror_dsns=nil) + @logger = logger @connection_options = connection_options + @mirror_dsns = mirror_dsns connect super(raw_connection, logger) initialize_sqlserver_caches @@ -743,13 +747,26 @@ module ActiveRecord # CONNECTION MANAGEMENT ====================================# - def connect - driver_url, username, password = @connection_options - @connection = DBI.connect(driver_url, username, password) + def connect + if @mirror_dsns + raise DBI::DatabaseError.new('Communication link failure') unless connect_mirror(0) || connect_mirror(1) + else + driver_url, username, password = @connection_options + @connection = DBI.connect(driver_url, username, password) + end configure_connection rescue raise unless @auto_connecting end + + def connect_mirror(index = 0) + @connection = DBI.connect(@mirror_dsns[index], @connection_options[1], @connection_options[2]) + @logger.info "#{adapter_name} connection established to: #{@mirror_dsns[index]}" if @logger + true + rescue DBI::DatabaseError => e + @logger.info "#{adapter_name} connecting to: #{@mirror_dsns[index]} FAILED" if @logger + false + end def configure_connection raw_connection['AutoCommit'] = true lib/active_record/connection_adapters/sqlserver_adapter.rb 515b040b2ca3b0114893106789d9fe235e6edfbb Igor Anic igor.anic@gmail.com http://github.com/ianic/2000-2005-adapter/commit/20bf73a1c3d632f8d1649c851040887ec20983aa 20bf73a1c3d632f8d1649c851040887ec20983aa 2009-05-11T14:06:59-07:00 2009-05-11T14:06:59-07:00 Database mirroring support for ODBC connections. For more information please look at test/cases/mirroring_test.rb 8d33534cdff8028c9e067804621945d4990f5924 Igor Anic igor.anic@gmail.com