diff options
author | Pratik Naik <pratiknaik@gmail.com> | 2009-03-11 15:24:30 +0000 |
---|---|---|
committer | Pratik Naik <pratiknaik@gmail.com> | 2009-03-11 15:24:30 +0000 |
commit | 106976df0911e423042ec4abc165fd561766a047 (patch) | |
tree | f1f1678e5f545bc3db9a2f2764b339e323667c6f /activerecord/lib | |
parent | f23adf0ed4bd596c9e7688455489a79f8b35eb3f (diff) | |
download | rails-106976df0911e423042ec4abc165fd561766a047.tar.gz rails-106976df0911e423042ec4abc165fd561766a047.tar.bz2 rails-106976df0911e423042ec4abc165fd561766a047.zip |
Ensure ActiveRecord::Base.find_in_batches fires doesnt fire an extra query unless needed
Diffstat (limited to 'activerecord/lib')
-rw-r--r-- | activerecord/lib/active_record/batches.rb | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/activerecord/lib/active_record/batches.rb b/activerecord/lib/active_record/batches.rb index 4ea932f34d..03bd4f9f93 100644 --- a/activerecord/lib/active_record/batches.rb +++ b/activerecord/lib/active_record/batches.rb @@ -49,12 +49,15 @@ module ActiveRecord raise "You can't specify a limit, it's forced to be the batch_size" if options[:limit] start = options.delete(:start).to_i + batch_size = options.delete(:batch_size) || 1000 - with_scope(:find => options.merge(:order => batch_order, :limit => options.delete(:batch_size) || 1000)) do + with_scope(:find => options.merge(:order => batch_order, :limit => batch_size)) do records = find(:all, :conditions => [ "#{table_name}.#{primary_key} >= ?", start ]) while records.any? yield records + + break if records.size < batch_size records = find(:all, :conditions => [ "#{table_name}.#{primary_key} > ?", records.last.id ]) end end |