PHP 操作mongodb api大部分方法

时间：2021-12-29 09:19:32
<?php

/* PHP mongodb

 * 全部curd操作

 * @author:xiaojiang

 * @date: 2014-10-27

 */

//查看 mongo类版本  1.30 以后版本使用 MongoClient

//Mongo::VERSION;

/*连接*/

    $m = new Mongo("mongodb://localhost");

    //连接多台

    //$m = new Mongo("mongodb://localhost:27017,localhost:27018");

//选择数据库

$db = $m->selectDB("banggoCMS");

    //$db = $m->banggoCMS;

$col = $db->dbeleComment2014;

/*新增*/

/*

  $opt = array(

      'fsync' => 1 //默认为 false , false时当日志配置开启时和 j 参数的功能类似 否则写操作会等到数据完全同步到硬盘后...true则忽略执行结果

      //...

  )

*/

//$ret = $col->insert( array('pid'=>2 , 'content'=>'test123') , $opt );

/*更新*/

    //$set

    //修改属性

    //$ret = $col->update( array('pid'=> 2 ), array('$set'=> array('content'=>'123456') ) );

    //$unset

    //删除某个属性$unset

    //$ret = $col->update( array('pid'=> 2 ), array('$unset'=> array('content'=>1 ,'contents'=>1) ) );

    //$push

    //为某个属性 新增/更新 一条记录 若属性不存在则新增属性

    //$ret = $col->update( array('pid'=> 2 ), array('$push'=> array('contents'=> array('v'=>1) ) ) );

    //$pushall

    //批量增加数据

    //$ret = $col->update( array('pid'=> 2 ), array('$pushAll'=> array('contents'=> array(1,2,3,4) ) ) );

    //$addToSet

    //和push功能类似 与$push不同的是$addToSet会保证元素的唯一性，防止重复添加

    //$ret = $col->update( array('pid'=> 2 ), array('$addToSet'=> array('contents'=> 1 ) ) );

    //$pop

    //删除字段数组中的第一条记录 。mongodb 1.1及以后的版本可以用 2或-2来删除两条，

    //$ret = $col->update( array('pid'=> 2 ), array('$pop'=> array('contents'=> -1 ) ) );

    //$pull   index

    //$ret = $col->update( array('pid'=> 2 ), array('$pull'=> array( 'contents' => 2 ) ) );

    //$pullAll

    //$ret = $col->update( array('pid'=> 2 ), array('$pullAll'=> array( 'contents' => array(1,2,3,4) ) ) );

    //$inc  $代表子项中的自身

    //$ret = $col->update( array('contents'=> 3 ), array('$inc'=> array('contents.$' => 100 )  ) );

    //$代表子项中的匹配记录自身

        //删除

        //$ret = $col->update( array('contents'=> 8 ), array('$unset'=> array('contents.$' => 1 )  ) );

        //修改

        //$ret = $col->update( array('contents'=> 2 ), array('$set'=> array('contents.$' => 11 )  ) );

        //添加 PS:更新的节点要是数组类型

        //  $ret = $col->update( array('contents.v'=> 34 ), array('$push'=> array('contents.$.test' => array('t1'=>1 ,'t2'=>2) ) ));

/*删除*/

    //$ret = $col->remove( array('pid'=> 2 ) );

    //只删除一条

    //$ret = $col->remove( array('pid'=> 2 ) , array("justOne" => true));

/*查询*/

 //$ret = $col->find( array('pid'=>2 , 'content'=>'test123') );

 //子查询

    //$ret = $col->findOne( array('pid'=>2 , 'contents'=>  1 ) );

    //$ret = $col->findOne( array('pid'=>2 , 'contents.t'=>  5 ) );

//获取总数

//$t = $ret->count();

//越过多少

//$ret = $col->find( array('pid'=>2) )->skip( 10 );

//排序

//$ret = $col->find( array('pid'=>2) )->sort(array("a" => 1)）;

//返回字段

//$ret = $col->find( array('pid'=>2), array('content') );

//$ret = $col->find( array('pid'=>2), array('content' => 0 ) ); //忽略字段

//返回对象  php >= 5.1  iterator_to_array

//var_dump( iterator_to_array( $ret ) );

//否则

//foreach( $ret  as $v){

//    var_dump( $v );

//}

//$ret = $col->findOne(array('pid'=>2 , 'content'=>'test123'));

// 直接返回数组

?>

相关文章