<?php/** * PHP操作mongodb數據庫操作類 */class Database {  protected $database  = '';  protected $mo;  /**   * 構造方法   */  public function __construct() {    $server = DBSERVER;    $user = DBUSER;    $password = DBPASS;    $port = DBPORT;    $database = DBNAME;    $mongo = $this->getInstance($server, $user, $password, $port);    $this->database = $mongo->$database;  }  /**   * 數據庫單例方法   * @param $server   * @param $user   * @param $password   * @param $port   * @return Mongo   */  public function getInstance($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 Mongo("mongodb://{$user}:{$password}@{$server}:{$port}");          } else {            $this->mo = new Mongo("mongodb://{$server}:{$port}");          }        } else {          $this->mo = new Mongo("mongodb://{$server}");        }      } else {        $this->mo = new Mongo();      }      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;  }  /**   * 查詢指定一條數據   * @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'];  }}?>