mongo Table類(lèi)文件獲取MongoCursor(游標(biāo))的實(shí)現(xiàn)方法分析

更新時(shí)間：2013年07月01日 09:57:29 作者：

本篇文章是對(duì)mongo Table類(lèi)文件獲取MongoCursor(游標(biāo))的實(shí)現(xiàn)方法進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下

MongoCursor Object
游標(biāo)類(lèi)

Mongo
Config.php配置文件
Table.php（mongodb操作數(shù)據(jù)庫(kù)類(lèi)文件）

Config.php配置文件

復(fù)制代碼代碼如下:

<?php
require_once 'Zend/Exception.php';
class Hrs_Mongo_Config
{
    const VERSION = '1.7.0';
    const DEFAULT_HOST = 'localhost';
    const DEFAULT_PORT = 27017;
    private static $host = self::DEFAULT_HOST ;
    private static $port = self::DEFAULT_PORT ;
    private static $options = array(
            'connect' => true,
            'timeout' => 30,
            //'replicaSet' => '' //If this is given, the master will be determined by using the ismaster database command on the seeds
    );
    public static $conn = '';
    public static $defaultDb = '';
    public static $linkStatus = '';
    public static function set($server = 'mongodb://localhost:27017', $options = array('connect' => true)) {
        if(!$server){
            $url = 'mongodb://'.self::$host.':'.self::$port;
        }
        if(is_array($server)){
            if(isset($server['host'])){
                self::$host = $server['host'];
            }
            if(isset($server['port'])){
                self::$port = $server['port'];
            }
            if(isset($server['user']) && isset($server['pass'])){
                $url = 'mongodb://'.$server['user'].':'.$server['pass'].'@'.self::$host.':'.self::$port;
            }else{
                $url = 'mongodb://'.self::$host.':'.self::$port;
            }
        }
        if(is_array($options)){
            foreach (self::$options as $o_k=>$o_v){
                if(isset($options[$o_k]))
                    self::$options[$o_k] = $o_v;
            }
        }
        try{                        
            self::$conn = new Mongo($url, self::$options);
            self::$linkStatus = 'success';
        }catch (Exception $e){
            self::$linkStatus = 'failed';
        }
        if(isset($server['database'])){
            self::selectDB($server['database']);
        }
    }
    public static function selectDB($database){
        if($database){
            try {
                if(self::$linkStatus=='success')
                    self::$defaultDb = self::$conn->selectDB($database);
                return self::$defaultDb;
            }
            catch(InvalidArgumentException $e) {
                throw new Zend_Exception('Mongodb數(shù)據(jù)庫(kù)名稱不正確');
            }
        }else{
            throw new Zend_Exception('Mongodb數(shù)據(jù)庫(kù)名稱不能為空');
        }
    }
}

Table.php（mongodb操作數(shù)據(jù)庫(kù)類(lèi)文件）

復(fù)制代碼代碼如下:

<?php
require_once 'Hrs/Mongo/Config.php';
abstract class Hrs_Mongo_Table
{
    protected $_db = '';
    protected $_name = '';
    protected $_data = array();
    protected $c_options = array(
            'fsync'=>true,
            'safe'=>true
    );
    protected $u_options = array(
    //'upsert'=>false,
            'multiple'=>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數(shù)據(jù)庫(kù)名稱不能為空');
        Hrs_Mongo_Config::selectDB($database);
    }
    public function __construct() {
        if(Hrs_Mongo_Config::$conn instanceof Mongo){
            $name = $this->_name;
            $defDb = Hrs_Mongo_Config::$defaultDb;
            $this->_db = $defDb->$name;
        }else{
            throw new Zend_Exception('Mongodb服務(wù)器連接失敗');
        }
    }
    public function 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->find()->limit($limit)->snapshot();
            }else{
                $this->_data = $where ? $this->_db->find($where)->limit($limit)->snapshot() : $this->_db->find()->limit($limit)->snapshot();
            }
        }
        return $this;
    }
    //find cursor
    /*
     * 獲取游標(biāo)對(duì)象
     */
    public function 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);
    }
    public function 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;
    }
    protected function testLink(){
        return Hrs_Mongo_Config::$linkStatus == 'success' ? true :false;
    }
}

要點(diǎn)注意?。?！
第一種方法

復(fù)制代碼代碼如下:

    //find cursor
    /*
     * 獲取游標(biāo)對(duì)象
     */
    public function 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;
    }

第二種方法

復(fù)制代碼代碼如下:

    public function find($where=array(),$field=array()){
        if($this->testLink()) {
            $this->_data = $this->_db->find($where,$field)->sort(array("_id" => -1));
        }
        return $this;
    }

復(fù)制代碼代碼如下:

    /*
     * 獲取游標(biāo)對(duì)象
     */
    public function getCursor(){
     return $this->_data;
    }

第二種需要的是find得到的不是數(shù)組
find($where)->getCursor();是MongoCursor Object

注意注意
find()返回的是當(dāng)前對(duì)象
toArray()方法是把當(dāng)前對(duì)象轉(zhuǎn)換為數(shù)組
getCursor()方法是把當(dāng)前對(duì)象轉(zhuǎn)換為MongoCursor Object（游標(biāo)對(duì)象）

相關(guān)文章

PHP實(shí)現(xiàn)簡(jiǎn)單數(shù)字分頁(yè)效果
我們平時(shí)在開(kāi)發(fā)中，經(jīng)常需要用到分頁(yè)，在項(xiàng)目中要用到分頁(yè)。分頁(yè)功能是經(jīng)常使用的一個(gè)功能，下面我們就來(lái)簡(jiǎn)單分享個(gè)數(shù)字的分頁(yè)效果
2015-07-07
PHP工廠模式簡(jiǎn)單實(shí)現(xiàn)方法示例
這篇文章主要介紹了PHP工廠模式簡(jiǎn)單實(shí)現(xiàn)方法,簡(jiǎn)單說(shuō)明了工廠模式的概念、原理并結(jié)合實(shí)例形式分析了php實(shí)現(xiàn)工廠模式的相關(guān)操作技巧,需要的朋友可以參考下
2018-05-05
PHP中時(shí)間處理類(lèi)Carbon的用法詳解
Carbon?是php的日期處理類(lèi)庫(kù)（A?simple?PHP?API?extension?for?DateTime.），繼承了PHP的?Datetime?類(lèi)。本文將詳細(xì)講解一下該類(lèi)的使用，需要的可以參考一下
2022-05-05
php實(shí)現(xiàn)微信公眾號(hào)主動(dòng)推送消息
這篇文章主要介紹了php實(shí)現(xiàn)微信公眾號(hào)主動(dòng)推送消息的方法，PHP版微信公共平臺(tái)消息主動(dòng)推送，突破訂閱號(hào)一天只能發(fā)送一條信息限制,需要的朋友可以參考下
2015-12-12
靜態(tài)html文件執(zhí)行php語(yǔ)句的方法(推薦)
下面小編就為大家?guī)?lái)一篇靜態(tài)html文件執(zhí)行php語(yǔ)句的方法(推薦)。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
2016-11-11
PHP 多進(jìn)程解決難題
PHP在很多時(shí)候不適合做常駐的SHELl進(jìn)程, 他沒(méi)有專門(mén)的gc例程, 也沒(méi)有有效的內(nèi)存管理途徑. 所以如果用PHP做常駐SHELL, 你會(huì)經(jīng)常被內(nèi)存耗盡導(dǎo)致abort而unhappy.
2009-06-06
這篇文章主要介紹了php實(shí)現(xiàn)的簡(jiǎn)易掃雷游戲,涉及php字符串及流程控制的相關(guān)技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下
2015-07-07