Php操作mongodb的基本操作—增删改…

1. 连接mongodb数据库

直接实例化mongo类+创建连接：

$mo = new Mongo();//得到一个Mongo连接对象

实例化了一个Mongo类，并且与默认的localhost:27017端口的mongoDB建立连接。

如果相联系其他的mongodb数据库，可以如下方式：

$mongo = new Mongo("mongodb://username:password@192.168.1.22:端口号");

另外一种防暑，实现mongo类，手动连接

另外一种方式，实例化mongo类，再手动建立连接：
$mongo=new Mongo("mongodb://username:password@192.168.1.22:12345",array('connect'=>false));//初始化类

$mongo->connect();
 

Mongo类中有用的一些方法：

Mongo::listDBs() 

返回一个包含当前mongo服务上的库（DB）信息的数组。
$mo = new Mongo();
$dbs = $mo->listDBs();//获得一个包含db信息的数组

Mongo::selectCollection($db,$coll) 

返回一个当前连接下的某db中的collection对象。

$mo = new Mongo();

$coll = $mo->selectCollection(’db’,'mycoll’);//得到一个collection对象
 

选择要操作的数据库:

第一种方式：

$mongo = new Mongo();
$db = $mongo->db;//得到一个MongoDB对象

第二种方式：

$mongo = new Mongo();

$db = $mongo->selectDB(‘db’);//得到一个MongoDB对象

创建一个MongoDB对象:

$mo = new Mongo();

$db = new MongoDB($mo,’dbname’);//通过创建方式获得一个MongoDB对象
 

删除当前的数据库

$db = $mo->dbname;

$db->drop();
 

获得当前数据库的名称

$db = $mo->dbname;

$db->_tostring();
 

选择想要的collection(得到需要的表)

A:

$mo = new Mongo();

$coll = $mo->dbname->coll;

B:

$mo = new Mongo();

$db = $mo->selectDB(‘dbnamel’);//选择数据库

$coll = $db->coll;

C:

$mo = new Mongo();

$db = $mo->selectDB(‘dbnamel’);//选择数据库

$coll = $db->selectCollection(‘collname’);

插入数据（MongoCollection对象）：

MongoCollection::insert(array $a,array $options)

array $a 要插入的数组

array $options 选项

safe 是否返回操作结果信息

fsync 是否直接插入到物理硬盘

 

eg:

$mo = new Mongo();//建立mongodb连接

$coll = $mo->dbname->coll;//选择collection

$a = array(’a'=>;’b');

$options = array(’safe’=>;true);//构建选项数据

$rs =$coll->insert($a,$options);

$rs为一个array型的数组，包含操作信息

array(4) {

  ["n"]=>

  int(0)

  ["connectionId"]=>

  int(82343)

  ["err"]=>

  NULL

  ["ok"]=>

  float(1)

}

 

删除数据库中的记录（MongoCollection对象）：

MongoCollection::remove(array $criteria,array $options)

array $criteria 条件

array $options 选项

safe 是否返回操作结果

fsync 是否是直接影响到物理硬盘

justOne 是否只影响一条记录

eg:

$conn = new Mongo();

$db = $conn->selectDB(‘dbname’) ;

 

$coll = $db->coll;

$data = array('user_id'=>'32423434');

$option = array('safe'=>true);

$rs = $coll->remove($data,$option);

更新数据库中的记录（MongoCollection对象）：

MongoCollection::update(array $criceria,array $newobj,array $options)

array $criteria 条件

array $newobj 要更新的内容

array $options 选项

safe 是否返回操作结果

fsync 是否是直接影响到物理硬盘
upsert 是否没有匹配数据就添加一条新的

multiple 是否影响所有符合条件的记录，默认只影响一条
 

eg:

$conn = new Mongo();

$db = $conn->selectDB(‘dbname’) ;
 

$table = $db->ActivityModel;

$data = array('user_id'=>'32423434');

$newData = array('user_id'=>'123456dd','action_type'=>1,'pin_id'=>'12121212');

$option = array('safe'=>true,'upsert'=>true);

$rs = $table->update($data,$newData,$option);
 
 

查询collection获得单条记录（MongoCollection类）：

array MongoCollection::findOne(array $query,array $fields)

array $query 条件

array $fields 要获得的字段

eg：

$conn = new Mongo('mongodb://' . MONGODB_USER . ':' . MONGODB_PASSWORD . '@' . MONGODB_CONN_HOST);

$db = $conn->selectDB(MONGODB_DB_NAME) ;
 

$table = $db->coll;

$data = array('user_id'=>'123456dd');//查询条件

$fields = array('pin_id'=>true);//要查询的字段

$rs = $table->findOne($data,$fields);
 

var_dump($rs);
 

查询collection获得多条记录（MongoCollection类）：

MongoCursor MongoCollection::find(array $query,array $fields)

array $query 条件

array $fields 要获得的字段

 

$conn = new Mongo();

$db = $conn->selectDB(‘dbname’) ;

$table = $db->coll;

$data = array('action_type'=>1);//查询条件

$fields = array('pin_id'=>true,'user_id'=>true,'action_type'=>true);//要查询的字段

$cursor = $table->find($data,$fields);//进行查询

针对游标对象MongoCursor的操作(MongoCursor类)：
 

$table = $db->coll;

$data = array('action_type'=>1);//查询条件

$fields = array('pin_id'=>true,'user_id'=>true,'action_type'=>true);

$cursor = $table->find($data,$fields);
 

while($rs->hasNext())

{

$cursor = $rs->getNext();

var_dump($cursor);

}
 

或者
 
$table = $db->coll;

$data = array('action_type'=>1);//查询条件

$fields = array('pin_id'=>true,'user_id'=>true,'action_type'=>true);
$cursor = $table->find($data,$fields);
 

Foreach($curso as $k => $v)

{

var_dump($v);

}
 

或者
 

$table = $db->coll;

$data = array('action_type'=>1);//查询条件

$fields = array('pin_id'=>true,'user_id'=>true,'action_type'=>true);

$cursor = $table->find($data,$fields);
 

$array = iterator_to_array($cursor);//将查询结果放入数组

var_dump($array);
 

在我们做了find()操作，获得$cursor游标之后，这个游标还是动态的，也就是在我获得游标到我循环操作完成对应记录的过程中，默认情况下，这对符合条件的记录如果增加，结果集也会自动增加。换句话说，在我find()之后，到我的游标循环完成这段时间，如果再有符合条件的记录被插入到collection,那么这些记录也会被$cursor获得。

如果你想在获得$cursor之后的结果集不变化，需要这样做：

$cursor = $coll->find($query,$fields);

$cursor->snapshot();//该方法用来控制cursor是否动态

foreache($cursor as $k=>$v){

var_dump($v);

}
 
 

php的官方手册 ：http://us.php.net/manual/en/book.mongo.php

在php的mongo扩展中，提供了4类接口（对象）：

1，针对mongoDB连接的操作：Mongo
http://us.php.net/manual/en/class.mongo.php
2，针对mongoDB中数据库的操作：MongoDB
http://us.php.net/manual/en/class.mongodb.php
3，针对mongoDB中collection的操作：MongoCollection
http://us.php.net/manual/en/class.mongocollection.php
4，针对查询结果集的操作：MongoCursor
http://us.php.net/manual/en/class.mongocursor.php