class ActiveRecord::Result
end
puts row + “ ” + row[‘body’]
result.each do |row|
# ActiveRecord::Result also includes Enumerable.
]
…
{“id” => 2, “title” => “title_2”, “body” => “body_2”},
# => [{“id” => 1, “title” => “title_1”, “body” => “body_1”},
result.to_a
# Get an array of hashes representing the result (column => value):
]
…
[2, “title_2”, “body_2”],
# => [[1, “title_1”, “body_1”],
result.rows
# Get the record values of the result:
# => [“id”, “title”, “body”]
result.columns
# Get the column names of the result:
result # => #<ActiveRecord::Result:0xdeadbeef>
result = ActiveRecord::Base.lease_connection.exec_query(‘SELECT id, title, body FROM posts’)
on any database connection adapter. For example:
This class encapsulates a result returned from calling
= Active Record Result
##
def self.empty(async: false) # :nodoc:
def self.empty(async: false) # :nodoc: if async EMPTY_ASYNC else EMPTY end end
def [](idx)
def [](idx) hash_rows[idx] end
def cancel # :nodoc:
def cancel # :nodoc: self end
def cast_values(type_overrides = {}) # :nodoc:
def cast_values(type_overrides = {}) # :nodoc: if columns.one? # Separated to avoid allocating an array per row type = if type_overrides.is_a?(Array) type_overrides.first else column_type(columns.first, 0, type_overrides) end rows.map do |(value)| type.deserialize(value) end else types = if type_overrides.is_a?(Array) type_overrides else columns.map.with_index { |name, i| column_type(name, i, type_overrides) } end rows.map do |values| Array.new(values.size) { |i| types[i].deserialize(values[i]) } end end end
def column_indexes # :nodoc:
def column_indexes # :nodoc: @column_indexes ||= begin index = 0 hash = {} length = columns.length while index < length hash[columns[index]] = index index += 1 end hash.freeze end end
def column_type(name, index, type_overrides)
def column_type(name, index, type_overrides) type_overrides.fetch(name) do column_types.fetch(index) do column_types.fetch(name, Type.default_value) end end end
def each(&block)
To get real hashes, use +.to_a.each+.
row as parameter. Each row is a Hash-like, read only object.
Calls the given block once for each element in row collection, passing
def each(&block) if block_given? hash_rows.each(&block) else hash_rows.to_enum { @rows.size } end end
def empty?
def empty? rows.empty? end
def freeze # :nodoc:
def freeze # :nodoc: hash_rows.freeze indexed_rows.freeze super end
def hash_rows
def hash_rows # We use transform_values to rows. # This is faster because we avoid any reallocs and avoid hashing entirely. @hash_rows ||= @rows.map do |row| column_indexes.transform_values { |index| row[index] } end end
def includes_column?(name)
def includes_column?(name) @columns.include? name end
def indexed_rows # :nodoc:
def indexed_rows # :nodoc: @indexed_rows ||= begin columns = column_indexes @rows.map { |row| IndexedRow.new(columns, row) }.freeze end end
def initialize(columns, rows, column_types = nil)
def initialize(columns, rows, column_types = nil) # We freeze the strings to prevent them getting duped when # used as keys in ActiveRecord::Base's @attributes hash @columns = columns.each(&:-@).freeze @rows = rows @hash_rows = nil @column_types = column_types || EMPTY_HASH @column_indexes = nil end
def initialize_copy(other)
def initialize_copy(other) @rows = rows.dup @column_types = column_types.dup @hash_rows = nil end
def last(n = nil)
def last(n = nil) n ? hash_rows.last(n) : hash_rows.last end
def length
def length @rows.length end
def result # :nodoc:
def result # :nodoc: self end
def to_ary
def to_ary hash_rows end