Важно е да запомните, когато използвате mapReduce(), че върнатата стойност на функцията reduce() трябва да бъде със същата форма като тази, която очаквате да получите в елемента „стойности“ на функцията reduce() -- и това, на свой ред трябва да има същата форма като това, което се излъчва от функцията emit().
Дадена е колекция, съдържаща документи със следната форма:
> db.posts.count();
1000
> db.posts.findOne();
{
"_id" : 0,
"date_posted" : ISODate("2012-04-04T05:54:44.535Z"),
"topic_id" : "sierra"
}
Следният код ще създаде желания резултат:
<?php
$conn = new Mongo("localhost:$port");
$db = $conn->test;
$collection = $db->tst;
$map = new MongoCode(
"function() { emit( this.topic_id, { last_post: this.date_posted } ); }"
);
$reduce = new MongoCode(
"function(key, values) { ".
"var max = ISODate('1970-01-01T00:00:00Z'); ".
"values.forEach(function(val) { ".
"if ( max < val.last_post ) max = val.last_post; ".
"}); ".
"return {last_post : max}; " .
"}"
);
$result = $db->command( array(
"mapreduce" => "posts",
"map" => $map,
"reduce" => $reduce,
"query" => array( "topic_id" => "alpha"),
"out" => array( "merge" => "lastPosts")
)
);
echo "result: "; print_r($result);
$collection = $db->lastPosts;
$cursor = $collection->find()->limit(6);
date_default_timezone_set("UTC");
foreach( $cursor as $doc ) {
$date = date( "r", $doc['value']['last_post']->sec );
echo $doc['_id'] . " last visited at " . $date ."\n" ;
}
?>