激情久久久_欧美视频区_成人av免费_不卡视频一二三区_欧美精品在欧美一区二区少妇_欧美一区二区三区的

服務器之家：專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - PHP教程 - PHP實現的MongoDB數據庫操作類分享

PHP實現的MongoDB數據庫操作類分享

2020-06-29 13:49服務器之家 PHP教程

這篇文章主要介紹了PHP實現的MongoDB數據庫操作類分享,模板mysql版的操作類,需要的朋友可以參考下

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
class HMongodb {  
 
  private $mongo;  //Mongodb連接
  private $curr_db_name;
  private $curr_table_name;
  private $error;  
 
  public function getInstance($mongo_server, $flag=array())
  {
    static $mongodb_arr;
    if (empty($flag['tag']))
    {
      $flag['tag'] = 'default';     }
    if (isset($flag['force']) && $flag['force'] == true)
    {
      $mongo = new HMongodb($mongo_server);
      if (empty($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;
    }
  }
 
  /**
   * 構造函數
   * 支持傳入多個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
   */
  private 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;
   }
  }
 
  /**
  * 連接mongodb server
  *
  * 參數：無
  *
  * 返回值：
  * 成功：true
  * 失敗：false
  */
  public function connect()
  {
    try {
      $this->mongo->connect();
      return true;
    }
    catch (MongoConnectionException $e)
    {
      $this->error = $e->getMessage();
      return false;
    }
  }  
 
  /**
  * select db
  *
  * 參數：$dbname
  *
  * 返回值：無
  */
  public function selectDb($dbname)
  {
    $this->curr_db_name = $dbname;
  }  
 
  /**
  * 創建索引：如索引已存在，則返回。
  *
  * 參數：
  * $table_name:表名
  * $index:索引-array("id"=>1)-在id字段建立升序索引
  * $index_param:其它條件-是否唯一索引等
  *
  * 返回值：
  * 成功：true
  * 失敗：false
  */
  public 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
  */
  public 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:表名
  *
  * 返回值：表的記錄數
  */
  public 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
  */
  public 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
  */
  public 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
  */
  public 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 (!empty($result_condition['start']))
    {
      $cursor->skip($result_condition['start']);
    }
    if (!empty($result_condition['limit']))
    {
      $cursor->limit($result_condition['limit']);
    }
    if (!empty($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
  */
  public function findOne($table_name, $condition, $fields=array())
  {
    $dbname = $this->curr_db_name;
    return $this->mongo->$dbname->$table_name->findOne($condition, $fields);
  }  
 
  /**
  * 獲取當前錯誤信息
  *
  * 參數：無
  *
  * 返回值：當前錯誤信息
  */
  public function getError()
  {
    return $this->error;
  }
 
  /*** 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();
  */
 
}

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板： 中文字幕免费一区 | 91短视频在线 | 97久色| 免费黄色小网站 | 久久精品国产99久久久古代 | 国产喷白浆10p | 成人黄色短视频在线观看 | 久久超碰99 | 精品国产乱码一区二区三区四区 | www.9191.com| 中国黄色一级生活片 | av久草| 久久久一二三 | 日韩激情 | 青青国产在线视频 | 亚洲经典视频 | 亚洲欧美国产高清va在线播放 | 中文国产在线视频 | 一本色道久久99精品综合蜜臀 | 毛片免费在线观看 | 国产18视频 | 91精品国产91久久久久久蜜臀 | 一级黄色影院 | 精品一区二区6 | 夜夜夜精品视频 | 国产成人自拍视频在线 | 特级毛片a级毛片100免费 | 热久久91 | 欧美黄色大片免费观看 | 国产午夜精品理论片a级探花 | 毛片免费视频观看 | china对白普通话xxxx | 日本不卡一区二区三区在线观看 | 国产精品视频自拍 | 欧美a视频在线观看 | 欧美a∨一区二区三区久久黄 | 黄色一级片免费观看 | 天天干导航 | 视频一区 在线 | 奇米影视888狠狠狠777不卡 | 欧美一区在线观看视频 |