Jingga/phpOMS
1
0
Fork 0
mirror of https://github.com/Karaka-Management/phpOMS.git synced 2026-02-05 20:18:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Draft conditional data

Browse Source
This commit is contained in:
Dennis Eichhorn 2019-09-03 14:49:42 +02:00 committed by GitHub
parent c8ec18f912
commit bb1aa4044a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 98 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

129
DataStorage/Database/DataMapperAbstract.php
View File

@ -82,6 +82,16 @@ class DataMapperAbstract implements DataMapperInterface
*/ */
protected static array $columns = []; protected static array $columns = [];
/**
* Conditional.
*
* Most often used for localizations
*
* @var array<string, array<string, string>>
* @since 1.0.0
*/
protected static array $conditionals = [];
/** /**
* Has many relation. * Has many relation.
* *
@ -361,6 +371,7 @@ class DataMapperAbstract implements DataMapperInterface
if ($relations === RelationType::ALL) { if ($relations === RelationType::ALL) {
self::createHasMany($refClass, $obj, $objId); self::createHasMany($refClass, $obj, $objId);
self::createConditionals($refClass, $obj, $objId);
} }
return $objId; return $objId;
@ -390,6 +401,7 @@ class DataMapperAbstract implements DataMapperInterface
if ($relations === RelationType::ALL) { if ($relations === RelationType::ALL) {
self::createHasManyArray($obj, $objId); self::createHasManyArray($obj, $objId);
self::createConditionalsArray($refClass, $obj, $objId);
} }
return $objId; return $objId;
@ -1401,6 +1413,7 @@ class DataMapperAbstract implements DataMapperInterface
if ($relations === RelationType::ALL) { if ($relations === RelationType::ALL) {
self::updateHasMany($refClass, $obj, $objId, --$depth); self::updateHasMany($refClass, $obj, $objId, --$depth);
self::updateConditionals($refClass, $obj, $objId);
} }
if (empty($objId)) { if (empty($objId)) {
@ -1447,6 +1460,7 @@ class DataMapperAbstract implements DataMapperInterface
if ($relations === RelationType::ALL) { if ($relations === RelationType::ALL) {
self::updateHasManyArray($obj, $objId, --$depth); self::updateHasManyArray($obj, $objId, --$depth);
self::updateConditionalsArray($refClass, $obj, $objId);
} }
if ($update) { if ($update) {
@ -1662,6 +1676,7 @@ class DataMapperAbstract implements DataMapperInterface
if ($relations !== RelationType::NONE) { if ($relations !== RelationType::NONE) {
self::deleteHasMany($refClass, $obj, $objId, $relations); self::deleteHasMany($refClass, $obj, $objId, $relations);
self::deleteConditionals($refClass, $obj, $objId);
} }
self::deleteModel($obj, $objId, $relations, $refClass); self::deleteModel($obj, $objId, $relations, $refClass);
@ -1669,6 +1684,8 @@ class DataMapperAbstract implements DataMapperInterface
return $objId; return $objId;
} }
// @todo: implement todo delete
/** /**
* Populate data. * Populate data.
* *
@ -1708,9 +1725,9 @@ class DataMapperAbstract implements DataMapperInterface
foreach ($result as $element) { foreach ($result as $element) {
if (isset($element[static::$primaryField])) { if (isset($element[static::$primaryField])) {
$row[$element[static::$primaryField]] = self::populateAbstractArray($element); $row[$element[static::$primaryField]] = self::populateAbstractArray($element, [], static::$columns);
} else { } else {
$row[] = self::populateAbstractArray($element); $row[] = self::populateAbstractArray($element, [], static::$columns);
} }
} }
@ -1745,7 +1762,7 @@ class DataMapperAbstract implements DataMapperInterface
$obj = new $class(); $obj = new $class();
} }
return self::populateAbstract($result, $obj); return self::populateAbstract($result, $obj, static::$columns);
} }
/** /**
@ -1853,6 +1870,39 @@ class DataMapperAbstract implements DataMapperInterface
} }
} }
/**
* Populate data.
*
* @param mixed $obj Object to add the relations to
*
* @return void
*
* @todo accept reflection class as parameter
*
* @since 1.0.0
*/
public static function getConditionals($key, string $table) : array
{
$query = new Builder(self::$db);
$query->prefix(self::$db->getPrefix())
->select(...static::$conditionals[$table]['values'])
->from($table)
->where(static::$conditionals[$table]['dest'], '=', $key);
foreach (static::$conditionals[$table]['filter'] as $column => $filter) {
if ($filter !== null) {
$query->where($column, '=', $filter);
}
}
$sth = self::$db->con->prepare($query->toSql());
$sth->execute();
$results = $sth->fetch(\PDO::FETCH_ASSOC);
return $results === false ? [] : $results;
}
/** /**
* Populate data. * Populate data.
* *
@ -1958,12 +2008,12 @@ class DataMapperAbstract implements DataMapperInterface
* *
* @since 1.0.0 * @since 1.0.0
*/ */
public static function populateAbstract(array $result, $obj) public static function populateAbstract(array $result, $obj, array $columns)
{ {
$refClass = new \ReflectionClass($obj); $refClass = new \ReflectionClass($obj);
foreach ($result as $column => $value) { foreach ($result as $column => $value) {
if (!isset(static::$columns[$column]['internal']) /* && $refClass->hasProperty(static::$columns[$column]['internal']) */) { if (!isset($columns[$column]['internal']) /* && $refClass->hasProperty($columns[$column]['internal']) */) {
continue; continue;
} }
@ -1971,9 +2021,9 @@ class DataMapperAbstract implements DataMapperInterface
$aValue = []; $aValue = [];
$arrayPath = ''; $arrayPath = '';
if (\stripos(static::$columns[$column]['internal'], '/') !== false) { if (\stripos($columns[$column]['internal'], '/') !== false) {
$hasPath = true; $hasPath = true;
$path = \explode('/', static::$columns[$column]['internal']); $path = \explode('/', $columns[$column]['internal']);
$refProp = $refClass->getProperty($path[0]); $refProp = $refClass->getProperty($path[0]);
if (!($accessible = $refProp->isPublic())) { if (!($accessible = $refProp->isPublic())) {
@ -1984,17 +2034,17 @@ class DataMapperAbstract implements DataMapperInterface
$arrayPath = \implode('/', $path); $arrayPath = \implode('/', $path);
$aValue = $refProp->getValue($obj); $aValue = $refProp->getValue($obj);
} else { } else {
$refProp = $refClass->getProperty(static::$columns[$column]['internal']); $refProp = $refClass->getProperty($columns[$column]['internal']);
if (!($accessible = $refProp->isPublic())) { if (!($accessible = $refProp->isPublic())) {
$refProp->setAccessible(true); $refProp->setAccessible(true);
} }
} }
if (\in_array(static::$columns[$column]['type'], ['string', 'int', 'float', 'bool'])) { if (\in_array($columns[$column]['type'], ['string', 'int', 'float', 'bool'])) {
// todo: what is this or condition for? seems to be wrong if obj null then it doesn't work anyways // todo: what is this or condition for? seems to be wrong if obj null then it doesn't work anyways
if ($value !== null || $refProp->getValue($obj) !== null) { if ($value !== null || $refProp->getValue($obj) !== null) {
\settype($value, static::$columns[$column]['type']); \settype($value, $columns[$column]['type']);
} }
if ($hasPath) { if ($hasPath) {
@ -2002,24 +2052,24 @@ class DataMapperAbstract implements DataMapperInterface
} }
$refProp->setValue($obj, $value); $refProp->setValue($obj, $value);
} elseif (static::$columns[$column]['type'] === 'DateTime') { } elseif ($columns[$column]['type'] === 'DateTime') {
$value = $value === null ? null : new \DateTime($value); $value = $value === null ? null : new \DateTime($value);
if ($hasPath) { if ($hasPath) {
$value = ArrayUtils::setArray($arrayPath, $aValue, $value, '/', true); $value = ArrayUtils::setArray($arrayPath, $aValue, $value, '/', true);
} }
$refProp->setValue($obj, $value); $refProp->setValue($obj, $value);
} elseif (static::$columns[$column]['type'] === 'Json') { } elseif ($columns[$column]['type'] === 'Json') {
if ($hasPath) { if ($hasPath) {
$value = ArrayUtils::setArray($arrayPath, $aValue, $value, '/', true); $value = ArrayUtils::setArray($arrayPath, $aValue, $value, '/', true);
} }
$refProp->setValue($obj, \json_decode($value, true)); $refProp->setValue($obj, \json_decode($value, true));
} elseif (static::$columns[$column]['type'] === 'Serializable') { } elseif ($columns[$column]['type'] === 'Serializable') {
$member = $refProp->getValue($obj); $member = $refProp->getValue($obj);
$member->unserialize($value); $member->unserialize($value);
} else { } else {
throw new \UnexpectedValueException('Value "' . static::$columns[$column]['type'] . '" is not supported.'); throw new \UnexpectedValueException('Value "' . $columns[$column]['type'] . '" is not supported.');
} }
if (!$accessible) { if (!$accessible) {
@ -2039,12 +2089,11 @@ class DataMapperAbstract implements DataMapperInterface
* *
* @since 1.0.0 * @since 1.0.0
*/ */
public static function populateAbstractArray(array $result) : array public static function populateAbstractArray(array $result, array $obj, array $columns) : array
{ {
$obj = [];
foreach ($result as $column => $value) { foreach ($result as $column => $value) {
if (isset(static::$columns[$column]['internal'])) { if (isset($columns[$column]['internal'])) {
$path = static::$columns[$column]['internal']; $path = $columns[$column]['internal'];
if (\stripos($path, '/') !== false) { if (\stripos($path, '/') !== false) {
$path = \explode('/', $path); $path = \explode('/', $path);
@ -2052,11 +2101,11 @@ class DataMapperAbstract implements DataMapperInterface
$path = \implode('/', $path); $path = \implode('/', $path);
} }
if (\in_array(static::$columns[$column]['type'], ['string', 'int', 'float', 'bool'])) { if (\in_array($columns[$column]['type'], ['string', 'int', 'float', 'bool'])) {
\settype($value, static::$columns[$column]['type']); \settype($value, $columns[$column]['type']);
} elseif (static::$columns[$column]['type'] === 'DateTime') { } elseif ($columns[$column]['type'] === 'DateTime') {
$value = $value === null ? null : new \DateTime($value); $value = $value === null ? null : new \DateTime($value);
} elseif (static::$columns[$column]['type'] === 'Json') { } elseif ($columns[$column]['type'] === 'Json') {
$value = \json_decode($value, true); $value = \json_decode($value, true);
} }
@ -2184,7 +2233,7 @@ class DataMapperAbstract implements DataMapperInterface
continue; continue;
} }
$obj[$value] = self::populateAbstractArray(self::getRaw($value)); $obj[$value] = self::populateAbstractArray(self::getRaw($value), [], static::$columns);
self::addInitializedArray(static::class, $value, $obj[$value]); self::addInitializedArray(static::class, $value, $obj[$value]);
} }
@ -2492,11 +2541,12 @@ class DataMapperAbstract implements DataMapperInterface
return; return;
} }
$hasMany = !empty(static::$hasMany); $hasMany = !empty(static::$hasMany);
$ownsOne = !empty(static::$ownsOne); $ownsOne = !empty(static::$ownsOne);
$belongsTo = !empty(static::$belongsTo); $belongsTo = !empty(static::$belongsTo);
$hasConditionals = !empty(static::$conditionals);
if (!($hasMany || $ownsOne || $belongsTo)) { if (!($hasMany || $ownsOne || $belongsTo || $hasConditionals)) {
return; return;
} }
@ -2513,6 +2563,12 @@ class DataMapperAbstract implements DataMapperInterface
if ($belongsTo) { if ($belongsTo) {
self::populateBelongsTo($obj[$key], $depth); self::populateBelongsTo($obj[$key], $depth);
} }
if ($hasConditionals) {
foreach (static::$conditionals as $table => $conditional) {
$obj[$key] = self::populateAbstract(self::getConditionals($key, $table), $obj[$key], $conditional['values']);
}
}
} }
} }
@ -2537,14 +2593,19 @@ class DataMapperAbstract implements DataMapperInterface
return; return;
} }
$hasMany = !empty(static::$hasMany); $hasMany = !empty(static::$hasMany);
$ownsOne = !empty(static::$ownsOne); $ownsOne = !empty(static::$ownsOne);
$belongsTo = !empty(static::$belongsTo); $belongsTo = !empty(static::$belongsTo);
$hasConditionals = !empty(static::$conditionals);
if (!($hasMany || $ownsOne || $belongsTo)) { if (!($hasMany || $ownsOne || $belongsTo || $hasConditionals)) {
return; return;
} }
if ($conditionals) {
self::populateConditionalsArray();
}
foreach ($obj as $key => $value) { foreach ($obj as $key => $value) {
/* loading relations from relations table and populating them and then adding them to the object */ /* loading relations from relations table and populating them and then adding them to the object */
if ($hasMany) { if ($hasMany) {
@ -2558,6 +2619,12 @@ class DataMapperAbstract implements DataMapperInterface
if ($belongsTo) { if ($belongsTo) {
self::populateBelongsToArray($obj[$key], $depth); self::populateBelongsToArray($obj[$key], $depth);
} }
if ($hasConditionals) {
foreach (static::$conditionals as $table => $conditional) {
$obj[$key] = self::populateAbstractArray(self::getConditionals($key, $table), $obj[$key], $conditional['values']);
}
}
} }
} }