aboutsummaryrefslogtreecommitdiffstats
path: root/activerecord/lib/active_record/relation/calculations.rb
diff options
context:
space:
mode:
Diffstat (limited to 'activerecord/lib/active_record/relation/calculations.rb')
-rw-r--r--activerecord/lib/active_record/relation/calculations.rb39
1 files changed, 13 insertions, 26 deletions
diff --git a/activerecord/lib/active_record/relation/calculations.rb b/activerecord/lib/active_record/relation/calculations.rb
index 0abf57cd91..9c27392299 100644
--- a/activerecord/lib/active_record/relation/calculations.rb
+++ b/activerecord/lib/active_record/relation/calculations.rb
@@ -107,7 +107,6 @@ module ActiveRecord
relation = with_default_scope
if relation.equal?(self)
-
if has_include?(column_name)
construct_relation_for_association_calculations.calculate(operation, column_name, options)
else
@@ -139,9 +138,6 @@ module ActiveRecord
# # SELECT people.id FROM people
# # => [1, 2, 3]
#
- # Person.pluck([:id, :name])
- # # SELECT people.id, people.name FROM people
- #
# Person.pluck(:id, :name)
# # SELECT people.id, people.name FROM people
#
@@ -158,23 +154,19 @@ module ActiveRecord
# # => ['0', '27761', '173']
#
def pluck(*column_names)
- column_names = column_names.flatten
-
- if column_names.first.is_a?(Symbol) && self.column_names.include?(column_names.first.to_s)
- if column_names.one?
- column_names = "#{table_name}.#{column_names.first}"
+ column_names.map! do |column_name|
+ if column_name.is_a?(Symbol) && self.column_names.include?(column_name.to_s)
+ "#{table_name}.#{column_name}"
else
- column_names = column_names.collect{|column_name| "#{table_name}.#{column_name}"}
+ column_name
end
end
- if has_include?(column_names)
- construct_relation_for_association_calculations.pluck(column_names)
+ if has_include?(column_names.first)
+ construct_relation_for_association_calculations.pluck(*column_names)
else
- result = klass.connection.select_all(select(column_names).arel, nil, bind_values)
-
- keys = column_names.is_a?(Array) && !column_names.one? ? result.columns : [result.columns.first]
- columns = keys.map do |key|
+ result = klass.connection.select_all(select(column_names).arel, nil, bind_values)
+ columns = result.columns.map do |key|
klass.column_types.fetch(key) {
result.column_types.fetch(key) {
Class.new { def type_cast(v); v; end }.new
@@ -182,19 +174,14 @@ module ActiveRecord
}
end
- result.map do |attributes|
- if attributes.one?
- value = klass.initialize_attributes(attributes).values.first
-
- columns.first.type_cast(value)
- else
- values = klass.initialize_attributes(attributes).values
+ result = result.map do |attributes|
+ values = klass.initialize_attributes(attributes).values
- values.each_with_index.map do |value, i|
- columns[i].type_cast(value)
- end
+ columns.zip(values).map do |column, value|
+ column.type_cast(value)
end
end
+ columns.one? ? result.map!(&:first) : result
end
end