Added support for map-reduce

lib/mongo/collection.rb

@@ -298,6 +298,33 @@ module Mongo
       @db.drop_collection(@name)
     end
 
+    def mapreduce(map, reduce, options={})
+      case map
+      when Code
+      else
+        map = Code.new(map)
+      end
+
+      case reduce
+      when Code
+      else
+        reduce = Code.new(reduce)
+      end
+
+      hash = OrderedHash.new
+      hash['mapreduce'] = self.name
+      hash['map'] = map
+      hash['reduce'] = reduce
+      hash.merge! options
+
+      result = @db.db_command(hash)
+      if result["ok"] == 1
+      return @db[result["result"]]
+      else
+        raise Mongo::OperationFailure, "map-reduce failed: #{result['errmsg']}"
+      end
+    end
+
     # Perform a query similar to an SQL group by operation.
     #
     # Returns an array of grouped items.

test/test_collection.rb

@@ -265,6 +265,18 @@ class TestCollection < Test::Unit::TestCase
     assert c.closed?
   end
 
+  def test_mapreduce
+    @@test << { "user_id" => 1 }
+    @@test << { "user_id" => 2 }
+
+    m = "function() { emit(this.user_id, 1); }"
+    r = "function(k,vals) { return 1; }"
+    res = @@test.mapreduce(m, r);
+    assert res.find_one({"_id" => 1})
+    assert res.find_one({"_id" => 2})
+
+  end
+
   def test_saving_dates_pre_epoch
     begin
       @@test.save({'date' => Time.utc(1600)})