国产片侵犯亲女视频播放_亚洲精品二区_在线免费国产视频_欧美精品一区二区三区在线_少妇久久久_在线观看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();
  */
 
}

延伸 · 閱讀

精彩推薦
Weibo Article 1 Weibo Article 2 Weibo Article 3 Weibo Article 4 Weibo Article 5 Weibo Article 6 Weibo Article 7 Weibo Article 8 Weibo Article 9 Weibo Article 10 Weibo Article 11 Weibo Article 12 Weibo Article 13 Weibo Article 14 Weibo Article 15 Weibo Article 16 Weibo Article 17 Weibo Article 18 Weibo Article 19 Weibo Article 20 Weibo Article 21 Weibo Article 22 Weibo Article 23 Weibo Article 24 Weibo Article 25 Weibo Article 26 Weibo Article 27 Weibo Article 28 Weibo Article 29 Weibo Article 30 Weibo Article 31 Weibo Article 32 Weibo Article 33 Weibo Article 34 Weibo Article 35 Weibo Article 36 Weibo Article 37 Weibo Article 38 Weibo Article 39 Weibo Article 40
主站蜘蛛池模板： 国产视频第一页 | 成人高清 | 久久性色 | 成人免费淫片aa视频免费 | 国产中文字幕在线免费观看 | 欧美第一视频 | 欧美一级欧美三级在线观看 | 欧美日韩亚洲国产 | 99久久夜色精品国产网站 | 欧美一区二区三区在线 | 色综合成人 | 黄色小视频在线免费观看 | 日韩一区二区不卡 | 91国内外精品自在线播放 | 日韩精品免费一区二区三区 | 欧美日韩国产一区二区三区 | 免费看黄色大片 | 日韩精品一区二区三区中文在线 | 日韩精品免费视频 | 国产精品欧美日韩在线观看 | 国产精品不卡一区 | 中文字幕乱码亚洲精品一区 | 国产精品女同一区二区免费站 | 在线观看五码 | 天天拍拍天天干 | 午夜在线观看视频网站 | 伦一区二区三区中文字幕v亚洲 | 91久久精品日日躁夜夜躁国产 | 综合色导航 | 亚洲91av | 日韩精品在线视频 | 国产精品福利在线观看 | 久久国产高清 | 国产日韩欧美在线 | 青青草亚洲| 噜噜噜在线 | 中文字幕一区二区三区精彩视频 | 日韩精品影院 | 欧美大片免费影院在线观看 | 五月婷婷在线观看视频 | 精品久久中文 |