esoko/soko-web
esoko/soko-web
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

implement multi relation loading
All checks were successful
soko-web/pipeline/pr-master This commit looks good
Details

Browse Source
This commit is contained in:
Bence Pőcze 2023-06-17 11:53:46 +02:00
parent 8d490e48aa
commit 91175d8072
Signed by: bence
GPG Key ID: DC5BD6E95A333E6D
3 changed files with 43 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Interfaces/PersistentData/IPersistentDataManager.php
View File

@ -16,6 +16,8 @@ interface IPersistentDataManager
public function loadRelationsFromDb(Model $model, bool $recursive = false, array $withRelations = []): void;
public function loadMultiRelationsFromDb(array $models, string $relation, bool $useRelations = false, array $withRelations = []): void;
public function saveToDb(Model $model): void;
public function deleteFromDb(Model $model): void;

7
src/PersistentData/Model/Model.php
View File

@ -8,6 +8,8 @@ abstract class Model
protected static array $relations = [];
protected static array $multiRelations = [];
protected $id = null;
private array $snapshot = [];
@ -27,6 +29,11 @@ abstract class Model
return static::$relations;
}
public static function getMultiRelations(): array
{
return static::$multiRelations;
}
public function setId($id): void
{
$this->id = $id;

34
src/PersistentData/PersistentDataManager.php
View File

@ -92,6 +92,40 @@ class PersistentDataManager implements IPersistentDataManager
}
}
public function loadMultiRelationsFromDb(array $models, string $relation, bool $useRelations = false, array $withRelations = []): void
{
if (count($models) === 0) {
return;
}
$parentModelType = get_class($models[0]);
$relationModelsSetter = 'set' . str_replace('_', '', ucwords($relation, '_'));
[$relationModelType, $reverseRelation] = call_user_func($parentModelType, 'getMultiRelations')[$relation];
$reverseRelationIdGetter = 'get' . str_replace('_', '', ucwords($reverseRelation, '_')) . 'Id';
$parentModelsById = [];
foreach ($models as $model) {
$parentModelsById[$model->getId()] = $model;
}
$select = new Select($this->dbConnection);
$select->where($reverseRelation . '_id', 'IN', array_keys($parentModelsById));
$relationsByParentModelId = [];
foreach ($this->selectMultipleFromDb($select, $relationModelType, $useRelations, $withRelations) as $relationModel) {
$reverseRelationId = $relationModel->$reverseRelationIdGetter();
if (!isset($relationsByParentModelId[$reverseRelationId])) {
$relationsByParentModelId[$reverseRelationId] = [];
}
$relationsByParentModelId[$reverseRelationId][] = $relationModel;
}
foreach ($parentModelsById as $parentModelId => $parentModel) {
$relationModels = $relationsByParentModelId[$parentModelId] ?? [];
$parentModel->$relationModelsSetter($relationModels);
}
}
public function saveToDb(Model $model): void
{
$this->syncRelations($model);