说到php连mongoDB，不得不先介绍一下php的官方手册，网址在：http://us.php.net/manual/en/book.mongo.php，接下来给大家分享一个本人常用的MONGODB的操作类，详见的数据库操作都有了，小伙伴可以参考下。

mongo_db.php

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
<?php
  
/**
 * Created by PhpStorm.
 * User: yangyulong
 * Date: 2015/5/26
 * Time: 13:45
 */
class Mongo_db
{
  private static $instanceof = NULL;
  public $mongo;
  private $host = 'localhost';
  private $port = '27017';
  
  private $db;
  public $dbname;
  private $table = NULL;
  
  /**
   * 初始化类，得到mongo的实例对象
   */
  public function __construct($host = NULL, $port = NULL, $dbname = NULL, $table = NULL)
  {
  
    if (NULL === $dbname) {
      $this->throwError('集合不能为空！');
    }
  
    //判断是否传递了host和port
    if (NULL !== $host) {
      $this->host = $host;
    }
  
    if (NULL !== $port) {
      $this->port = $port;
    }
  
    $this->table = $table;
  
    $this->mongo = new MongoClient($this->host . ':' . $this->port);
    if ($this->getVersion() >= '0.9.0') {
      $this->dbname = $this->mongo->selectDB($dbname);
      $this->db = $this->dbname->selectCollection($table);
    } else {
      $this->db = $this->mongo->$dbname->$table;
    }
  }
  
  public function getVersion()
  {
    return MongoClient::VERSION;
  }
  
  /**
   * 单例模式
   * @return Mongo|null
   */
  //public static function getInstance($host=null, $port=null, $dbname=null, $table=null){
  //
  //  if(!(self::$instanceof instanceof self)){
  //    self::$instanceof = new self($host, $port, $dbname, $table);
  //  }
  //
  //  return self::$instanceof;
  //}
  
  /**
   * 插入一条数据
   * @param array $doc
   */
  public function insert($doc = array())
  {
    if (empty($doc)) {
      $this->throwError('插入的数据不能为空！');
    }
    //保存数据信息
    try {
      if (!$this->db->insert($doc)) {
        throw new MongoException('插入数据失败');
      }
    } catch (MongoException $e) {
      $this->throwError($e->getMessage());
    }
  }
  
  /**
   * 插入多条数据信息
   * @param array $doc
   */
  public function insertMulti($doc = array())
  {
    if (empty($doc)) {
      $this->throwError('插入的数据不能为空！');
    }
    //插入数据信息
    foreach ($doc as $key => $val) {
      //判断$val是不是数组
      if (is_array($val)) {
        $this->insert($val);
      }
    }
  }
  
  /**
   * 查找一条记录
   * @return array|null
   */
  public function findOne($where = NULL)
  {
    if (NULL === $where) {
      try {
        if ($result = $this->db->findOne()) {
          return $result;
        } else {
          throw new MongoException('查找数据失败');
        }
      } catch (MongoException $e) {
        $this->throwError($e->getMessage());
      }
    } else {
      try {
        if ($result = $this->db->findOne($where)) {
          return $result;
        } else {
          throw new MongoException('查找数据失败');
        }
      } catch (MongoException $e) {
        $this->throwError($e->getMessage());
      }
    }
  
  }
  
  /**
   * todo 带条件的随后做
   * 查找所有的文档
   * @return MongoCursor
   */
  public function find($where = NULL)
  {
    if (NULL === $where) {
  
      try {
        if ($result = $this->db->find()) {
  
        } else {
          throw new MongoException('查找数据失败');
        }
      } catch (MongoException $e) {
        $this->throwError($e->getMessage());
      }
    } else {
      try {
        if ($result = $this->db->find($where)) {
  
        } else {
          throw new MongoException('查找数据失败');
        }
      } catch (MongoException $e) {
        $this->throwError($e->getMessage());
      }
    }
  
    $arr = array();
    foreach ($result as $id => $val) {
      $arr[] = $val;
    }
  
    return $arr;
  }
  
  /**
   * 获取记录条数
   * @return int
   */
  public function getCount()
  {
    try {
      if ($count = $this->db->count()) {
        return $count;
      } else {
        throw new MongoException('查找总数失败');
      }
    } catch (MongoException $e) {
      $this->throwError($e->getMessage());
    }
  }
  
  /**
   * 获取所有的数据库
   * @return array
   */
  public function getDbs()
  {
    return $this->mongo->listDBs();
  }
  
  /**
   * 删除数据库
   * @param null $dbname
   * @return mixed
   */
  public function dropDb($dbname = NULL)
  {
    if (NULL !== $dbname) {
      $retult = $this->mongo->dropDB($dbname);
      if ($retult['ok']) {
        return TRUE;
      } else {
        return FALSE;
      }
    }
    $this->throwError('请输入要删除的数据库名称');
  }
  
  /**
   * 强制关闭数据库的链接
   */
  public function closeDb()
  {
    $this->mongo->close(TRUE);
  }
  
  /**
   * 输出错误信息
   * @param $errorInfo 错误内容
   */
  public function throwError($errorInfo='')
  {
    echo "<h3>出错了：$errorInfo</h3>";
    die();
  }
  
}

来源:http://www.jb51.net/article/66882.htm

php实现的mongodb操作类相关推荐

  1. PHP操作Mongodb API 及使用类 封装好的MongoDB操作类

    来源:http://www.itokit.com/2012/0427/73656.html <?php /*** Mongodb类** examples: * $mongo = new HMon ...

  2. Spring整合Mongodb,Maven的依赖,Spring配置,MongoDB的公共操作类,使用SpringMVC的Controller进行测试并返回结果的案例

    在和Spring和MongoDB进行整合的时候需要如下三个jar,分别是: spring-data-commons spring-data-mongodb mongo-java-driver 下面讲解 ...

  3. PHP操作mongodb数据库操作类

    最近的项目开发中使用的数据库是mongodb数据库,因为小编的公司也是刚刚使用mongodb数据库,所以之前没有封装好的mongodb数据库操作类拿来使用,所以小编在项目中自己封装了一个mongodb ...

  4. mongodb java 单例_Java单例MongoDB工具类

    我经常对MongoDB进行一些基础操作,将这些常用操作合并到一个工具类中,方便自己开发使用. 没用Spring Data.Morphia等框架是为了减少学习.维护成本,另外自己直接JDBC方式的话可以 ...

  5. mysql 数据库操作类_【数据库操作类】10个php操作数据库类下载

    数据库(Database)操作是在开发过程中重要的组成部分,熟练掌握数据库的操作是开发人员必备的武器.PHP中文网为大家提供了各种封装好的php数据库操作类库,供大家下载和学习. 相关mysql视频教 ...

  6. Java学习总结：41(文件操作类：File)

    Java文件操作类:File 在java.io包中,如果要进行文件自身的操作(例如:创建.删除等),只能依靠java.io.File类完成. File类的常用操作方法 No. 方法 类型 描述 1 p ...

  7. Java学习总结：35(数字操作类)

    Java的数字操作类 一.Math类 Math类是一个专门用来进行数学计算的操作类,它提供了一系列的数学计算方法.在Math类里面提供的一切方法都是static型方法,所以可以直接由类名称进行调用. ...

  8. classlist使用方法_如何通过使用HTML5的classList API在没有jQuery的情况下操作类

    classlist使用方法 by Ayo Isaiah 通过Ayo Isaiah 如何通过使用HTML5的classList API在没有jQuery的情况下操作类 (How to manipulat ...

  9. python mysql类里_Python MySql 操作类

    # -*- coding:utf-8 -*- import MySQLdb import time ''' · MySQL 操作类 · V1.0 ''' class MySQLClass(object ...

最新文章

  1. python将视频转为多个gif
  2. 对比Memcached和Redis，谁才是适合你的缓存？
  3. java 8位随机数_JAVA中生成指定位数随机数的方法总结
  4. Anaconda+用conda创建python虚拟环境
  5. android tcp socket框架_最流行的 Web 框架 Gin 源码阅读
  6. arm-linux 程序开发入门（QT窗口应用程序、编码、交叉编译、调试）（三机器和双机器搭建方法）（笔记）
  7. 动态系统开发方法DSDM
  8. 设计冲刺下载_如何运行成功的设计冲刺
  9. RecyclerView学习（二）之缓存探索
  10. 23岁女工为600元全勤奖带伤加班3天 一周后身亡
  11. 5.23低版本到高版本问题
  12. 没有会员wps合并多个sheet_WPS隐藏黑科技：合并工作簿再也不用复杂操作了，一键就搞定！...
  13. 零代码的科普算法书《未来算法》读后
  14. HZNU 与班尼特·胡迪一起攻破浮空城 【DP】
  15. 001简谱的调号、拍号和情绪
  16. 王者荣耀的服务器是什么系统,王者荣耀健康系统 健康系统是什么
  17. [SP1839]The Bookcase
  18. Python 抓取软科中国大学排名首页数据
  19. 2022年股权转让怎么计算个人所得税
  20. vimdiff颜色设置 + vimrc设置 （copied）

热门文章

  1. python类_Python中的类
  2. 先天性脑部发育异常_宝宝出现发育迟缓，会有哪些症状？修正育儿知识分享！...
  3. 04_pandas字符串函数；数据合并concat、merge；分组groupby；Reshaping；Pivot tables；时间处理（date_range、tz_localize等）
  4. 做谷歌地图是获得Map key的方法
  5. mysql允许两个用户远程连接_mysql允许用户远程连接
  6. python代码质量检查工具_python代码检查工具pylint 让你的python更规范
  7. 目标检测比赛中的 trick
  8. 主流深度学习框架对比（TensorFlow、Keras、MXNet、PyTorch）
  9. 15 函数回调 模块
  10. Spring Cloud Feign设计原理