class ActiveRecord::Batches::BatchEnumerator
Attributes
The primary key value at which the BatchEnumerator
ends, inclusive of the value.
The relation from which the BatchEnumerator
yields batches.
The primary key value from which the BatchEnumerator
starts, inclusive of the value.
Public Instance Methods
The size of the batches yielded by the BatchEnumerator
.
# File activerecord/lib/active_record/relation/batches/batch_enumerator.rb, line 27 def batch_size @of end
Deletes records in batches. Returns the total number of rows affected.
Person.in_batches.delete_all
See Relation#delete_all
for details of how each batch is deleted.
# File activerecord/lib/active_record/relation/batches/batch_enumerator.rb, line 65 def delete_all sum(&:delete_all) end
Destroys records in batches. Returns the total number of rows affected.
Person.where("age < 10").in_batches.destroy_all
See Relation#destroy_all
for details of how each batch is destroyed.
# File activerecord/lib/active_record/relation/batches/batch_enumerator.rb, line 96 def destroy_all sum do |relation| relation.destroy_all.count(&:destroyed?) end end
Yields an ActiveRecord::Relation
object for each batch of records.
Person.in_batches.each do |relation| relation.update_all(awesome: true) end
# File activerecord/lib/active_record/relation/batches/batch_enumerator.rb, line 107 def each(&block) enum = @relation.to_enum(:in_batches, of: @of, start: @start, finish: @finish, load: false, order: @order, use_ranges: @use_ranges) return enum.each(&block) if block_given? enum end
Looping through a collection of records from the database (using the all
method, for example) is very inefficient since it will try to instantiate all the objects at once.
In that case, batch processing methods allow you to work with the records in batches, thereby greatly reducing memory consumption.
Person.in_batches.each_record do |person| person.do_awesome_stuff end Person.where("age > 21").in_batches(of: 10).each_record do |person| person.party_all_night! end
If you do not provide a block to each_record
, it will return an Enumerator for chaining with other methods:
Person.in_batches.each_record.with_index do |person, index| person.award_trophy(index + 1) end
# File activerecord/lib/active_record/relation/batches/batch_enumerator.rb, line 52 def each_record(&block) return to_enum(:each_record) unless block_given? @relation.to_enum(:in_batches, of: @of, start: @start, finish: @finish, load: true, order: @order).each do |relation| relation.records.each(&block) end end
Touches records in batches. Returns the total number of rows affected.
Person.in_batches.touch_all
See Relation#touch_all
for details of how each batch is touched.
# File activerecord/lib/active_record/relation/batches/batch_enumerator.rb, line 85 def touch_all(...) sum do |relation| relation.touch_all(...) end end
Updates records in batches. Returns the total number of rows affected.
Person.in_batches.update_all("age = age + 1")
See Relation#update_all
for details of how each batch is updated.
# File activerecord/lib/active_record/relation/batches/batch_enumerator.rb, line 74 def update_all(updates) sum do |relation| relation.update_all(updates) end end