0

PHP で mongo::command を使用して MapReduce を構築しようとしましたが、コードを実行するたびに次のエラーが発生します。PHP Fatal Error, call to undefined method "mongo:command"

私のコード:

try {
    $map = new MongoCode("function() {
                    if (!this.tags) {
                        return;
                    }

                    for (index in this.tags) {
                        emit(this.tags[index], 1);
                    }");
    $reduce = new MongoCode("function(previous, current) {
                                var count = 0;

                                for (index in current) {
                                   count += current[index];
                                 }

                                return count;
                            }");
    $tags = $this->db->command(array(         //Line the error is found on
             "mapreduce" => "blog", 
             "map" => $map,
             "reduce" => $reduce));
    $con=$this->db->selectCollection($tags['result'])->find();
    var_dump($con);
}
catch(MongoCursorException $e) {
    echo "error message: ".$e->getMessage()."\n";
    echo "error code: ".$e->getCode()."\n";
}

$this->db私の接続 (以前に定義された) を指しblog、コレクションであることに注意してください。

参考のために私が使用した：http://php.net/manual/en/mongodb.command.php

私が使用しているOSはUbuntu 12.04で、mongo.soを含む両方のphp.iniファイルを再確認しました-データの挿入やフェッチなど、mongodbで通常のクエリを実行できますが、コマンドだけが機能していないようです。

4

1 に答える 1

0

あなたは好きなコレクションを選びますか$d = $m->demo;

php.net:

<?php
$m = new MongoClient();
$d = $m->demo;
$c = $d->poiConcat;

$r = $d->command(array(
'geoNear' => "poiConcat",      // Search in the poiConcat collection
'near' => array(-0.08, 51.48), // Search near 51.48°N, 0.08°E
'spherical' => true,           // Enable spherical search
'num' => 5,                    // Maximum 5 returned documents
));
print_r($r);
?>

あなたのコードでは、コレクションを選択しなかったと思います $d = $this->db->demo;代わりにコレクション名を入力してくださいdemo

try {
    $map = new MongoCode("function() {
                if (!this.tags) {
                    return;
                }

                for (index in this.tags) {
                    emit(this.tags[index], 1);
                }");
    $reduce = new MongoCode("function(previous, current) {
                            var count = 0;

                            for (index in current) {
                               count += current[index];
                             }

                            return count;
                        }");
     $d = $this->db->demo;// attention 
     $tags = $d->command(array(         //Line the error is found on
         "mapreduce" => "blog", 
         "map" => $map,
         "reduce" => $reduce));
     $con=$d->selectCollection($tags['result'])->find();
     var_dump($con);
}
catch(MongoCursorException $e) {
   echo "error message: ".$e->getMessage()."\n";
   echo "error code: ".$e->getCode()."\n";
}

サンプルの編集:i このサンプルを参照してください

try {
   $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; }");
      $db=new Mongo("mongodb://sepidar:123@localhost:27017/admin");                 
      $d = $db->SepidarSoft_CBMS;// attention 
      $tags = $d->command(array(         //Line the error is found on
          'mapReduce'=>'RunUser',
          "map" => $map,
          "reduce" => $reduce,
          "out" => array('merge'=>'SepidarSoft_CBMS', 'db'=> 'RunUser')
      ));
      print_r($tags);
}
catch(MongoCursorException $e) {
     echo "error message: ".$e->getMessage()."\n";
     echo "error code: ".$e->getCode()."\n";
}

私のmongodb構造体

結果

 Array
(
    [result] => Array
    (
        [db] => RunUser
        [collection] => SepidarSoft_CBMS
    )

    [timeMillis] => 2
    [counts] => Array
    (
        [input] => 1
        [emit] => 1
        [reduce] => 0
        [output] => 1
    )

    [ok] => 1
)
于 2013-05-04T15:03:55.323 に答える