0

ID を別のコレクションに参照するだけの Mongo コレクションがあります。仮説として、私が具体的に言及しているコレクションは次のように呼ばれる可能性があります。

あるきます。Walks には owner_id への参照があります。飼い主は毎日たくさんのペットと散歩をしています。私がやりたいのは、N 個の owner_id のリストについて Walks をクエリし、owner_id によって所有者とグループごとに行った最後の散歩だけを取得することです。上記のリストですべての散歩のリストを取得するには、次のようにします。

Walk.any_in(:owner_id => list_of_ids)

私の質問は、list_of_ids を照会し、owner_id ごとに 1 つのウォークのみを取得する方法があるかどうかです (フィールドでソートし、created_at各ウォークが次のような owner_id によってポイントされるハッシュで返すことができる最後のものを取得します:

{ 5 => {..walk data..}, 10 => {.. walk data ..}}

4

1 に答える 1

0

これは、MongoDB の group コマンドを使用した回答です。テストの目的で、created_at の代わりに walk_time を使用しました。これがお役に立てば幸いです。

class Owner
  include Mongoid::Document
  field :name, type: String
  has_many :walks
end

class Walk
  include Mongoid::Document
  field :pet_name, type: String
  field :walk_time, type: Time
  belongs_to :owner
end

テスト/ユニット/walk_test.rb

require 'test_helper'

class WalkTest < ActiveSupport::TestCase
  def setup
    Owner.delete_all
    Walk.delete_all
  end

  test "group in Ruby" do
    walks_input = {
        'George' => [ ['Fido',  2.days.ago], ['Fifi',  1.day.ago],  ['Fozzy',    3.days.ago] ],
        'Helen'  => [ ['Gerty', 4.days.ago], ['Gilly', 2.days.ago], ['Garfield', 3.days.ago] ],
        'Ivan'   => [ ['Happy', 2.days.ago], ['Harry', 6.days.ago], ['Hipster',  4.days.ago] ]
    }
    owners = walks_input.map do |owner_name, pet_walks|
      owner = Owner.create(name: owner_name)
      pet_walks.each do |pet_name, time|
        owner.walks << Walk.create(pet_name: pet_name, walk_time: time)
      end
      owner
    end
    assert_equal(3, Owner.count)
    assert_equal(9, Walk.count)
    condition = { owner_id: { '$in' => owners[0..1].map(&:id) } } # don't use all owners for testing
    reduce = <<-EOS
      function(doc, out) {
        if (out.last_walk == undefined || out.last_walk.walk_time < doc.walk_time)
          out.last_walk = doc;
      }
    EOS
    last_walk_via_group = Walk.collection.group(key: :owner_id, cond: condition, initial: {}, reduce: reduce)
    p last_walk_via_group.collect{|r|[Owner.find(r['owner_id']).name, r['last_walk']['pet_name']]}
    last_walk = last_walk_via_group.collect{|r|Walk.new(r['last_walk'])}
    p last_walk
  end
end

テスト出力

Run options: --name=test_group_in_Ruby

# Running tests:

[["George", "Fifi"], ["Helen", "Gilly"]]
[#<Walk _id: 4fbfa7a97f11ba53b3000003, _type: nil, pet_name: "Fifi", walk_time: 2012-05-24 15:39:21 UTC, owner_id: BSON::ObjectId('4fbfa7a97f11ba53b3000001')>, #<Walk _id: 4fbfa7a97f11ba53b3000007, _type: nil, pet_name: "Gilly", walk_time: 2012-05-23 15:39:21 UTC, owner_id: BSON::ObjectId('4fbfa7a97f11ba53b3000005')>]
.

Finished tests in 0.051868s, 19.2797 tests/s, 38.5594 assertions/s.

1 tests, 2 assertions, 0 failures, 0 errors, 0 skips
于 2012-05-25T15:51:01.963 に答える