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

implement multi relation loading

Browse Source
This commit is contained in:
Bence Pőcze 2023-06-17 11:53:46 +02:00
parent 8d490e48aa
commit 8451dead61
Signed by: bence
GPG Key ID: DC5BD6E95A333E6D
3 changed files with 39 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 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 saveToDb(Model $model): void;
public function deleteFromDb(Model $model): void; public function deleteFromDb(Model $model): void;

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

@ -8,6 +8,8 @@ abstract class Model
protected static array $relations = []; protected static array $relations = [];
protected static array $multiRelations = [];
protected $id = null; protected $id = null;
private array $snapshot = []; private array $snapshot = [];

35
src/PersistentData/PersistentDataManager.php
View File

@ -92,6 +92,41 @@ 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 = $parentModelType::$multiRelations[$relation][0];
$reverseRelation = $parentModelType::$multiRelations[$relation][1];
$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 public function saveToDb(Model $model): void
{ {
$this->syncRelations($model); $this->syncRelations($model);