Jingga/phpOMS
1
0
Fork 0
mirror of https://github.com/Karaka-Management/phpOMS.git synced 2026-02-08 21:28:40 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Relations create+formatting

Browse Source
This commit is contained in:
Dennis Eichhorn 2016-02-06 18:20:23 +01:00
parent d44f18963d
commit e02de0b5a4
1 changed files with 57 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

112
DataStorage/Database/DataMapperAbstract.php
View File

@ -235,7 +235,7 @@ abstract class DataMapperAbstract implements DataMapperInterface
* @since 1.0.0 * @since 1.0.0
* @author Dennis Eichhorn <d.eichhorn@oms.com> * @author Dennis Eichhorn <d.eichhorn@oms.com>
*/ */
public function create($obj) public function create($obj, bool $relations = true)
{ {
// todo: create should also have an option to create relations (default = true) // todo: create should also have an option to create relations (default = true)
$query = new Builder($this->db); $query = new Builder($this->db);
@ -278,72 +278,74 @@ abstract class DataMapperAbstract implements DataMapperInterface
$objId = $this->db->con->lastInsertId(); $objId = $this->db->con->lastInsertId();
// handle relations // handle relations
foreach (static::$hasMany as $member => $rel) { if($relations) {
/* is a has many property */ foreach (static::$hasMany as $member => $rel) {
$property = $reflectionClass->getProperty($member); // throws ReflectionException /* is a has many property */
$property = $reflectionClass->getProperty($member); // throws ReflectionException
if (!($isPublic = $property->isPublic())) { if (!($isPublic = $property->isPublic())) {
$property->setAccessible(true); $property->setAccessible(true);
}
$values = $property->getValue($obj);
$temp = reset($values);
$pname = $property->getName(); // todo: isn't this just member? and not necessary?
if (!($isPublic)) {
$property->setAccessible(false);
}
if (is_object($temp)) {
// todo: only create if object doesn't exists... get primaryKey field, then get member name based on this
// now check if id is null or set.
$mapper = static::$hasMany[$pname]['mapper'];
$mapper = new $mapper($this->db);
$objsIds = [];
if (isset(static::$hasMany[$pname]['mapper']) && static::$hasMany[$pname]['mapper'] === static::$hasMany[$pname]['relationmapper']) {
$relReflectionClass = new \ReflectionClass(get_class($temp));
} }
foreach ($values as $key => &$value) { $values = $property->getValue($obj);
// Skip if already in db/has key $temp = reset($values);
$relProperty = $relReflectionClass->getProperty($mapper::$columns[$mapper::$primaryField]['internal']); $pname = $property->getName(); // todo: isn't this just member? and not necessary?
$relProperty->setAccessible(true);
$primaryKey = $relProperty->getValue($value);
$relProperty->setAccessible(false);
if ($primaryKey !== 0 && $primaryKey !== null && $primaryKey !== '') { if (!($isPublic)) {
continue; $property->setAccessible(false);
} }
if (is_object($temp)) {
// todo: only create if object doesn't exists... get primaryKey field, then get member name based on this
// now check if id is null or set.
$mapper = static::$hasMany[$pname]['mapper'];
$mapper = new $mapper($this->db);
$objsIds = [];
// Setting relation value for relation (since the relation is not stored in an extra relation table)
if (isset(static::$hasMany[$pname]['mapper']) && static::$hasMany[$pname]['mapper'] === static::$hasMany[$pname]['relationmapper']) { if (isset(static::$hasMany[$pname]['mapper']) && static::$hasMany[$pname]['mapper'] === static::$hasMany[$pname]['relationmapper']) {
$relProperty = $relReflectionClass->getProperty($mapper::$columns[static::$hasMany[$pname]['dst']]['internal']); $relReflectionClass = new \ReflectionClass(get_class($temp));
$relProperty->setAccessible(true);
$relProperty->setValue($value, $objId);
$relProperty->setAccessible(false);
} }
$objsIds[$key] = $mapper->create($value); foreach ($values as $key => &$value) {
} // Skip if already in db/has key
} elseif (is_scalar($temp)) { $relProperty = $relReflectionClass->getProperty($mapper::$columns[$mapper::$primaryField]['internal']);
$objsIds = $values; $relProperty->setAccessible(true);
} else { $primaryKey = $relProperty->getValue($value);
throw new \Exception('Unexpected value for relational data mapping.'); $relProperty->setAccessible(false);
}
if (isset(static::$hasMany[$pname]['mapper']) && static::$hasMany[$pname]['mapper'] !== static::$hasMany[$pname]['relationmapper']) { if ($primaryKey !== 0 && $primaryKey !== null && $primaryKey !== '') {
/* is many->many */ continue;
$relQuery = new Builder($this->db); }
$relQuery->prefix($this->db->getPrefix())
->into(static::$hasMany[$pname]['table'])
->insert(static::$hasMany[$pname]['src'], static::$hasMany[$pname]['dst']);
foreach ($objsIds as $key => $src) { // Setting relation value for relation (since the relation is not stored in an extra relation table)
$relQuery->values($src, $objId); if (isset(static::$hasMany[$pname]['mapper']) && static::$hasMany[$pname]['mapper'] === static::$hasMany[$pname]['relationmapper']) {
$relProperty = $relReflectionClass->getProperty($mapper::$columns[static::$hasMany[$pname]['dst']]['internal']);
$relProperty->setAccessible(true);
$relProperty->setValue($value, $objId);
$relProperty->setAccessible(false);
}
$objsIds[$key] = $mapper->create($value);
}
} elseif (is_scalar($temp)) {
$objsIds = $values;
} else {
throw new \Exception('Unexpected value for relational data mapping.');
} }
$this->db->con->prepare($relQuery->toSql())->execute(); if (isset(static::$hasMany[$pname]['mapper']) && static::$hasMany[$pname]['mapper'] !== static::$hasMany[$pname]['relationmapper']) {
/* is many->many */
$relQuery = new Builder($this->db);
$relQuery->prefix($this->db->getPrefix())
->into(static::$hasMany[$pname]['table'])
->insert(static::$hasMany[$pname]['src'], static::$hasMany[$pname]['dst']);
foreach ($objsIds as $key => $src) {
$relQuery->values($src, $objId);
}
$this->db->con->prepare($relQuery->toSql())->execute();
}
} }
} }