时时商务社区

标题: php实现的mongodb操作类 [打印本页]

作者: 网络通达 时间: 2018-2-14 05:45

         mongo_db.php
throwError('集合不能为空！');
}

//判断是否传递了host和port
if (NULL !== $host) {
   $this->host = $host;
}

if (NULL !== $port) {
   $this->port = $port;
}

$this->table = $table;

$this->mongo = new MongoClient($this->host . ':' . $this->port);
if ($this->getVersion() >= '0.9.0') {
   $this->dbname = $this->mongo->selectDB($dbname);
   $this->db = $this->dbname->selectCollection($table);
} else {
   $this->db = $this->mongo->$dbname->$table;
}
  }

  public function getVersion()
  {
return MongoClient::VERSION;
  }

  /**
* 单例模式
* @return Mongo|null
*/
  //public static function getInstance($host=null, $port=null, $dbname=null, $table=null){
  //
  //  if(!(self:

instanceof instanceof self)){
// self:

instanceof = new self($host, $port, $dbname, $table);
  //  }
  //
  //  return self:

instanceof;
  //}

  /**
* 插入一条数据
* @param array $doc
*/
  public function insert($doc = array())
  {
if (empty($doc)) {
   $this->throwError('插入的数据不能为空！');
}
//保存数据信息
try {
   if (!$this->db->insert($doc)) {
      throw new MongoException('插入数据失败');
   }
} catch (MongoException $e) {
   $this->throwError($e->getMessage());
}
  }

  /**
* 插入多条数据信息
* @param array $doc
*/
  public function insertMulti($doc = array())
  {
if (empty($doc)) {
   $this->throwError('插入的数据不能为空！');
}
//插入数据信息
foreach ($doc as $key => $val) {
   //判断$val是不是数组
   if (is_array($val)) {
      $this->insert($val);
   }
}
  }

  /**
* 查找一条记录
* @return array|null
*/
  public function findOne($where = NULL)
  {
if (NULL === $where) {
   try {
      if ($result = $this->db->findOne()) {
      return $result;
      } else {
      throw new MongoException('查找数据失败');
      }
   } catch (MongoException $e) {
      $this->throwError($e->getMessage());
   }
} else {
   try {
      if ($result = $this->db->findOne($where)) {
      return $result;
      } else {
      throw new MongoException('查找数据失败');
      }
   } catch (MongoException $e) {
      $this->throwError($e->getMessage());
   }
}

  }

  /**
* todo 带条件的随后做
* 查找所有的文档
* @return MongoCursor
*/
  public function find($where = NULL)
  {
if (NULL === $where) {

   try {
      if ($result = $this->db->find()) {

      } else {
      throw new MongoException('查找数据失败');
      }
   } catch (MongoException $e) {
      $this->throwError($e->getMessage());
   }
} else {
   try {
      if ($result = $this->db->find($where)) {

      } else {
      throw new MongoException('查找数据失败');
      }
   } catch (MongoException $e) {
      $this->throwError($e->getMessage());
   }
}

$arr = array();
foreach ($result as $id => $val) {
   $arr[] = $val;
}

return $arr;
  }

  /**
* 获取记录条数
* @return int
*/
  public function getCount()
  {
try {
   if ($count = $this->db->count()) {
      return $count;
   } else {
      throw new MongoException('查找总数失败');
   }
} catch (MongoException $e) {
   $this->throwError($e->getMessage());
}
  }

  /**
* 获取所有的数据库
* @return array
*/
  public function getDbs()
  {
return $this->mongo->listDBs();
  }

  /**
* 删除数据库
* @param null $dbname
* @return mixed
*/
  public function dropDb($dbname = NULL)
  {
if (NULL !== $dbname) {
   $retult = $this->mongo->dropDB($dbname);
   if ($retult['ok']) {
      return TRUE;
   } else {
      return FALSE;
   }
}
$this->throwError('请输入要删除的数据库名称');
  }

  /**
* 强制关闭数据库的链接
*/
  public function closeDb()
  {
$this->mongo->close(TRUE);
  }

  /**
* 输出错误信息
* @param $errorInfo 错误内容
*/
  public function throwError($errorInfo='')
  {
echo "出错了：$errorInfo";
die();
  }

}
以上所述就是本文的全部内容了，希望大家能够喜欢。


您可能感兴趣的文章:

php对mongodb的扩展(初识如故)

PHP对MongoDB[NoSQL]数据库的操作

解析PHP中常见的mongodb查询操作

PHP实现的MongoDB数据库操作类分享

高效mongodb的php分页类（不使用skip）

PHP中MongoDB数据库的连接、添加、修改、查询、删除等操作实例

php实现的mongodb操作类实例

php操作MongoDB类实例

PHP7之Mongodb API使用详解

php mongodb操作类带几个简单的例子

php封装的mongodb操作类代码

php实现的mongoDB单例模式操作类

欢迎光临时时商务社区 (http://bbs.4435.cn/)