github-migration/mongo-ruby-driver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

minor: mapreduce test added, check for version

Browse Source
This commit is contained in:
Kyle Banker 2009-12-16 11:01:35 -05:00
parent 2fb5c92b60
commit 0acafa2fdf
1 changed files with 42 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
test/test_collection.rb
View File

@ -91,12 +91,16 @@ class TestCollection < Test::Unit::TestCase
assert_equal ["a", "b", "c"], @@test.distinct("b.c").sort assert_equal ["a", "b", "c"], @@test.distinct("b.c").sort
end end
should "filter collection with query" do if @@version >= "1.2"
assert_equal [2, 3], @@test.distinct(:a, {:a => {"$gt" => 1}}).sort
end should "filter collection with query" do
assert_equal [2, 3], @@test.distinct(:a, {:a => {"$gt" => 1}}).sort
end
should "filter nested objects" do
assert_equal ["a", "b"], @@test.distinct("b.c", {"b.c" => {"$ne" => "c"}}).sort
end
should "filter nested objects" do
assert_equal ["a", "b"], @@test.distinct("b.c", {"b.c" => {"$ne" => "c"}}).sort
end end
end end
end end
@ -292,26 +296,42 @@ class TestCollection < Test::Unit::TestCase
assert c.closed? assert c.closed?
end end
def test_mapreduce if @@version < "1.1.1"
@@test << { "user_id" => 1 } def test_map_reduce
@@test << { "user_id" => 2 } @@test << { "user_id" => 1 }
@@test << { "user_id" => 2 }
m = "function() { emit(this.user_id, 1); }" m = "function() { emit(this.user_id, 1); }"
r = "function(k,vals) { return 1; }" r = "function(k,vals) { return 1; }"
res = @@test.map_reduce(m, r); res = @@test.map_reduce(m, r);
assert res.find_one({"_id" => 1}) assert res.find_one({"_id" => 1})
assert res.find_one({"_id" => 2}) assert res.find_one({"_id" => 2})
end end
def test_mapreduce_with_code_objects def test_map_reduce_with_code_objects
@@test << { "user_id" => 1 } @@test << { "user_id" => 1 }
@@test << { "user_id" => 2 } @@test << { "user_id" => 2 }
m = Code.new("function() { emit(this.user_id, 1); }") m = Code.new("function() { emit(this.user_id, 1); }")
r = Code.new("function(k,vals) { return 1; }") r = Code.new("function(k,vals) { return 1; }")
res = @@test.map_reduce(m, r); res = @@test.map_reduce(m, r);
assert res.find_one({"_id" => 1}) assert res.find_one({"_id" => 1})
assert res.find_one({"_id" => 2}) assert res.find_one({"_id" => 2})
end
def test_map_reduce_with_options
@@test.remove
@@test << { "user_id" => 1 }
@@test << { "user_id" => 2 }
@@test << { "user_id" => 3 }
m = Code.new("function() { emit(this.user_id, 1); }")
r = Code.new("function(k,vals) { return 1; }")
res = @@test.map_reduce(m, r, :query => {"user_id" => {"$gt" => 1}});
assert_equal 2, res.count
assert res.find_one({"_id" => 2})
assert res.find_one({"_id" => 3})
end
end end
def test_saving_dates_pre_epoch def test_saving_dates_pre_epoch