之前,我讲解过PHP中mongodb扩展的安装,及启动,链接操作【忘记了?去看看吧!PHP操作Mongodb之一】。本文主要就是讲在PHP中Mongodb的增加,查询,修改及删除数据的操作。
1、增加数据
语法格式:
$db->insert($array); //参数表示需要插入的数据
例如:我们插入一个id为1,名称为PHP,年龄为25的数据。代码如下:
<?php //连接数据库 $connnect = new Mongo("mongodb://127.0.0.1:27017"); //选择数据库 $db = $connnect->selectDB(‘mydb‘)->selectCollection("user"); //整理需要插入的数据 $array = array(); $array[‘id‘] = 1; $array[‘name‘] = ‘php‘; $array[‘age‘] = 25; //插入数据 $db->insert($array); ?>
这样,就将一条数据插入到mydb的user集合里了。当然,上面的$db->insert($array);也可以换成$db->save($array);。insert()和save()的区别在于:若存在主键,insert()不做操作,而save()则更改原来的内容为新内容。
2、查询数据
语法格式:
$db->find(array(‘_id‘ => new MongoId($id))); //参数可以为空,那么就查询所有数据
例如,我们查询数据库中的所有数据,代码如下:
<?php //连接数据库 $connnect = new Mongo("mongodb://127.0.0.1:27017"); //选择数据库 $db = $connnect->selectDB(‘mydb‘)->selectCollection("user"); //查询数据 $cursor = $db->find(); $array = array(); while($cursor->hasNext()) { $array[] = $cursor->getNext(); } echo "<pre>"; print_r($array); ?>
运行结果如下:
可见数据已经取出来了。如只想取出一条数据。可以使用$db->findOne();,这时候,只会取出第一个文档的数据。
特定条件的查询
例如,我们要查询年纪大于25的成员的信息,就在find()中写条件,代码如下:
<?php //连接数据库 $connnect = new Mongo("mongodb://127.0.0.1:27017"); //选择数据库 $db = $connnect->selectDB(‘mydb‘)->selectCollection("user"); //查询条件 $cursor = $db->find(array(‘age‘ => array(‘$gt‘ => 25))); $array = array(); while($cursor->hasNext()) { $array[] = $cursor->getNext(); } ?>
需要注意的是‘$gt‘,是单引号!
3、修改数据
语法格式:
$db->update(array(‘_id‘ => new MongoId($id)), $array); //第一个参数为指定的条件,第二个参数为要更新的对象
例如我们修改ID为537097b59067916c06000003的数据,代码如下:
<?php //连接数据库 $connnect = new Mongo("mongodb://127.0.0.1:27017"); //选择数据库 $db = $connnect->selectDB(‘mydb‘)->selectCollection("user"); //需要修改的数据 $array = array(); $array[‘id‘] = 1; $array[‘name‘] = ‘java‘; $array[‘age‘] = 25; $db->update(array(‘_id‘ => new MongoId(‘537097b59067916c06000003‘)), $array); ?>
这就ID为537097b59067916c06000003的数据进行了修改。
4、删除数据
语法格式:
$db->remove(array(‘_id‘ => new MongoId($id)), array(‘justOne‘ => True)); //第一个参数为指定的条件,如果加了justOne的参数,则只删除符合条件的一条记录而已,其他不删除
例如我们删除ID为5370a05d4b628998570cdf6d的数据,代码如下:
<?php //连接数据库 $connnect = new Mongo("mongodb://127.0.0.1:27017"); //选择数据库 $db = $connnect->selectDB(‘mydb‘)->selectCollection("user"); //需要删除的数据 $db->remove(array(‘_id‘ => new MongoId(‘5370a05d4b628998570cdf6d‘))); ?>
这就ID为5370a05d4b628998570cdf6d的数据就被删除了。