이 글의 내용은 mongodb 캡슐화의 여러 방법을 공유하는 것입니다. 이제 여러분과 공유합니다. 도움이 필요한 친구들이 참고할 수 있습니다.
이 글은 제가 php5.6을 위해 작성한 것입니다. 위의 내용은 php7mongodb의 캡슐화 클래스가 있는 경우 링크를 보내주시면 살펴보겠습니다
<?php/**
* Created by sublime.
* User: yuepeng
* Date: 2017/12/1
* Time: 15:44
*/namespace Lib;use MongoClient;//下面是驱动类，现在没有用到，我的版本php5.5，如果是php7就要用到这些类use MongoDB\BSON\ObjectID;use MongoDB\Driver\BulkWrite;use MongoDB\Driver\Command;use MongoDB\Driver\Cursor;use MongoDB\Driver\Exception\AuthenticationException;use MongoDB\Driver\Exception\BulkWriteException;use MongoDB\Driver\Exception\ConnectionException;use MongoDB\Driver\Exception\InvalidArgumentException;use MongoDB\Driver\Exception\RuntimeException;use MongoDB\Driver\Manager;use MongoDB\Driver\Query as MongoQuery;use MongoDB\Driver\ReadPreference;use MongoDB\Driver\WriteConcern;/**
* PHP操作mongodb数据库操作类
*/class MongoDb {
protected $database = ''; protected $mo; /**
* 构造方法
*/
public function __construct() {
$database = DBNAME; $mongo = $this->getConnect(DBSERVER, DBUSER, DBPASS, DBPORT); $this->database = $mongo->$database;
} /**
* 数据库单例方法
* @param $server
* @param $user
* @param $password
* @param $port
* test 测试
* @return Mongo
*/
/*public function getConnect($server, $user, $password, $port)
{
// echo "mongodb://{$server}:{$port}";die;
// $mongo = new MongoClient("mongodb://{$server}:{$port}");
$mongo = new MongoClient("mongodb://{$server}:{$port}");
return $mongo;
}*/
/**
* 数据库单例方法
* @param $server
* @param $user
* @param $password
* @param $port
* @return Mongo
*/
public function getConnect($server, $user, $password, $port) {
if (isset($this->mo)) { return $this->mo;
} else { if (!empty($server)) { if (!empty($port)) { if (!empty($user) && !empty($password)) { $this->mo = new MongoClient("mongodb://{$user}:{$password}@{$server}:{$port}");
} else { $this->mo = new MongoClient("mongodb://{$server}:{$port}");
}
} else { $this->mo = new MongoClient("mongodb://{$server}");
}
} else { $this->mo = new MongoClient();
} return $this->mo;
}
} /**
* 查询表中所有数据
* @param $table
* @param array $where
* @param array $sort
* @param string $limit
* @param string $skip
* @return array|int
*/
public function getAll($table, $where = array(), $sort = array(), $limit = '', $skip = '') {
if (!empty($where)) { $data = $this->database->$table->find($where);
} else { $data = $this->database->$table->find();
} if (!empty($sort)) { $data = $data->sort($sort);
} if (!empty($limit)) { $data = $data->limit($limit);
} if (!empty($skip)) { $data = $data->skip($skip);
} $newData = array(); while ($data->hasNext()) { $newData[] = $data->getNext();
} if (count($newData) == 0) { return 0;
} return $newData;
} /**
* 查询表中所有数据，将_id 对象变成数组
* @param $table
* @param array $where
* @param array $sort
* @param string $limit
* @param string $skip
* @return array
*/
public function getAllArray($table, $where = array(), $sort = array(), $limit = '', $skip = '') {
if (!empty($where)) { $data = $this->database->$table->find($where);
} else { $data = $this->database->$table->find();
} if (!empty($sort)) { $data = $data->sort($sort);
} if (!empty($limit)) { $data = $data->limit($limit);
} if (!empty($skip)) { $data = $data->skip($skip);
} $newData = array(); while ($data->hasNext()) { $newData[] = $data->getNext();
} if (count($newData) == 0) { return 0;
} foreach ($newData as $key => $val) { $id = $val['_id']->{'$id'}; $newData[$key]['_id'] = $id;
} return $newData;
} /**
* 查询指定一条数据
* @param $table
* @param array $where
* @return int
*/
public function getOne($table, $where = array()) {
if (!empty($where)) { $data = $this->database->$table->findOne($where);
} else { $data = $this->database->$table->findOne();
} return $data;
} /**
* 统计个数
* @param $table
* @param array $where
* @return mixed
*/
public function getCount($table, $where = array()) {
if (!empty($where)) { $data = $this->database->$table->find($where)->count();
} else { $data = $this->database->$table->find()->count();
} return $data;
} /**
* 直接执行mongo命令
* @param $sql
* @return array
*/
public function toExcute($sql) {
$result = $this->database->execute($sql); return $result;
} /**
* 分组统计个数
* @param $table
* @param $where
* @param $field
*/
public function groupCount($table, $where, $field) {
$cond = array( array( '$match' => $where,
), array( '$group' => array( '_id' => '$' . $field, 'count' => array('$sum' => 1),
),
), array( '$sort' => array("count" => -1),
),
); $this->database->$table->aggregate($cond);
} /**
* 删除数据
* @param $table
* @param $where
* @return array|bool
*/
public function toDelete($table, $where) {
$re = $this->database->$table->remove($where); return $re;
} /**
* 插入数据
* @param $table
* @param $data
* @return array|bool
*/
public function toInsert($table, $data) {
$re = $this->database->$table->insert($data); return $re;
} /**
* 更新数据
* @param $table
* @param $where
* @param $data
* @return bool
*/
public function toUpdate($table, $where, $data) {
$re = $this->database->$table->update($where, array('$set' => $data)); return $re;
} /**
* 获取唯一数据
* @param $table
* @param $key
* @return array
*/
public function distinctData($table, $key, $query = array()) {
if (!empty($query)) { $where = array('distinct' => $table, 'key' => $key, 'query' => $query);
} else { $where = array('distinct' => $table, 'key' => $key);
} $data = $this->database->command($where); return $data['values'];
}
}?>관련 권장 사항:
위 내용은 mongodb 캡슐화의 여러 방법 공유의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
