Contents

require 'active_support/concern'

module Journey::Resource::BatchWhere
  extend ActiveSupport::Concern

  included do

    def self.batch_where(clauses, batch_size=100)

      total_count = count_multiple(clauses)
      query_count = (total_count / batch_size.to_f).ceil.to_i

      (0 ... query_count).to_a.map do |batch_index|

        where_multiple clauses.merge({
          limit: batch_size,
          skip: batch_index * batch_size
        })

      end.flatten
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
embark-journey-0.1.4	lib/journey/resource/batch_where.rb