Mongo Tableクラスファイル取得MongoCursor(カーソル)実装メソッド解析_PHPチュートリアル

require_once 'Hrs/Mongo/Config.php';
抽象クラス Hrs_Mongo_Table
{
protected $_db = '';
protected $_name = '';
protected $_data = array();
protected $c_options = array(
'fsync'=>true,
'safe'=>true
);
protected $u_options = array(
//'upsert'=>false,
'複数'=> ;true,
'fsync'=>true,
'safe'=>true
);
/*
protected $r_options = array(
);*/
protected $d_options = array(
'fsync'= >true,
'justOne'=>false,
'safe'=>true
);
protected function _setAdapter($database=''){
if(!$database)
throw new Zend_Exception('Mongodbデータ库名は空にすることはできません');
Hrs_Mongo_Config::selectDB($database);
}
public function __construct() {
if(Hrs_Mongo_Config::$conn instanceof Mongo){
$name = t;_名前;
$defDb = Hrs_Mongo_Config::$defaultDb;
$this->_db = $defDb->$name;
}else{
throw new Zend_Exception('Mongodbサービス务器连接失败');
}
}
公開機能insert($data){
if(!$this->testLink()) return false;
$ret = $this->db->insert($data, $this->c_options);
return $ret;
}
public function update($data, $where){
if(!$this->testLink()) return false;
return $this->_db->update($where, $ data, $this->u_options);
}
public function find($where=array(),$limit=0){
if($this->testLink()) {
if($limit>0 ){
$this->_data = $where ? $this->_db->find($where)->limit($limit)->snapshot() : $this->_db->gt;find()->limit($limit)- >snapshot();
}else{
$this->data = $where ? $this->_db->find($where)->limit($limit)->snapshot() : $this->_db->gt;find()->limit($limit)- >snapshot();
}
}
return $this;
}
//カーソルを見つける
/*
* 获取游标对象
*/
パブリック関数 look($where=array(),$fields=array( )){
if($this->testLink()) {
if($fields){
return $where ? $this->db->find($where,$fields): $this->_db->find()->fields($fields);
}else{
return $where ? $this->_db->find($where) : $this->_db->find();
}
}
return false;
}
public function delete($where){
if( !$this->testLink()) return false;
return $this->_db->remove($where, $this->d_options);
}
パブリック関数dropMe(){
if(! $this->testLink()) return false;
return $this->_db->drop();
}
public function __toString(){
return $this->_data;
}
public function toArray(){
$tmpData = array();
foreach($this->_data as $id=>$row){
$one_row = array();
foreach($row as $key=> $col){
$one_row[$key] = $col;
}
$one_row['_id'] = $id;
$tmpData[] = $one_row;
}
return $tmpData;
}
保護された関数testLink(){
return Hrs_Mongo_Config::$linkStatus == '成功' ? true :false;
}
}

第二の方法





复制代码

代码如下:


public function find($where=array(),$field=array()){

/*
* 获取游标对象
*/
public function getCursor(){
return $this->_data;
}