MongoConfig.php配置文件Table.php(mongodb操作數據庫類文件)

Config.php配置文件復制代碼 代碼如下:<?phprequire_once 'Zend/Exception.php';class Hrs_Mongo_Config{ const VERSION " /> 乳色吐息未增删樱花ED在线观看 ,刮伦人妇A极一片,久久精品AV无码亚洲色欲

天天躁日日躁狠狠躁AV麻豆-天天躁人人躁人人躁狂躁-天天澡夜夜澡人人澡-天天影视香色欲综合网-国产成人女人在线视频观看-国产成人女人视频在线观看

mongo Table類文件 獲取MongoCursor(游標)的實現方法分析

MongoCursor Object
游標類

Mongo
Config.php配置文件
Table.php(mongodb操作數據庫類文件)

Config.php配置文件
復制代碼 代碼如下:
<?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數據庫名稱不正確');
            }
        }else{
            throw new Zend_Exception('Mongodb數據庫名稱不能為空');
        }
    }
}

Table.php(mongodb操作數據庫類文件)
復制代碼 代碼如下:
<?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數據庫名稱不能為空');
        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服務器連接失敗');
        }
    }
    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
    /*
     * 獲取游標對象
     */
    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;
    }
}

要點注意!!!
第一種方法
復制代碼 代碼如下:
    //find cursor
    /*
     * 獲取游標對象
     */
    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 find($where=array(),$field=array()){
        if($this->testLink()) {
            $this->_data = $this->_db->find($where,$field)->sort(array("_id" => -1));
        }
        return $this;
    }

復制代碼 代碼如下:
    /*
     * 獲取游標對象
     */
    public function getCursor(){
     return $this->_data;
    }

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

注意注意
find()返回的是當前對象
toArray()方法是把當前對象轉換為數組
getCursor()方法是把當前對象轉換為MongoCursor Object(游標對象)

php技術mongo Table類文件 獲取MongoCursor(游標)的實現方法分析,轉載需保留來源!

鄭重聲明:本文版權歸原作者所有,轉載文章僅為傳播更多信息之目的,如作者信息標記有誤,請第一時間聯系我們修改或刪除,多謝。

主站蜘蛛池模板: 亚洲爆乳少妇精品无码专区 | 午夜性色一区二区三区不卡视频 | 午夜DJ国产精华日本无码 | 一攻多受h嗯啊巨肉bl巨污 | 俄罗斯孩交精品 | 兔费看少妇性L交大片免费 偷偷要色偷偷 | 久久久无码AV精品亚洲A片软件 | 国产精品久久毛片A片软件爽爽 | 中文字幕在线视频网站 | 2021久久99国产熟女人妻 | 国产日韩欧美高清免费视频 | 伊人久久大香线蕉综合亚洲 | 毛片大片免费看 | 九色PORNY蝌蚪视频首页 | 99在线观看免费视频 | 激情内射亚洲一区二区三区爱妻 | 亚洲日本欧美产综合在线 | 伦理 电影在线观看 | 动漫护士被乳羞羞漫 | 欧美日本韩国一二区视频 | 午夜日本大胆裸艺术 | 成年免费三级视频 | gogo亚洲肉体艺术照片9090 | 看80后操| 欧美AAAAAA级午夜福利视频 | 日本熟妇乱妇熟色A片蜜桃亚洲 | 好想被狂躁A片免费久99 | 黄瓜视频苹果直接安装 | 小776 论坛 | 爽爽窝窝午夜精品一区二区 | 制服的微热 | 国产精品欧美一区二区在线看 | 午夜免费无码福利视频麻豆 | 欧美精品99久久久啪啪 | 免费麻豆国产黄网站在线观看 | 男人和女人全黄一级毛片 | 好姑娘BD高清在线观看免费 | 欧美日韩精品不卡在线观看 | 免费三级播放器 | 久久国产乱子伦免费精品 | 午夜免费啪视频观看视频 |