Module: Resque::Reports::Common::BatchedReport

Extended by:
ActiveSupport::Concern
Defined in:
lib/resque/reports/common/batched_report.rb

Instance Method Summary collapse

Instance Method Details

#connection ⇒ Object

Internal: Подключение используемое для выполнения запросов

Returns connection adapter



15
16
17
 
# File 'lib/resque/reports/common/batched_report.rb', line 15

def connection
  ActiveRecord::Base.connection
end

#data_each(force = false) ⇒ Object

Internal: Выполняет запрос отчета пачками и выполняет block для каждой пачки

Переопредленный метод из Resque::Reports

Returns Nothing



23
24
25
26
27
28
29
 
# File 'lib/resque/reports/common/batched_report.rb', line 23

def data_each(force = false)
  0.step(data_size, batch_size) do |batch_offset|
    connection.execute(batched_query(batch_offset)).each do |element|
      yield element
    end
  end
end

#data_size ⇒ Object

Internal: Возвращает общее кол-во строк в отчете

Переопредленный метод из Resque::Reports

Returns Fixnum



35
36
37
 
# File 'lib/resque/reports/common/batched_report.rb', line 35

def data_size
  @data_size ||= connection.execute(count_query)[0]['count'].to_i
end