1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
/** |
4
|
|
|
* This software package is licensed under AGPL or Commercial license. |
5
|
|
|
* |
6
|
|
|
* @package maslosoft/mangan |
7
|
|
|
* @licence AGPL or Commercial |
8
|
|
|
* @copyright Copyright (c) Piotr Masełkowski <[email protected]> |
9
|
|
|
* @copyright Copyright (c) Maslosoft |
10
|
|
|
* @copyright Copyright (c) Others as mentioned in code |
11
|
|
|
* @link https://maslosoft.com/mangan/ |
12
|
|
|
*/ |
13
|
|
|
|
14
|
|
|
namespace Maslosoft\Mangan\Abstracts; |
15
|
|
|
|
16
|
|
|
use Iterator; |
17
|
|
|
use Maslosoft\Addendum\Interfaces\AnnotatedInterface; |
18
|
|
|
use Maslosoft\Mangan\Adapters\Finder\MongoAdapter; |
19
|
|
|
use Maslosoft\Mangan\Cursor; |
20
|
|
|
use Maslosoft\Mangan\Finder; |
21
|
|
|
use Maslosoft\Mangan\Helpers\PkManager; |
22
|
|
|
use Maslosoft\Mangan\Interfaces\Adapters\FinderAdapterInterface; |
23
|
|
|
use Maslosoft\Mangan\Interfaces\Adapters\FinderCursorInterface; |
24
|
|
|
use Maslosoft\Mangan\Interfaces\CriteriaInterface; |
25
|
|
|
use Maslosoft\Mangan\Interfaces\FinderEventsInterface; |
26
|
|
|
use Maslosoft\Mangan\Interfaces\FinderInterface; |
27
|
|
|
use Maslosoft\Mangan\Interfaces\ModelAwareInterface; |
28
|
|
|
use Maslosoft\Mangan\Interfaces\ProfilerInterface; |
29
|
|
|
use Maslosoft\Mangan\Interfaces\ScenariosInterface; |
30
|
|
|
use Maslosoft\Mangan\Interfaces\ScopeManagerInterface; |
31
|
|
|
use Maslosoft\Mangan\ScenarioManager; |
32
|
|
|
use Maslosoft\Mangan\Traits\Finder\FinderHelpers; |
33
|
|
|
use Maslosoft\Mangan\Traits\ModelAwareTrait; |
34
|
|
|
use MongoCursor; |
35
|
|
|
use UnexpectedValueException; |
36
|
|
|
|
37
|
|
|
/** |
38
|
|
|
* AbstractFinder |
39
|
|
|
* |
40
|
|
|
* @author Piotr Maselkowski <pmaselkowski at gmail.com> |
41
|
|
|
*/ |
42
|
|
|
abstract class AbstractFinder implements FinderInterface, ModelAwareInterface |
43
|
|
|
{ |
44
|
|
|
|
45
|
|
|
use ModelAwareTrait; |
46
|
|
|
|
47
|
|
|
/** |
48
|
|
|
* Whenever to use cursors |
49
|
|
|
* @var bool |
50
|
|
|
*/ |
51
|
|
|
private $useCursor = false; |
52
|
|
|
|
53
|
|
|
// <editor-fold defaultstate="collapsed" desc="Required getters/setters"> |
54
|
|
|
/** |
55
|
|
|
* @see FinderHelpers |
56
|
|
|
* @return FinderAdapterInterface|MongoAdapter |
57
|
|
|
*/ |
58
|
|
|
abstract public function getAdapter(); |
59
|
|
|
|
60
|
|
|
/** |
61
|
|
|
* @see FinderHelpers |
62
|
|
|
* @return ScopeManagerInterface |
63
|
|
|
*/ |
64
|
|
|
abstract public function getScopeManager(); |
65
|
|
|
|
66
|
|
|
/** |
67
|
|
|
* @see FinderHelpers |
68
|
|
|
* @return FinderEventsInterface |
69
|
|
|
*/ |
70
|
|
|
abstract public function getFinderEvents(); |
71
|
|
|
|
72
|
|
|
/** |
73
|
|
|
* @see FinderHelpers |
74
|
|
|
* @return ProfilerInterface |
75
|
|
|
*/ |
76
|
|
|
abstract public function getProfiler(); |
77
|
|
|
|
78
|
|
|
/** |
79
|
|
|
* @see FinderHelpers |
80
|
|
|
* @return static |
81
|
|
|
*/ |
82
|
|
|
abstract public function setAdapter(FinderAdapterInterface $adapter); |
83
|
|
|
|
84
|
|
|
/** |
85
|
|
|
* @see FinderHelpers |
86
|
|
|
* @return static |
87
|
|
|
*/ |
88
|
|
|
abstract public function setScopeManager(ScopeManagerInterface $scopeManager); |
89
|
|
|
|
90
|
|
|
/** |
91
|
|
|
* @see FinderHelpers |
92
|
|
|
* @return static |
93
|
|
|
*/ |
94
|
|
|
abstract public function setFinderEvents(FinderEventsInterface $finderEvents); |
95
|
|
|
|
96
|
|
|
/** |
97
|
|
|
* @see FinderHelpers |
98
|
|
|
* @return static |
99
|
|
|
*/ |
100
|
|
|
abstract public function setProfiler(ProfilerInterface $profiler); |
101
|
|
|
// </editor-fold> |
102
|
|
|
|
103
|
|
|
/** |
104
|
|
|
* Finds a single Document with the specified condition. |
105
|
|
|
* |
106
|
|
|
* @param array|CriteriaInterface $criteria query criteria. |
107
|
|
|
* @return AnnotatedInterface |
108
|
|
|
* @Ignored |
109
|
|
|
*/ |
110
|
81 |
|
public function find($criteria = null) |
111
|
|
|
{ |
112
|
81 |
|
if ($this->getFinderEvents()->beforeFind($this)) |
113
|
|
|
{ |
114
|
81 |
|
$criteria = $this->getScopeManager()->apply($criteria); |
115
|
81 |
|
$data = $this->getAdapter()->findOne($criteria, $criteria->getSelect()); |
116
|
81 |
|
return $this->populateRecord($data); |
117
|
|
|
} |
118
|
|
|
return null; |
119
|
|
|
} |
120
|
|
|
|
121
|
|
|
/** |
122
|
|
|
* Finds document with the specified primary key. Primary key by default |
123
|
|
|
* is defined by `_id` field. But could be any other. For simple (one column) |
124
|
|
|
* keys use it's value. |
125
|
|
|
* |
126
|
|
|
* For composite use key-value with column names as keys |
127
|
|
|
* and values for values. |
128
|
|
|
* |
129
|
|
|
* Example for simple pk: |
130
|
|
|
* ```php |
131
|
|
|
* $pk = '51b616fcc0986e30026d0748' |
132
|
|
|
* ``` |
133
|
|
|
* |
134
|
|
|
* Composite pk: |
135
|
|
|
* ```php |
136
|
|
|
* $pk = [ |
137
|
|
|
* 'mainPk' => 1, |
138
|
|
|
* 'secondaryPk' => 2 |
139
|
|
|
* ]; |
140
|
|
|
* ``` |
141
|
|
|
* |
142
|
|
|
* @param mixed $pkValue primary key value. Use array for composite key. |
143
|
|
|
* @param array|CriteriaInterface $criteria |
144
|
|
|
* @return AnnotatedInterface|null |
145
|
|
|
* @Ignored |
146
|
|
|
*/ |
147
|
58 |
|
public function findByPk($pkValue, $criteria = null) |
148
|
|
|
{ |
149
|
58 |
|
$pkCriteria = $this->getScopeManager()->getNewCriteria($criteria); |
150
|
58 |
|
$pkCriteria->mergeWith(PkManager::prepare($this->getModel(), $pkValue)); |
151
|
58 |
|
return $this->find($pkCriteria); |
152
|
|
|
} |
153
|
|
|
|
154
|
|
|
/** |
155
|
|
|
* Finds document with the specified attributes. |
156
|
|
|
* Attributes should be specified as key-value pairs. |
157
|
|
|
* This allows easier syntax for simple queries. |
158
|
|
|
* |
159
|
|
|
* Example: |
160
|
|
|
* ```php |
161
|
|
|
* $attributes = [ |
162
|
|
|
* 'name' => 'John', |
163
|
|
|
* 'title' => 'dr' |
164
|
|
|
* ]; |
165
|
|
|
* ``` |
166
|
|
|
* |
167
|
|
|
* @param mixed[] Array of stributes and values in form of ['attributeName' => 'value'] |
168
|
|
|
* @return AnnotatedInterface|null |
169
|
|
|
*/ |
170
|
2 |
|
public function findByAttributes(array $attributes) |
171
|
|
|
{ |
172
|
2 |
|
$criteria = $this->getScopeManager()->getNewCriteria(); |
173
|
2 |
|
foreach ($attributes as $name => $value) |
174
|
|
|
{ |
175
|
2 |
|
$criteria->addCond($name, '==', $value); |
176
|
|
|
} |
177
|
2 |
|
return $this->find($criteria); |
178
|
|
|
} |
179
|
|
|
|
180
|
|
|
/** |
181
|
|
|
* Finds all documents satisfying the specified condition. |
182
|
|
|
* See {@link find()} for detailed explanation about $condition and $params. |
183
|
|
|
* |
184
|
|
|
* @param array|CriteriaInterface $criteria query criteria. |
185
|
|
|
* @return AnnotatedInterface[]|Cursor |
186
|
|
|
*/ |
187
|
25 |
|
public function findAll($criteria = null) |
188
|
|
|
{ |
189
|
25 |
|
if ($this->getFinderEvents()->beforeFind($this)) |
190
|
|
|
{ |
191
|
23 |
|
$criteria = $this->getScopeManager()->apply($criteria); |
192
|
23 |
|
$cursor = $this->getAdapter()->findMany($criteria); |
193
|
|
|
|
194
|
23 |
|
assert(is_object($cursor), sprintf('Expected cursor to be compatible object, got %s', gettype($cursor))); |
195
|
23 |
|
assert($cursor instanceof FinderCursorInterface || $cursor instanceof MongoCursor, new UnexpectedValueException(sprintf('Expected `%s` or `%s` got `%s`', FinderCursorInterface::class, MongoCursor::class, get_class($cursor)))); |
196
|
|
|
|
197
|
23 |
|
if ($criteria->getSort() !== null) |
198
|
|
|
{ |
199
|
23 |
|
$cursor->sort($criteria->getSort()); |
200
|
|
|
} |
201
|
23 |
|
if ($criteria->getLimit() !== null) |
202
|
|
|
{ |
203
|
6 |
|
$cursor->limit($criteria->getLimit()); |
204
|
|
|
} |
205
|
23 |
|
if ($criteria->getOffset() !== null) |
206
|
|
|
{ |
207
|
6 |
|
$cursor->skip($criteria->getOffset()); |
208
|
|
|
} |
209
|
23 |
|
if ($criteria->getSelect()) |
210
|
|
|
{ |
211
|
5 |
|
$cursor->fields(array_merge($criteria->getSelect(), ['_class' => true])); |
212
|
|
|
} |
213
|
23 |
|
$this->getProfiler()->cursor($cursor); |
214
|
23 |
|
if ($this->isWithCursor()) |
215
|
|
|
{ |
216
|
1 |
|
return new Cursor($cursor, $this->getModel()); |
217
|
|
|
} |
218
|
|
|
else |
219
|
|
|
{ |
220
|
22 |
|
return $this->populateRecords($cursor); |
221
|
|
|
} |
222
|
|
|
} |
223
|
2 |
|
return []; |
224
|
|
|
} |
225
|
|
|
|
226
|
|
|
/** |
227
|
|
|
* Finds all documents with the specified attributes. |
228
|
|
|
* |
229
|
|
|
* @param mixed[] Array of stributes and values in form of ['attributeName' => 'value'] |
230
|
|
|
* @return AnnotatedInterface[]|Cursor - Array or cursor of Documents |
231
|
|
|
* @since v1.0 |
232
|
|
|
*/ |
233
|
1 |
|
public function findAllByAttributes(array $attributes) |
234
|
|
|
{ |
235
|
1 |
|
$criteria = $this->getScopeManager()->getNewCriteria(); |
236
|
1 |
|
foreach ($attributes as $name => $value) |
237
|
|
|
{ |
238
|
1 |
|
$criteria->$name('==', $value); |
239
|
|
|
} |
240
|
|
|
|
241
|
1 |
|
return $this->findAll($criteria); |
242
|
|
|
} |
243
|
|
|
|
244
|
|
|
/** |
245
|
|
|
* Finds all documents with the specified primary keys. |
246
|
|
|
* In MongoDB world every document has '_id' unique field, so with this method that |
247
|
|
|
* field is in use as PK by default. |
248
|
|
|
* See {@link find()} for detailed explanation about $condition. |
249
|
|
|
* |
250
|
|
|
* @param mixed $pkValues primary key value(s). Use array for multiple primary keys. For composite key, each key value must be an array (column name=>column value). |
251
|
|
|
* @param array|CriteriaInterface $criteria query criteria. |
252
|
|
|
* @return AnnotatedInterface[]|Cursor - Array or cursor of Documents |
253
|
|
|
* @since v1.0 |
254
|
|
|
*/ |
255
|
7 |
|
public function findAllByPk($pkValues, $criteria = null) |
256
|
|
|
{ |
257
|
7 |
|
$pkCriteria = $this->getScopeManager()->getNewCriteria($criteria); |
258
|
7 |
|
PkManager::prepareAll($this->getModel(), $pkValues, $pkCriteria); |
259
|
|
|
|
260
|
7 |
|
return $this->findAll($pkCriteria); |
261
|
|
|
} |
262
|
|
|
|
263
|
|
|
/** |
264
|
|
|
* Counts all documents satisfying the specified condition. |
265
|
|
|
* See {@link find()} for detailed explanation about $condition and $params. |
266
|
|
|
* @param array|CriteriaInterface $criteria query criteria. |
267
|
|
|
* @return integer Count of all documents satisfying the specified condition. |
268
|
|
|
* @since v1.0 |
269
|
|
|
*/ |
270
|
31 |
|
public function count($criteria = null) |
271
|
|
|
{ |
272
|
31 |
|
if ($this->getFinderEvents()->beforeCount($this)) |
273
|
|
|
{ |
274
|
31 |
|
$criteria = $this->getScopeManager()->apply($criteria); |
275
|
31 |
|
$count = $this->getAdapter()->count($criteria); |
276
|
31 |
|
$this->getFinderEvents()->afterCount($this); |
277
|
31 |
|
return $count; |
278
|
|
|
} |
279
|
|
|
return 0; |
280
|
|
|
} |
281
|
|
|
|
282
|
|
|
/** |
283
|
|
|
* Counts all documents found by attribute values. |
284
|
|
|
* |
285
|
|
|
* Example: |
286
|
|
|
* ```php |
287
|
|
|
* $attributes = [ |
288
|
|
|
* 'name' => 'John', |
289
|
|
|
* 'title' => 'dr' |
290
|
|
|
* ]; |
291
|
|
|
* ``` |
292
|
|
|
* |
293
|
|
|
* @param mixed[] Array of attributes and values in form of ['attributeName' => 'value'] |
294
|
|
|
* @return int |
295
|
|
|
* @since v1.2.2 |
296
|
|
|
* @Ignored |
297
|
|
|
*/ |
298
|
1 |
|
public function countByAttributes(array $attributes) |
299
|
|
|
{ |
300
|
1 |
|
if ($this->getFinderEvents()->beforeCount($this)) |
301
|
|
|
{ |
302
|
1 |
|
$criteria = $this->getScopeManager()->getNewCriteria(); |
303
|
1 |
|
foreach ($attributes as $name => $value) |
304
|
|
|
{ |
305
|
1 |
|
$criteria->$name = $value; |
306
|
|
|
} |
307
|
|
|
|
308
|
1 |
|
$scopedCriteria = $this->getScopeManager()->apply($criteria); |
309
|
|
|
|
310
|
1 |
|
$count = $this->getAdapter()->count($scopedCriteria); |
311
|
1 |
|
$this->getFinderEvents()->afterCount($this); |
312
|
1 |
|
return $count; |
313
|
|
|
} |
314
|
|
|
return 0; |
315
|
|
|
} |
316
|
|
|
|
317
|
|
|
/** |
318
|
|
|
* Checks whether there is document satisfying the specified condition. |
319
|
|
|
* |
320
|
|
|
* @param CriteriaInterface $criteria |
321
|
|
|
* @return bool |
322
|
|
|
*/ |
323
|
7 |
|
public function exists(CriteriaInterface $criteria = null) |
324
|
|
|
{ |
325
|
7 |
|
if ($this->getFinderEvents()->beforeExists($this)) |
326
|
|
|
{ |
327
|
7 |
|
$criteria = $this->getScopeManager()->apply($criteria); |
328
|
|
|
|
329
|
|
|
//Select only Pk Fields to not fetch possibly large document |
330
|
7 |
|
$pkKeys = PkManager::getPkKeys($this->getModel()); |
331
|
7 |
|
if (is_string($pkKeys)) |
332
|
|
|
{ |
333
|
5 |
|
$pkKeys = [$pkKeys]; |
334
|
|
|
} |
335
|
7 |
|
$cursor = $this->getAdapter()->findMany($criteria, $pkKeys); |
336
|
7 |
|
$cursor->limit(1); |
337
|
|
|
|
338
|
|
|
// NOTE: Cannot use count(true) here because of hhvm mongofill compatibility, see: |
339
|
|
|
// https://github.com/mongofill/mongofill/issues/86 |
340
|
7 |
|
$exists = ($cursor->count() !== 0); |
341
|
7 |
|
$this->getFinderEvents()->afterExists($this); |
342
|
7 |
|
return $exists; |
343
|
|
|
} |
344
|
|
|
return false; |
345
|
|
|
} |
346
|
|
|
|
347
|
|
|
/** |
348
|
|
|
* Resets all scopes and criteria applied including default scope. |
349
|
|
|
* |
350
|
|
|
* @return Finder |
351
|
|
|
* @since v1.0 |
352
|
|
|
*/ |
353
|
|
|
public function resetScope() |
354
|
|
|
{ |
355
|
|
|
$this->getScopeManager()->reset(); |
356
|
|
|
return $this; |
357
|
|
|
} |
358
|
|
|
|
359
|
|
|
/** |
360
|
|
|
* Whenever to use cursor |
361
|
|
|
* @param bool $useCursor |
362
|
|
|
* @return FinderInterface |
363
|
|
|
*/ |
364
|
108 |
|
public function withCursor($useCursor = true) |
365
|
|
|
{ |
366
|
108 |
|
$this->useCursor = $useCursor; |
367
|
108 |
|
return $this; |
368
|
|
|
} |
369
|
|
|
|
370
|
23 |
|
public function isWithCursor() |
371
|
|
|
{ |
372
|
23 |
|
return $this->useCursor; |
373
|
|
|
} |
374
|
|
|
|
375
|
|
|
/** |
376
|
|
|
* Creates an model with the given attributes. |
377
|
|
|
* This method is internally used by the find methods. |
378
|
|
|
* @param mixed[] $data attribute values (column name=>column value) |
379
|
|
|
* @return AnnotatedInterface|null the newly created document. The class of the object is the same as the model class. |
380
|
|
|
* Null is returned if the input data is false. |
381
|
|
|
* @since v1.0 |
382
|
|
|
*/ |
383
|
95 |
|
protected function populateRecord($data) |
384
|
|
|
{ |
385
|
95 |
|
if ($data !== null) |
386
|
|
|
{ |
387
|
92 |
|
$model = $this->createModel($data); |
388
|
92 |
|
ScenarioManager::setScenario($model, ScenariosInterface::Update); |
389
|
92 |
|
$this->getFinderEvents()->afterFind($this, $model); |
390
|
92 |
|
return $model; |
391
|
|
|
} |
392
|
|
|
else |
393
|
|
|
{ |
394
|
13 |
|
return null; |
395
|
|
|
} |
396
|
|
|
} |
397
|
|
|
|
398
|
|
|
/** |
399
|
|
|
* Creates a list of documents based on the input data. |
400
|
|
|
* This method is internally used by the find methods. |
401
|
|
|
* @param Iterator|array $cursor Results found to populate active records. |
402
|
|
|
* @return AnnotatedInterface[] array list of active records. |
403
|
|
|
* @since v1.0 |
404
|
|
|
*/ |
405
|
22 |
|
private function populateRecords($cursor) |
406
|
|
|
{ |
407
|
22 |
|
$records = array(); |
408
|
22 |
|
foreach ($cursor as $data) |
409
|
|
|
{ |
410
|
22 |
|
$records[] = $this->populateRecord($data); |
411
|
|
|
} |
412
|
22 |
|
return $records; |
413
|
|
|
} |
414
|
|
|
|
415
|
|
|
} |
416
|
|
|
|