2010-10-12 18:57:26 -04:00
|
|
|
module ActiveRecord
|
|
|
|
###
|
2015-07-08 06:16:16 -04:00
|
|
|
# This class encapsulates a result returned from calling
|
|
|
|
# {#exec_query}[rdoc-ref:ConnectionAdapters::DatabaseStatements#exec_query]
|
|
|
|
# on any database connection adapter. For example:
|
2010-10-12 18:57:26 -04:00
|
|
|
#
|
2013-07-22 08:30:55 -04:00
|
|
|
# result = ActiveRecord::Base.connection.exec_query('SELECT id, title, body FROM posts')
|
|
|
|
# result # => #<ActiveRecord::Result:0xdeadbeef>
|
|
|
|
#
|
|
|
|
# # Get the column names of the result:
|
|
|
|
# result.columns
|
|
|
|
# # => ["id", "title", "body"]
|
|
|
|
#
|
|
|
|
# # Get the record values of the result:
|
|
|
|
# result.rows
|
|
|
|
# # => [[1, "title_1", "body_1"],
|
|
|
|
# [2, "title_2", "body_2"],
|
|
|
|
# ...
|
|
|
|
# ]
|
|
|
|
#
|
|
|
|
# # Get an array of hashes representing the result (column => value):
|
|
|
|
# result.to_hash
|
|
|
|
# # => [{"id" => 1, "title" => "title_1", "body" => "body_1"},
|
|
|
|
# {"id" => 2, "title" => "title_2", "body" => "body_2"},
|
|
|
|
# ...
|
|
|
|
# ]
|
|
|
|
#
|
|
|
|
# # ActiveRecord::Result also includes Enumerable.
|
|
|
|
# result.each do |row|
|
|
|
|
# puts row['title'] + " " + row['body']
|
|
|
|
# end
|
2010-10-12 18:57:26 -04:00
|
|
|
class Result
|
|
|
|
include Enumerable
|
|
|
|
|
2014-06-09 09:56:36 -04:00
|
|
|
IDENTITY_TYPE = Type::Value.new # :nodoc:
|
2013-07-01 21:00:52 -04:00
|
|
|
|
2012-02-07 14:51:30 -05:00
|
|
|
attr_reader :columns, :rows, :column_types
|
2010-10-12 18:57:26 -04:00
|
|
|
|
2012-08-21 12:23:40 -04:00
|
|
|
def initialize(columns, rows, column_types = {})
|
2012-09-20 00:43:36 -04:00
|
|
|
@columns = columns
|
2012-02-07 14:51:30 -05:00
|
|
|
@rows = rows
|
|
|
|
@hash_rows = nil
|
2012-08-21 12:23:40 -04:00
|
|
|
@column_types = column_types
|
2010-10-12 18:57:26 -04:00
|
|
|
end
|
|
|
|
|
2014-10-13 15:01:41 -04:00
|
|
|
def length
|
|
|
|
@rows.length
|
|
|
|
end
|
|
|
|
|
2010-10-12 18:57:26 -04:00
|
|
|
def each
|
2013-06-18 06:32:01 -04:00
|
|
|
if block_given?
|
|
|
|
hash_rows.each { |row| yield row }
|
|
|
|
else
|
2014-01-29 15:42:07 -05:00
|
|
|
hash_rows.to_enum { @rows.size }
|
2013-06-18 06:32:01 -04:00
|
|
|
end
|
2010-10-12 18:57:26 -04:00
|
|
|
end
|
|
|
|
|
2011-02-04 21:08:31 -05:00
|
|
|
def to_hash
|
|
|
|
hash_rows
|
|
|
|
end
|
|
|
|
|
2012-01-26 18:16:12 -05:00
|
|
|
alias :map! :map
|
|
|
|
alias :collect! :map
|
|
|
|
|
2012-05-07 07:43:05 -04:00
|
|
|
# Returns true if there are no records.
|
2012-01-26 18:16:12 -05:00
|
|
|
def empty?
|
|
|
|
rows.empty?
|
|
|
|
end
|
|
|
|
|
|
|
|
def to_ary
|
|
|
|
hash_rows
|
|
|
|
end
|
|
|
|
|
|
|
|
def [](idx)
|
|
|
|
hash_rows[idx]
|
|
|
|
end
|
|
|
|
|
|
|
|
def last
|
|
|
|
hash_rows.last
|
|
|
|
end
|
|
|
|
|
2014-06-21 13:31:57 -04:00
|
|
|
def cast_values(type_overrides = {}) # :nodoc:
|
|
|
|
types = columns.map { |name| column_type(name, type_overrides) }
|
|
|
|
result = rows.map do |values|
|
2015-02-17 13:29:51 -05:00
|
|
|
types.zip(values).map { |type, value| type.deserialize(value) }
|
2014-06-21 13:31:57 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
columns.one? ? result.map!(&:first) : result
|
|
|
|
end
|
|
|
|
|
2012-01-26 19:51:54 -05:00
|
|
|
def initialize_copy(other)
|
2013-11-09 02:56:11 -05:00
|
|
|
@columns = columns.dup
|
|
|
|
@rows = rows.dup
|
|
|
|
@column_types = column_types.dup
|
|
|
|
@hash_rows = nil
|
2012-01-26 19:51:54 -05:00
|
|
|
end
|
|
|
|
|
2010-10-12 18:57:26 -04:00
|
|
|
private
|
2013-07-22 08:30:55 -04:00
|
|
|
|
2014-06-21 13:31:57 -04:00
|
|
|
def column_type(name, type_overrides = {})
|
|
|
|
type_overrides.fetch(name) do
|
|
|
|
column_types.fetch(name, IDENTITY_TYPE)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2010-10-12 18:57:26 -04:00
|
|
|
def hash_rows
|
2012-09-20 11:59:31 -04:00
|
|
|
@hash_rows ||=
|
|
|
|
begin
|
|
|
|
# We freeze the strings to prevent them getting duped when
|
2014-06-07 15:46:22 -04:00
|
|
|
# used as keys in ActiveRecord::Base's @attributes hash
|
2012-09-20 11:59:31 -04:00
|
|
|
columns = @columns.map { |c| c.dup.freeze }
|
|
|
|
@rows.map { |row|
|
2013-08-28 22:23:15 -04:00
|
|
|
# In the past we used Hash[columns.zip(row)]
|
|
|
|
# though elegant, the verbose way is much more efficient
|
|
|
|
# both time and memory wise cause it avoids a big array allocation
|
|
|
|
# this method is called a lot and needs to be micro optimised
|
|
|
|
hash = {}
|
|
|
|
|
|
|
|
index = 0
|
|
|
|
length = columns.length
|
|
|
|
|
|
|
|
while index < length
|
|
|
|
hash[columns[index]] = row[index]
|
|
|
|
index += 1
|
|
|
|
end
|
|
|
|
|
|
|
|
hash
|
2012-09-20 11:59:31 -04:00
|
|
|
}
|
|
|
|
end
|
2010-10-12 18:57:26 -04:00
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|