2. 程式人生 > >分享下mongodb封裝的幾個方法

分享下mongodb封裝的幾個方法

阿新 • • 發佈：2018-12-24
<?php /** * Created by sublime. * User: XXXX * Date: 2017/12/1 * Time: 15:44 */ namespace Lib; use MongoClient; //下面是驅動類，現在沒有用到，我的版本php5.5，如果是php7就要用到這些類 use MongoDB\BSON\ObjectID; use MongoDB\Driver\BulkWrite; use MongoDB\Driver\Command; use MongoDB\Driver\Cursor; use MongoDB\Driver\Exception\AuthenticationException
; use MongoDB\Driver\Exception\BulkWriteException; use MongoDB\Driver\Exception\ConnectionException; use MongoDB\Driver\Exception\InvalidArgumentException; use MongoDB\Driver\Exception\RuntimeException; use MongoDB\Driver\Manager; use MongoDB\Driver\Query as MongoQuery; use MongoDB\Driver\ReadPreference
; use MongoDB\Driver\WriteConcern; /** * PHP操作mongodb資料庫操作類 */ class MongoDb { protected $database = ''; protected $mo; /** * 構造方法 */ public function __construct() { $database = DBNAME; $mongo = $this->getConnect(DBSERVER, DBUSER, DBPASS, DBPORT); $this
->database = $mongo->$database; } /** * 資料庫單例方法 * @param $server * @param $user * @param $password * @param $port * test 測試 * @return Mongo */ /*public function getConnect($server, $user, $password, $port) { // echo "mongodb://{$server}:{$port}";die; // $mongo = new MongoClient("mongodb://{$server}:{$port}"); $mongo = new MongoClient("mongodb://{$server}:{$port}"); return $mongo; }*/ /** * 資料庫單例方法 * @param $server * @param $user * @param $password * @param $port * @return Mongo */ public function getConnect($server, $user, $password, $port) { if (isset($this->mo)) { return $this->mo; } else { if (!empty($server)) { if (!empty($port)) { if (!empty($user) && !empty($password)) { $this->mo = new MongoClient("mongodb://{$user}:{$password}@{$server}:{$port}"); } else { $this->mo = new MongoClient("mongodb://{$server}:{$port}"); } } else { $this->mo = new MongoClient("mongodb://{$server}"); } } else { $this->mo = new MongoClient(); } return $this->mo; } } /** * 查詢表中所有資料 * @param $table * @param array $where * @param array $sort * @param string $limit * @param string $skip * @return array|int */ public function getAll($table, $where = array(), $sort = array(), $limit = '', $skip = '') { if (!empty($where)) { $data = $this->database->$table->find($where); } else { $data = $this->database->$table->find(); } if (!empty($sort)) { $data = $data->sort($sort); } if (!empty($limit)) { $data = $data->limit($limit); } if (!empty($skip)) { $data = $data->skip($skip); } $newData = array(); while ($data->hasNext()) { $newData[] = $data->getNext(); } if (count($newData) == 0) { return 0; } return $newData; } /** * 查詢表中所有資料，將_id 物件變成陣列 * @param $table * @param array $where * @param array $sort * @param string $limit * @param string $skip * @return array */ public function getAllArray($table, $where = array(), $sort = array(), $limit = '', $skip = '') { if (!empty($where)) { $data = $this->database->$table->find($where); } else { $data = $this->database->$table->find(); } if (!empty($sort)) { $data = $data->sort($sort); } if (!empty($limit)) { $data = $data->limit($limit); } if (!empty($skip)) { $data = $data->skip($skip); } $newData = array(); while ($data->hasNext()) { $newData[] = $data->getNext(); } if (count($newData) == 0) { return 0; } foreach ($newData as $key => $val) { $id = $val['_id']->{'$id'}; $newData[$key]['_id'] = $id; } return $newData; } /** * 查詢指定一條資料 * @param $table * @param array $where * @return int */ public function getOne($table, $where = array()) { if (!empty($where)) { $data = $this->database->$table->findOne($where); } else { $data = $this->database->$table->findOne(); } return $data; } /** * 統計個數 * @param $table * @param array $where * @return mixed */ public function getCount($table, $where = array()) { if (!empty($where)) { $data = $this->database->$table->find($where)->count(); } else { $data = $this->database->$table->find()->count(); } return $data; } /** * 直接執行mongo命令 * @param $sql * @return array */ public function toExcute($sql) { $result = $this->database->execute($sql); return $result; } /** * 分組統計個數 * @param $table * @param $where * @param $field */ public function groupCount($table, $where, $field) { $cond = array( array( '$match' => $where, ), array( '$group' => array( '_id' => '$' . $field, 'count' => array('$sum' => 1), ), ), array( '$sort' => array("count" => -1), ), ); $this->database->$table->aggregate($cond); } /** * 刪除資料 * @param $table * @param $where * @return array|bool */ public function toDelete($table, $where) { $re = $this->database->$table->remove($where); return $re; } /** * 插入資料 * @param $table * @param $data * @return array|bool */ public function toInsert($table, $data) { $re = $this->database->$table->insert($data); return $re; } /** * 更新資料 * @param $table * @param $where * @param $data * @return bool */ public function toUpdate($table, $where, $data) { $re = $this->database->$table->update($where, array('$set' => $data)); return $re; } /** * 獲取唯一資料 * @param $table * @param $key * @return array */ public function distinctData($table, $key, $query = array()) { if (!empty($query)) { $where = array('distinct' => $table, 'key' => $key, 'query' => $query); } else { $where = array('distinct' => $table, 'key' => $key); } $data = $this->database->command($where); return $data['values']; } } ?>

相關推薦

分享下mongodb封裝的幾個方法

<?php /** * Created by sublime. * User: XXXX * Date: 2017/12/1 * Time: 15:44 */ namespace Lib; use MongoClient; //下面是驅動類，現在沒有用到，我的版本php5.5，如果是php

網站原創內容獲取的幾個方法分享

原創的方法有很多，這裡我就列出來，不詳細解讀了。但我重點說說時間差原創法。 　　1、純原創，結合網站的需求有自己的編輯新聞隊伍。這種方法獲益最大，但付出的也最多，不適用小網站。 　　2、資訊採集原創，很多新站，由於人力的問題，多采用這種方法，但收錄的效果和活動連結並不多。

Ubuntu下檢視SD卡裝置名的幾個方法

Ubuntu下使用SD卡查詢SD卡的裝置檔名：sudo fdisk -leg:Disk /dev/sdb：14.9 GiB，15931539456 位元組，31116288 個扇區單元：扇區 / 1 * 512 = 512 位元組扇區大小(邏輯/物理)：512 位元組 / 512 位元組I/O 大小(最小/最

Python+Selenium中級篇之3-二次封裝Selenium中幾個方法

       本文來介紹，如何把常用的幾個webdriver的方法封裝到自己寫的一個類中去，這個封裝過程叫二次封裝Selenium方法。我們把開啟站點，瀏覽器前進和後退，關閉和退出瀏覽器這這個方法封裝

讓一個元素在容器中垂直居中的幾個方法

body 垂直居中 -s ntb offset set log off htm 方法一，使用js讓元素水平垂直居中 <!DOCTYPE html> <html> <head> <meta charset

php中mysqli 處理查詢結果集的幾個方法

數值 集中 style 索引 php bsp 枚舉 tab object 最近對php查詢mysql處理結果集的幾個方法不太明白的地方查閱了資料，在此整理記下 Php使用mysqli_result類處理結果集有以下幾種方法 fetch_all() 抓取所有的結果行並且

Unity插件擴展中組件常用的幾個方法

重新 paths form log public 名字查找 實例化 dna mat 最近為美術編寫一個Unity編輯器的擴展，主要為了減輕美術在修改預制對象時的機械化操作的繁瑣和出錯。具體實現的幾個功能： 1、刪除指定組件； 2、復制、粘貼指定的組件； 3、重新關聯新的屬性

淘寶爆款詳情頁制作的幾個方法(理論)

運營 如果 article class clas es2017 文章 art -1 淘寶爆款詳情頁制作的幾個方法 如果你是運營淘寶的店主，抑或是準備從事這個行業的，這個文章將會對你有很大幫助。 淘寶爆款詳情頁制作的幾個方法(理論)

Webpack打包構建太慢了？試試幾個方法

hash vid put es5 階段 ade new contex 版本 Webpack是個很流行的打包工具，但其打包速度卻一直被吐槽著 如果不用上一些打包的優化建議，單單打包兩三個文件就能花上好幾秒，放上幾十個入口文件依賴幾百上千個包的話，幾分鐘十幾分鐘妥妥的

論找網站後臺的幾個方法

htm round 忘記 http 你在 直接 admin 備份 .cn 前言: 有可能你在滲透測試的過程中會遇到這樣一個問題:目標站存在sql註入，卻找不到後臺，這是不是很蛋疼呢?所以這就是寫這篇文章的目的：如何找網站後臺 1、字典掃描 原理:利用敏感url（由很多u

linux下常用的幾個時間函數：time,gettimeofday,clock_gettime,_ftime

turn mon nan start 存儲 mono star 結合 eva time()提供了秒級的精確度 1、頭文件 <time.h> 2、函數原型 time_t time(time_t * timer) 函數返回從TC1970-1

取IP的幾個方法

awk conf $# brush config light cut grep add ifconfig eth0|grep " inet add"|cut -d":" -f2|cut -d " " -f1 ifconfig eth0|grep " inet add"|

CSS響應式：根據分辨路加載不同CSS的幾個方法，親測可用

響應 col 但是 max-width width media 總結 屏幕 link 有時候你需要把同一個頁面在手機和pc同時打開，其中有一個辦法就是判斷不同分辨路加載不同的css 小編總結了幾種分別加載css的方法： 1.比較復雜的使用js判斷加載不同css （親

介紹nodejs中的path模塊的幾個方法

rsync wro 不同 osi {} tip multi 發現 post webpack中常用的： var path = require(‘path‘) 是nodejs中的path模塊，介紹一下webpack中常用的幾個path模塊的方法： 應用node環境的時候，這個p

java保留小數點的幾個方法

bsp turn 格式 pre brush system float mat integer 方法一: String類自帶的方法 String.format("%.2f", 1.2548); "%.2f"其中的數字決定保留幾位方法二: 格式化的方法 private st

數組去重的幾個方法

一輪 遍歷數組 簡單的 數組 RR 第一次 沒有 結構 都是 1.遍歷數組法 它是最簡單的數組去重方法（indexOf方法） 實現思路：新建一個數組，遍歷去要重的數組，當值不在新數組的時候（indexOf為-1）就加入該新數組中； var arr=[2,8,5,0,5,2,

查看Android應用包名、Activity的幾個方法

local get edit pack too edi androidm shell mcu 一、沒有apk，應用已經安裝到手機或虛擬機中 1.logcat .清除logcat內容，使用命令adb logcat -c .啟動logcat，使用命令adb logcat Act

今天給大家分享一篇關於幾個C語言幾個難題

字符 多少 std stdio.h c語言 程序 是什麽 include 輸出 .下面這個程序的輸出結果是什麽？ #include<stdio.h>int main(){int i=43;printf("%d\n",printf("

操作系統下cache的幾個概念

cpu 程序 性能 存儲 支持 由於 機制 訪問 芯片 　　Cache是一種容量比較小，但訪問速度比較快存儲器。由於處理器的速度遠高於主存，處理器直接從內存中存取數據要等待一定周期，而Cache位於處理器與主存之間，保存著最近一段時間處理器涉及到的主存塊內容。在需要讀取數據

數組的幾個方法

並且 ans 都去 microsoft 順序 才會 實踐 兩個 info 數組的 every() 、some() 、filter() 三者的回調函數都有三個參數：元素、索引和當前數組，用到哪個寫哪個（元素一定要有），順序不可亂 every() 當數組的每個元素都滿足條件（