php操作mongodb教程
2015-11-01 13:48
549 查看
PHP的mongodb扩展安装
将mongo.so添加到php.ini
重启php-fpm生效
php的mongodb扩展,提供了4个核心类接口
1). 针对mongodb的连接操作类MongoClient http://www.php.net/manual/zh/class.mongoclient.php 2). 针对mongodb的数据库操作类MongoDB http://www.php.net/manual/zh/class.mongodb.php 3). 针对mongodb的集合操作类MongoCollection http://www.php.net/manual/zh/class.mongocollection.php 4). 针对mongodb的查询结果集(游标)操作类MongoCursor http://www.php.net/manual/zh/class.mongocursor.php连接MongoDB mongodb驱动连接格式为:mongodb://[username:password@]host1[:port1][,host2[:port2],…[,hostN[:portN]]][/[database][?options]],如:
mongodb://localhost
mongodb://user:password@localhost
mongodb://user:password@localhost/database
mongodb://example1.com:27017,example2.com:27017
mongodb://localhost,localhost:27018,localhost:27019
mongodb://host1,host2,host3/?slaveOk=true
mongodb://localhost/?safe=true
mongodb://host1,host2,host3/?safe=true;w=2;wtimeoutMS=2000
mongodb://rs1.example.com:27017,rs2.example.com:27017/?replicaSet=myReplSetName
mongodb://localhost/?journal=true&w=majority&wTimeoutMS=20000
具体含义参见《ttlsa教程系列之mongodb—(一)mongodb介绍》 http://www.ttlsa.com/html/1594.htmlPHP连接实例:
在连接到复制集时,用它来判断哪台是primary。返回主机名称、端口号、健康程度、状态(1-primary,2-secondary,0-other)、ping耗时、前一次ping的时间戳。
列出所有数据库,返回数据库名称、大小、是否为空以及总大小、ok状态。
选择数据库,返回数据库对象
选择表(集合),返回文档集合对象
列出所有集合,返回集合对象
获取当前选择的数据库名,返回数据库名
删除当前数据库
设置slaveok状态(可读状态设置)
获取slaveok当前状态
插入数据MongoCollection::insert(array $a,array $options)
array $a 要插入的数组
array $options 选项:safe 是否返回操作结果信息;fsync 是否直接插入到物理硬盘;w 写入份数;timeout 超时时间
删除集合中的记录MongoCollection::remove(array $criteria,array $options)
array $criteria 条件
array $options 选项: safe 是否返回操作结果; fsync 是否是直接影响到物理硬盘; justOne 是否只影响一条记录
更新集合中的记录MongoCollection::update(array $criceria,array $newobj,array $options)
array $criteria 条件
array $newobj 要更新的内容
array $options 选项: safe 是否返回操作结果; fsync 是否是直接影响到物理硬盘; upsert 是否没有匹配数据就添加一条新的; multiple 是否影响所有符合条件的记录,默认只影响一条
查询集合获取单条记录MongoCollection::findOne(array $query,array $fields)
array $query 条件
array $fields 要获得的字段
获取多条记录MongoCollection::find(array $query,array $fields)
array $query 条件
array $fields 要获得的字段
获取查询结果数量
选定列MongoCursor::fields
分页
排序MongoCursor::sort
取查询结果
快照MongoCursor::snapshot
保证一致性。在做find()操作时,获得$cursor之后,这个游标是动态的,在循环取结果过程中,如果有其他连接来更改符合条件的记录时,这个$cursor也会跟着变化的。$cursor->snapshot();之后,再插入或删除符合条件的记录时,获取的结果集将不再变化。如果是小于1M的结果集会自动被当作snapshot来处理。
如果要获取$cursor之后不变的结果需要这么做:
snapshot对findOne无效。
123456 | # https://github.com/mongodb/mongo-php-driver/archive/master.zip# unzip master.zip# /usr/local/php/bin/phpize# ./config --with-php-config=/usr/local/php/bin/php-config# make# make install |
1 2 | # vim /usr/local/php/etc/php.ini extension = mongo.so |
1 | # /usr/local/php/sbin/php-fpm -y /usr/local/php/etc/php-fpm.comf |
1). 针对mongodb的连接操作类MongoClient http://www.php.net/manual/zh/class.mongoclient.php 2). 针对mongodb的数据库操作类MongoDB http://www.php.net/manual/zh/class.mongodb.php 3). 针对mongodb的集合操作类MongoCollection http://www.php.net/manual/zh/class.mongocollection.php 4). 针对mongodb的查询结果集(游标)操作类MongoCursor http://www.php.net/manual/zh/class.mongocursor.php连接MongoDB mongodb驱动连接格式为:mongodb://[username:password@]host1[:port1][,host2[:port2],…[,hostN[:portN]]][/[database][?options]],如:
mongodb://localhost
mongodb://user:password@localhost
mongodb://user:password@localhost/database
mongodb://example1.com:27017,example2.com:27017
mongodb://localhost,localhost:27018,localhost:27019
mongodb://host1,host2,host3/?slaveOk=true
mongodb://localhost/?safe=true
mongodb://host1,host2,host3/?safe=true;w=2;wtimeoutMS=2000
mongodb://rs1.example.com:27017,rs2.example.com:27017/?replicaSet=myReplSetName
mongodb://localhost/?journal=true&w=majority&wTimeoutMS=20000
具体含义参见《ttlsa教程系列之mongodb—(一)mongodb介绍》 http://www.ttlsa.com/html/1594.htmlPHP连接实例:
1 2 3 4 5 | <?php $m = new MongoClient("mongodb://localhost/?journal=true&w=majority&wTimeoutMS=20000"); $m = new MongoClient("mongodb://rs1.example.com:27017,rs2.example.com:27017/?replicaSet=myReplSetName")); $m = new MongoClient("mongodb://rs1.example.com:27017", array("replicaSet" => "myReplSetName")); $m = new MongoClient("mongodb://rs1.example.com:27017,rs2.example.com:27017", array("replicaSet" => "myReplSetName","wTimeoutMS"=>20000)); |
1 | $m->getHosts(); |
1 | $m->listDBs(); |
123 | $db = $m->db_name;或$db = $m->selectDB(db_name); |
1 2 3 4 5 | $col = $m->selectCollection(db_name, col_name); 或 $col = $m->selectDB(db_name)->selectCollection(col_name); 或 $col = $m->db_name->col_name; |
1 | $col_list = $db->listCollections(); |
1 | $db_name = $db->__toString(); |
1 | $db->drop(); |
1 | $db->setSlaveOkay(true/false); |
1 | $db->getSlaveOkay(); |
array $a 要插入的数组
array $options 选项:safe 是否返回操作结果信息;fsync 是否直接插入到物理硬盘;w 写入份数;timeout 超时时间
1 2 3 4 5 | <?php $coll = $m->db_name->col_name; $a = array(’website'=>’www.ttlsa.com'); $options = array(’safe’=>true); $rs = $coll->insert($a,$options); $rs为数组,包含操作信息 |
array $criteria 条件
array $options 选项: safe 是否返回操作结果; fsync 是否是直接影响到物理硬盘; justOne 是否只影响一条记录
12345 | <?php$coll = $m->db_name->col_name;$c = array(’website'=>'www.ttlsa.com',’hit’=>array(’$lt’=>100));$options = array(’safe’=>true);$rs = $coll->remove($c,$options); $rs为数组,包含操作信息 |
array $criteria 条件
array $newobj 要更新的内容
array $options 选项: safe 是否返回操作结果; fsync 是否是直接影响到物理硬盘; upsert 是否没有匹配数据就添加一条新的; multiple 是否影响所有符合条件的记录,默认只影响一条
1 2 3 4 5 6 | <?php $coll = $m->db_name->coll_name; $c = array(’uid'=>888,’login_count’=>array(’$lt’=>100)); $newobj = array(’vip'=>’1',’score'=>’10000'); $options = array(’safe’=>true,’multiple’=>true); $rs = $coll->remove($c,$newobj,$options); $rs为数组,包含操作信息 |
array $query 条件
array $fields 要获得的字段
12345 | <?php$coll = $m->db_name->col_name;$query = array(’score’=>array(’$lt’=>10000));$fields = array(’uid'=>true,’vip'=>true);$rs = $coll->findOne($query,$fields); 返回array或null |
array $query 条件
array $fields 要获得的字段
1 2 3 4 5 6 | <?php $coll = $m->db_name->col_name; $query = array(’s’=>array(’$lt’=>100)); $query = array(’score’=>array(’$lt’=>10000)); $fields = array(’uid'=>true,’vip'=>true); $rs = $coll->find($query,$fields); 返回游标对象MongoCursor。 |
12 | $cursor = $coll->find();$num = $cursor->count(); |
1 2 3 | $cursor->fields(array(column_name1 => true, column_name2 => false)); 或 $cursor = $coll->find()->fields(array(column_name1 => true, column_name2 => false)); |
1 | $cursor = $coll->find()->limit(30)->skip(0); |
1 | $cursor = $coll->find()->sort(array(column_name1 => -1, column_name2 => 1)); |
123456789101112131415 | $cursor = $coll->find($query,$fields);while($cursor->hasNext()){ $r = $cursor->getNext(); var_dump($r);}或者$cursor = $coll->find($query,$fields);$r = array();foreache($cursor as $k=>$v){ var_dump($v); $r[] = $v;}或者$cursor = $coll->find($query,$fields);$array= iterator_to_array($cursor); |
保证一致性。在做find()操作时,获得$cursor之后,这个游标是动态的,在循环取结果过程中,如果有其他连接来更改符合条件的记录时,这个$cursor也会跟着变化的。$cursor->snapshot();之后,再插入或删除符合条件的记录时,获取的结果集将不再变化。如果是小于1M的结果集会自动被当作snapshot来处理。
如果要获取$cursor之后不变的结果需要这么做:
1 2 | $cursor = $coll->find($query,$fields); $cursor->snapshot(); |
相关文章推荐
- MongoDB自学日记1——基本操作
- Linux非法关机后重新开启MongoDB
- php 操作mongodb
- zendframwork2添加对mongodb的支持
- 用CRT connect MongoDB 使用Backspace无效
- centos安装mongodb
- MongoDB高级查询详细
- 通过Python将MongoDB导出的json数据转换成Mysql的insert语句导入
- MongoDB创建系统管理员账户和数据库管理员账户
- MongoDB文档的主键_id
- MongoDB基本命令---来自半瓶子
- 安装配置MongoDB数据库
- MongoDB(五)之分片
- MongoDB 3.0 导入命令
- MongoDB学习笔记(查询)
- spring boot 通过配置文件连接mongodb
- Mongodb数据导出工具mongoexport和导入工具mongoimport介绍
- spring boot 连接mongodb
- springmvc+mongodb+maven 项目搭建配置
- Spring MVC + Spring MongoDB + Querydsl 通过maven整合实例