|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
namespace Apix\Cache\Mongo; |
|
4
|
|
|
|
|
5
|
|
|
use MongoDB\Collection; |
|
6
|
|
|
|
|
7
|
|
|
/** |
|
8
|
|
|
* allows to use \MongoDB\Collection in the code as \MongoCollection |
|
9
|
|
|
*/ |
|
10
|
|
|
class CollectionAdapter /*extends \MongoCollection*/ |
|
11
|
|
|
{ |
|
12
|
|
|
/** |
|
13
|
|
|
* @var Collection |
|
14
|
|
|
*/ |
|
15
|
|
|
private $collection; |
|
16
|
|
|
|
|
17
|
|
|
/** |
|
18
|
|
|
* CollectionAdapter constructor. |
|
19
|
|
|
* @param Collection $collection |
|
20
|
|
|
*/ |
|
21
|
|
|
public function __construct(Collection $collection) |
|
22
|
|
|
{ |
|
23
|
|
|
$this->collection = $collection; |
|
24
|
|
|
} |
|
25
|
|
|
|
|
26
|
|
|
public function ensureIndex(array $keys, array $options = array()) |
|
27
|
|
|
{ |
|
28
|
|
|
$this->collection->createIndex($keys, $options); |
|
29
|
|
|
} |
|
30
|
|
|
|
|
31
|
|
View Code Duplication |
public function insert($a, array $options = array()) |
|
|
|
|
|
|
32
|
|
|
{ |
|
33
|
|
|
try { |
|
34
|
|
|
$this->collection->insertOne($a, $options); |
|
35
|
|
|
return ['ok' => 1]; |
|
36
|
|
|
} catch (\Exception $e) { |
|
37
|
|
|
return ['ok' => 0, 'error' => $e->getMessage()]; |
|
38
|
|
|
} |
|
39
|
|
|
} |
|
40
|
|
|
|
|
41
|
|
View Code Duplication |
public function update(array $criteria, array $newobj, array $options = array()) |
|
|
|
|
|
|
42
|
|
|
{ |
|
43
|
|
|
try { |
|
44
|
|
|
$this->collection->updateOne($criteria, array('$set' => $newobj), $options); |
|
45
|
|
|
return ['ok' => 1]; |
|
46
|
|
|
} catch (\Exception $e) { |
|
47
|
|
|
return ['ok' => 0, 'error' => $e->getMessage()]; |
|
48
|
|
|
} |
|
49
|
|
|
} |
|
50
|
|
|
|
|
51
|
|
|
public function remove(array $criteria = array(), array $options = array()) |
|
52
|
|
|
{ |
|
53
|
|
|
try { |
|
54
|
|
|
$result = $this->collection->deleteMany($criteria, $options); |
|
55
|
|
|
return ['ok' => 1, 'n' => $result->getDeletedCount()]; |
|
56
|
|
|
} catch (\Exception $e) { |
|
57
|
|
|
return ['ok' => 0, 'error' => $e->getMessage()]; |
|
58
|
|
|
} |
|
59
|
|
|
} |
|
60
|
|
|
|
|
61
|
|
|
public function find(array $query = array(), array $fields = array()) |
|
62
|
|
|
{ |
|
63
|
|
|
$options = ['projection' => array_fill_keys($fields, 1) + ['_id' => 0]]; |
|
64
|
|
|
|
|
65
|
|
|
return $this->collection->find($query, $options); |
|
66
|
|
|
} |
|
67
|
|
|
|
|
68
|
|
|
public function findOne(array $query = array(), array $fields = array()) |
|
69
|
|
|
{ |
|
70
|
|
|
$options = ['projection' => array_fill_keys($fields, 1) + ['_id' => 0]]; |
|
71
|
|
|
|
|
72
|
|
|
$result = $this->collection->findOne($query, $options); |
|
73
|
|
|
|
|
74
|
|
|
// mimic \MongoDate->sec |
|
75
|
|
|
if (!empty($result['expire'])) { |
|
76
|
|
|
$sec = $result['expire']->toDateTime()->getTimestamp(); |
|
77
|
|
|
$result['expire'] = new \stdClass(); |
|
78
|
|
|
$result['expire']->sec = $sec; |
|
79
|
|
|
} |
|
80
|
|
|
|
|
81
|
|
|
return $result; |
|
82
|
|
|
} |
|
83
|
|
|
|
|
84
|
|
|
public function drop() |
|
85
|
|
|
{ |
|
86
|
|
|
$this->collection->drop(); |
|
87
|
|
|
return ['ok' => 1]; |
|
88
|
|
|
} |
|
89
|
|
|
|
|
90
|
|
|
public function count($query = array()) |
|
91
|
|
|
{ |
|
92
|
|
|
return $this->collection->count($query); |
|
93
|
|
|
} |
|
94
|
|
|
} |
frqnck /
apix-cache
Loading history...
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.