Module: ActiveRecord::ConnectionAdapters::Mysql2::DatabaseStatements
Relationships & Source Files | |
Extension / Inclusion / Inheritance Descendants | |
Included In:
| |
Defined in: | activerecord/lib/active_record/connection_adapters/mysql2/database_statements.rb |
Instance Attribute Summary
- #multi_statements_enabled? ⇒ Boolean readonly private
Instance Method Summary
- #affected_rows(result) private
- #cast_result(result) private
- #execute_batch(statements, name = nil, **kwargs) private
- #last_inserted_id(result) private
- #perform_query(raw_connection, sql, binds, type_casted_binds, prepare:, notification_payload:, batch: false) private
-
#select_all
Internal use only
Returns an
::ActiveRecord::Result
instance.
Instance Attribute Details
#multi_statements_enabled? ⇒ Boolean
(readonly, private)
[ GitHub ]
Instance Method Details
#affected_rows(result) (private)
[ GitHub ]# File 'activerecord/lib/active_record/connection_adapters/mysql2/database_statements.rb', line 90
def affected_rows(result) @affected_rows_before_warnings end
#cast_result(result) (private)
[ GitHub ]# File 'activerecord/lib/active_record/connection_adapters/mysql2/database_statements.rb', line 82
def cast_result(result) if result.nil? || result.fields.empty? ActiveRecord::Result.empty else ActiveRecord::Result.new(result.fields, result.to_a) end end
#execute_batch(statements, name = nil, **kwargs) (private)
[ GitHub ]# File 'activerecord/lib/active_record/connection_adapters/mysql2/database_statements.rb', line 17
def execute_batch(statements, name = nil, **kwargs) combine_multi_statements(statements).each do |statement| raw_execute(statement, name, batch: true, **kwargs) end end
#last_inserted_id(result) (private)
[ GitHub ]# File 'activerecord/lib/active_record/connection_adapters/mysql2/database_statements.rb', line 23
def last_inserted_id(result) if supports_insert_returning? super else @raw_connection&.last_id end end
#perform_query(raw_connection, sql, binds, type_casted_binds, prepare:, notification_payload:, batch: false) (private)
[ GitHub ]# File 'activerecord/lib/active_record/connection_adapters/mysql2/database_statements.rb', line 41
def perform_query(raw_connection, sql, binds, type_casted_binds, prepare:, notification_payload:, batch: false) reset_multi_statement = if batch && !multi_statements_enabled? raw_connection.set_server_option(::Mysql2::Client::OPTION_MULTI_STATEMENTS_ON) true end # Make sure we carry over any changes to ActiveRecord.default_timezone that have been # made since we established the connection raw_connection. [:database_timezone] = default_timezone result = if prepare stmt = @statements[sql] ||= raw_connection.prepare(sql) begin ActiveSupport::Dependencies.interlock.permit_concurrent_loads do stmt.execute(*type_casted_binds) end rescue ::Mysql2::Error @statements.delete(sql) stmt.close raise end verified! else raw_connection.query(sql) end notification_payload[:row_count] = result&.size || 0 @affected_rows_before_warnings = raw_connection.affected_rows raw_connection.abandon_results! verified! handle_warnings(sql) result ensure if reset_multi_statement && active? raw_connection.set_server_option(::Mysql2::Client::OPTION_MULTI_STATEMENTS_OFF) end end
#select_all
This method is for internal use only.
Returns an ::ActiveRecord::Result
instance.
# File 'activerecord/lib/active_record/connection_adapters/mysql2/database_statements.rb', line 8
def select_all(*, **) # :nodoc: if ExplainRegistry.collect? && prepared_statements unprepared_statement { super } else super end end