|
1
|
|
|
<?php |
|
2
|
|
|
/** |
|
3
|
|
|
* components |
|
4
|
|
|
* |
|
5
|
|
|
* @author Wolfy-J |
|
6
|
|
|
*/ |
|
7
|
|
|
namespace Spiral\ORM; |
|
8
|
|
|
|
|
9
|
|
|
use Spiral\Core\Component; |
|
10
|
|
|
use Spiral\Core\Traits\SaturateTrait; |
|
11
|
|
|
use Spiral\Models\AccessorInterface; |
|
12
|
|
|
use Spiral\Models\SchematicEntity; |
|
13
|
|
|
use Spiral\Models\Traits\SolidableTrait; |
|
14
|
|
|
use Spiral\ORM\Exceptions\FieldException; |
|
15
|
|
|
|
|
16
|
|
|
/** |
|
17
|
|
|
* Provides ActiveRecord-less abstraction for carried data with ability to automatically apply |
|
18
|
|
|
* setters, getters, generate update, insert and delete sequences and access nested relations. |
|
19
|
|
|
* |
|
20
|
|
|
* Class implementations statically analyzed to define DB schema. |
|
21
|
|
|
* |
|
22
|
|
|
* @see RecordEntity::SCHEMA |
|
23
|
|
|
*/ |
|
24
|
|
|
abstract class RecordEntity extends SchematicEntity |
|
25
|
|
|
{ |
|
26
|
|
|
use SaturateTrait, SolidableTrait; |
|
27
|
|
|
|
|
28
|
|
|
/* |
|
29
|
|
|
* Begin set of behaviour and description constants. |
|
30
|
|
|
* ================================================ |
|
31
|
|
|
*/ |
|
32
|
|
|
|
|
33
|
|
|
/** |
|
34
|
|
|
* Set of schema sections needed to describe entity behaviour. |
|
35
|
|
|
*/ |
|
36
|
|
|
const SH_PRIMARIES = 0; |
|
37
|
|
|
const SH_DEFAULTS = 1; |
|
38
|
|
|
const SH_RELATIONS = 6; |
|
39
|
|
|
|
|
40
|
|
|
/** |
|
41
|
|
|
* Default ORM relation types, see ORM configuration and documentation for more information. |
|
42
|
|
|
* |
|
43
|
|
|
* @see RelationSchemaInterface |
|
44
|
|
|
* @see RelationSchema |
|
45
|
|
|
*/ |
|
46
|
|
|
const HAS_ONE = 101; |
|
47
|
|
|
const HAS_MANY = 102; |
|
48
|
|
|
const BELONGS_TO = 103; |
|
49
|
|
|
const MANY_TO_MANY = 104; |
|
50
|
|
|
|
|
51
|
|
|
/** |
|
52
|
|
|
* Morphed relation types are usually created by inversion or equivalent of primary relation |
|
53
|
|
|
* types. |
|
54
|
|
|
* |
|
55
|
|
|
* @see RelationSchemaInterface |
|
56
|
|
|
* @see RelationSchema |
|
57
|
|
|
* @see MorphedRelation |
|
58
|
|
|
*/ |
|
59
|
|
|
const BELONGS_TO_MORPHED = 108; |
|
60
|
|
|
const MANY_TO_MORPHED = 109; |
|
61
|
|
|
|
|
62
|
|
|
/** |
|
63
|
|
|
* Constants used to declare relations in record schema, used in normalized relation schema. |
|
64
|
|
|
* |
|
65
|
|
|
* @see RelationSchemaInterface |
|
66
|
|
|
*/ |
|
67
|
|
|
const OUTER_KEY = 901; //Outer key name |
|
68
|
|
|
const INNER_KEY = 902; //Inner key name |
|
69
|
|
|
const MORPH_KEY = 903; //Morph key name |
|
70
|
|
|
const PIVOT_TABLE = 904; //Pivot table name |
|
71
|
|
|
const PIVOT_COLUMNS = 905; //Pre-defined pivot table columns |
|
72
|
|
|
const PIVOT_DEFAULTS = 906; //Pre-defined pivot table default values |
|
73
|
|
|
const THOUGHT_INNER_KEY = 907; //Pivot table options |
|
74
|
|
|
const THOUGHT_OUTER_KEY = 908; //Pivot table options |
|
75
|
|
|
const WHERE = 909; //Where conditions |
|
76
|
|
|
const WHERE_PIVOT = 910; //Where pivot conditions |
|
77
|
|
|
|
|
78
|
|
|
/** |
|
79
|
|
|
* Additional constants used to control relation schema behaviour. |
|
80
|
|
|
* |
|
81
|
|
|
* @see RecordEntity::SCHEMA |
|
82
|
|
|
* @see RelationSchemaInterface |
|
83
|
|
|
*/ |
|
84
|
|
|
const INVERSE = 1001; //Relation should be inverted to parent record |
|
85
|
|
|
const CREATE_CONSTRAINT = 1002; //Relation should create foreign keys (default) |
|
86
|
|
|
const CONSTRAINT_ACTION = 1003; //Default relation foreign key delete/update action (CASCADE) |
|
87
|
|
|
const CREATE_PIVOT = 1004; //Many-to-Many should create pivot table automatically (default) |
|
88
|
|
|
const NULLABLE = 1005; //Relation can be nullable (default) |
|
89
|
|
|
const CREATE_INDEXES = 1006; //Indication that relation is allowed to create required indexes |
|
90
|
|
|
const MORPHED_ALIASES = 1007; //Aliases for morphed sub-relations |
|
91
|
|
|
|
|
92
|
|
|
/** |
|
93
|
|
|
* Set of columns to be used in relation (attention, make sure that loaded records are set as |
|
94
|
|
|
* NON SOLID if you planning to modify their data). |
|
95
|
|
|
*/ |
|
96
|
|
|
const RELATION_COLUMNS = 1009; |
|
97
|
|
|
|
|
98
|
|
|
/** |
|
99
|
|
|
* Constants used to declare indexes in record schema. |
|
100
|
|
|
* |
|
101
|
|
|
* @see Record::INDEXES |
|
102
|
|
|
*/ |
|
103
|
|
|
const INDEX = 1000; //Default index type |
|
104
|
|
|
const UNIQUE = 2000; //Unique index definition |
|
105
|
|
|
|
|
106
|
|
|
/* |
|
107
|
|
|
* ================================================ |
|
108
|
|
|
* End set of behaviour and description constants. |
|
109
|
|
|
*/ |
|
110
|
|
|
|
|
111
|
|
|
/** |
|
112
|
|
|
* Model behaviour configurations. |
|
113
|
|
|
*/ |
|
114
|
|
|
const SECURED = '*'; |
|
115
|
|
|
const HIDDEN = []; |
|
116
|
|
|
const FILLABLE = []; |
|
117
|
|
|
const SETTERS = []; |
|
118
|
|
|
const GETTERS = []; |
|
119
|
|
|
const ACCESSORS = []; |
|
120
|
|
|
|
|
121
|
|
|
/** |
|
122
|
|
|
* Record relations and columns can be described in one place - record schema. |
|
123
|
|
|
* Attention: while defining table structure make sure that ACTIVE_SCHEMA constant is set to t |
|
124
|
|
|
* rue. |
|
125
|
|
|
* |
|
126
|
|
|
* Example: |
|
127
|
|
|
* const SCHEMA = [ |
|
128
|
|
|
* 'id' => 'primary', |
|
129
|
|
|
* 'name' => 'string', |
|
130
|
|
|
* 'biography' => 'text' |
|
131
|
|
|
* ]; |
|
132
|
|
|
* |
|
133
|
|
|
* You can pass additional options for some of your columns: |
|
134
|
|
|
* const SCHEMA = [ |
|
135
|
|
|
* 'pinCode' => 'string(128)', //String length |
|
136
|
|
|
* 'status' => 'enum(active, hidden)', //Enum values |
|
137
|
|
|
* 'balance' => 'decimal(10, 2)' //Decimal size and precision |
|
138
|
|
|
* ]; |
|
139
|
|
|
* |
|
140
|
|
|
* Every created column will be stated as NOT NULL with forced default value, if you want to |
|
141
|
|
|
* have nullable columns, specify special data key: protected $schema = [ |
|
142
|
|
|
* 'name' => 'string, nullable' |
|
143
|
|
|
* ]; |
|
144
|
|
|
* |
|
145
|
|
|
* You can easily combine table and relations definition in one schema: |
|
146
|
|
|
* const SCHEMA = [ |
|
147
|
|
|
* 'id' => 'bigPrimary', |
|
148
|
|
|
* 'name' => 'string', |
|
149
|
|
|
* 'email' => 'string', |
|
150
|
|
|
* 'phoneNumber' => 'string(32)', |
|
151
|
|
|
* |
|
152
|
|
|
* //Relations |
|
153
|
|
|
* 'profile' => [ |
|
154
|
|
|
* self::HAS_ONE => 'Records\Profile', |
|
155
|
|
|
* self::INVERSE => 'user' |
|
156
|
|
|
* ], |
|
157
|
|
|
* 'roles' => [ |
|
158
|
|
|
* self::MANY_TO_MANY => 'Records\Role', |
|
159
|
|
|
* self::INVERSE => 'users' |
|
160
|
|
|
* ] |
|
161
|
|
|
* ]; |
|
162
|
|
|
* |
|
163
|
|
|
* @var array |
|
164
|
|
|
*/ |
|
165
|
|
|
const SCHEMA = []; |
|
166
|
|
|
|
|
167
|
|
|
/** |
|
168
|
|
|
* Default field values. |
|
169
|
|
|
* |
|
170
|
|
|
* @var array |
|
171
|
|
|
*/ |
|
172
|
|
|
const DEFAULTS = []; |
|
173
|
|
|
|
|
174
|
|
|
/** |
|
175
|
|
|
* Set of indexes to be created for associated record table, indexes only created when record is |
|
176
|
|
|
* not abstract and has active schema set to true. |
|
177
|
|
|
* |
|
178
|
|
|
* Use constants INDEX and UNIQUE to describe indexes, you can also create compound indexes: |
|
179
|
|
|
* const INDEXES = [ |
|
180
|
|
|
* [self::UNIQUE, 'email'], |
|
181
|
|
|
* [self::INDEX, 'board_id'], |
|
182
|
|
|
* [self::INDEX, 'board_id', 'check_id'] |
|
183
|
|
|
* ]; |
|
184
|
|
|
* |
|
185
|
|
|
* @var array |
|
186
|
|
|
*/ |
|
187
|
|
|
const INDEXES = []; |
|
188
|
|
|
|
|
189
|
|
|
/** |
|
190
|
|
|
* Record behaviour definition. |
|
191
|
|
|
* |
|
192
|
|
|
* @var array |
|
193
|
|
|
*/ |
|
194
|
|
|
private $recordSchema = []; |
|
195
|
|
|
|
|
196
|
|
|
/** |
|
197
|
|
|
* Record state. |
|
198
|
|
|
* |
|
199
|
|
|
* @var int |
|
200
|
|
|
*/ |
|
201
|
|
|
private $state; |
|
202
|
|
|
|
|
203
|
|
|
/** |
|
204
|
|
|
* Record field updates (changed values). |
|
205
|
|
|
* |
|
206
|
|
|
* @var array |
|
207
|
|
|
*/ |
|
208
|
|
|
private $changes = []; |
|
209
|
|
|
|
|
210
|
|
|
/** |
|
211
|
|
|
* Associated relation instances and/or initial loaded data. |
|
212
|
|
|
* |
|
213
|
|
|
* @var array |
|
214
|
|
|
*/ |
|
215
|
|
|
private $relations = []; |
|
216
|
|
|
|
|
217
|
|
|
/** |
|
218
|
|
|
* Parent ORM instance, responsible for relation initialization and lazy loading operations. |
|
219
|
|
|
* |
|
220
|
|
|
* @invisible |
|
221
|
|
|
* @var ORMInterface |
|
222
|
|
|
*/ |
|
223
|
|
|
protected $orm; |
|
224
|
|
|
|
|
225
|
|
|
/** |
|
226
|
|
|
* Initiate entity inside or outside of ORM scope using given fields and state. |
|
227
|
|
|
* |
|
228
|
|
|
* @param array $fields |
|
229
|
|
|
* @param int $state |
|
230
|
|
|
* @param ORMInterface|null $orm |
|
231
|
|
|
* @param array|null $schema |
|
232
|
|
|
*/ |
|
233
|
|
|
public function __construct( |
|
234
|
|
|
array $fields = [], |
|
235
|
|
|
int $state = ORMInterface::STATE_NEW, |
|
236
|
|
|
ORMInterface $orm = null, |
|
237
|
|
|
array $schema = null |
|
238
|
|
|
) {//We can use global container as fallback if no default values were provided |
|
239
|
|
|
$this->orm = $this->saturate($orm, ORMInterface::class); |
|
240
|
|
|
|
|
241
|
|
|
//Use supplied schema or fetch one from ORM |
|
242
|
|
|
$this->recordSchema = !empty($schema) ? $schema : $this->orm->define( |
|
243
|
|
|
static::class, |
|
244
|
|
|
ORMInterface::R_SCHEMA |
|
245
|
|
|
); |
|
246
|
|
|
|
|
247
|
|
|
$this->state = $state; |
|
248
|
|
|
if ($this->state == ORMInterface::STATE_NEW) { |
|
249
|
|
|
//Non loaded records should be in solid state by default |
|
250
|
|
|
$this->solidState(true); |
|
251
|
|
|
} |
|
252
|
|
|
|
|
253
|
|
|
$this->extractRelations($fields); |
|
254
|
|
|
parent::__construct($fields + $this->recordSchema[self::SH_DEFAULTS], $schema); |
|
255
|
|
|
} |
|
256
|
|
|
|
|
257
|
|
|
//todo: think about it |
|
258
|
|
|
public function getState(): int |
|
259
|
|
|
{ |
|
260
|
|
|
return $this->state; |
|
261
|
|
|
} |
|
262
|
|
|
|
|
263
|
|
|
//todo: think about it |
|
264
|
|
|
public function setState(int $state): self |
|
265
|
|
|
{ |
|
266
|
|
|
$this->state = $state; |
|
267
|
|
|
|
|
268
|
|
|
return $this; |
|
269
|
|
|
} |
|
270
|
|
|
|
|
271
|
|
|
/** |
|
272
|
|
|
* {@inheritdoc} |
|
273
|
|
|
*/ |
|
274
|
|
|
public function getField(string $name, $default = null, bool $filter = true) |
|
275
|
|
|
{ |
|
276
|
|
|
if (!$this->hasField($name) && !isset($this->recordSchema[self::SH_RELATIONS][$name])) { |
|
277
|
|
|
throw new FieldException(sprintf( |
|
278
|
|
|
"No such property '%s' in '%s', check schema being relevant", |
|
279
|
|
|
$name, |
|
280
|
|
|
get_called_class() |
|
281
|
|
|
)); |
|
282
|
|
|
} |
|
283
|
|
|
|
|
284
|
|
|
//todo: get relation |
|
285
|
|
|
|
|
286
|
|
|
return parent::getField($name, $default, $filter); |
|
287
|
|
|
} |
|
288
|
|
|
|
|
289
|
|
|
/** |
|
290
|
|
|
* {@inheritdoc} |
|
291
|
|
|
* |
|
292
|
|
|
* Tracks field changes. |
|
293
|
|
|
*/ |
|
294
|
|
|
public function setField(string $name, $value, bool $filter = true) |
|
295
|
|
|
{ |
|
296
|
|
|
//todo: check if relation |
|
297
|
|
|
|
|
298
|
|
|
if (!$this->hasField($name)) { |
|
299
|
|
|
//We are only allowing to modify existed fields, this is strict schema |
|
300
|
|
|
throw new FieldException(sprintf( |
|
301
|
|
|
"No such property '%s' in '%s', check schema being relevant", |
|
302
|
|
|
$name, |
|
303
|
|
|
get_called_class() |
|
304
|
|
|
)); |
|
305
|
|
|
} |
|
306
|
|
|
|
|
307
|
|
|
$this->registerChange($name); |
|
308
|
|
|
|
|
309
|
|
|
parent::setField($name, $value, $filter); |
|
310
|
|
|
} |
|
311
|
|
|
|
|
312
|
|
|
/** |
|
313
|
|
|
* {@inheritdoc} |
|
314
|
|
|
*/ |
|
315
|
|
|
public function __isset($name) |
|
316
|
|
|
{ |
|
317
|
|
|
//todo: if relation |
|
318
|
|
|
|
|
319
|
|
|
return parent::__isset($name); |
|
320
|
|
|
} |
|
321
|
|
|
|
|
322
|
|
|
/** |
|
323
|
|
|
* {@inheritdoc} |
|
324
|
|
|
* |
|
325
|
|
|
* @throws FieldException |
|
326
|
|
|
*/ |
|
327
|
|
|
public function __unset($offset) |
|
328
|
|
|
{ |
|
329
|
|
|
if (!$this->isNullable($offset)) { |
|
330
|
|
|
throw new FieldException("Unable to unset not nullable field '{$offset}'"); |
|
331
|
|
|
} |
|
332
|
|
|
|
|
333
|
|
|
$this->setField($offset, null, false); |
|
334
|
|
|
} |
|
335
|
|
|
|
|
336
|
|
|
/** |
|
337
|
|
|
* {@inheritdoc} |
|
338
|
|
|
* |
|
339
|
|
|
* Method does not check updates in nested relation, but only in primary record. |
|
340
|
|
|
* |
|
341
|
|
|
* @param string $field Check once specific field changes. |
|
342
|
|
|
*/ |
|
343
|
|
|
public function hasUpdates(string $field = null): bool |
|
344
|
|
|
{ |
|
345
|
|
|
//Check updates for specific field |
|
346
|
|
|
if (!empty($field)) { |
|
347
|
|
|
if (array_key_exists($field, $this->changes)) { |
|
348
|
|
|
return true; |
|
349
|
|
|
} |
|
350
|
|
|
|
|
351
|
|
|
//Do not force accessor creation |
|
352
|
|
|
$value = $this->getField($field, null, false); |
|
353
|
|
|
if ($value instanceof SQLAccessorInterface && $value->hasUpdates()) { |
|
354
|
|
|
return true; |
|
355
|
|
|
} |
|
356
|
|
|
|
|
357
|
|
|
return false; |
|
358
|
|
|
} |
|
359
|
|
|
|
|
360
|
|
|
if (!empty($this->changes)) { |
|
361
|
|
|
return true; |
|
362
|
|
|
} |
|
363
|
|
|
|
|
364
|
|
|
//Do not force accessor creation |
|
365
|
|
|
foreach ($this->getFields(false) as $value) { |
|
366
|
|
|
//Checking all fields for changes (handled internally) |
|
367
|
|
|
if ($value instanceof SQLAccessorInterface && $value->hasUpdates()) { |
|
368
|
|
|
return true; |
|
369
|
|
|
} |
|
370
|
|
|
} |
|
371
|
|
|
|
|
372
|
|
|
return false; |
|
373
|
|
|
} |
|
374
|
|
|
|
|
375
|
|
|
/** |
|
376
|
|
|
* @return array |
|
377
|
|
|
*/ |
|
378
|
|
|
public function __debugInfo() |
|
379
|
|
|
{ |
|
380
|
|
|
return [ |
|
381
|
|
|
'database' => $this->orm->define(static::class, ORMInterface::R_DATABASE), |
|
382
|
|
|
'table' => $this->orm->define(static::class, ORMInterface::R_TABLE), |
|
383
|
|
|
'fields' => $this->getFields(), |
|
384
|
|
|
'relations' => $this->relations |
|
385
|
|
|
]; |
|
386
|
|
|
} |
|
387
|
|
|
|
|
388
|
|
|
/** |
|
389
|
|
|
* {@inheritdoc} |
|
390
|
|
|
* |
|
391
|
|
|
* DocumentEntity will pass ODM instance as part of accessor context. |
|
392
|
|
|
* |
|
393
|
|
|
* @see CompositionDefinition |
|
394
|
|
|
*/ |
|
395
|
|
|
protected function createAccessor( |
|
396
|
|
|
$accessor, |
|
397
|
|
|
string $name, |
|
398
|
|
|
$value, |
|
399
|
|
|
array $context = [] |
|
400
|
|
|
): AccessorInterface { |
|
401
|
|
|
//Giving ORM as context |
|
402
|
|
|
return parent::createAccessor($accessor, $name, $value, $context + ['orm' => $this->orm]); |
|
403
|
|
|
} |
|
404
|
|
|
|
|
405
|
|
|
/** |
|
406
|
|
|
* {@inheritdoc} |
|
407
|
|
|
*/ |
|
408
|
|
|
protected function iocContainer() |
|
409
|
|
|
{ |
|
410
|
|
|
if ($this->orm instanceof Component) { |
|
411
|
|
|
//Forwarding IoC scope to parent ORM instance |
|
412
|
|
|
return $this->orm->iocContainer(); |
|
413
|
|
|
} |
|
414
|
|
|
|
|
415
|
|
|
return parent::iocContainer(); |
|
416
|
|
|
} |
|
417
|
|
|
|
|
418
|
|
|
/** |
|
419
|
|
|
* @param string $name |
|
420
|
|
|
*/ |
|
421
|
|
|
private function registerChange(string $name) |
|
422
|
|
|
{ |
|
423
|
|
|
$original = $this->getField($name, null, false); |
|
424
|
|
|
|
|
425
|
|
|
if (!array_key_exists($name, $this->changes)) { |
|
426
|
|
|
//Let's keep track of how field looked before first change |
|
427
|
|
|
$this->changes[$name] = $original instanceof AccessorInterface |
|
428
|
|
|
? $original->packValue() |
|
429
|
|
|
: $original; |
|
430
|
|
|
} |
|
431
|
|
|
} |
|
432
|
|
|
|
|
433
|
|
|
/** |
|
434
|
|
|
* Extract relations data from given entity fields. |
|
435
|
|
|
* |
|
436
|
|
|
* @param array $data |
|
437
|
|
|
*/ |
|
438
|
|
|
private function extractRelations(array &$data) |
|
439
|
|
|
{ |
|
440
|
|
|
//Fetch all relations |
|
441
|
|
|
$relations = array_intersect_key($data, $this->recordSchema[self::SH_RELATIONS]); |
|
442
|
|
|
|
|
443
|
|
|
foreach ($relations as $name => $relation) { |
|
444
|
|
|
$this->relations[$name] = $relation; |
|
445
|
|
|
unset($data[$name]); |
|
446
|
|
|
} |
|
447
|
|
|
} |
|
448
|
|
|
} |