1

我是 Ruby 的新手，但我在其他编程语言方面有很多经验。我需要迭代大量记录（来自数据库或任何持久存储）。存储引擎允许我按范围检索部分记录。在 PHP 中，我通常编写自定义迭代器来加载记录范围，并在需要时加载记录的下一部分并忘记前一部分。脚本内存使用和存储请求计数之间的一些权衡。像这样的东西（从这里的评论复制）：

class Database_Result_Iterator {
...
private $_db_resource = null;
private $_loaded = false;
private $_valid = false;

function rewind() {
    if ($this->_db_resource) {
        mysql_free($this->_db_resource);
        $this->_db_resource = null;
    }
    $this->_loaded = false;
    $this->_valid = false;
}

function valid() {
    if ($this->_loaded) {
        $this->load();
    }
    return $this->_valid;
}

private function load() {
    $this->_db_resource = mysql_query(...);
    $this->_loaded = true;
    $this->next(); // Sets _valid
}

}

这种方法在 Ruby 中是如何转变的？即我有一些类Voter和方法get_votes返回所有投票属于当前选民对象。可以检索的不是具有所有投票的数组，而是可以迭代的投票集合。我应该如何实施？

更新

请不要将 ActiveRecord 和 RDBMS 视为仅一种可能的存储。Redis 作为存储和 LRANGE 之类的命令又如何呢？我对解决 Ruby 中此类问题的通用代码模式感兴趣。

4

3 回答 3

4

来自Ruby on Rails的指南：

User.all.each do |user|
  NewsLetter.weekly_deliver(user)
end

非常低效。首先，您可能希望在数据库中进行大部分过滤。ActiveRecord 提供了一个为此调用的方法find_each：

User.find_each(:batch_size => 5000) do |user|
  NewsLetter.weekly_deliver(user)
end

该:batch_size参数允许获取数据切片而不是获取整个结果集。在大多数情况下非常有帮助。

但是，您可能首先不想对所有记录进行操作：

User.with_newsletter.each do |user| 
   NewsLetter.weekly_deliver(user)
end

with_newsletter所谓的作用域在哪里。

于 2013-05-11T12:33:37.310 回答
2

我真的不明白这个问题的意义。AR 是用于查询 RDBMS 的 API，这就是您在 AR 中的操作方式。

如果你想做redis，你必须自己在驱动程序级别编写它，或者为Redis找到与AR类似的抽象......我认为DataMapper有一个redis适配器。如果有一种通用的方法可以对任何数据存储执行此操作，那么它很可能在 DataMapper 中，但是在创建自己的存储时要遵循的基本模式是查看 AR 如何实现 find_each/find_in_batches 并为您选择的存储执行此操作。

于 2013-05-11T13:16:30.727 回答
1

听起来您想使用find_each（http://apidock.com/rails/ActiveRecord/Batches/ClassMethods/find_each）。这使您可以通过加载少量数据来迭代大型数据集，迭代它们，然后加载另一个批次等等。

User.find_each do |user|
  user.do_some_stuff
end

将遍历所有用户，而不会一次将大量用户加载到内存中。

于 2013-05-11T12:32:47.200 回答