찾다

집  >  기사  >  백엔드 개발  >  PHP로 캡슐화된 mongodb 작업 클래스

PHP로 캡슐화된 mongodb 작업 클래스

WBOY
WBOY원래의
2016-07-25 08:43:17828검색
  2. /*
  3. * 이 템플릿을 변경하려면 도구 | 템플릿
  4. * 편집기에서 템플릿을 엽니다.
  5. */
  8. class mongo_db {
  10. private $config;
  11. 비공개 $connection;
  12. 비공개 $db;
  13. 비공개 $connection_string;
  14. 비공개 $host;
  15. 비공개 $port;
  16. 개인 $user;
  17. 비공개 $pass;
  18. 비공개 $dbname;
  19. 비공개 $persist;
  20. 비공개 $persist_key;
  21. 비공개 $selects = array();
  22. 비공개 $wheres = array();
  23. 비공개 $sorts = array();
  24. 비공개 $limit = 999999;
  25. 비공개 $offset = 0;
  26. 비공개 $timeout = 200;
  27. 개인 $key = 0;
  28. /*** ------------------------------------------------- ------------------ * 생성자 * --- ------------------------------------- -------------- * * Mongo PECL 확장이 설치/활성화되었는지 자동으로 확인합니다. * 연결 문자열을 생성하고 MongoDB에 대한 연결을 설정합니다.*/
  30. 공개 함수 __construct() {
  31. if((IS_NOSQL != 1)){
  32. return;
  33. }
  34. if (!class_exists('Mongo')) {
  35. //$this->error("MongoDB PECL 확장이 설치되지 않았거나 활성화되지 않았습니다.", 500);
  36. }
  37. $configs =wxcity_base::load_config("캐시","mongo_db");
  38. $num = count($configs['connect']);
  39. $this->timeout = Trim($configs['timeout']);
  40. $keys = wxcity_base::load_config('double');
  41. $this->key = $keys['mongo_db'];
  42. $this->config = $configs['connect'][$this->key];
  43. $status = $this->connect();
  44. if($status == false)
  45. {
  46. for($i = 1; $i < $num; $i )
  47. {
  48. $n = $this-> 키 $i;
  49. $key = $n >= $num ? $n - $번호 : $n;
  50. $this->config = $configs['connect'][$key];
  51. $status = $this->connect();
  52. if($status!=false)
  53. {
  54. $keys['mongo_db'] = $key ;
  55. $this->key = $key;
  56. $data = "";
  57. file_put_contents(WHTY_PATH.'configs/double.php', $data, LOCK_EX);
  58. 휴식;
  59. }
  60. }
  61. }
  62. if($status==false)
  63. {
  64. die('mongoDB가 연결되지 않음');
  65. }
  66. }
  68. function __destruct() {
  69. if((IS_NOSQL != 1)){
  70. return;
  71. }
  72. if($this->connection)
  73. {
  74. $this->connection->close();
  75. }
  76. }
  78. /*** ------------------------------------------------- ------------------ * MONGODB에 연결 * -------------- ------------------------------------- ---------------- * * * Connection_string() 메소드에서 생성된 연결 문자열을 사용하여 MongoDB에 대한 연결을 설정합니다. * 구성 파일에서 'mongo_persist_key'가 true로 설정된 경우 영구 연결을 설정합니다. 즉시 연결을 설정하려고 하기 때문에 'persist' * 옵션만 설정하도록 허용합니다.*/
  79. private function connect() {
  80. $this->connection_string();
  81. $options = array('connect'=>true,'timeout'=>$this->timeout);
  82. try {
  83. $this->connection = new Mongo($this->connection_string, $options);
  84. $this->db = $this->connection->{$this->dbname};
  85. return($this);
  86. } catch(MongoConnectionException $e) {
  87. return false;
  88. }
  90. }
  91. /*** ------------------------------------------------- ------------------------------- * 建構連接字串* ------------- ------------------------------------------------- - ---------------- * * 從設定檔建立連接字串。*/
  92. private function connection_string() {
  93. $this->host = trim($this->config['hostname']);
  94. $this->port = trim($this->config['port']);
  95. $this->user = trim($this->config['使用者名稱']);
  96. $this->pass = trim($this->config['password']);
  97. $this->dbname = trim($this->config['database']);
  98. $this->persist = trim($this->config['autoconnect']);
  99. $this->persist_key = trim($this->config['mongo_persist_key']);
  101. $connection_string = "mongodb://";
  102. if (emptyempty($this->host)) {
  103. $this->error("必須將主機設定為連接到 MongoDB", 500);
  104. } if (emptyempty($this->dbname)) {
  105. $this->error("資料庫必須設定為連接到 MongoDB", 500);
  106. } if (!emptyempty($this->user) && !emptyempty($this->pass)) {
  107. $connection_string .= "{$this->user}:{$this->透過} @”；
  108. } if (isset($this->port) && !emptyempty($this->port)) {
  109. $connection_string .= "{$this->host}:{$this-> ;港口} 」;
  110. } else {
  111. $connection_string .= "{$this->host}";
  112. } $this->connection_string = trim($connection_string); > /*** ------------------------------------------------- ------------------------------- * Switch_db * ---------------- -------------------------------------------------- -------------- * * 從預設資料庫切換到不同的資料庫*/
  113. public function switch_db($database = '') {
  114. if (emptyempty($database)) {
  115. $this- >error(" 切換MongoDB資料庫，必須指定新的資料庫名稱", 500) ;
  116. } $this->dbname = $database;
  117. 嘗試{
  118. $this->db = $this->connection->{$this->dbname };
  119. 回傳（真） ;
  120. } catch (Exception $e) {
  121. $this->error(" 無法切換Mongo 資料庫：{$e->getMessage()}", 500);
  122. }
  123. }
  125. /*** ------------------------------------------------- ------------------------------- * 選擇欄位* --------------- -------------------------------------------------- --------------- * * 決定在查詢過程中包含哪些欄位或排除哪些欄位。 * 目前，不能同時包含和排除，因此 * $includes 陣列將優先於 $excludes 陣列。 如果您只想選擇要排除的字段，請將 $includes 保留為空 array()。 * * @usage: $this->mongo_db->select(array('foo', 'bar'))->get('foobar');*/
  126. public function select($includes = array(), $excludes = array()) {
  127. if (! is_array($includes)) {
  128. $includes = array()
  129. }
  130. if (!is_array($excludes)) {
  131. $excludes = array()
  132. } if (!emptyempty($includes)) {
  133. foreach ($includes as $col) {
  134. $this->selects[$col] = 1;
  135. }
  136. } else {
  137. foreach ($excludes as $col) {
  138. $this->selects[$col] = 0;
  139. }
  140. } return($this);
  141. }
  143. /*** ------------------------------------------------- ------------------------------- * 參數所在* --------------- -------------------------------------------------- ---------------- * * 根據這些搜尋參數取得文件。 $wheres 數組應該是一個關聯數組，其中字段作為鍵，值作為搜尋條件。 * * @usage = $this->mongo_db->where(array('foo' => 'bar'))->get('foobar');*/
  144. public function where($wheres = array()) {
  145. foreach ((array)$wheres as $wh => $ val ) {
  146. $this->wheres[$wh] = $val;
  147. } return($this);
  148. }
  150. /*** ------------------------------------------------- ------------------ * WHERE_IN 매개변수 * --------------- ------------------------------------- --------------- * * $field의 값이 주어진 $in array()에 있는 문서를 가져옵니다. * * @usage = $this->mongo_db->where_in('foo', array('bar', 'zoo', 'blah'))->get('foobar');*/
  151. 공용 함수 where_in($field = "", $in = array()) {
  152. $this->where_init($field);
  153. $this->wheres[$field]['$in'] = $in;
  154. return($this);
  155. }
  157. /*** ------------------------------------------------- ------------------ * WHERE_NOT_IN 매개변수 * --------------- ------------------------------------- --------------- * * $field의 값이 주어진 $in array()에 없는 문서를 가져옵니다. * * @usage = $this->mongo_db->where_not_in('foo', array('bar', 'zoo', 'blah'))->get('foobar');*/
  158. 공개 함수 where_not_in($field = "", $in = array()) {
  159. $this->where_init($ 필드);
  160. $this->wheres[$field]['$nin'] = $in;
  161. return($this);
  162. }
  164. /*** ------------------------------------------------- ------------------ * 매개변수보다 큰 경우 * ------------- ------------------------------------- ----------------- * * $field의 값이 $x보다 큰 문서 가져오기 * * @usage = $this->mongo_db->where_gt( '푸', 20);*/
  165. 공개 함수 where_gt($field = "", $x) {
  166. $this->where_init($field);
  167. $this->wheres[$field]['$gt'] = $x;
  168. return($this);
  169. }
  171. /*** ------------------------------------------------- ------------------ * 매개변수보다 크거나 같은 경우 * ---------- ------------------------------------- ------- * * $field의 값이 $x보다 크거나 같은 문서를 가져옵니다. * * @usage = $this-> mongo_db->where_gte('foo', 20);*/
  172. 공개 함수 where_gte($field = "", $x) {
  173. $this->where_init($field);
  174. $this->wheres[$field]['$gte'] = $x;
  175. return($this);
  176. }
  178. /*** ------------------------------------------------- ------------------ * 매개변수보다 작은 경우 * ------------- ------------------------------------- ----------------- * * $field의 값이 $x보다 작은 문서 가져오기 * * @usage = $this->mongo_db->where_lt( '푸', 20);*/
  179. 공개 함수 where_lt($field = "", $x) {
  180. $this->where_init($field);
  181. $this->wheres[$field]['$lt'] = $x;
  182. return($this);
  183. }
  185. /*** ------------------------------------------------- ------------------ * 매개변수보다 작거나 같은 경우 * ---------- ------------------------------------- ------- * * $field의 값이 $x보다 작거나 같은 문서 가져오기 * * @usage = $this-> mongo_db->where_lte('foo', 20);*/
  186. 공개 함수 where_lte($field = "", $x) {
  187. $this->where_init($field);
  188. $this->wheres[$field]['$lte'] = $x;
  189. return($this);
  190. }
  192. /*** ------------------------------------------------- ------------------ * 매개변수 사이 * -------------- ------------------------------------- ---------------- * * $field의 값이 $x와 $y 사이에 있는 문서 가져오기 * * @usage = $this->mongo_db->where_between ('푸', 20, 30);*/
  193. 공개 함수 where_between($field = "", $x, $y) {
  194. $this->where_init($field );
  195. $this->wheres[$field]['$gte'] = $x;
  196. $this->wheres[$field]['$lte'] = $y;
  197. return($this);
  198. }
  200. /*** ------------------------------------------------- ------------------ * 매개변수 사이 및 매개변수와 같지 않음 * ---------- ------------------------------------- ------- * * $field의 값이 $x와 $y 사이이지만 같지 않은 문서를 가져옵니다. * * @usage = $this ->mongo_db->where_between_ne('foo', 20, 30);*/
  201. 공개 함수 where_between_ne($field = "", $x, $y) {
  202. $this->where_init($field);
  203. $this->wheres[$field]['$gt'] = $x;
  204. $this->wheres[$field]['$lt'] = $y;
  205. return($this);
  206. }
  208. /*** ------------------------------------------------- ------------------ * 매개변수와 같지 않은 경우 * ------------ ------------------------------------- ------------------ * * $field의 값이 $x와 같지 않은 문서를 가져옵니다. * * @usage = $this->mongo_db-> where_between('foo', 20, 30);*/
  209. 공개 함수 where_ne($field = "", $x) {
  210. $this->where_init($field);
  211. $this->wheres[$field]['$ne'] = $x;
  212. return($this);
  213. }
  215. /*** ------------------------------------------------- ------------------ * 어디서 또는 * --------------- ------------------------------------- --------------- * * $field의 값이 하나 이상의 값에 있는 문서 가져오기 * * @usage = $this->mongo_db->where_or(' foo', array( 'foo', 'bar', 'blegh' );*/
  216. 공개 함수 where_or($field = "", $values) {
  217. $this->where_init($field);
  218. $this->wheres[$field]['$or'] = $values;
  219. return($this);
  220. }
  222. /*** ------------------------------------------------- ------------------ * 어디서 그리고 * --------------- ------------------------------------- --------------- * * 요소가 지정된 값과 일치하는 문서 가져오기 * * @usage = $this->mongo_db->where_and( array ( 'foo' => ; 1, 'b' => '일부 예' );*/
  223. 공개 함수 where_and($elements_values ​​= array()) {
  224. foreach ((array)$elements_values ​​as $element => $ val) {
  225. $this->wheres[$element] = $val;
  226. } return($this);
  227. }
  229. /*** ------------------------------------------------- ------------------ * MOD는 어디에 * --------------- ------------------------------------- --------------- * * $field % $mod = $result * * @usage = $this->mongo_db->where_mod( 'foo', 10 있는 문서 가져오기 , 1 );*/
  230. 공개 함수 where_mod($field, $num, $result) {
  231. $this->where_init($field);
  232. $this->wheres[$field]['$mod'] = array($num, $result);
  233. return($this);
  234. }
  236. /*** ------------------------------------------------- ------------------ * 사이즈는 * --------------- ------------------------------------- --------------- * * 필드 크기가 지정된 $size int인 문서 가져오기 * * @usage : $this->mongo_db->where_size(' foo', 1)->get('foobar');*/
  237. 공개 함수 where_size($field = "", $size = "") {
  238. $this->_where_init($field );
  239. $this->wheres[$field]['$size'] = $size;
  240. 반환($this);
  241. }
  243. /*** ------------------------------------------------- ------------------------------- * 類似參數 * --------------- -------------------------------------------------- --------------- * * 取得$field 的（字串）值類似值的文件。預設值 * 允許不區分大小寫的搜尋。 * * @param $flags * 允許典型的正規表示式標誌： * i = 不區分大小寫* m = 多行* x = 可以包含註解* l = 區域設定* s = dotall, "."符合所有內容，包括換行符* u = 匹配unicode * * @param $enable_start_wildcard * 如果設定為TRUE 以外的任何內容，則在搜尋值前面新增起始行字元“^”，表示僅搜尋開頭處的值* 一新行。 * * @param $enable_end_wildcard * 如果設定為 TRUE 以外的任何值，則結束行字元「$」將附加到搜尋值，表示僅搜尋行末尾的值。 * * @usage = $this->mongo_db->like('foo', 'bar', 'im', FALSE, TRUE);*/
  244. 公用函數如($field = "", $value = "", $flags = "i", $enable_start_wildcard = TRUE, $enable_end_wildcard = TRUE) {
  245. $field = (string) 修剪($field);
  246. $this->where_init($field);
  247. $值 = (字串) 修剪($值);
  248. $value = quotemeta($value);
  249. if ($enable_start_wildcard !== TRUE) {
  250. $value = "^" . $值;
  251. } if ($enable_end_wildcard !== TRUE) {
  252. $value .= "$";
  253. } $regex = "/$value/$flags";
  254. $this->wheres[$field] = new MongoRegex($regex);
  255. 返回($this);
  256. }
  258. public function wheres($where){
  259. $this->wheres = $where;
  260. }
  262. /*** ------------------------------------------------- ------------------------------- * 依參數排序 * -------------- -------------------------------------------------- ---------------- * * 根據傳遞的參數對文件進行排序。若要將值設為降序，* 您必須傳遞 -1、FALSE、'desc' 或 'DESC' 值，否則它們將被 * 設定為 1 (ASC)。 * * @usage = $this->mongo_db->where_ Between('foo', 20, 30);*/
  263. public function order_by($fields = array()) {
  264. if (!is_array($fields) || !count($ ) ) 欄位)）回傳；
  265. foreach ($fields as $col => $val) {
  266. if ($val == -1 || $val === FALSE || strtolower($val) = = 'desc') {
  267. $this->sorts[$col] = -1; } else {
  268. $this->sorts[$col] = 1;
  269. }
  270. } return( $this); }
  272. /*** ------------------------------------------------- ------------------------------- * 限製檔案* --------------- -------------------------------------------------- --------------- * * 將結果集限制為$x 個文件* * @usage = $this->mongo_db->limit($x);*/
  273. 公用函數limit($x = 99999) {
  274. if ($x !== NULL && is_numeric ($x) && $ x >= 1) {
  275. $this->limit = (int) $x;
  276. } return($this); }
  278. /** * ------------------------------------------------- ------------------------------- * 抵銷文件 * --------------- -------------------------------------------------- --------------- * * 偏移結果集以跳過$x 個文件* * @usage = $this->mongo_db->offset($x);*/
  279. public function offset($x = 0) {
  280. if ($x !== NULL && is_numeric($x) && $ x >= 1) {
  281. $this-> offset = (int) $x;
  282. } return($this)
  283. }
  285. /*** ------------------------------------------------- ------------------------------------------- * 到達地點 * --- ------------- ------------------------------------- ------------- -------------- * * 根據傳入的參數取得文件* * @usage = $this->mongo_db->get_where( 'foo', array('bar' = >「某事」））；*/
  286. public function get_where($collection = "", $ where = array(), $limit = 99999, $orderby=array()) {
  287. if (is_array($orderby) || !emptyempty($orderby)) {
  288. $order_by = $this->order_by ($order_by);
  289. }
  290. return($this->where($where)->limit($limit)->get($collection));
  291. }
  292. public function selectA( $collection = "", $limit = 99999, $orderby=array()) {
  293. if(intval($limit) $limit = 999999；
  294. }
  295. $order_by = $this->order_by($orderby);
  296. $re = $this->limit($limit)->get($collection);
  297. $this->clear();
  298. return (배열)$re;
  299. }
  301. 공개 함수 listinfo($collection = "", $orderby=array(), $page=1, $pagesize=12) {
  302. $page = max(intval($page) ), 1);
  303. $offset = $pagesize * ($page - 1);
  304. $pagesizes = $offset $pagesize;
  305. $this->offset($offset);
  306. $order_by = $this->order_by($orderby);
  307. $re = $this->limit($pagesize)->get($collection);
  308. $this->limit(999999);
  309. $count = $this->count($collection);
  310. $this->pages = 페이지($count, $page, $pagesize);
  311. return (배열)$re;
  312. }
  314. /*** ------------------------------------------------- ------------------------------- * 얻다 * ---------------- ------------------------------------- -------------- * * 전달된 매개변수를 기반으로 문서 가져오기 * * @usage = $this->mongo_db->get('foo', array('bar' = > '뭔가'));*/
  315. 공개 함수 get($collection = "") {
  316. if (emptyempty($collection)) {
  317. $this- >error("MongoDB에서 문서를 검색하려면 컬렉션 이름을 전달해야 합니다.", 500);
  318. } $결과 = 배열();
  319. $documents = $this->db->{$collection}->find($this->wheres, $this->selects)->limit((int) $this-> ;limit)->skip((int) $this->offset)->sort($this->sorts);
  320. $returns = 배열();
  321. foreach($documents를 $doc로): $returns[] = $doc;
  322. endforeach;
  323. 반환($returns);
  324. }
  326. public function getMy($collection = "") {
  327. if (emptyempty($collection)) {
  328. $this->error("다음에서 문서를 검색하려면 MongoDB, 컬렉션 이름을 전달해야 합니다.", 500);
  329. } $결과 = 배열();
  330. $documents = $this->db->{$collection}->find($this->wheres, $this->selects)->limit((int) $this-> ;limit)->skip((int) $this->offset)->sort($this->sorts);
  331. $returns = 배열();
  332. foreach($documents를 $doc로): $returns[] = $doc;
  333. endforeach;
  334. $이것 -> 분명한();
  335. 반환($returns);
  336. }
  338. /*** ------------------------------------------------- ------------------------------- * 세다 * ---------------- ------------------------------------- -------------- * * 전달된 매개변수를 기반으로 문서 개수 * * @usage = $this->mongo_db->get('foo');*/
  339. 공개 함수 개수($collection = "") {
  340. if (emptyempty($collection)) {
  341. $this- >error("MongoDB에서 문서 개수를 검색하려면 컬렉션 이름을 전달해야 합니다.", 500);
  342. } $count = $this->db->{$collection}->find($this->wheres)->limit((int) $this->limit)-> Skip((int) $this->offset)->count();
  343. $this->clear();
  344. 반환($count);
  345. }
  347. /*** ------------------------------------------------- ------------------ * 삽입 * --- ------------------------------------- -------------- * * 전달된 컬렉션에 새 문서 삽입 * * @usage = $this->mongo_db->insert('foo', $data = array() );*/
  348. 공개 함수 insert($collection = "", $data = array(), $name='ID') {
  349. if (emptyempty($collection)) {
  350. $this->error("삽입할 Mongo 컬렉션을 선택하지 않았습니다.", 500);
  351. } if (count($data) == 0 || !is_array($data)) {
  352. $this->error("Mongo 컬렉션에 삽입할 항목이 없거나 삽입할 항목이 배열이 아닙니다.", 500 );
  353. } try {
  354. /**
  355. wxcity_base::load_sys_class('whtysqs','',0);
  356. $mongoseq_class = new whtysqs('creaseidsqs');
  357. $re = $mongoseq_class->query("?name=" . $collection . "&opt=put&data=1");
  358. **/
  359. $re = put_sqs('list_mongo_creaseidsqs','1');
  360. if(is_numeric($re)){
  361. $re ;
  362. $data[$name] = intval($re);
  363. }else{
  364. $data[$name] = intval(time());
  365. //die('mongosqs 오류');
  366. }
  367. $this->db->{$collection}->插入($data, array('fsync' => TRUE));
  368. $this->clear();
  369. 回傳$data[$name];
  370. } catch (MongoCursorException $e) {
  371. $this->error("將資料插入MongoDB 失敗：{$e->getMessage()}", 500);
  372. }
  373. }
  375. public function insertWithId($ collection = "", $data = array()) {
  376. if (emptyempty($collection)) {
  377. $this- >error("沒有選擇要插入的Mongo 集合", 500);
  378. } if (count($data) == 0 || !is_array($data)) {
  379. $this->error("Nothing to insert into Mongo collection or insert is not an array", 500 ）；
  380. } try {
  381. $this->db->{$collection}->insert($data, array('fsync' => TRUE));
  382. $this->clear();
  383. 回傳1;
  384. } catch (MongoCursorException $e) {
  385. $this->error("將資料插入MongoDB 失敗：{$e->getMessage()}", 500);
  386. }
  387. }
  388. /*** ------------------------------------------------- - - - - - - - - - - - - - - - - * 更新* - - - - - - - - ----------------------- --------------------------- -------------- * * 將文件更新到傳遞的集合中* * @usage = $this->mongo_db->update('foo', $data = array()) ;*/
  389. public function update($collection = "", $data = array()) {
  390. if (emptyempty($collection) ) {
  391. $ this->error("沒有選擇要更新的Mongo 集合", 500);
  392. } if (count($data) == 0 || !is_array($data)) {
  393. $this->error ("Mongo 集合中沒有要更新的內容或更新不是陣列", 500 ）；
  394. } try {
  395. $this->db->{$collection}->update($this->wheres, array ('$set' => $data), array(' fsync' => TRUE，'多個' => FALSE));
  396. $this->clear();
  397. 回傳（真）；
  398. } catch (MongoCursorException $e) {
  399. $this->error("將資料更新至MongoDB 失敗：{$e->getMessage()}", 500);
  400. }
  401. }
  403. /*** ------------------------------------------------- ------------------------------- * UPDATE_ALL * ---------------- -------------------------------------------------- -------------- * * 將新文件插入傳遞的集合* * @usage = $this->mongo_db->update_all('foo', $data = array() ） ；*/
  404. public function update_all($collection = "", $data = array()) {
  405. if (emptyempty( $collection)) {
  406. $ this->error("沒有選擇要更新的Mongo 集合", 500);
  407. } if (count($data) == 0 || !is_array($data)) {
  408. $this->error ("Mongo 集合中沒有要更新的內容或更新不是陣列", 500 ）；
  409. } try {
  410. $this->db->{$collection}->update($this->wheres, array ('$set' => $data), array(' fsync' => TRUE, '多個' => TRUE);
  411. 回傳（真）；
  412. } catch (MongoCursorException $e) {
  413. $this->error("將資料更新至MongoDB 失敗：{$e->getMessage()}", 500);
  414. }
  415. }
  417. /*** ------------------------------------------------- - - - - - - - - - - - - - - - - * 刪除* - - - - - - - - ----------------------- --------------------------- -------------- * * 依特定條件從傳遞的集合中刪除文件* * @usage = $this->mongo_db->delete('foo', $data = array ());* /
  418. public function delete($collection = "") {
  419. if (emptyempty($collection)) {
  420. $this->error("沒有選擇要刪除的Mongo 集合", 500);
  421. } try {
  422. $this->db->{$collection}->remove($this->wheres, array('fsync' => TRUE, 'justOne' =>;真的));
  423. $this->clear();
  424. 回傳（真）；
  425. } catch (MongoCursorException $e) {
  426. $this->error("刪除MongoDB 資料失敗：{$e->getMessage ()}", 500);
  427. }
  428. }
  430. /*** ------------------------------------------------- ------------------ * DELETE_ALL * --- ------------------------------------- -------------- * * 특정 기준에 따라 전달된 컬렉션에서 모든 문서 삭제 * * @usage = $this->mongo_db->delete_all('foo', $data = 정렬());*/
  431. public function delete_all($collection = "") {
  432. if (emptyempty($collection)) {
  433. $this->error( "삭제할 Mongo 컬렉션이 선택되지 않았습니다.", 500);
  434. } try {
  435. $this->db->{$collection}->remove($this->wheres, array('fsync' => TRUE, 'justOne' => 거짓));
  436. 반환(TRUE);
  437. } catch (MongoCursorException $e) {
  438. $this->error("MongoDB로의 데이터 삭제 실패: {$e->getMessage()}", 500);
  439. }
  440. }
  442. /*** ------------------------------------------------- ------------------ * ADD_INDEX * --- ------------------------------------- -------------- * * 선택적 매개변수를 사용하여 컬렉션의 키 인덱스를 확인합니다. 값을 내림차순으로 설정하려면 * -1, FALSE, 'desc' 또는 'DESC' 값을 전달해야 합니다. 그렇지 않으면 * 1(ASC)로 설정됩니다. * * @usage = $this->mongo_db->add_index($collection, array('first_name' => 'ASC', 'last_name' => -1), array('unique' => TRUE )));*/
  443. 공개 함수 add_index($collection = "", $keys = array(), $options = array()) {
  444. if (emptyempty($collection)) {
  445. $this->error("인덱스를 추가할 Mongo 컬렉션이 지정되지 않았습니다.", 500);
  446. } if (emptyempty($keys) || !is_array($keys)) {
  447. $this->error("키가 지정되지 않았기 때문에 MongoDB 컬렉션에 인덱스를 생성할 수 없습니다.", 500);
  448. } foreach ($keys as $col => $val) {
  449. if ($val == -1 || $val === FALSE || strtolower($val) == 'desc') {
  450. $keys[$col] = -1;
  451. } else {
  452. $keys[$col] = 1;
  453. }
  454. } if ($this->db->{$collection}->ensureIndex($keys, $options) == TRUE) {
  455. $this->clear() ;
  456. return($this);
  457. } else {
  458. $this->error("MongoDB 컬렉션에 인덱스를 추가하려고 할 때 오류가 발생했습니다.", 500);
  459. }
  460. }
  462. /*** ------------------------------------------------- ------------------ * REMOVE_INDEX * --- ------------------------------------- -------------- * * 컬렉션에 있는 키의 인덱스를 제거합니다. 값을 내림차순으로 설정하려면 * -1, FALSE, 'desc' 또는 'DESC' 값을 전달해야 합니다. 그렇지 않으면 * 1(ASC)로 설정됩니다. * * @usage = $this->mongo_db->remove_index($collection, array('first_name' => 'ASC', 'last_name' => -1));*/
  463. 공개 함수 Remove_index($collection = "", $keys = array()) {
  464. if (emptyempty( $collection)) {
  465. $this->error("인덱스를 제거할 Mongo 컬렉션이 지정되지 않았습니다.", 500);
  466. } if (emptyempty($keys) || !is_array($keys)) {
  467. $this->error("지정된 키가 없기 때문에 MongoDB 컬렉션에서 인덱스를 제거할 수 없습니다.", 500);
  468. } if ($this->db->{$collection}->deleteIndex($keys, $options) == TRUE) {
  469. $this->clear();
  470. return($this);
  471. } else {
  472. $this->error("MongoDB 컬렉션에서 인덱스를 제거하려고 할 때 오류가 발생했습니다.", 500);
  473. }
  474. }
  476. /*** ------------------------------------------------- ------------------ * REMOVE_ALL_INDEXES * --- ------------------------------------- -------------- * * 컬렉션에서 모든 인덱스를 제거합니다. * * @usage = $this->mongo_db->remove_all_index($collection);*/
  477. 공개 함수 Remove_all_indexes($collection = "") {
  478. if (emptyempty($collection)) {
  479. $this->error("모든 인덱스를 제거하기 위해 지정된 Mongo 컬렉션이 없습니다.", 500);
  480. } $this->db->{$collection}->deleteIndexes();
  481. $this->clear();
  482. return($this);
  483. }
  485. /*** ------------------------------------------------- ------------------------------- * LIST_INDEXES * ---------------- -------------------------------------------------- -------------- * * 列出集合中的所有索引。 * * @usage = $this->mongo_db->list_indexes($collection);*/
  486. public function list_indexes($collection = "") {
  487. if (emptyempty($collection)) {
  488. $this->error( “沒有指定要從中刪除所有索引的Mongo 集合」, 500);
  489. } return($this->db->{$collection}->getIndexInfo());
  490. }
  492. / *** ------------------------------------------------- ------------------------------- * 刪除收藏 * --------------- -------------------------------------------------- --------------- * * 從資料庫中刪除指定的集合。 請小心，因為這 * 在生產中可能會出現一些非常大的問題！*/
  493. public function drop_collection($collection = "") {
  494. if (emptyempty($collection)) {
  495. $this- >錯誤(「沒有指定從資料庫中刪除的Mongo 集合」, 500);
  496. } $this->db->{$collection}->drop();
  497. 回傳TRUE;
  498. }
  500. /*** ------------------------------------------------- - - - - - - - - - - - - - - - - * 清除* - - - - - - - - ----------------------- --------------------------- -------------- * * 將類別變數重設為默認設定 */
  501. private function clear() {
  502. $this->selects = array();
  503. $this->wheres = array();
  504. $this->limit = NULL;
  505. $this->offset = NULL;
  506. $this->sorts = array();
  507. }
  509. /*** ------------------------------------------------- ------------------------------- * 初始化器所在位置* ------------- -- ------------------------------------------------ -- --------------- * * 準備參數以插入$wheres array() 中。*/
  510. private function where_init($param) {
  511. if (!isset($this->wheres[$param])) {
  512. $this->wheres[$param] = array();
  513. }
  514. }
  516. 公用函數錯誤($str, $t) {
  517. echo $str;
  518. 退出；
  519. }
  521. }
  523. ？ >
複製程式碼

使用範例
  1. $table_name=trim(strtolower($this->table_name));
  2. $this->mongo_db->where($where);
  3. $this->mongo_db->where($where);
  4. $order=!emptyempty($order)?array('AID'=>'DESC'):array('AID'=>'ASC');//升序降序
$infos=$ this->mongo_db ->listinfo($table_name,$order,$page,$pagesize);
複製程式碼

PHP、MongoDB


성명：
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
이전 기사：PHP 대칭 암호화 알고리즘(DES/AES) 코드다음 기사：PHP 대칭 암호화 알고리즘(DES/AES) 코드

관련 기사

더보기