php mongo 使用execute执行mapreduce报错

$map = "function() {
for (var i = 0; i < this.items.length; i++) {
emit(this.name, this.items[i].$param); } }";
$reduce = "function(name, sum) { return Array.sum(sum); }";
$opt = "{ out: 'totals' }";
$db->execute("db.stores.mapReduce($map, $reduce, $opt);");

报错信息:

Cannot run mapReduce command from eval()
阅读 3.2k
1 个回答

execute方法通过eval执行JS代码。eval好像Mongo 3里是deprecated。eval也用个global write lock,最好不用。

你可以用command方法,PHP.net上有个mapReduce例子(http://php.net/manual/en/mong...),下面给你参考:

// construct map and reduce functions
$map = new MongoCode("function() { emit(this.user_id,1); }");
$reduce = new MongoCode("function(k, vals) { ".
    "var sum = 0;".
    "for (var i in vals) {".
        "sum += vals[i];". 
    "}".
    "return sum; }");

$sales = $db->command(array(
    "mapreduce" => "events", 
    "map" => $map,
    "reduce" => $reduce,
    "query" => array("type" => "sale"),
    "out" => array("merge" => "eventCounts")));

但是我建议这样简单的mapreduce可以通过aggregation framework写出来。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题