【Mongodb教程 第十三课 】PHP mongodb 的增删改查使用

<pre>
<?php
#phpinfo();die;

#其他链接方式
#$conn=new Mongo(); #连接本地主机,默认端口.
#$conn=new Mongo("127.0.0.1"); #连接远程主机
#$conn=new Mongo("xiaocai.loc:10086"); #连接指定端口远程主机
//$conn=new Mongo(“xiaocai.loc”,array(“replicaSet”=>true)); #负载均衡
//$conn=new Mongo(“xiaocai.loc”,array(“persist”=>”t”)); #持久连接
//$conn=new Mongo(“mongodb://sa:[email protected]”); #带用户名密码
//$conn=new Mongo("mongodb://localhost:27017,localhost:27018"); #连接多个服务器
//$conn=new Mongo(“mongodb:///tmp/mongo-27017.sock”); #域套接字
#$conn=new Mongo("mongodb://admin_miss:[email protected]:27017/test",array(‘persist‘=>‘p‘,‘replicaSet‘=>true)); #完整

 $conn=new Mongo("127.0.0.1:27017"); #连接指定端口远程主机
$db=$conn->sky; #选择mydb数据库
$collection=$db->bobo; #选择集合(选择’表’)

//$collection=$db->selectCollection(myTable); #第二种写法
//$collection=$conn->mydb->myTable; #更简洁的写法

$array=array(
          ‘column_name‘=>‘col‘.rand(100,999),
          ‘column_exp‘=>‘xiaocai‘
          );
$result=$collection->insert($array); #简单插入
//echo "新记录ID:".$array[‘_id‘]; #MongoDB会返回一个记录标识
#var_dump($result); #返回:bool(true)

//**向集合中安全插入数据,返回插入状态(数组). **/
$array = array(
  ‘column_name‘=>‘col‘.rand(100,999),
  ‘column_exp‘=>‘jshaibozhong‘
  );
#$result=$collection->insert($array,true); #用于等待MongoDB完成操作,以便确定是否成功.(当有大量记录插入时使用该参数会比较有用)

#echo "新记录ID:".$array[‘_id‘]; #MongoDB会返回一个记录标识
#var_dump($result); #返回:array(3) { ["err"]=> NULL ["n"]=> int(0) ["ok"]=> float(1) }

//** 统计表记录数 **/

echo ‘count:‘.$collection->count()."<br>"; #全部
echo ‘count:‘.$collection->count(array(‘type‘=>‘user‘))."<br>"; #统计‘type‘ 为 user 的记录
echo ‘count:‘.$collection->count(array(‘age‘=>array(‘$gt‘=>50,‘$lte‘=>74)))."<br>"; #统计大于50小于等于74
echo ‘count:‘.$collection->find()->limit(5)->skip(0)->count(true)."<br>"; #获得实际返回的结果数
/**
* 注:$gt为大于、$gte为大于等于、$lt为小于、$lte为小于等于、$ne为不等于、$exists不存在
*/

//** 获取表中所有记录 **/
$cursor = $collection->find()->snapshot();
foreach ($cursor as $id => $value) {
//echo "$id: "; var_dump($value); echo "<br>";
}

/**
* 注意:
* 在我们做了find()操作,获得$cursor游标之后,这个游标还是动态的.
* 换句话说,在我find()之后,到我的游标循环完成这段时间,如果再有符合条件的记录被插入到collection,那么这些记录也会被$cursor 获得.
* 如果你想在获得$cursor之后的结果集不变化,需要这样做:
* $cursor = $collection->find();
*/

//** 查询一条数据 **/
$cursor = $collection->findOne();
/**
*  注意:findOne()获得结果集后不能使用snapshot(),fields()等函数;
*/

//** 设置显示字段 age,type 列不显示 **/
$cursor = $collection->find()->fields(array("age"=>false,"type"=>false));
$cursor = $collection->find()->fields(array("user"=>true)); //只显示user 列
/**
* 我这样写会出错:$cursor->fields(array("age"=>true,"type"=>false));
*/

//** 设置条件 (存在type,age节点) and age!=0 and age<50 **/
$where=array(‘type‘=>array(‘$exists‘=>true),‘age‘=>array(‘$ne‘=>0,‘$lt‘=>50,‘$exists‘=>true));
$cursor = $collection->find($where);

//** 分页获取结果集  **/
$cursor = $collection->find()->limit(5)->skip(0);
//** 排序  **/
$cursor = $collection->find()->sort(array(‘age‘=>-1,‘type‘=>1)); ##1表示降序 -1表示升序,参数的先后影响排序顺序
//** 索引  **/
$collection->ensureIndex(array(‘age‘ => 1,‘type‘=>-1)); #1表示降序 -1表示升序
$collection->ensureIndex(array(‘age‘ => 1,‘type‘=>-1),array(‘background‘=>true)); #索引的创建放在后台运行(默认是同步运行)
$collection->ensureIndex(array(‘age‘ => 1,‘type‘=>-1),array(‘unique‘=>true)); #该索引是唯一的
/**
* ensureIndex (array(),array(‘name‘=>‘索引名称‘,‘background‘=true,‘unique‘=true))
* 详见:http://www.php.net/manual/en/mongocollection.ensureindex.php
*/

//** 取得查询结果 **/
$cursor = $collection->find();
$array=array();
foreach ($cursor as $id => $value) {
    $array[]=$value;
}

 print_r($array);

 //** 删除节点 **/
//$where=array(‘column_name‘=>‘col685‘);
//$result=$collection->update($where,array(‘$unset‘=>‘column_exp‘));
/**
* 删除节点column_exp
*/
/*
* *
* 完整格式:update(array $criteria, array $newobj [, array $options = array()  ] )
*       注意:1.注意区分替换更新与修改更新
*    2.注意区分数据类型如 array(‘91u‘=>‘684435‘)与array(‘91u‘=>684435)
* *
*/

//** 清空表 **/
//$collection->remove(); #清空集合

//** 删除指定MongoId **/
//$id = new MongoId("4d638ea1d549a02801000011");
//$collection->remove(array(‘_id‘=>(object)$id));

 //** 修改更新 传统更新 **/
$where=array("column_name"=>"col123");
$newdata=array("column_exp"=>"GGGGG33sGG","column_fid"=>444);
$result=$collection->update($where,array("\$set"=>$newdata)); #$set:让某节点等于给定值,类似的还有$pull $pullAll $pop $inc,在后面慢慢说明用法
/*
* 结果:
* 原数据
* {"_id”:ObjectId("4d635ba2d549a02801000003"),”column_name”:”col123",”column_exp”:”xiaocai”}
* 被替换成了
* {"_id”:ObjectId("4d635ba2d549a02801000003"),”column_name”:”col123",”column_exp”:”GGGGGGG”,”column_fid”:444}
*/

//** 替换更新 ,覆盖原记录**/
$where = array("column_name"=>"col123");
$newdata = array("column_exp"=>"HHHHHHHHH","column_fid"=>123);
$result = $collection->update($where,$newdata);
/*
* 结果:
* 原数据
* {"_id”:ObjectId("4d635ba2d549a02801000003"),”column_name”:”col709",”column_exp”:”xiaocai”}
* 被替换成了
* {"_id”:ObjectId("4d635ba2d549a02801000003"),”column_exp”:”HHHHHHHHH”,”column_fid”:123}
*/

//** 批量更新 **/
$where=array("column_name"=>"col");
$newdata=array("column_exp"=>"multiple","91u"=>684435);
 $result=$collection->update($where,array("\$set"=>$newdata),array("multiple"=>true));
/**
* 所有"column_name"="col"都被修改
*/

//** 自动累加 **/
$where=array("91u"=>684435);
$newdata=array("column_exp"=>"edit");
 $result=$collection->update($where,array(‘\$set‘=>$newdata,"\$inc"=>array("91u"=>-5)));
/**
* 更新91u=684435的数据,并且91u自减5
*/

 $conn->close(); #关闭连接

?>
时间: 2024-10-24 11:34:58

【Mongodb教程 第十三课 】PHP mongodb 的增删改查使用的相关文章

【Mongodb教程 第八课 】MongoDB 更新文档

MongoDB的 update() 和 save() 方法用于更新文档的集合. update()方法更新现有的文档值,而替换现有的文档通过的文件中 save() 方法. MongoDB Update() 方法 update()方法更新现有文档值. 语法: update() 方法的基本语法如下 >db.COLLECTION_NAME.update(SELECTIOIN_CRITERIA, UPDATED_DATA) 例子 考虑以下数据mycol集合. { "_id" : Objec

【Mongodb教程 第十一课 】MongoDB 聚合

聚合操作过程中的数据记录和计算结果返回.聚合操作分组值从多个文档,并可以执行各种操作,分组数据返回单个结果.在SQL COUNT(*)和group by 相当于MongoDB的聚集. aggregate() 方法 对于在MongoDB中聚集,应该使用aggregate()方法. 语法: aggregate() 方法的基本语法如下 >db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION) 例子: 在集合中,有以下的数据: { _id: ObjectId(

【Mongodb教程 第七课 】MongoDB 查询文档

find() 方法 要从MongoDB 查询集合数据,需要使用MongoDB 的 find() 方法. 语法 基本的find()方法语法如下 >db.COLLECTION_NAME.find() find() 方法将在非结构化的方式显示所有的文件. pretty() 方法 结果显示在一个格式化的方式,可以使用 pretty() 方法. 语法: >db.mycol.find().pretty() 例子 >db.mycol.find().pretty() { "_id":

【Mongodb教程 第六课 】MongoDB 插入文档

insert() 方法 要插入数据到 MongoDB 集合,需要使用 MongoDB 的  insert() 或 save() 方法. 语法 insert() 命令的基本语法如下: >db.COLLECTION_NAME.insert(document) 例子 >db.mycol.insert({ _id: ObjectId(7df78ad8902c), title: 'MongoDB Overview', description: 'MongoDB is no sql database',

【Mongodb教程 第十课 】MongoDB 备份

MongoDB 数据转储 创建备份MongoDB中的数据库,应该使用mongodump命令.此命令将服务器的所有数据转储到转储目录.有许多可供选择,通过它可以限制的数据量或创建备份您的远程服务器. 语法: mongodump命令的基本语法如下 >mongodump 例子 启动mongod 服务器.假设服务器上运行 mongod localhost 端口为 27017.现在打开一个命令提示符并进入 MongoDB实例的bin目录,然后键入命令 mongodump 考虑以下数据mycol集合. >

【Mongodb教程 第三课 】MongoDB 删除数据库

dropDatabase() 方法 MongoDB db.dropDatabase() 命令是用来删除一个现有的数据库. 语法: dropDatabase() 命令的基本语法如下: db.dropDatabase() 这将删除选定的数据库.如果还没有选择任何数据库,然后它会删除默认的 ' test' 数据库 示例: 首先,检查列表数据库通过使用命令 show dbs >show dbs local 0.78125GB mydb 0.23012GB test 0.23012GB > 如果想删除新

【Mongodb教程 第五课 】MongoDB 删除集合

drop() 方法 MongoDB 的 db.collection.drop() 是用来从数据库中删除一个集合. 语法: drop() 命令的基本语法如下 db.COLLECTION_NAME.drop() 示例: 首先,检查可用的集合在数据库 mydb >use mydb switched to db mydb >show collections mycol mycollection system.indexes yiibai > 现在删除集合名称为 mycollection >

【Mongodb教程 第四课 】MongoDB 创建集合

reateCollection() 方法 MongoDB db.createCollection(name, options) 是用来创建集合. 语法: 基本的 createCollection() 命令语法如下: db.createCollection(name, options) 在命令中, name 是要创建的集合的名称. Options 是一个文件,用于指定配置的集合 参数 类型 描述 Name String 要创建的集合名称 Options Document (可选)指定有关内存大小和

【Mongodb教程 第十七课 】MongoDB常用命令 数据库命令 集合操作命令

(1)数据库命令 a)添加用户 db.addUser(‘name’,’pwd’) b)删除用户 db.removeUser(‘name’) c)用户验证 db.auth(‘name’,’pwd’) d)拷贝数据库,从test库拷贝  db.copyDatabase(‘test’,’mydb’) e)删掉数据库 db.dropDatabase() f)获取数据库下所有集合 db.getCollectionNames() g)停止mongo服务 db.shutdownServer() h)使用某个数