PHP操作Mongodb API 及使用类 封装好的MongoDB操作类
来源:http://www.itokit.com/2012/0427/73656.html
- <?php
- /*** Mongodb类** examples:
- * $mongo = new HMongodb("127.0.0.1:11223");
- * $mongo->selectDb("test_db");
- * 创建索引
- * $mongo->ensureIndex("test_table", array("id"=>1), array('unique'=>true));
- * 获取表的记录
- * $mongo->count("test_table");
- * 插入记录
- * $mongo->insert("test_table", array("id"=>2, "title"=>"asdqw"));
- * 更新记录
- * $mongo->update("test_table", array("id"=>1),array("id"=>1,"title"=>"bbb"));
- * 更新记录-存在时更新,不存在时添加-相当于set
- * $mongo->update("test_table", array("id"=>1),array("id"=>1,"title"=>"bbb"),array("upsert"=>1));
- * 查找记录
- * $mongo->find("c", array("title"=>"asdqw"), array("start"=>2,"limit"=>2,"sort"=>array("id"=>1)))
- * 查找一条记录
- * $mongo->findOne("$mongo->findOne("ttt", array("id"=>1))", array("id"=>1));
- * 删除记录
- * $mongo->remove("ttt", array("title"=>"bbb"));
- * 仅删除一条记录
- * $mongo->remove("ttt", array("title"=>"bbb"), array("justOne"=>1));
- * 获取Mongo操作的错误信息
- * $mongo->getError();
- */
- class HMongodb {
- //Mongodb连接
- var $mongo;
- var $curr_db_name;
- var $curr_table_name;
- var $error;
- /**
- * 构造函数
- * 支持传入多个mongo_server(1.一个出问题时连接其它的server 2.自动将查询均匀分发到不同server)
- *
- * 参数:
- * $mongo_server:数组或字符串-array("127.0.0.1:1111", "127.0.0.1:2222")-"127.0.0.1:1111"
- * $connect:初始化mongo对象时是否连接,默认连接
- * $auto_balance:是否自动做负载均衡,默认是
- *
- * 返回值:
- * 成功:mongo object
- * 失败:false
- */
- function __construct($mongo_server, $connect=true, $auto_balance=true)
- {
- if (is_array($mongo_server))
- {
- $mongo_server_num = count($mongo_server);
- if ($mongo_server_num > 1 && $auto_balance)
- {
- $prior_server_num = rand(1, $mongo_server_num);
- $rand_keys = array_rand($mongo_server,$mongo_server_num);
- $mongo_server_str = $mongo_server[$prior_server_num-1];
- foreach ($rand_keys as $key)
- {
- if ($key != $prior_server_num - 1)
- {
- $mongo_server_str .= ',' . $mongo_server[$key];
- }
- }
- }
- else
- {
- $mongo_server_str = implode(',', $mongo_server);
- } }
- else
- {
- $mongo_server_str = $mongo_server;
- }
- try {
- $this->mongo = new Mongo($mongo_server, array('connect'=>$connect));
- }
- catch (MongoConnectionException $e)
- {
- $this->error = $e->getMessage();
- return false;
- }
- }
- function getInstance($mongo_server, $flag=array())
- {
- static $mongodb_arr;
- if (emptyempty($flag['tag']))
- {
- $flag['tag'] = 'default'; }
- if (isset($flag['force']) && $flag['force'] == true)
- {
- $mongo = new HMongodb($mongo_server);
- if (emptyempty($mongodb_arr[$flag['tag']]))
- {
- $mongodb_arr[$flag['tag']] = $mongo;
- }
- return $mongo;
- }
- else if (isset($mongodb_arr[$flag['tag']]) && is_resource($mongodb_arr[$flag['tag']]))
- {
- return $mongodb_arr[$flag['tag']];
- }
- else
- {
- $mongo = new HMongodb($mongo_server);
- $mongodb_arr[$flag['tag']] = $mongo;
- return $mongo; } }
- /**
- * 连接mongodb server
- *
- * 参数:无
- *
- * 返回值:
- * 成功:true
- * 失败:false
- */
- function connect()
- {
- try {
- $this->mongo->connect();
- return true;
- }
- catch (MongoConnectionException $e)
- {
- $this->error = $e->getMessage();
- return false;
- }
- }
- /**
- * select db
- *
- * 参数:$dbname
- *
- * 返回值:无
- */
- function selectDb($dbname)
- {
- $this->curr_db_name = $dbname;
- }
- /**
- * 创建索引:如索引已存在,则返回。
- *
- * 参数:
- * $table_name:表名
- * $index:索引-array("id"=>1)-在id字段建立升序索引
- * $index_param:其它条件-是否唯一索引等
- *
- * 返回值:
- * 成功:true
- * 失败:false
- */
- function ensureIndex($table_name, $index, $index_param=array())
- {
- $dbname = $this->curr_db_name;
- $index_param['safe'] = 1;
- try {
- $this->mongo->$dbname->$table_name->ensureIndex($index, $index_param);
- return true;
- }
- catch (MongoCursorException $e)
- {
- $this->error = $e->getMessage();
- return false;
- }
- }
- /**
- * 插入记录
- *
- * 参数:
- * $table_name:表名
- * $record:记录
- *
- * 返回值:
- * 成功:true
- * 失败:false
- */
- function insert($table_name, $record)
- {
- $dbname = $this->curr_db_name;
- try {
- $this->mongo->$dbname->$table_name->insert($record, array('safe'=>true));
- return true;
- }
- catch (MongoCursorException $e)
- {
- $this->error = $e->getMessage();
- return false;
- }
- }
- /**
- * 查询表的记录数
- *
- * 参数:
- * $table_name:表名
- *
- * 返回值:表的记录数
- */
- function count($table_name)
- {
- $dbname = $this->curr_db_name;
- return $this->mongo->$dbname->$table_name->count();
- }
- /**
- * 更新记录
- *
- * 参数:
- * $table_name:表名
- * $condition:更新条件
- * $newdata:新的数据记录
- * $options:更新选择-upsert/multiple
- *
- * 返回值:
- * 成功:true
- * 失败:false
- */
- function update($table_name, $condition, $newdata, $options=array())
- {
- $dbname = $this->curr_db_name;
- $options['safe'] = 1;
- if (!isset($options['multiple']))
- {
- $options['multiple'] = 0; }
- try {
- $this->mongo->$dbname->$table_name->update($condition, $newdata, $options);
- return true;
- }
- catch (MongoCursorException $e)
- {
- $this->error = $e->getMessage();
- return false;
- } }
- /**
- * 删除记录
- *
- * 参数:
- * $table_name:表名
- * $condition:删除条件
- * $options:删除选择-justOne
- *
- * 返回值:
- * 成功:true
- * 失败:false
- */
- function remove($table_name, $condition, $options=array())
- {
- $dbname = $this->curr_db_name;
- $options['safe'] = 1;
- try {
- $this->mongo->$dbname->$table_name->remove($condition, $options);
- return true;
- }
- catch (MongoCursorException $e)
- {
- $this->error = $e->getMessage();
- return false;
- } }
- /**
- * 查找记录
- *
- * 参数:
- * $table_name:表名
- * $query_condition:字段查找条件
- * $result_condition:查询结果限制条件-limit/sort等
- * $fields:获取字段
- *
- * 返回值:
- * 成功:记录集
- * 失败:false
- */
- function find($table_name, $query_condition, $result_condition=array(), $fields=array())
- {
- $dbname = $this->curr_db_name;
- $cursor = $this->mongo->$dbname->$table_name->find($query_condition, $fields);
- if (!emptyempty($result_condition['start']))
- {
- $cursor->skip($result_condition['start']);
- }
- if (!emptyempty($result_condition['limit']))
- {
- $cursor->limit($result_condition['limit']);
- }
- if (!emptyempty($result_condition['sort']))
- {
- $cursor->sort($result_condition['sort']);
- }
- $result = array();
- try {
- while ($cursor->hasNext())
- {
- $result[] = $cursor->getNext();
- }
- }
- catch (MongoConnectionException $e)
- {
- $this->error = $e->getMessage();
- return false;
- }
- catch (MongoCursorTimeoutException $e)
- {
- $this->error = $e->getMessage();
- return false;
- }
- return $result;
- }
- /**
- * 查找一条记录
- *
- * 参数:
- * $table_name:表名
- * $condition:查找条件
- * $fields:获取字段
- *
- * 返回值:
- * 成功:一条记录
- * 失败:false
- */
- function findOne($table_name, $condition, $fields=array())
- {
- $dbname = $this->curr_db_name;
- return $this->mongo->$dbname->$table_name->findOne($condition, $fields);
- }
- /**
- * 获取当前错误信息
- *
- * 参数:无
- *
- * 返回值:当前错误信息
- */
- function getError()
- {
- return $this->error;
- }
- }
- ?>
转载于:https://www.cnblogs.com/hasayaki/archive/2013/06/07/3124136.html
PHP操作Mongodb API 及使用类 封装好的MongoDB操作类相关推荐
- java类成员和实例成员,面向对象Java实验:实验二 类封装,实例成员与类成员,包...
面向对象Java实验:实验二 类封装,实例成员与类成员,包 程序1: class Trangle { double sideA,sideB,sideC,area,length; boolean boo ...
- azure api 管理_Azure Cosmos DB和MongoDB API入门
azure api 管理 In the previous article on Azure Cosmos DB, we reviewed NoSQL concepts and how to integ ...
- AD——如何进行IC类封装创建?
*写在前面: 本文使用AD2018,同时本文案例中的说明书可直接下载. 点击下载(百度网盘,提取码xwla) 首先介绍一下IC类封装的概念. IC类封装: IC封装,就是指把硅片上的电路管脚,用导线接 ...
- ( 持续更新,目前含 200+ 工具类 ) DevUtils 是一个 Android 工具库, 主要根据不同功能模块,封装快捷使用的工具类及 API 方法调用。
DevUtils GitHub About ( 持续更新,目前含 200+ 工具类 ) Roadmap DevUtils 是一个 Android 工具库,主要根据不同功能模块,封装快捷使用的工具类及 ...
- thinkphp mysql类_PHP封装类似thinkphp连贯操作数据库的Db类(简单版)
为了方便操作Mysql数据库, 封装类似thinkphp连贯操作数据库的Db类<?php header("Content-Type:text/html;charset=utf-8&qu ...
- php操作mysql的封装类_PHP封装的mysqli数据库操作类示例
本文实例讲述了PHP封装的mysqli数据库操作类.分享给大家供大家参考,具体如下: 由于PHPMySQL操作在PHP5.4以下被弃用而推荐使用mysqli(MySQL Improvement),这里 ...
- php db类 应用实例,PHP封装类似thinkphp连贯操作数据库Db类与简单应用示例
本文实例讲述了PHP封装类似thinkphp连贯操作数据库Db类与简单应用.分享给大家供大家参考,具体如下: header("Content-Type:text/html;charset=u ...
- QT 操作excel 类封装(转载)
QT 操作excel 类封装(转载) 原链接:http://blog.csdn.net/liliming1234/article/details/7054941 pro file [plain] v ...
- Spring Boot神操作-多个数据源Service层封装
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 作者:@pdai pdai.tech/md/spring/spri ...
最新文章
- C和C++安全编码笔记:整数安全
- pandas使用read_csv读取文件数据、设置converters参数将百分比字符串转换为数字
- Java核心技术笔记 语言基础
- iOS中 动态启动图GIF的简单设置 韩俊强的博客
- 生命html文档,Web前端第一季(HTML)
- 手机吃鸡登显示服务器繁忙,国际版吃鸡登录一直显示服务器繁忙 | 手游网游页游攻略大全...
- linux 安装_Linux安装JDK
- NVIDIA历史驱动下载
- 2022年大厂中秋礼盒大赏,卷的就是创意!
- “我培训完JAVA,进了美团,美团氛围特别好,就是送餐特别累”
- 1.python程序图标制作
- PMU 精密测量单元
- 对大学三年学习生活的总结与反思
- Sources for ‘Android API 32 Platform’ not found
- 【记录贴】联想笔记本小新进入BIOS的方法
- 如何写一封稍微像样的求职邮件
- 招商银行信用卡使用说明
- 学人工智能电脑主机八大件配置选择指南
- 05 高等数学专题——无穷级数
- java简单通讯录实现
热门文章
- Flutter中使用友盟统计
- VC++判断文件或文件夹是否存在(转)
- Linux下安装Beego:go install: cannot install cross-compiled binaries when GOBIN is set
- sweetalert 1.0多次回调函数bug
- C语言实现二叉树-04版
- iOS中创建,使用动态库(dylib)
- 如何在程序中打开PDF文件 -C#文章(.net)
- Elementui 自定义loading
- IE overflow:hidden失效的解决方法:
- JS-数组-声明方式-读写添加删除-遍历