首页 / PHP / php mongodb如何实现增删改查

php mongodb如何实现增删改查

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了php mongodb如何实现增删改查，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含11120字，纯文字阅读大概需要16分钟。

内容图文

php mongodb实现增删改查的方法：1、数据插入，代码为【$res = $collection->insert($doc)】；2、数据查询，代码为【$one = $collection->findOne(['First Name)】。

php mongodb如何实现增删改查 - 文章图片

本教程操作环境：windows7系统、PHP5.6版，DELL G3电脑。

php mongodb实现增删改查的方法：

MongoDB的PHP驱动提供了一些核心类来操作MongoDB，总的来说MongoDB命令行中有的功能，它都可以实现，而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同，本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作，最后再简单说明一下PHP7以后版本对MongoDB的操作。

一、数据插入

//insert()
//参数1：一个数组或对象
//参数2：扩展选项
//  fsync：默认为false，若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘
//  j：默认为false，若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
//  w：默认为1，写操作会被（主）服务器确认，若为0则将不会得到确认，使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认
//  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
//  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;//选择数据库
$collection = $db->friend;//选择文档集合
$doc = [//定义一个文档，即一个数组
    'First Name' => 'Jet',
    'Last Name' => 'Wu',
    'Age' => 26,
    'Phone' => '110',
    'Address' => [
        'Country' => 'China',
        'City' => 'Shen Zhen'
    ],
    'E-Mail' => [
        '123456@qq.com',
        '666666@sina.com',
        '8888888@qq.com',
        '77887788@qq.com'
    ]
];
$res = $collection->insert($doc);//向集合中插入一个文档
echo '<pre>';
print_r($res);//$res['ok']=1表示插入成功

二、数据查询

1. 查询单个文档：

//findOne()
//参数1：搜索条件
//参数2：指定返回字段，array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回，除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$one = $collection->findOne(['First Name' => 'Jet']);
echo '<pre>';
print_r($one);//返回一个数组，查不到数据则返回NULL

2. 查询多个文档：

//find()
//参数1：搜索条件
//参数2：指定返回字段，array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回，除非显式设置为false不返回。不设置则返回所有字段
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
echo '<pre>';
while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
    print_r($doc);
}

使用各种条件操作符定义查询：

//mongodb分别使用$lt、$lte、$eq、$gte、$gt、$ne表示<、<=、=、>=、>、<>，用于整数字段查询
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$cursor = $collection->find(['Age' => ['$gt' => 30]]);
echo '<pre>';
while($doc = $cursor->getNext()) {
    print_r($doc);
}
　　//查询某个字段的所有不重复的值
　　$res = $collection->distinct('Age');

//$in：匹配多个值中任意一个
$cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
 
//$all：匹配多个值中所有值（用于数组字段查询）
$cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
 
//$or：或查询
$cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);
 
//$slice：获取数组字段中指定数目的元素，位于find()函数第二个参数中
$cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
$cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email
$cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个，返回接下来两个
 
//$exists：根据某个字段是否有设置值进行查询
$cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档
 
//正则表达式查询
$cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档，忽略大小写差异

使用MongoCursor类提供的其他函数：

//排序：1升序，-1降序
$cursor->sort(['Age' => 1]);
 
//忽略前n个匹配的文档
$cursor->skip(1);
 
//只返回前n个匹配的文档（limit()与skip()结合使用可实现数据分页功能）
$cursor->limit(1);
 
//匹配文档的总数
$cursor->count();
 
//指定查询索引
$cursor->hint(['Last Name' => -1]);//若索引不存在则会报错

聚集查询：对数据进行分组统计

//聚合查询：对数据进行分组统计
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$res = $collection->aggregate([
    '$group' => [
        '_id' => '$Address.Country',//分组字段，注意要加上“$”，这里是根据数组字段某个元素值进行分组
        'total' => ['$sum' => 1],//求总和，表示每匹配一个文档总和就加1
        'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值
        'minAge' => ['$min' => '$Age']//分组中Age字段最小值
    ]
]);
echo '<pre>';
print_r($res);//返回一个数组，$ret['result']为数组，存放统计结果
 
 
//存在其它操作的聚合查询：多个操作之间执行先后顺序取决于它们位置的先后顺序
//聚合查询中的所有操作，包括'$group'在内，都是可选的。
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$res = $collection->aggregate([
    [//过滤条件：只对符合条件的原始文档进行聚合运算，若是放在'$group'之后则是只返回符合条件的结果文档
        '$match' => ['Age' => ['$gt' => 30]]
    ],
    [//指定分组字段、统计字段
        '$group' => [
            '_id' => '$Address.Country',
            'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
        ]
    ],
    //以下操作若是放在'$group'之前则在聚合前作用于原始文档，若放在'$group'之后则在聚合后作用于结果文档
    ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档，每个文档的同名字段的值为数组中的一个值。
    ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段，可以对字段进行重命名，格式：返回字段名 => $原来字段名
    ['$skip' => 2],//跳过指定数量的文档
    ['$limit' => 2],//只返回指定数量的文档
    ['$sort' => ['totalAge' => 1]]//排序
]);
echo '<pre>';
print_r($res);

三、数据修改

//update()
//参数1：更新条件，指定更新的目标对象。
//参数2：指定用于更新匹配记录的对象。
//参数3：扩展选项组。
//  upsert：若设置为true，当没有匹配文档的时候会创建一个新的文档。
//  multiple：默认为false，若设置为true，匹配文档将全部被更新。
//  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。
//  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作
//  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。
//  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
//  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
//注意：若不使用任何修改操作符，则匹配文档将直接被整个替换为参数2指定的对象。
 
//$inc：增加特定键的值，若字段不存在则新建字段并赋值
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);
echo '<pre>';
print_r($res);//$res['ok']=1表示修改成功，$res['nModified']表示修改的文档数量
 
//$set：重置特定键的值，若字段不存在则新建字段并赋值
$res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
 
//$unset：删除字段
$res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
 
//$rename：重命名字段，若字段不存在则不进行任何操作
$res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);
//注意：如果文档中已经使用了指定名称的字段，则该字段将会被删除，然后再进行重命名操作。
 
//$setOnInsert：设置了upsert为true，并且发生了插入操作的时候，将某个字段设置为特定的
$res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
 
//$push：向指定字段添加一个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
$res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
 
//$push：向指定字段添加多个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
$res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);
 
//使用$push和$each向某个字段添加多个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
$res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
 
//$addToSet：将数据添加到数组中（只在目标数组没有该数据的时候才将数据添加到数组中）
$res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
$res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
 
//$pop：从数组中删除一个元素，-1表示删除第一个元素，1表示删除最后一个元素（其实负数都删除第一个元素，0或正数都删除最后一个元素）
$res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);
 
//$pull：删除数组中所有指定值
$res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);
 
//$pullAll：删除数组中多个元素的所有值
$res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);

//save()
//参数1：希望保存的信息数组
//参数2：扩展选项
//  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。
//  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作
//  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。
//  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
//  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
//注意：若已存在则更新，若不存在则插入；更新时使用参数1指定的信息数组替换整个文档。
//若想更新则应该在参数1中指定_id键的值。
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$doc = [//定义一个文档，即一个数组
    'First Name' => 'Jet',
    'Last Name' => 'Wu',
    'Age' => 26,
    'Phone' => '110',
    'Address' => [
        'Country' => 'China',
        'City' => 'Shen Zhen'
    ],
    'E-Mail' => [
        '123456@qq.com',
        '666666@sina.com',
        '8888888@qq.com',
        '77887788@qq.com'
    ]
];
$res = $collection->save($doc);
echo '<pre>';
print_r($res);//$res['ok']=1表示操作成功，$res['updatedExisting']=1表示更新，$res['upserted']=1表示插入

//findAndModify()
//参数1：指定查询条件
//参数2：指定用于更新文档的信息
//参数3：可选，指定希望返回的字段
//参数4：扩展选项
//  sort：以特定顺序对匹配文档进行排序
//  remove：若设置为true，第一个匹配文档将被删除
//  update：若设置为true，将在被选择的文档上执行更新操作
//  new：默认为false，若设置为true则返回更新后的文档，否则返回更新前的文档
//  upsert：若设置为true，没有找到匹配文档的时候将插入一个新的文档
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);
echo '<pre>';
print_r($res);

四、数据删除

//remove()
//参数1：查询条件
//参数2：扩展选项
//  justOne：若设置为true，则最多只有一个匹配的文档将被删除
//  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。
//  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作
//  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。
//  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
//  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
$mongo = new MongoClient('mongodb://localhost:27017');
$db = $mongo->mf;
$collection = $db->friend;
$res = $collection->remove(['First Name' => 'jet']);
echo '<pre>';
print_r($res);//$res['n']表示删除了几个文档

相关视频推荐：PHP视频教程

以上就是php mongodb如何实现增删改查的详细内容。

本文系统来源：https://www.php.cn/php-ask-471746.html

内容总结

以上是互联网集市为您收集整理的php mongodb如何实现增删改查全部内容，希望文章能够帮你解决php mongodb如何实现增删改查所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/121984.html

来源：【匿名】

【上一篇】php怎么去掉首尾空格【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【php mongodb如何实现增删改查】教程文章相关的互联网学习教程文章

ThinkPHP 数据库操作(二) : 增删改查【代码】

基本使用可以直接使用数据库运行原生SQL操作了，支持 query （查询操作）和 execute （写入操作）方法，并且支持参数绑定。Db::query(‘select * from think_user where id=?‘,[8]); Db::execute(‘insert into think_user (id, name) values (?, ?)‘,[8,‘thinkphp‘]);也支持命名占位符绑定，例如：Db::query(‘select * from think_user where id=:id‘,[‘id‘=>8]); Db::execute(‘insert into think_user (id, name) value...

php+ci对mysql进行增删改查【代码】【图】

php的ci是一个mvc模式的框架，本文是通过php+ci对mysql数据库进行增删改查。0. 首先在mysql数据库方创建数据库和数据表1createdatabase test; 2use test; 3create tables user( 4 id int(10) notnull auto_increment, 5 name varchar(50) notnull, 6 age int(10) notnull, 7primarykey (id) 8 );View Code1. 修改database配置文件（application/config/database.php）2. 追加models处理模块（application/models/u...

php操作mysql数据库的连接语句以及最简单的增删改查语句

<?php/*//给大家带来php最基本的增删改查的方法，我的mysql数据库配置信息如下：//主机IP：localhost//用户名：root//密码：123456//数据库名：databaseTest//表名：test(两个字段，id(int),name())//-----------------------向数据库插入一条数据--------------------- $id=1; $name="zhangsan"; $con = mysql_connect("localhost","root","123456"); mysql_select_db("databaseTest", $con); $sql="INSERT INTO test (id,name) ...

PHP 页面中实现数据的增删改查【代码】

main页面(主页面)<table width="100%" border="1" cellpadding="0" cellspacing="0"> <tr> <td>代号</td> <td>姓名</td> <td>性别</td> <td>民族</td> <td>生日</td> <td>操作</td> </tr><?php $db = new MySQLi("localhost","root","","mydb"); !mysqli_connect_error() or die("连接失败"); $sql = "select * from Info"; $result = $db->query($sql); $attr = $result->fetch_all(); foreach($attras$v) {$sex = $v[2]? ‘男‘:...

php学习day11---数据库（3）数据表的增删改查【图】

今天我们学习了数据表的相关操作，以下是笔记。一、数据操作语言　　1.增添数据　　　　在数据表中添加数据有多种的语法形式　　　　　　形式1：insert [into] table_name [(字段1，字段2，字段3......)] values (值1，值2，值3......),(......),(......)......;　　　　　形式2：replace [into] table_name [(字段1，字段2，字段3......)] values (值1，值2，值3......),(......),(......)......;　　　　　形式3：insert [in...

php对数据库增删改查操作类【代码】

1 <?php 2 3/**4 * 函数名称：SqlTool.class.php 5 * 函数功能：php对数据库增删改查操作类6 * 函数作者：张真贵7 * 创建时间：2015-01-058 * 修改时间：9*/10header("Content-Type:text/html;charset=utf-8"); 11class SqlTool{ 12private$conn; 13private$host = ‘localhost‘; 14private$root = ‘root‘; 15private$password = ‘‘; 16private$dbname = test; 1718function __construct(){ 19# code...20$thi...

EasyUI DataGrid结合ThinkPHP实现增删改查操作———初学者【代码】【图】

EasyUI是基于jQuery的用户界面插件集合；DataGrid是数据表格；ThinkPHP是快速、简单的基于MVC和面向对象的轻量级PHP开发框架。使用的集成开发环境是 WAMPSever，（wampserver是一个集成了Apache、PHP和MySQL的开发套件，而且支持不同PHP版本、MySQL版本和Apache版本的切换）效果如下：主要代码如下 1、定义一个表格 <table id="dg" class="easyui-datagrid" title="DataGrid Complex Toolbar" style="width:700px;height:250p...

php使用memcached缓存进行增删改查数据

//创建一个memcache对象实例$memcache = new Memcache;if(!$memcache->connect("127.0.0.1",11211)){ die('连接失败');}if($memcache->set('key1',"xian",MEMCACHE_COMPRESSED,60)){ echo 'sucess!';}//存值,其中xian字符串，也可以为数组，对象，但不能为资源// bbs.it-home.org$val = $memcache->get('key1');//查询获取值echo $val;$memcache->replace('key1','beijing',MEMCACHE_COMPRESSED,60);//修改$memcache->delete('key1...

php中操作memcached缓存进行增删改查数据的实现代码

核心代码： <?php//创建一个memcache对象实例$memcache = new Memcache;if(!$memcache->connect("127.0.0.1",11211)){die(连接失败);}if($memcache->set(key1,"xian",MEMCACHE_COMPRESSED,60)){echo sucess!;}//存值,其中xian字符串，也可以为数组，对象，但不能为资源$val = $memcache->get(key1);//查询获取值echo $val;$memcache->replace(key1,beijing,MEMCACHE_COMPRESSED,60);//修改$memcache->delete(key1);//删除 ?>

php中操作memcached缓存进行增删改查数据的实现代码_PHP

核心代码：<?php//创建一个memcache对象实例$memcache = new Memcache;if(!$memcache->connect("127.0.0.1",11211)){die(连接失败);}if($memcache->set(key1,"xian",MEMCACHE_COMPRESSED,60)){echo sucess!;}//存值,其中xian字符串，也可以为数组，对象，但不能为资源$val = $memcache->get(key1);//查询获取值echo $val;$memcache->replace(key1,beijing,MEMCACHE_COMPRESSED,60);//修改$memcache->delete(key1);//删除 ?>

php中操作memcached缓存进行增删改查数据的实现代码_php技巧

php中操作memcached缓存进行增删改查数据的实现代码，phpmemcached_PHP教程

php中操作memcached缓存进行增删改查数据的实现代码，phpmemcached 核心代码： <?php//创建一个memcache对象实例$memcache = new Memcache;if(!$memcache->connect("127.0.0.1",11211)){die(连接失败);}if($memcache->set(key1,"xian",MEMCACHE_COMPRESSED,60)){echo sucess!;}//存值,其中xian字符串，也可以为数组，对象，但不能为资源$val = $memcache->get(key1);//查询获取值echo $val;$memcache->replace(key1,beijing,MEMCAC...

php中PDO方式实现数据库的增删改查示例代码

PDO是mysql数据库操作的一个公用类了，我们不需要进行自定类就可以直接使用pdo来操作数据库了，但是在php默认配置中pdo是未开启所以我们必须先在php.ini中开启它才可以使用。需要开启php的pdo支持，php5.1以上版本支持实现数据库连接单例化，有三要素静态变量、静态实例化方法、私有构造函数 DPDO.phpclass DPDO{private $DSN;private $DBUser;private $DBPwd;private $longLink;private $pdo;//私有构造函数防止被直接实例化pri...

php+mysql面向对象增删改查

新手一枚，求指导。 localhost = $localhost; //就用$this->localhost 代替。 $this->root = $root; $this->password = $password; $this->database = $database; } public function Connect(){ mysql_connect ($this->localhost,$this-root,$this->password); mysql_select_db ($this->database); mysql_query ("set names utf8"); } public function Close(){ mysql_close(); } public functio...