検索

ホームページ  >  記事  >  バックエンド開発  >  PHP でカプセル化された mongodb 操作クラス

PHP でカプセル化された mongodb 操作クラス

WBOY
WBOYオリジナル
2016-07-25 08:43:17827ブラウズ
  2. /*
  3. * このテンプレートを変更するには、[ツール] | [ツール] を選択します。テンプレート
  4. * エディタでテンプレートを開きます。
  5. */
  8. class mongo_db {
  10. private $config;
  11. プライベート $connection;
  12. プライベート $db;
  13. プライベート $connection_string;
  14. プライベート $host;
  15. プライベート $ポート;
  16. プライベート $user;
  17. プライベート$パス;
  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. public function __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("cache","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->key + $i;
  49. $key = $n >= $num ? $n - $num : $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 not connect');
  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 への接続を確立します。 * config ファイルで 'mongo_persist_key' が true に設定されている場合は、永続的な接続を確立します。 すぐに接続を確立したいため、「persist」 * オプションのみを設定できます。*/
  79. プライベート関数 connect() {
  80. $this->connection_string();
  81. $options = array('connect'=>true,'timeout'=>$this->timeout);
  82. {
  83. $this->connection = new Mongo($this->connection_string, $options); を試してください。
  84. $this->db = $this->接続->{$this->dbname};
  85. return($this);
  86. } catch (MongoConnectionException $e) {
  87. false を返します。
  88. }
  90. }
  91. /*** -------------------------------------------------- ----------------------------- * 接続文字列の構築 * -------------- -------------------------------------------------- ---------------- * * 構成ファイルから接続文字列を構築します。*/
  92. プライベート関数 connection_string() {
  93. $this->host = トリム($this->config['hostname']);
  94. $this->port = トリム($this->config['port']);
  95. $this->user = trim($this->config['username']);
  96. $this->pass = トリム($this->config['パスワード']);
  97. $this->dbname = トリム($this->config['データベース']);
  98. $this->persist = trim($this->config['autoconnect']);
  99. $this->persist_key = トリム($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->pass} @";
  108. } if (isset($this->port) && !emptyempty($this->port)) {
  109. $connection_string .= "{$this->host}:{$this->port}" ;
  110. } else {
  111. $connection_string .= "{$this->host}";
  112. } $this->接続文字列 = トリム($接続_文字列);
  113. }
  115. /*** -------------------------------------------------- ----------------------------- * Switch_db * ---------------- -------------------------------------------------- -------------- * * デフォルトのデータベースから別のデータベースに切り替えます*/
  116. public function switch_db($database = '') {
  117. if (emptyempty($database)) {
  118. $this->error("MongoDB データベースを切り替えるには、新しいデータベース名を指定する必要があります", 500);
  119. } $this->dbname = $database;
  120. {
  121. $this->db = $this->接続->{$this->dbname}; を試してください。
  122. 戻り値(TRUE);
  123. } catch (Exception $e) {
  124. $this->error("Mongo データベースを切り替えることができません: {$e->getMessage()}", 500);
  125. }
  126. }
  128. /*** -------------------------------------------------- ----------------------------- * フィールドを選択 * --------------- -------------------------------------------------- --------------- * * クエリ プロセス中にどのフィールドを含めるか、またはどのフィールドを除外するかを決定します。 * 現在、包含と除外を同時に行うことはできないため、 * $includes 配列が $excludes 配列よりも優先されます。 * 除外するフィールドのみを選択したい場合は、$includes を空の array() のままにしておきます。 * * @usage: $this->mongo_db->select(array('foo', 'bar'))->get('foobar');*/
  129. public function select($includes = array(), $excludes = array()) {
  130. if (!is_array($includes)) {
  131. $includes = array ();
  132. }
  133. if (!is_array($excludes)) {
  134. $excludes = array();
  135. }
  136. if (!emptyempty($includes)) {
  137. foreach ($includes as $col) {
  138. $this->selects[$col] = 1;
  139. }
  140. } else {
  141. foreach ($excludes as $col) {
  142. $this->selects[$col] = 0;
  143. }
  144. } return($this);
  145. }
  147. /*** -------------------------------------------------- ----------------------------- * WHERE パラメータ * --------------- -------------------------------------------------- --------------- * * これらの検索パラメータに基づいてドキュメントを取得します。 $wheres 配列は、 * フィールドをキーとし、 * 値を検索条件とする連想配列である必要があります。 * * @usage = $this->mongo_db->where(array('foo' =>'bar'))->get('foobar');*/
  148. public function where($wheres = array()) {
  149. foreach ((array)$wheres as $wh =>$val) {
  150. $this->wheres [$wh] = $val;
  151. } return($this);
  152. }
  154. /*** -------------------------------------------------- ----------------------------- * WHERE_IN パラメータ * --------------- -------------------------------------------------- --------------- * * $field の値が指定された $in array() にあるドキュメントを取得します。 * * @usage = $this->mongo_db->where_in('foo', array('bar', 'zoo', 'blah'))->get('foobar');*/
  155. public function where_in($field = "", $in = array()) {
  156. $this->where_init($field);
  157. $this->wheres[$field]['$in'] = $in;
  158. return($this);
  159. }
  161. /*** -------------------------------------------------- ----------------------------- * WHERE_NOT_IN パラメータ * --------------- -------------------------------------------------- --------------- * * $field の値が指定された $in array() にないドキュメントを取得します。 * * @usage = $this->mongo_db->where_not_in('foo', array('bar', 'zoo', 'blah'))->get('foobar');*/
  162. public function where_not_in($field = "", $in = array()) {
  163. $this->where_init($field);
  164. $this->wheres[$field]['$nin'] = $in;
  165. return($this);
  166. }
  168. /*** -------------------------------------------------- ----------------------------- * パラメータより大きい場合 * ------------- -------------------------------------------------- ----------------- * * $field の値が $x より大きいドキュメントを取得します * * @usage = $this->mongo_db->where_gt( 「フー」、20);*/
  169. public function where_gt($field = "", $x) {
  170. $this->where_init($field);
  171. $this->wheres[$field]['$gt'] = $x;
  172. return($this);
  173. }
  175. /*** -------------------------------------------------- ----------------------------- * パラメータ以上の場合 * ---------- -------------------------------------------------- -------------------- * * $field の値が $x 以上であるドキュメントを取得します * * @usage = $this-> mongo_db->where_gte('foo', 20);*/
  176. public function where_gte($field = "", $x) {
  177. $this->where_init($field);
  178. $this->wheres[$field]['$gte'] = $x;
  179. return($this);
  180. }
  182. /*** -------------------------------------------------- ----------------------------- * パラメータ未満の場合 * ------------- -------------------------------------------------- ----------------- * * $field の値が $x より小さいドキュメントを取得します * * @usage = $this->mongo_db->where_lt( 「フー」、20);*/
  183. public function where_lt($field = "", $x) {
  184. $this->where_init($field);
  185. $this->wheres[$field]['$lt'] = $x;
  186. return($this);
  187. }
  189. /*** -------------------------------------------------- ----------------------------- * パラメータ以下の場合 * ---------- -------------------------------------------------- -------------------- * * $field の値が $x 以下のドキュメントを取得します * * @usage = $this-> mongo_db->where_lte('foo', 20);*/
  190. public function where_lte($field = "", $x) {
  191. $this->where_init($field);
  192. $this->wheres[$field]['$lte'] = $x;
  193. return($this);
  194. }
  196. /*** -------------------------------------------------- ----------------------------- * パラメータの間の場所 * -------------- -------------------------------------------------- ---------------- * * $field の値が $x と $y の間にあるドキュメントを取得します * * @usage = $this->mongo_db->where_between ('foo'、20、30);*/
  197. public function where_between($field = "", $x, $y) {
  198. $this->where_init($field);
  199. $this->wheres[$field]['$gte'] = $x;
  200. $this->wheres[$field]['$lte'] = $y;
  201. return($this);
  202. }
  204. /*** -------------------------------------------------- ----------------------------- * パラメータの間および等しくない場合 * ---------- -------------------------------------------------- -------------------- * * $field の値が $x と $y の間にあるが等しくないドキュメントを取得します * * @usage = $this ->mongo_db->where_between_ne('foo', 20, 30);*/
  205. public function where_between_ne($field = "", $x, $y) {
  206. $this->where_init($field);
  207. $this->wheres[$field]['$gt'] = $x;
  208. $this->wheres[$field]['$lt'] = $y;
  209. return($this);
  210. }
  212. /*** -------------------------------------------------- ----------------------------- * パラメーターと等しくない場合 * ------------ -------------------------------------------------- ------------------ * * $field の値が $x と等しくないドキュメントを取得します * * @usage = $this->mongo_db-> where_between('foo', 20, 30);*/
  213. public function where_ne($field = "", $x) {
  214. $this->where_init($field);
  215. $this->wheres[$field]['$ne'] = $x;
  216. return($this);
  217. }
  219. /*** -------------------------------------------------- ----------------------------- * どこまたは * --------------- -------------------------------------------------- --------------- * * $field の値が 1 つ以上の値に含まれるドキュメントを取得します * * @usage = $this->mongo_db->where_or(' foo', array( 'foo', 'bar', 'blegh' );*/
  220. public function where_or($field = "", $values) {
  221. $this->where_init($field);
  222. $this->wheres[$field]['$or'] = $values;
  223. return($this);
  224. }
  226. /*** -------------------------------------------------- ----------------------------- * どこで * --------------- -------------------------------------------------- --------------- * * 要素が指定された値と一致するドキュメントを取得します * * @usage = $this->mongo_db->where_and( array ( 'foo' => ; 1, 'b' => 'いくつかの例' );*/
  227. public function where_and($elements_values = array()) {
  228. foreach ((array)$elements_values as $element =>$val) {
  229. $this->wheres [$要素] = $val;
  230. } return($this);
  231. }
  233. /*** -------------------------------------------------- ----------------------------- * WHERE MOD * --------------- -------------------------------------------------- --------------- * * ドキュメントを取得します。 where $field % $mod = $result * * @usage = $this->mongo_db->where_mod( 'foo', 10 、1);*/
  234. public function where_mod($field, $num, $result) {
  235. $this->where_init($field);
  236. $this->wheres[$field]['$mod'] = array($num, $result);
  237. return($this);
  238. }
  240. /*** -------------------------------------------------- ----------------------------- * サイズの場所 * --------------- -------------------------------------------------- --------------- * * フィールドのサイズが指定された $size int にあるドキュメントを取得します * * @usage : $this->mongo_db->where_size(' foo', 1)->get('foobar');*/
  241. public function where_size($field = "", $size = "") {
  242. $this->_where_init($field);
  243. $this->wheres[$field]['$size'] = $size;
  244. リターン ($this);
  245. }
  247. /*** -------------------------------------------------- ----------------------------- * パラメータのようなもの * --------------- -------------------------------------------------- --------------- * * $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);*/
  248. public function like($field = "", $value = "", $flags = "i", $enable_start_wildcard = TRUE, $enable_end_wildcard = TRUE) {
  249. $field = (文字列) トリム($field);
  250. $this->where_init($field);
  251. $value = (文字列) トリム($value);
  252. $value = quotemeta($value);
  253. if ($enable_start_wildcard !== TRUE) {
  254. $value = "^" . $値;
  255. } if ($enable_end_wildcard !== TRUE) {
  256. $value .= "$";
  257. } $regex = "/$value/$flags";
  258. $this->wheres[$field] = new MongoRegex($regex);
  259. return($this);
  260. }
  262. public function wheres($where){
  263. $this->wheres = $where;
  264. }
  266. /*** -------------------------------------------------- ----------------------------- * パラメータによる順序 * -------------- -------------------------------------------------- ---------------- * * 渡されたパラメータに基づいてドキュメントを並べ替えます。値を降順に設定するには、 * -1、FALSE、'desc'、または 'DESC' のいずれかの値を渡す必要があります。それ以外の場合、値は * 1 (ASC) に設定されます。 * * @usage = $this->mongo_db->where_between('foo', 20, 30);*/
  267. public function order_by($fields = array()) {
  268. if (!is_array($fields) || !count($fields)) return ;
  269. foreach ($fields as $col => $val) {
  270. if ($val == -1 || $val === FALSE || strto lower($val) == 'desc') {
  271. $this- > ソート[$col] = -1;
  272. } else {
  273. $this->sorts[$col] = 1;
  274. }
  275. } return($this);
  276. }
  278. /*** -------------------------------------------------- ----------------------------- * 書類の制限 * --------------- -------------------------------------------------- --------------- * * 結果セットを $x 個のドキュメントに制限します * * @usage = $this->mongo_db->limit($x);*/
  279. public function limit($x = 99999) {
  280. if ($x !== NULL && is_numeric($x) && $x >= 1) {
  281. $this ->limit = (int) $x;
  282. } return($this);
  283. }
  285. /*** -------------------------------------------------- ----------------------------- * オフセット書類 * --------------- -------------------------------------------------- --------------- * * $x 個のドキュメントをスキップするために結果セットをオフセットします * * @usage = $this->mongo_db->offset($x);*/
  286. public function offset($x = 0) {
  287. if ($x !== NULL && is_numeric($x) && $x >= 1) {
  288. $this ->オフセット = (int) $x;
  289. } return($this);
  290. }
  292. /*** -------------------------------------------------- ----------------------------- * GET_WHERE * -------------- -------------------------------------------------- -------------- * * 渡されたパラメータに基づいてドキュメントを取得します * * @usage = $this->mongo_db->get_where('foo', array('bar' = >「何か」));*/
  293. public function get_where($collection = "", $where = array(), $limit = 99999, $orderby=array()) {
  294. if (is_array($orderby) ) || !emptyempty($orderby)) {
  295. $order_by = $this->order_by($order_by);
  296. }
  297. return($this->where($where)->limit($limit)->get($collection));
  298. }
  299. public function selectA($collection = "", $limit = 99999, $orderby=array()) {
  300. if(intval($limit) $limit = 999999;
  301. }
  302. $order_by = $this->order_by($orderby);
  303. $re = $this->limit($limit)->get($collection);
  304. $this->clear();
  305. return (配列)$re;
  306. }
  308. public function listinfo($collection = "", $orderby=array(), $page=1, $pagesize=12) {
  309. $page = max(intval($page), 1);
  310. $offset = $pagesize * ($page - 1);
  311. $pagesizes = $offset + $pagesize;
  312. $this->offset($offset);
  313. $order_by = $this->order_by($orderby);
  314. $re = $this->limit($pagesize)->get($collection);
  315. $this->limit(999999);
  316. $count = $this->count($collection);
  317. $this->pages = ページ($count, $page, $pagesize);
  318. return (配列)$re;
  319. }
  321. /*** -------------------------------------------------- - - - - - - - - - - - - - - - - * 得る * - - - - - - - - -------------------------------------------------- -------------- * * 渡されたパラメータに基づいてドキュメントを取得します * * @usage = $this->mongo_db->get('foo', array('bar' = >「何か」));*/
  322. public function get($collection = "") {
  323. if (emptyempty($collection)) {
  324. $this->error("MongoDB からドキュメントを取得するため、コレクション名を渡す必要があります", 500);
  325. } $results = array();
  326. $documents = $this->db->{$collection}->find($this->wheres, $this->selects)->limit((int) $this->limit )->skip((int) $this->offset)->sort($this->sorts);
  327. $returns = array();
  328. foreach ($documents as $doc): $returns[] = $doc;
  329. エンドフォーリーチ;
  330. return($returns);
  331. }
  333. public function getMy($collection = "") {
  334. if (emptyempty($collection)) {
  335. $this->error("MongoDB からドキュメントを取得するには、コレクション名を渡す必要があります", 500);
  336. } $results = array();
  337. $documents = $this->db->{$collection}->find($this->wheres, $this->selects)->limit((int) $this->limit )->skip((int) $this->offset)->sort($this->sorts);
  338. $returns = array();
  339. foreach ($documents as $doc): $returns[] = $doc;
  340. エンドフォーリーチ;
  341. $this ->クリア（）;
  342. return($returns);
  343. }
  345. /*** -------------------------------------------------- - - - - - - - - - - - - - - - - * カウント * - - - - - - - - -------------------------------------------------- -------------- * * 渡されたパラメータに基づいてドキュメントをカウントします * * @usage = $this->mongo_db->get('foo');*/
  346. public function count($collection = "") {
  347. if (emptyempty($collection)) {
  348. $this->error(" MongoDB からのドキュメント、コレクション名を渡す必要があります", 500);
  349. } $count = $this->db->{$collection}->find($this->wheres)->limit((int) $this->limit)->skip( (int) $this->offset)->count();
  350. $this->clear();
  351. return($count);
  352. }
  354. /*** -------------------------------------------------- - - - - - - - - - - - - - - - - * 入れる * - - - - - - - - -------------------------------------------------- -------------- * * 渡されたコレクションに新しいドキュメントを挿入します * * @usage = $this->mongo_db->insert('foo', $data = array() );*/
  355. public function insert($collection = "", $data = array(), $name='ID') {
  356. if (emptyempty($collection)) {
  357. $ this->error("挿入する Mongo コレクションが選択されていません", 500);
  358. } if (count($data) == 0 || !is_array($data)) {
  359. $this->error("Mongo コレクションに挿入するもの、または挿入するものが配列ではありません", 500);
  360. } try {
  361. /**
  362. wxcity_base::load_sys_class('whtysqs','',0);
  363. $mongoseq_class = new whtysqs('creaseidsqs');
  364. $re = $mongoseq_class->query("?name=" . $collection . "&opt=put&data=1");
  365. **/
  366. $re = put_sqs('list_mongo_creaseidsqs','1');
  367. if(is_numeric($re)){
  368. $re++;
  369. $data[$name] = intval($re);
  370. }else{
  371. $data[$name] = intval(time());
  372. //die('mongosqs エラー');
  373. }
  374. $this->db->{$collection}->insert($data, array('fsync' => TRUE));
  375. $this->clear();
  376. $data[$name] を返します;
  377. } catch (MongoCursorException $e) {
  378. $this->error("MongoDB へのデータの挿入に失敗しました: {$e->getMessage()}", 500);
  379. }
  380. }
  382. public function insertWithId($collection = "", $data = array()) {
  383. if (emptyempty($collection)) {
  384. $this->error("挿入する Mongo コレクションが選択されていません"、500);
  385. } if (count($data) == 0 || !is_array($data)) {
  386. $this->error("Mongo コレクションに挿入するもの、または挿入するものが配列ではありません", 500);
  387. } try {
  388. $this->db->{$collection}->insert($data, array('fsync' => TRUE));
  389. $this->clear();
  390. 1 を返します。
  391. } catch (MongoCursorException $e) {
  392. $this->error("MongoDB へのデータの挿入に失敗しました: {$e->getMessage()}", 500);
  393. }
  394. }
  395. /*** -------------------------------------------------- - - - - - - - - - - - - - - - - * アップデート * - - - - - - - - -------------------------------------------------- -------------- * * 渡されたコレクションにドキュメントを更新します * * @usage = $this->mongo_db->update('foo', $data = array()) ;*/
  396. public function update($collection = "", $data = array()) {
  397. if (emptyempty($collection)) {
  398. $this->error( 「更新する Mongo コレクションが選択されていません」、500);
  399. } if (count($data) == 0 || !is_array($data)) {
  400. $this->error("Mongo コレクションに更新するものがない、または更新するものが配列ではありません", 500);
  401. } try {
  402. $this->db->{$collection}->update($this->wheres, array('$set' => $data), array('fsync' =>) ; TRUE、「複数」 => FALSE);
  403. $this->clear();
  404. 戻り値(TRUE);
  405. } catch (MongoCursorException $e) {
  406. $this->error("MongoDB へのデータの更新に失敗しました: {$e->getMessage()}", 500);
  407. }
  408. }
  410. /*** -------------------------------------------------- ----------------------------- * UPDATE_ALL * ---------------- -------------------------------------------------- -------------- * * 渡されたコレクションに新しいドキュメントを挿入します * * @usage = $this->mongo_db->update_all('foo', $data = array() );*/
  411. public function update_all($collection = "", $data = array()) {
  412. if (emptyempty($collection)) {
  413. $this->error (「更新する Mongo コレクションが選択されていません」、500);
  414. } if (count($data) == 0 || !is_array($data)) {
  415. $this->error("Mongo コレクションに更新するものがない、または更新するものが配列ではありません", 500);
  416. } try {
  417. $this->db->{$collection}->update($this->wheres, array('$set' => $data), array('fsync' =>) ; TRUE、'複数' =>
  418. 戻り値(TRUE);
  419. } catch (MongoCursorException $e) {
  420. $this->error("MongoDB へのデータの更新に失敗しました: {$e->getMessage()}", 500);
  421. }
  422. }
  424. /*** -------------------------------------------------- - - - - - - - - - - - - - - - - * 消去 * - - - - - - - - -------------------------------------------------- -------------- * * 特定の基準に基づいて、渡されたコレクションからドキュメントを削除します * * @usage = $this->mongo_db->delete('foo', $data = array ());*/
  425. public function delete($collection = "") {
  426. if (emptyempty($collection)) {
  427. $this->error("Mongo コレクションが選択されていませんから削除", 500);
  428. } try {
  429. $this->db->{$collection}->remove($this->wheres, array('fsync' => TRUE, 'justOne' => TRUE));
  430. $this->clear();
  431. 戻り値(TRUE);
  432. } catch (MongoCursorException $e) {
  433. $this->error("MongoDB へのデータの削除に失敗しました: {$e->getMessage()}", 500);
  434. }
  435. }
  437. /*** -------------------------------------------------- - - - - - - - - - - - - - - - - * すべて削除 * - - - - - - - - -------------------------------------------------- -------------- * * 特定の基準に基づいて、渡されたコレクションからすべてのドキュメントを削除します * * @usage = $this->mongo_db->delete_all('foo', $data =配列（））;*/
  438. public function delete_all($collection = "") {
  439. if (emptyempty($collection)) {
  440. $this->error("削除する Mongo コレクションが選択されていません", 500);
  441. } try {
  442. $this->db->{$collection}->remove($this->wheres, array('fsync' => TRUE, 'justOne' => FALSE));
  443. 戻り値(TRUE);
  444. } catch (MongoCursorException $e) {
  445. $this->error("MongoDB へのデータの削除に失敗しました: {$e->getMessage()}", 500);
  446. }
  447. }
  449. /*** -------------------------------------------------- ----------------------------- * 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 ));*/
  450. public function add_index($collection = "", $keys = array(), $options = array()) {
  451. if (emptyempty($collection)) {
  452. $this->error("インデックスを追加する Mongo コレクションが指定されていません", 500);
  453. } if (emptyempty($keys) || !is_array($keys)) {
  454. $this->error("キーが指定されていないため、MongoDB コレクションにインデックスを作成できませんでした", 500);
  455. } foreach ($keys as $col => $val) {
  456. if ($val == -1 || $val === FALSE || strto lower($val) == 'desc') {
  457. $keys [$col] = -1;
  458. } else {
  459. $keys[$col] = 1;
  460. }
  461. } if ($this->db->gt;{$collection}->ensureIndex($keys, $options) == TRUE) {
  462. $this->clear();
  463. return($this);
  464. } else {
  465. $this->error("MongoDB コレクションにインデックスを追加しようとしたときにエラーが発生しました", 500);
  466. }
  467. }
  469. /*** -------------------------------------------------- ----------------------------- * REMOVE_INDEX * ---------------- -------------------------------------------------- -------------- * * コレクション内のキーのインデックスを削除します。値を降順に設定するには、 * -1、FALSE、'desc'、または 'DESC' のいずれかの値を渡す必要があります。それ以外の場合、値は * 1 (ASC) に設定されます。 * * @usage = $this->mongo_db->remove_index($collection, array('first_name' => 'ASC', 'last_name' => -1));*/
  470. public function Remove_index($collection = "", $keys = array()) {
  471. if (emptyempty($collection)) {
  472. $this->error ("インデックスを削除する Mongo コレクションが指定されていません", 500);
  473. } if (emptyempty($keys) || !is_array($keys)) {
  474. $this->error("キーが指定されていないため、MongoDB コレクションからインデックスを削除できませんでした", 500);
  475. } if ($this->db->{$collection}->deleteIndex($keys, $options) == TRUE) {
  476. $this->clear();
  477. return($this);
  478. } else {
  479. $this->error("MongoDB コレクションからインデックスを削除しようとしたときにエラーが発生しました", 500);
  480. }
  481. }
  483. /*** -------------------------------------------------- ----------------------------- * REMOVE_ALL_INDEXES * ---------------- -------------------------------------------------- -------------- * * コレクションからすべてのインデックスを削除します。 * * @usage = $this->mongo_db->remove_all_index($collection);*/
  484. public function Remove_all_indexes($collection = "") {
  485. if (emptyempty($collection)) {
  486. $this->error("Mongo コレクションが指定されていませんすべてのインデックスを削除します", 500);
  487. } $this->db->{$collection}->deleteIndexes();
  488. $this->clear();
  489. return($this);
  490. }
  492. /*** -------------------------------------------------- ----------------------------- * LIST_INDEXES * -------------- -------------------------------------------------- -------------- * * コレクション内のすべてのインデックスをリストします。 * * @usage = $this->mongo_db->list_indexes($collection);*/
  493. public function list_indexes($collection = "") {
  494. if (emptyempty($collection)) {
  495. $this->error("すべてのインデックスを削除するための Mongo コレクションが指定されていません"、500);
  496. } return($this->db->{$collection}->getIndexInfo());
  497. }
  499. /*** -------------------------------------------------- ----------------------------- *ドロップコレクション* --------------- -------------------------------------------------- --------------- * * 指定されたコレクションをデータベースから削除します。 * これは実稼働環境で非常に大きな問題を引き起こす可能性があるため、注意してください。*/
  500. public function drop_collection($collection = "") {
  501. if (emptyempty($collection)) {
  502. $this->error("ドロップ元の Mongo コレクションが指定されていませんデータベース」、500);
  503. } $this->db->{$collection}->drop();
  504. TRUE を返します。
  505. }
  507. /*** -------------------------------------------------- - - - - - - - - - - - - - - - - * クリア * - - - - - - - - -------------------------------------------------- -------------- * * クラス変数をデフォルト設定にリセットします*/
  508. プライベート関数 clear() {
  509. $this->selects = array();
  510. $this->wheres = array();
  511. $this->limit = NULL;
  512. $this->オフセット = NULL;
  513. $this->sorts = array();
  514. }
  516. /*** -------------------------------------------------- ----------------------------- * WHERE Initializer * --------------- -------------------------------------------------- --------------- * * $wheres array() に挿入するパラメータを準備します。*/
  517. プライベート関数 where_init($param) {
  518. if (!isset($this->wheres[$param])) {
  519. $this->wheres[$param] ] = 配列();
  520. }
  521. }
  523. public function error($str, $t) {
  524. echo $str;
  525. 終了;
  526. }
  528. }
  530. ?>
复制代

使用例
  1. $table_name=trim(strto lower($this->table_name));
  2. $this->mongo_db->where($where);
  3. $order=!emptyempty($order)?array('AID'=>'DESC'):array('AID'=>'ASC');//升序降順
  4. $infos=$this-> mongo_db->listinfo($table_name,$order,$page,$pagesize);
复制代

php、mongodb


声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：PHP 対称暗号化アルゴリズム (DES/AES) コード次の記事：PHP 対称暗号化アルゴリズム (DES/AES) コード

関連記事

続きを見る