AbstractMysqlAdapter
The MySQL adapter will work with both Ruby/MySQL, which is a Ruby-based MySQL adapter that comes bundled with Active Record, and with the faster C-based MySQL/Ruby adapter (available both as a gem and from www.tmtm.org/en/mysql/ruby/).
Options:
:host - Defaults to "localhost".
:port - Defaults to 3306.
:socket - Defaults to "/tmp/mysql.sock".
:username - Defaults to "root"
:password - Defaults to nothing.
:database - The name of the database. No default, must be provided.
:encoding - (Optional) Sets the client encoding by executing "SET NAMES <encoding>" after connection.
:reconnect - Defaults to false (See MySQL documentation: dev.mysql.com/doc/refman/5.0/en/auto-reconnect.html).
:sslca - Necessary to use MySQL with an SSL connection.
:sslkey - Necessary to use MySQL with an SSL connection.
:sslcert - Necessary to use MySQL with an SSL connection.
:sslcapath - Necessary to use MySQL with an SSL connection.
:sslcipher - Necessary to use MySQL with an SSL connection.
Taken from here:
https://github.com/tmtm/ruby-mysql/blob/master/lib/mysql/charset.rb
Author: TOMITA Masahiro <tommy@tmtm.org>
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 126 def initialize(connection, logger, connection_options, config) super @statements = StatementPool.new(@connection, config.fetch(:statement_limit) { 1000 }) @client_encoding = nil connect end
CONNECTION MANAGEMENT ====================================
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 175 def active? if @connection.respond_to?(:stat) @connection.stat else @connection.query 'select 1' end # mysql-ruby doesn't raise an exception when stat fails. if @connection.respond_to?(:errno) @connection.errno.zero? else true end rescue Mysql::Error false end
Clears the prepared statements cache.
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 223 def clear_cache! @statements.clear end
Get the client encoding for this database
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 275 def client_encoding return @client_encoding if @client_encoding result = exec_query( "SHOW VARIABLES WHERE Variable_name = 'character_set_client'", 'SCHEMA') @client_encoding = ENCODINGS[result.rows.last.last] end
Disconnects from the database if already connected. Otherwise, this method does nothing.
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 200 def disconnect! @connection.close rescue nil end
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 336 def exec_delete(sql, name, binds) affected_rows = 0 exec_query(sql, name, binds) do |n| affected_rows = n end affected_rows end
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 284 def exec_query(sql, name = 'SQL', binds = []) # If the configuration sets prepared_statements:false, binds will # always be empty, since the bind variables will have been already # substituted and removed from binds by BindVisitor, so this will # effectively disable prepared statement usage completely. if binds.empty? result_set, affected_rows = exec_without_stmt(sql, name) else result_set, affected_rows = exec_stmt(sql, name, binds) end yield affected_rows if block_given? result_set end
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 323 def execute_and_free(sql, name = nil) result = execute(sql, name) ret = yield result result.free ret end
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 300 def last_inserted_id(result) @connection.insert_id end
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 192 def reconnect! disconnect! clear_cache! connect end
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 204 def reset! if @connection.respond_to?(:change_user) # See http://bugs.mysql.com/bug.php?id=33540 -- the workaround way to # reset the connection is to change the user to the same user. @connection.change_user(@config[:username], @config[:password], @config[:database]) configure_connection end end
DATABASE STATEMENTS ======================================
# File lib/active_record/connection_adapters/mysql_adapter.rb, line 215 def select_rows(sql, name = nil) @connection.query_with_result = true rows = exec_query(sql, name).rows @connection.more_results && @connection.next_result # invoking stored procedures with CLIENT_MULTI_RESULTS requires this to tidy up else connection will be dropped rows end
Generated with the Darkfish Rdoc Generator 2.