Heim  >  Artikel  >  Backend-Entwicklung  >  MongoDB数据库常用操作PHP代码

MongoDB数据库常用操作PHP代码

WBOY
WBOYOriginal
2016-07-25 08:45:301307Durchsuche
  1. $conn = new Mongo();
  2. //可以简写为
  3. //$conn=new Mongo(); #连接本地主机,默认端口.
  4. //$conn=new Mongo(“172.21.15.69″); #连接远程主机
  5. //$conn=new Mongo(“xiaocai.loc:10086″); #连接指定端口远程主机
  6. //$conn=new Mongo(“xiaocai.loc”,array(“replicaSet”=>true)); #负载均衡
  7. //$conn=new Mongo(“xiaocai.loc”,array(“persist”=>”t”)); #持久连接
  8. //$conn=new Mongo(“mongodb://sa:123@localhost”); #带用户名密码
  9. #选择test数据库
  10. $db=$conn->test;
  11. //$db=$conn->selectDB("test"); #第二种写法
  12. #选择集合(选择"表")
  13. $collection=$db->user;
  14. //$collection=$db->selectCollection("user"); #第二种写法
  15. #插入操作
  16. $data=array("uid"=>"zz123","user_name"=>"张三");
  17. $result=$collection->insert($data); #简单插入
  18. echo "插入数据的id".$data["_id"];
  19. exit;
  20. #插入操作 安全插入
  21. $data=array("uid"=>"zz124","user_name"=>"李四");
  22. $result=$collection->insert($data,true); #用于等待MongoDB完成操作,以便确定是否成功.(当有大量记录插入时使用该参数会比较有用)
  23. #修改操作
  24. $where=array("uid"=>"zz123");
  25. $newdata=array("user_name"=>"张三三","tel"=>"123456789");
  26. $result=$collection->update($where,array('$set'=>$newdata));
  27. #替换更新
  28. $where=array("uid"=>"zz124");
  29. $newdata=array("user_age"=>"22","tel"=>"123456789");
  30. $result=$collection->update($where,$newdata);
  31. #批量更新
  32. $where=array("uid"=>'zz');
  33. $newdata=array("user_name"=>"zz","money"=>1000);
  34. $result=$collection->update($where,array('$set'=>$newdata),array('multiple'=>true));
  35. #自动累加
  36. $where=array('money'=>1000);
  37. $newdata=array('user_name'=>'edit');
  38. $result=$collection->update($where,array('$set'=>$newdata,'$inc'=>array('money'=>-5)));
  39. #删除节点
  40. $where=array('uid'=>'zz124');
  41. $result=$collection->update($where,array('$unset'=>'tel'));//删除节点tel
  42. #删除数据
  43. $collection->remove(array('uid'=>'zz124'));
  44. #删除指定MongoId
  45. $id = new MongoId('4d638ea1d549a02801000011');
  46. $collection->remove(array('_id'=>(object)$id));
  47. #查询数据 注:$gt为大于、$gte为大于等于、$lt为小于、$lte为小于等于、$ne为不等于、$exists不存在
  48. echo 'count:'.$collection->count()."
    "; #全部
  49. echo 'count:'.$collection->count(array('uid'=>'zz123'))."
    "; #可以加上条件
  50. echo 'count:'.$collection->count(array('age'=>array('$gt'=>10,'$lte'=>30)))."
    "; #大于50小于等于74
  51. echo 'count:'.$collection->find()->limit(5)->skip(0)->count(true)."
    "; #获得实际返回的结果数
  52. #集合中所有文档
  53. $cursor = $collection->find()->snapshot();
  54. foreach ($cursor as $id => $value) {
  55. echo "$id: "; var_dump($value);
  56. echo "
    ";
  57. }
  58. #查询一条数据
  59. $cursor = $collection->findOne();
  60. #排除列 false为不显示
  61. $cursor = $collection->find()->fields(array("age"=>false,"tel"=>false));
  62. #指定列 true为显示
  63. $cursor = $collection->find()->fields(array("user_name"=>true));
  64. #(存在tel,age节点) and age!=0 and age$where=array('tel'=>array('$exists'=>true),'age'=>array('$ne'=>0,'$lt'=>50,'$exists'=>true));
  65. $cursor = $collection->find($where);
  66. #分页获取结果集
  67. $cursor = $collection->find()->limit(5)->skip(0);
  68. #排序
  69. $cursor = $collection->find()->sort(array('age'=>-1,'type'=>1)); #1表示降序 -1表示升序,参数的先后影响排序顺序
  70. #索引
  71. $collection->ensureIndex(array('age' => 1,'money'=>-1)); #1表示降序 -1表示升序
  72. $collection->ensureIndex(array('age' => 1,'money'=>-1),array('background'=>true)); #索引的创建放在后台运行(默认是同步运行)
  73. $collection->ensureIndex(array('age' => 1,'money'=>-1),array('unique'=>true)); #该索引是唯一的
  74. #取得查询结果
  75. $cursor = $collection->find();
  76. $array=array();
  77. foreach ($cursor as $id => $value) {
  78. $array[]=$value;
  79. }
  80. #关闭连接
  81. $conn->close();
  82. ?>
复制代码

MongoDB, PHP


Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn