модуль ActiveRecord::Calculations
Вычисления Active Record
Методы экземпляра публичного доступа
# File activerecord/lib/active_record/relation/calculations.rb, line 122 def async_average(column_name) async.average(column_name) end
Аналогично average, но выполняет запрос асинхронно и возвращает ActiveRecord::Promise.
# File activerecord/lib/active_record/relation/calculations.rb, line 108 def async_count(column_name = nil) async.count(column_name) end
Аналогично count, но выполняет запрос асинхронно и возвращает ActiveRecord::Promise.
# File activerecord/lib/active_record/relation/calculations.rb, line 405 def async_ids async.ids end
Аналогично ids, но выполняет запрос асинхронно и возвращает ActiveRecord::Promise.
# File activerecord/lib/active_record/relation/calculations.rb, line 152 def async_maximum(column_name) async.maximum(column_name) end
Аналогично maximum, но выполняет запрос асинхронно и возвращает ActiveRecord::Promise.
# File activerecord/lib/active_record/relation/calculations.rb, line 137 def async_minimum(column_name) async.minimum(column_name) end
Аналогично minimum, но выполняет запрос асинхронно и возвращает ActiveRecord::Promise.
# File activerecord/lib/active_record/relation/calculations.rb, line 359 def async_pick(*column_names) async.pick(*column_names) end
Аналогично pick, но выполняет запрос асинхронно и возвращает ActiveRecord::Promise.
# File activerecord/lib/active_record/relation/calculations.rb, line 330 def async_pluck(*column_names) async.pluck(*column_names) end
Аналогично pluck, но выполняет запрос асинхронно и возвращает ActiveRecord::Promise.
# File activerecord/lib/active_record/relation/calculations.rb, line 182 def async_sum(identity_or_column = nil) async.sum(identity_or_column) end
Аналогично sum, но выполняет запрос асинхронно и возвращает ActiveRecord::Promise.
# File activerecord/lib/active_record/relation/calculations.rb, line 116 def average(column_name) calculate(:average, column_name) end
Вычисляет среднее значение в заданном столбце. Возвращает nil если нет строк. См. calculate для примеров с параметрами.
Person.average(:age) # => 35.8
# File activerecord/lib/active_record/relation/calculations.rb, line 217
def calculate(operation, column_name)
operation = operation.to_s.downcase
if @none
case operation
when "count", "sum"
result = group_values.any? ? Hash.new : 0
return @async ? Promise::Complete.new(result) : result
when "average", "minimum", "maximum"
result = group_values.any? ? Hash.new : nil
return @async ? Promise::Complete.new(result) : result
end
end
if has_include?(column_name)
relation = apply_join_dependency
if operation == "count"
unless distinct_value || distinct_select?(column_name || select_for_count)
relation.distinct!
relation.select_values = Array(klass.primary_key || table[Arel.star])
end
# PostgreSQL: ORDER BY expressions must appear in SELECT list when using DISTINCT
relation.order_values = [] if group_values.empty?
end
relation.calculate(operation, column_name)
else
perform_calculation(operation, column_name)
end
end Вычисляет агрегированные значения в заданном столбце. Методы для count, sum, average, minimum и maximum добавлены в качестве сокращений.
Person.calculate(:count, :all) # The same as Person.count
Person.average(:age) # SELECT AVG(age) FROM people...
# Selects the minimum age for any family without any minors
Person.group(:last_name).having("min(age) > 17").minimum(:age)
Person.sum("2 * age")
Существует два основных формата вывода:
-
Единичное агрегированное значение: единичное значение приводится к типу
Integerдля COUNT,Floatдля AVG и типу заданного столбца для всего остального. -
Сгруппированные значения: возвращает упорядоченный хэш значений, сгруппированных по ним. Принимает имя столбца или имя ассоциации belongs_to.
values = Person.group('last_name').maximum(:age) puts values["Drake"] # => 43 drake = Family.find_by(last_name: 'Drake') values = Person.group(:family).maximum(:age) # Person belongs_to :family puts values[drake] # => 43 values.each do |family, max_age| ... end
# File activerecord/lib/active_record/relation/calculations.rb, line 94
def count(column_name = nil)
if block_given?
unless column_name.nil?
raise ArgumentError, "Column name argument is not supported when a block is passed."
end
super()
else
calculate(:count, column_name)
end
end Подсчет записей.
Person.count # => the total count of all people Person.count(:age) # => returns the total count of all people whose age is present in database Person.count(:all) # => performs a COUNT(*) (:all is an alias for '*') Person.distinct.count(:age) # => counts the number of different age values
Если count используется с Relation#group, возвращает Hash, ключи которого представляют агрегированный столбец, а значения — соответствующие количества:
Person.group(:city).count
# => { 'Rome' => 5, 'Paris' => 3 }
Если count используется с Relation#group для нескольких столбцов, возвращает Hash, ключами которого являются массивы, содержащие индивидуальные значения каждого столбца, а значение каждого ключа — count.
Article.group(:status, :category).count
# => {["draft", "business"]=>10, ["draft", "technology"]=>4, ["published", "technology"]=>2}
Если count используется с Relation#select, он подсчитает выбранные столбцы:
Person.select(:age).count # => counts the number of different age values
Примечание: не все допустимые выражения Relation#select являются допустимыми выражениями count. Подробности зависят от базы данных. В недопустимых случаях выбрасывается ошибка из базы данных.
При передаче блока загружает все записи в отношении, если оно еще не загружено. Вызывает блок с каждой записью в отношении. Возвращает количество записей, для которых блок возвращает истинное значение.
Person.count { |person| person.age > 21 }
# => counts the number of people older that 21
Примечание: если в отношении много записей, загрузка всех записей может привести к проблемам с производительностью.
# File activerecord/lib/active_record/relation/calculations.rb, line 367
def ids
primary_key_array = Array(primary_key)
if loaded?
result = records.map do |record|
if primary_key_array.one?
record._read_attribute(primary_key_array.first)
else
primary_key_array.map { |column| record._read_attribute(column) }
end
end
return @async ? Promise::Complete.new(result) : result
end
if has_include?(primary_key)
relation = apply_join_dependency.group(*primary_key_array)
return relation.ids
end
columns = arel_columns(primary_key_array)
relation = spawn
relation.select_values = columns
result = if relation.where_clause.contradiction?
ActiveRecord::Result.empty
else
skip_query_cache_if_necessary do
klass.with_connection do |c|
c.select_all(relation, "#{klass.name} Ids", async: @async)
end
end
end
result.then { |result| type_cast_pluck_values(result, columns) }
end Возвращает идентификаторы базовой модели для отношения, используя первичный ключ таблицы
Person.ids # SELECT people.id FROM people Person.joins(:company).ids # SELECT people.id FROM people INNER JOIN companies ON companies.id = people.company_id
# File activerecord/lib/active_record/relation/calculations.rb, line 146 def maximum(column_name) calculate(:maximum, column_name) end
Вычисляет максимальное значение в заданном столбце. Значение возвращается с тем же типом данных, что и столбец, или nil если нет строк. См. calculate для примеров с параметрами.
Person.maximum(:age) # => 93
# File activerecord/lib/active_record/relation/calculations.rb, line 131 def minimum(column_name) calculate(:minimum, column_name) end
Вычисляет минимальное значение в заданном столбце. Значение возвращается с тем же типом данных, что и столбец, или nil если нет строк. См. calculate для примеров с параметрами.
Person.minimum(:age) # => 7
# File activerecord/lib/active_record/relation/calculations.rb, line 348
def pick(*column_names)
if loaded? && all_attributes?(column_names)
result = records.pick(*column_names)
return @async ? Promise::Complete.new(result) : result
end
limit(1).pluck(*column_names).then(&:first)
end Выбирает значение(я) из указанного(ых) столбца(ов) в текущем отношении. Это сокращение для relation.limit(1).pluck(*column_names).first, и оно полезно в основном, когда у вас есть отношение, уже суженное до одной строки.
Как и pluck, pick загрузит только фактическое значение, а не весь объект записи, поэтому он также более эффективен. Значение, как и при использовании pluck, приводится к типу данных столбца.
Person.where(id: 1).pick(:name) # SELECT people.name FROM people WHERE id = 1 LIMIT 1 # => 'David' Person.where(id: 1).pick(:name, :email_address) # SELECT people.name, people.email_address FROM people WHERE id = 1 LIMIT 1 # => [ 'David', 'david@loudthinking.com' ]
# File activerecord/lib/active_record/relation/calculations.rb, line 287
def pluck(*column_names)
if @none
if @async
return Promise::Complete.new([])
else
return []
end
end
if loaded? && all_attributes?(column_names)
result = records.pluck(*column_names)
if @async
return Promise::Complete.new(result)
else
return result
end
end
if has_include?(column_names.first)
relation = apply_join_dependency
relation.pluck(*column_names)
else
klass.disallow_raw_sql!(flattened_args(column_names))
columns = arel_columns(column_names)
relation = spawn
relation.select_values = columns
result = skip_query_cache_if_necessary do
if where_clause.contradiction?
ActiveRecord::Result.empty(async: @async)
else
klass.with_connection do |c|
c.select_all(relation.arel, "#{klass.name} Pluck", async: @async)
end
end
end
result.then do |result|
type_cast_pluck_values(result, columns)
end
end
end Используйте pluck в качестве сокращения для выбора одного или нескольких атрибутов без загрузки всего объекта записи на строку.
Person.pluck(:name)
вместо
Person.all.map(&:name)
Pluck возвращает Array значений атрибутов, типизированных в соответствии с именами выбранных столбцов, если их можно определить. Выборка SQL-фрагмента возвращает значения String по умолчанию.
Person.pluck(:name)
# SELECT people.name FROM people
# => ['David', 'Jeremy', 'Jose']
Person.pluck(:id, :name)
# SELECT people.id, people.name FROM people
# => [[1, 'David'], [2, 'Jeremy'], [3, 'Jose']]
Person.distinct.pluck(:role)
# SELECT DISTINCT role FROM people
# => ['admin', 'member', 'guest']
Person.where(age: 21).limit(5).pluck(:id)
# SELECT people.id FROM people WHERE people.age = 21 LIMIT 5
# => [2, 3]
Comment.joins(:person).pluck(:id, person: [:id])
# SELECT comments.id, people.id FROM comments INNER JOIN people on comments.person_id = people.id
# => [[1, 2], [2, 2]]
Person.pluck(Arel.sql('DATEDIFF(updated_at, created_at)'))
# SELECT DATEDIFF(updated_at, created_at) FROM people
# => ['0', '27761', '173']
См. также ids.
# File activerecord/lib/active_record/relation/calculations.rb, line 172
def sum(initial_value_or_column = 0, &block)
if block_given?
map(&block).sum(initial_value_or_column)
else
calculate(:sum, initial_value_or_column)
end
end Вычисляет сумму значений в заданном столбце. Значение возвращается с тем же типом данных, что и столбец, 0 если нет строк. См. calculate для примеров с опциями.
Person.sum(:age) # => 4562
Если задан блок, загружаются все записи в соотношении, если соотношение еще не загружено. Вызывается блок для каждой записи в соотношении. Возвращает сумму initial_value_or_column и значений, возвращаемых блоком:
Person.sum { |person| person.age } # => 4562
Person.sum(1000) { |person| person.age } # => 5562
Примечание: если в соотношении много записей, загрузка всех записей может привести к проблемам с производительностью.
© 2004–2021 David Heinemeier Hansson
Licensed under the MIT License.