• 售前

  • 售后

热门帖子
入门百科

PHP实现的mongoDB数据库操作类完整实例

[复制链接]
雅法海 显示全部楼层 发表于 2021-10-25 19:26:11 |阅读模式 打印 上一主题 下一主题
本文实例讲述了PHP实现的mongoDB数据库操作类。分享给各人供各人参考,具体如下:
最近的项目开发中使用的数据库是mongodb数据库,由于小编的公司也是刚刚使用mongodb数据库,以是之前没有封装好的mongodb数据库操作类拿来使用,以是小编在项目中自己封装了一个mongodb数据库操作类,特拿出来分享,不尽人意的地方盼望各人勿喷。
众所周知,mongodb是典范的nosql数据库的代表,受到很多开发者的追捧,近几年尤为火热,mongodb的盛行不是没有缘故原由的,下边给各人简朴先容下MongoDB。
MongoDB是一个介于关系数据库和非关系数据库之间的产物,是非关系数据库当中功能最丰富,最像关系数据库的。他支持的数据布局非常疏松,是雷同json的bjson格式,因此可以存储比较复杂的数据范例。Mongo最大的特点是他支持的查询语言非常强盛,其语法有点雷同于面向对象的查询语言,几乎可以实现雷同关系数据库单表查询的绝大部分功能,而且还支持对数据创建索引。
它的特点是高性能、易摆设、易使用,存储数据非常方便。紧张功能特性有:
面向聚集存储,易存储对象范例的数据。
模式自由。
支持动态查询。
支持完全索引,包罗内部对象。
支持查询。
支持复制和故障规复。
使用高效的二进制数据存储,包罗大型对象(如视频等)。
自动处理碎片,以支持云盘算层次的扩展性
支持RUBY,PYTHON,JAVA,C++,PHP等多种语言。
文件存储格式为BSON(一种JSON的扩展)
可通过网络访问

所谓“面向聚集”(Collenction-Orented),意思是数据被分组存储在数据会合,被称为一个聚集(Collenction)。每个 聚集在数据库中都有一个唯一的标识名,而且可以包罗无穷数目的文档。聚集的概念雷同关系型数据库(RDBMS)里的表(table),差别的是它不必要定 义任何模式(schema)。
模式自由(schema-free),意味着对于存储在mongodb数据库中的文件,我们不必要知道它的任何布局界说。假如必要的话,你完全可以把差别布局的文件存储在同一个数据库里。
存储在聚集中的文档,被存储为键-值对的情势。键用于唯一标识一个文档,为字符串范例,而值则可以是各中复杂的文件范例。我们称这种存储情势为BSON(Binary Serialized dOcument Format)。
MongoDB服务端可运行在Linux、Windows或OS X平台,支持32位和64位应用,默认端口为27017。保举运行在64位平台,由于MongoDB
在32位模式运行时支持的最大文件尺寸为2GB。
MongoDB把数据存储在文件中(默认路径为:/data/db),为进步服从使用内存映射文件举行管理。
小编自己封装的PHP操作MongoDB数据库的数据库操作类源码如下,仅供参考。
  1. <?php
  2. /**
  3. * PHP操作mongodb数据库操作类
  4. */
  5. class Database {
  6.   protected $database  = '';
  7.   protected $mo;
  8.   /**
  9.    * 构造方法
  10.    */
  11.   public function __construct() {
  12.     $server = DBSERVER;
  13.     $user = DBUSER;
  14.     $password = DBPASS;
  15.     $port = DBPORT;
  16.     $database = DBNAME;
  17.     $mongo = $this->getInstance($server, $user, $password, $port);
  18.     $this->database = $mongo->$database;
  19.   }
  20.   /**
  21.    * 数据库单例方法
  22.    * @param $server
  23.    * @param $user
  24.    * @param $password
  25.    * @param $port
  26.    * @return Mongo
  27.    */
  28.   public function getInstance($server, $user, $password, $port) {
  29.     if (isset($this->mo)) {
  30.       return $this->mo;
  31.     } else {
  32.       if (!empty($server)) {
  33.         if (!empty($port)) {
  34.           if (!empty($user) && !empty($password)) {
  35.             $this->mo = new Mongo("mongodb://{$user}:{$password}@{$server}:{$port}");
  36.           } else {
  37.             $this->mo = new Mongo("mongodb://{$server}:{$port}");
  38.           }
  39.         } else {
  40.           $this->mo = new Mongo("mongodb://{$server}");
  41.         }
  42.       } else {
  43.         $this->mo = new Mongo();
  44.       }
  45.       return $this->mo;
  46.     }
  47.   }
  48.   /**
  49.    * 查询表中所有数据
  50.    * @param $table
  51.    * @param array $where
  52.    * @param array $sort
  53.    * @param string $limit
  54.    * @param string $skip
  55.    * @return array|int
  56.    */
  57.   public function getAll($table, $where = array(), $sort = array(), $limit = '', $skip = '') {
  58.     if (!empty($where)) {
  59.       $data = $this->database->$table->find($where);
  60.     } else {
  61.       $data = $this->database->$table->find();
  62.     }
  63.     if (!empty($sort)) {
  64.       $data = $data->sort($sort);
  65.     }
  66.     if (!empty($limit)) {
  67.       $data = $data->limit($limit);
  68.     }
  69.     if (!empty($skip)) {
  70.       $data = $data->skip($skip);
  71.     }
  72.     $newData = array();
  73.     while ($data->hasNext()) {
  74.       $newData[] = $data->getNext();
  75.     }
  76.     if (count($newData) == 0) {
  77.       return 0;
  78.     }
  79.     return $newData;
  80.   }
  81.   /**
  82.    * 查询指定一条数据
  83.    * @param $table
  84.    * @param array $where
  85.    * @return int
  86.    */
  87.   public function getOne($table, $where = array()) {
  88.     if (!empty($where)) {
  89.       $data = $this->database->$table->findOne($where);
  90.     } else {
  91.       $data = $this->database->$table->findOne();
  92.     }
  93.     return $data;
  94.   }
  95.   /**
  96.    * 统计个数
  97.    * @param $table
  98.    * @param array $where
  99.    * @return mixed
  100.    */
  101.   public function getCount($table, $where = array()) {
  102.     if (!empty($where)) {
  103.       $data = $this->database->$table->find($where)->count();
  104.     } else {
  105.       $data = $this->database->$table->find()->count();
  106.     }
  107.     return $data;
  108.   }
  109.   /**
  110.    * 直接执行mongo命令
  111.    * @param $sql
  112.    * @return array
  113.    */
  114.   public function toExcute($sql) {
  115.     $result = $this->database->execute($sql);
  116.     return $result;
  117.   }
  118.   /**
  119.    * 分组统计个数
  120.    * @param $table
  121.    * @param $where
  122.    * @param $field
  123.    */
  124.   public function groupCount($table, $where, $field) {
  125.     $cond = array(
  126.       array(
  127.         '$match' => $where,
  128.       ),
  129.       array(
  130.         '$group' => array(
  131.           '_id' => '$' . $field,
  132.           'count' => array('$sum' => 1),
  133.         ),
  134.       ),
  135.       array(
  136.         '$sort' => array("count" => -1),
  137.       ),
  138.     );
  139.     $this->database->$table->aggregate($cond);
  140.   }
  141.   /**
  142.    * 删除数据
  143.    * @param $table
  144.    * @param $where
  145.    * @return array|bool
  146.    */
  147.   public function toDelete($table, $where) {
  148.     $re = $this->database->$table->remove($where);
  149.     return $re;
  150.   }
  151.   /**
  152.    * 插入数据
  153.    * @param $table
  154.    * @param $data
  155.    * @return array|bool
  156.    */
  157.   public function toInsert($table, $data) {
  158.     $re = $this->database->$table->insert($data);
  159.     return $re;
  160.   }
  161.   /**
  162.    * 更新数据
  163.    * @param $table
  164.    * @param $where
  165.    * @param $data
  166.    * @return bool
  167.    */
  168.   public function toUpdate($table, $where, $data) {
  169.     $re = $this->database->$table->update($where, array('$set' => $data));
  170.     return $re;
  171.   }
  172.   /**
  173.    * 获取唯一数据
  174.    * @param $table
  175.    * @param $key
  176.    * @return array
  177.    */
  178.   public function distinctData($table, $key, $query = array()) {
  179.     if (!empty($query)) {
  180.       $where = array('distinct' => $table, 'key' => $key, 'query' => $query);
  181.     } else {
  182.       $where = array('distinct' => $table, 'key' => $key);
  183.     }
  184.     $data = $this->database->command($where);
  185.     return $data['values'];
  186.   }
  187. }
  188. ?>
复制代码
更多关于PHP干系内容感爱好的读者可检察本站专题:《PHP+MongoDB数据库操作本事大全》、《PHP基于pdo操作数据库本事总结》、《php面向对象程序筹划入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作本事汇总》
盼望本文所述对各人PHP程序筹划有所资助。

帖子地址: 

回复

使用道具 举报

分享
推广
火星云矿 | 预约S19Pro,享500抵1000!
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

草根技术分享(草根吧)是全球知名中文IT技术交流平台,创建于2021年,包含原创博客、精品问答、职业培训、技术社区、资源下载等产品服务,提供原创、优质、完整内容的专业IT技术开发社区。
  • 官方手机版

  • 微信公众号

  • 商务合作