php mongodb操作类 找了很久，找不到合适用的（有的都是旧版mongo的,不是mongoDb的，吐血~），硬着头皮在2G的网络翻遍了不太好看的PHP官方文档，写了个简单的操作类，测试也简单地测试了一下，其他更多的操作和功能，还是得去翻官方文档...
<?php /** * @author Administrator * @date 2020/9/1 15:24 * @desciption:mongodb 操作类 */ declare(strict_types=1); class MongoDb { public static $_instance = null; public $conf = null; public $handle = null; public $_and = []; public $_or = []; public $collection = ""; public $limit = 0; public $skip = 0; public $_field = []; public $_sort = []; public static function getInstance($conf = null){ if(self::$_instance === null){ self::$_instance = new self($conf); } return self::$_instance; } private function __construct($conf=null) { $this->conf = $conf; if(!isset($this->conf["type"]) || empty($this->conf["type"])){ $this->conf["type"] = "mongodb"; } $this->connect(); } public function connect(){ if(!empty($this->conf["user"]) && !empty($this->conf["password"])){ $uri = "{$this->conf["type"]}://{$this->conf["user"]}:{$this->conf["password"]}@"; }else{ $uri = "{$this->conf["type"]}://"; } $uri .= "{$this->conf['host']}:{$this->conf['port']}/{$this->conf["db"]}"; try { $this->handle = new MongoDBDriverManager($uri); }catch (Exception $exception){ throw new Exception($exception->getMessage()); } } public function collection(string $collection){ $this->collection = $this->conf["db"] . "." . $collection; return $this; } public function where(array $where){ if(empty($where)){ $this->echoError(new Exception("param where is empty")); } $this->_and = array_merge($this->_and,$where); return $this; } public function orWhere(array $where){ if(empty($where)){ $this->echoError(new Exception("param where is empty")); } $this->_or = array_merge($this->_or,$where); return $this; } public function limit(int $limit){ $this->limit = $limit; return $this; } public function skip(int $skip){ $this->skip = $skip; return $this; } public function field(string $field,bool $_id=true){ if(!empty($field)){ $fieldArr = explode(",",$field); if(is_array($fieldArr)){ foreach($fieldArr as $val){ $this->_field[$val] = 1; } } } if(!$_id){ $this->_field["_id"] = 0; } return $this; } public function sort(string $field,int $sort){ $this->_sort["field"] = $field; $this->_sort["rule"] = $sort; return $this; } public function find(){ return $this->query(); } public function findOne(){ $this->limit = 1; $this->skip = 0; return $this->query(); } public function count(){ $filter = $this->getWhere(); $aggregate = [ "aggregate"=>str_replace($this->conf["db"].".","",$this->collection), "pipeline" => [ ['$match'=>$filter], ['$count'=>"count"], ], "cursor" => (object)array() ]; $command = new MongoDBDriverCommand($aggregate); $result = $this->command($this->conf["db"],$command); return $result ? $result->toArray()[0]->count : false; } public function sum(string $field){ $filter = $this->getWhere(); $aggregate = [ "aggregate"=>str_replace($this->conf["db"].".","",$this->collection), "pipeline" => [ ['$match' => $filter], [ '$group' => [ '_id' => '', 'total' => ['$sum' => '$' . $field], ] ], ], "cursor" => (object)array() ]; $command = new MongoDBDriverCommand($aggregate); $result = $this->command($this->conf["db"],$command); return $result ? $result->toArray()[0]->total : false; } public function getWhere(){ $filter = []; if(!empty($this->_and)){ $filter = array_merge($filter,$this->_and); } if(!empty($this->_or)){ foreach($this->_or as $key =>$val) { $filter['$or'][][$key] = $val; } } return $filter; } public function getQuery(){ $filter = $this->getWhere(); if(!empty($this->_field)){ $queryOptions["projection"] = $this->_field; } if(!empty($this->_sort)){ $queryOptions["sort"] = [$this->_sort["field"]=>$this->_sort["rule"]]; } if($this->limit > 0){ $queryOptions["limit"] = $this->limit; } if($this->skip > 0){ $queryOptions["skip"] = $this->skip; } $query = new MongoDBDriverQuery($filter,$queryOptions); return $query; } public function query(){ $query = $this->getQuery(); try { $result = $this->handle->executeQuery($this->collection,$query); }catch (Exception $exception){ $this->echoError($exception); $result = false; } $this->init(); return $result?:false; } /** * @param array $data * @param bool $batch 是否批量 * @return mixed */ public function insert(array $data,bool $batch=false){ $write = new MongoDBDriverBulkWrite(); if($batch){ foreach($data as $val){ $write->insert($val); } }else{ $write->insert($data); } $result = $this->execute($this->collection,$write); return $result ? $result->getInsertedCount() : false; } /** * @param array $update * @param bool $multi true 匹配所有文档 false 匹配一个 * @param bool $upsert true 匹配不到将插入 * @return bool * @throws Exception */ public function update(array $update,bool $multi = false, bool $upsert = true){ if(empty($this->_and)){ $this->echoError(new Exception("update where is empty")); } $write = new MongoDBDriverBulkWrite(); $write->update( $this->_and, ['$set'=>$update], ['multi' => $multi, 'upsert' => $upsert] ); $result = $this->execute($this->collection,$write); return $result ? $result->getUpsertedCount() + $result->getMatchedCount() : false; } public function delete(bool $all=false){ if(empty($this->_and)){ $this->echoError(new Exception("delete where is empty")); } $write = new MongoDBDriverBulkWrite(); $write->delete($this->_and,['limit'=>$all]); $result = $this->execute($this->collection,$write); return $result ? $result->getDeletedCount() : false; } /** * @param array $pipeline * $pipeline 参数说明： * [ * [ * '$match' => [ * 'time' => ['$lt'=>1598864580] * ], * ], * [ * '$group' => [ * "_id"=>'$time', "total" => ['$sum' => 1] * ], * ], * [ * '$limit' => 3 * ], * [ * '$sort' => ['total' => -1] * ] * ] * @return bool */ public function aggregate(array $pipeline){ $aggregate = [ "aggregate"=>str_replace($this->conf["db"].".","",$this->collection), "pipeline" => $pipeline, "cursor" => (object)array() ]; $command = new MongoDBDriverCommand($aggregate); $result = $this->command($this->conf["db"],$command); return $result ? $result->toArray() : false; } public function execute($namespace,$object){ try { $result = $this->handle->executeBulkWrite($namespace,$object); }catch (Exception $exception){ $this->echoError($exception); } $this->init(); return $result; } public function command($db,$command){ try { $result = $this->handle->executeCommand($db,$command); }catch (Exception $exception){ $this->echoError($exception); } $this->init(); return $result; } public function echoError(Exception $exception){ throw new Exception($exception->getMessage()); } public function init(){ $this->_and = []; $this->_or = []; $this->collection = ""; $this->limit = 0; $this->skip = 0; $this->_field = []; $this->_sort = []; } } //$db = MongoDB::getInstance([ // "type" => "mongodb", // "host" => "127.0.0.1", // "port" => "27017", // "db" => "db", // "user" => "", // "password" => "" //]); //查询 //$result = $db->collection("message")->Where(["time"=>['$lte'=>1598864449]])->sort("time",-1)->find(); //$result = $db->collection("message")->Where(["time"=>['$lte'=>1598864449]])->count(); //$result = $db->collection("message")->Where(["time"=>['$lte'=>1598864449]])->sum("time"); //写入 //$result = $db->collection("message")->insert([ // "from" => "a", // "type" => "write", // "content" => "哈哈", // "time" => time(), //]); //更新 //$result = $db->collection("message")->where(["from"=>"a"])->update(["type"=>"ssd"]); //删除 //$result = $db->collection("message")->where(["from"=>"a"])->delete(); //aggregate 聚合 //$result = $db->collection("message")->aggregate([ // ['$match'=>['time'=>['$gte'=>1598955498]]], // ['$group' => ["_id"=>'$time', "total" => ['$sum' => 1]]] //]); //var_dump($result);
发现有错误的地方，欢迎指正一下~~