Module: Believer::Purging

Included in:
Query
Defined in:
lib/believer/purging.rb

Instance Method Summary collapse

Instance Method Details

#delete_all ⇒ Object

Directly deletes rows the query references. No object are loaded.



14
15
16
17
18
 
# File 'lib/believer/purging.rb', line 14

def delete_all
  del = Delete.new(:record_class => self.record_class)
  del.wheres = self.wheres.dup
  del.execute
end

#delete_all_chunked(options = {}) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/believer/purging.rb', line 20

def delete_all_chunked(options = {})
  cnt = count
  chunk_size = options[:delete_batch_chunk_size] || (self.limit_to.nil? ? nil : self.limit_to.size) || cnt
  key_cols = self.record_class.primary_key_columns
  deleted_count = 0
  while deleted_count < cnt
    batch = Batch.new(:record_class => @record_class)
    rows_to_delete = clone.select(key_cols).limit(chunk_size).execute
    rows_to_delete.each do |row_to_delete|
      batch << Delete.new(:record_class => self.record_class).where(row_to_delete)
    end
    batch.execute
    deleted_count += batch.commands.size
  end
  deleted_count
end

#destroy_all ⇒ Object

Destroys all objects returned by the query. This first loads the object before deleting, allowing callbacks to be called.



5
6
7
8
9
10
11
 
# File 'lib/believer/purging.rb', line 5

def destroy_all
  objects = to_a
  objects.each do |obj|
    obj.destroy
  end
  objects.size
end