说到php连mongoDB,不得不先介绍一下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

与mongoDB建立连接:

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

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

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

如果想连接到其他的主机,可以这样写:$mongo = new Mongo("mongodb://username:password@192.168.1.22:12345");

另外一种方式,实例化mongo类,再手动建立连接:(http://www.my400800.cn )

$mongo = new Mongo("mongodb://username:password@192.168.1.22:12345",array('connect'=>false));//初始化类

$mongo->connect();//创建连接

Mongo类中有用的一些方法:

Mongo::listDBs()

http://us.php.net/manual/en/mongo.listdbs.php

返回一个包含当前mongo服务上的库(DB)信息的数组。

$mo = new Mongo();

$dbs = $mo->listDBs();//获得一个包含db信息的数组

Mongo::selectCollection($db,$coll)

http://us.php.net/manual/en/mongo.selectcollection.php

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

$mo = new Mongo();

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

选择想要的数据库(Mongo类):

一种方式:

http://us.php.net/manual/en/mongo.get.php

$mongo = new Mongo();

$db = $mongo->foo;//得到一个MongoDB对象

另一种方式:

http://us.php.net/manual/en/mongo.selectdb.php

$mongo = new Mongo();

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

MongoDB中有用的函数:

创建一个MongoDB对象

http://us.php.net/manual/en/mongodb.construct.php

$mo = new Mongo();

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

删除当前DB

http://us.php.net/manual/en/mongodb.drop.php

$db = $mo->dbname;

$db->drop();

获得当前数据库名

http://us.php.net/manual/en/mongodb.–tostring.php

$db = $mo->dbname;

$db->_tostring();

选择想要的collection:

A:

$mo = new Mongo();

$coll = $mo->dbname->collname;//获得一个collection对象

B:

$db = $mo->selectDB(’dbname’);

$coll = $db->collname;

C:

$db = $mo->dbname;

$coll = $db->selectCollectoin(’collname’);//获得一个collection对象

插入数据(MongoCollection对象):

http://us.php.net/manual/en/mongocollection.insert.php

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

array $a 要插入的数组

array $options 选项

safe 是否返回操作结果信息

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

例程:

$coll = $mo->db->foo;

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

$options = array(’safe’=>true);

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

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

删除数据库中的记录(MongoCollection对象):

http://us.php.net/manual/en/mongocollection.remove.php

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

array $criteria  条件

array $options 选项

safe 是否返回操作结果

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

justOne 是否只影响一条记录

例程:

$coll = $mo->db->coll;

$c = array(’a'=>1,’s’=>array(’$lt’=>100));

$options = array(’safe’=>true);

$rs = $coll->remove($c,$options);

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

更新数据库中的记录(MongoCollection对象):

http://us.php.net/manual/en/mongocollection.update.php

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

array $criteria  条件

array $newobj 要更新的内容

array $options 选项

safe 是否返回操作结果

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

upsert 是否没有匹配数据就添加一条新的

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

例程:

$coll = $mo->db->coll;

$c = array(’a'=>1,’s’=>array(’$lt’=>100));

$newobj = array(’e'=>’f',’x'=>’y');

$options = array(’safe’=>true,’multiple’=>true);

$rs = $coll->remove($c,$newobj,$options);

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

查询collection获得单条记录(MongoCollection类):

http://us.php.net/manual/en/mongocollection.findone.php

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

array $query 条件

array $fields 要获得的字段

例程:

$coll = $mo->db->coll;

$query = array(’s’=>array(’$lt’=>100));

$fields = array(’a'=>true,’b'=>true);

$rs = $coll->findOne($query,$fields);

如果有结果就返回一个array,如果没有结果就返回NULL

查询collection获得多条记录(MongoCollection类):

http://us.php.net/manual/en/mongocollection.find.php

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

array $query 条件

array $fields 要获得的字段

例程:

$coll = $mo->db->coll;

$query = array(’s’=>array(’$lt’=>100));

$fields = array(’a'=>true,’b'=>true);

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

返回一个游标记录对象MongoCursor。

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

http://us.php.net/manual/en/class.mongocursor.php

循环或的结果记录:

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

while($cursor->hasNext()){

$r = $cursor->getNext();

var_dump($r);

}

或者

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

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

var_dump($v);

}

或者

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

$array= iterator_to_array($cursor);

一个血的教训:

http://us.php.net/manual/en/mongocursor.snapshot.php

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

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

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

$cursor->snapshot();

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

var_dump($v);

}

下面让我们使用group操作,根据group_id分组,汇总计算count:

<?php

ini_set('mongo.native_long', 1);

$instance = new Mongo();

$instance = $instance->selectCollection('test', 'test');

$keys = array('group_id' => 1);

$initial = array('count' => 0);

$reduce = '
    function(obj, prev) {
        prev.count += obj.count;
    }
';

$result = $instance->group($keys, $initial, $reduce);

var_dump($result);

?>

结果和预想的有出入,count没有实现累加,而是变成了[object Object],目前,如果必须使用group操作,那么有两种方法可以缓解这个问题:

ini_set('mongo.native_long', 0);

$initial = array('count' => (float)0);

这两种方法都是治标不治本的权宜之计,既然当前PHP驱动里group的实现有问题,那我们就绕开它,用其它的方式实现同样的功能,这个方式就是MapReduce:

<?php

ini_set('mongo.native_long', 1);

$instance = new Mongo();

$instance = $instance->selectDB('test');

$map = '
    function() {
        emit(this.group_id, this.count);
    }
';

$reduce = '
    function(key, values) {
        var sum = 0;

for (var index in values) {
            sum += values[index];
        }

return sum;
    }
';

$result = $instance->command(array(
    'mapreduce' => 'test',
    'map'       => $map,
    'reduce'    => $reduce
));

$result = iterator_to_array($instance->{$result['result']}->find());

var_dump($result);

?>

转载于:https://www.cnblogs.com/jishu/archive/2011/09/15/2177620.html

用php实现mongoDB的基本操作相关推荐

  1. [ mongoDB ] - mongoDB的基本操作

    mongoDB的基本操作 强烈推荐参考官方用户手册: http://www.mongodb.org/display/DOCS   1)插入(insert) 插入的value是json对象,以下示例循环 ...

  2. [MongoDB] MongoDB的基本操作以及文档的增删改查

    参考视频 链接:https://pan.baidu.com/s/1tAWPEC8yppyrPupkUFdCWQ 提取码:gdn8 MongoDB的基本操作 基本概念 生活中:仓库.架子.物品 计算机: ...

  3. MongoDB 学习-MongoDB 的基本操作(二)

    1 MongoDB 的简介 MongoDB 是由C++编写的NOSQL 非关系型数据库,是非关系型数据库中最像关系型数据库的NoSQL 数据库. 2 MongoDB 和 关系型数据库对比 MongoD ...

  4. 孤荷凌寒自学python第六十三天学习mongoDB的基本操作并进行简单封装2

    孤荷凌寒自学python第六十三天学习mongoDB的基本操作并进行简单封装2 (完整学习过程屏幕记录视频地址在文末) 今天是学习mongoDB数据库的第九天. 今天继续学习mongoDB的简单操作, ...

  5. 头歌 MongoDB 数据库基本操作

    MongoDB 数据库基本操作 第1关:数据库创建 第2关:创建集合 第3关:文档操作一 第4关:文档操作二 第1关:数据库创建 pgrep mongo -l mongo use mydb db.my ...

  6. MongoDB的基本操作(创建数据库,数据表,查询数据表信息)

    今天,因为有朋友想要了解MongoDB的基本操作.所以,我就写一篇关于MongoDB的文章,占个坑以后有时间研究MongoDB再正式的写MongoDB的文章.关于MongoDB的安装,可以参考一下我的 ...

  7. mongodb:linux基本操作

    mongodb 基本操作 1.连接mongodb  mongo/bin目录下执行  ./mongo 或者全局直接 mongo 2.查看有哪些数据库 show dbs 3.查看当前所在数据库  db 4 ...

  8. 分布式数据库NoSQL(二)——MongoDB 数据库基本操作

    MongoDB 是一个基于分布式文件存储的数据库.由 C++ 语言编写.旨在为 WEB 应用提供可扩展的高性能数据存储解决方案. MongoDB 是一个介于关系数据库和非关系数据库之间的产品,是非关系 ...

  9. mongodb在mysql中怎么用,mongoDB数据库基本操作

    mongoDB中聚集集合(collection/coll)相当于mysql中的表 文档相当于mysql中的每一行数据 常用命令 1.获得帮助命令db.help() db.表名.help() db.表名 ...

  10. Mongodb aggregation 基本操作示例

    MongoDB二个主要的操作:一个是查询,另一个是统计.对于查询而言,主要是find()方法,再配合Filters组合多个查询条件. 对于统计而言,则主要是aggregate操作,比如 group.s ...

最新文章

  1. html form提交前验证,form表单提交前验证实现方法
  2. struts2官方 中文教程 系列一:创建一个struts2 web Application
  3. CSS样式让一个块在最上层中显示
  4. VTK:行军案用法实战
  5. Git初学札记(九)————EGit检出远程分支
  6. java封装需要多久_Java对时间操作的一些封装函数
  7. ExecutorService中submit和execute的区别转
  8. 梅花雨无法在 .net 2.0 下用行的问题
  9. idea每次都要配置tomcat_午饭收藏夹里的c位石锅拌饭,每次来到都要等位......
  10. 【BZOJ1057】[ZJOI2007] 棋盘制作(单调栈的运用)
  11. cuda驱动版本显卡对应关系
  12. Pt100 铂电阻的三线测温线路
  13. Eclipse中jsp文件ISO-8859-1编码转换为UTF-8或者GBK方法
  14. 又一个程序员,被抓捕!(真实事件)
  15. js之原生js轮盘抽奖实例分析(幸运大转盘抽奖)
  16. 西电计科操作系统实验
  17. 苹果的胜利:Adobe宣布Flash Media服务支持iOS设备运行Flash
  18. win10电脑插入耳机一边声音大一边声音小
  19. MySQL并发insert因唯一键导致的DeadLock
  20. 基于JAVA旅游景区预约管理系统计算机毕业设计源码+系统+mysql数据库+lw文档+部署

热门文章

  1. 【转】妈妈告诉我的细节
  2. [转]利用C#操作配置文件
  3. Python编码格式导致的csv读取错误
  4. ELK pipeline
  5. 不在更改国内网络账号的ID了
  6. 深入理解 Python 异步编程(上)
  7. 子群和Lagrange定理
  8. Spring-data-redis操作redis知识总结
  9. js圆角矩形旋转(div拼凑)
  10. c/c++将字符串中的空格替换成%20