public/rmphp-storage
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: public:4.0
Branches Tags
public:12.x public:11.x public:10.x public:9.x public:8.x public:7.x public:6.x public:5.x public:4.x public:3.x public:2.x public:1.x
public:12.0 public:11.0.1 public:11.0 public:10.1 public:10.0 public:9.1 public:9.0 public:8.0 public:7.1 public:7.0 public:6.0 public:5.1 public:5.0 public:4.1 public:4.0 public:3.1 public:3.0 public:2.0 public:1.0.1 public:1.0
..
compare: public:4.x
Branches Tags
public:12.x public:11.x public:10.x public:9.x public:8.x public:7.x public:6.x public:5.x public:4.x public:3.x public:2.x public:1.x
public:12.0 public:11.0.1 public:11.0 public:10.1 public:10.0 public:9.1 public:9.0 public:8.0 public:7.1 public:7.0 public:6.0 public:5.1 public:5.0 public:4.1 public:4.0 public:3.1 public:3.0 public:2.0 public:1.0.1 public:1.0

1 Commits
4.0 ... 4.x

Author SHA1 Message Date
User
2cfc92584c 20250126#2 2025-01-26 14:56:59 +03:00
2 changed files with 14 additions and 27 deletions
Expand all files Collapse all files

32
src/AbstractMysqlRepository.php
View File

@@ -51,21 +51,18 @@ abstract class AbstractMysqlRepository extends AbstractRepository implements Mys
/** @inheritDoc */
public function saveEntity(EntityInterface $object, string $table = null) : mixed {
if(!isset($table)){
$this->checkConst();
$table = static::TABLE;
}
public function saveEntity(EntityInterface $object) : mixed {
$this->checkConst();
$in = $this->getProperties($object, function ($value){
return (is_string($value)) ? $this->mysql->escapeStr($value) : $value;
});
if(static::DEBUG) {$this->getSaveDebug($object, $in, $table); exit;}
if(static::DEBUG) {$this->getSaveDebug($object, $in, static::TABLE); exit;}
try {
if (!empty($object->getId()) && !empty($this->mysql->findById($table, $object->getId()))) {
$this->mysql->updateById($table, $in, $object->getId());
if (!empty($object->getId()) && !empty($this->mysql->findById(static::TABLE, $object->getId()))) {
$this->mysql->updateById(static::TABLE, $in, $object->getId());
return $object->getId();
} else {
$this->mysql->insert($table, $in);
$this->mysql->insert(static::TABLE, $in);
return (is_string($object->getId())) ? $object->getId() : $this->mysql->mysql()->insert_id;
}
} catch (\Throwable $throwable) {throw new RepositoryException($throwable->getMessage());}
@@ -73,14 +70,10 @@ abstract class AbstractMysqlRepository extends AbstractRepository implements Mys
/** @inheritDoc */
public function saveGroup(array $objects, string $table = null): array {
if(!isset($table)){
$this->checkConst();
$table = static::TABLE;
}
public function saveGroup(array $objects): array {
try{
$this->mysql->mysql()->begin_transaction();
foreach($objects as $object) $id[] = $this->saveEntity($object, $table);
foreach($objects as $object) $id[] = $this->saveEntity($object);
$this->mysql->mysql()->commit();
return $id ?? [];
}
@@ -92,13 +85,10 @@ abstract class AbstractMysqlRepository extends AbstractRepository implements Mys
/** @inheritDoc */
public function deleteEntity(EntityInterface $object, string $table = null) : bool {
if(!isset($table)){
$this->checkConst();
$table = static::TABLE;
}
public function deleteEntity(EntityInterface $object) : bool {
$this->checkConst();
if(!empty($object->getId())){
return $this->mysql->deleteById($table, $object->getId());
return $this->mysql->deleteById(static::TABLE, $object->getId());
}
return false;
}

9
src/Mysql/MysqlRepositoryInterface.php
View File

@@ -39,27 +39,24 @@ interface MysqlRepositoryInterface extends RepositoryInterface {
/**
* @param EntityInterface $object
* @param string|null $table
* @return mixed
* @throws RepositoryException
*/
public function saveEntity(EntityInterface $object, string $table = null) : mixed;
public function saveEntity(EntityInterface $object) : mixed;
/**
* @param array $objects
* @param string|null $table
* @return array
* @throws RepositoryException
*/
public function saveGroup(array $objects, string $table = null): array;
public function saveGroup(array $objects): array;
/**
* @param EntityInterface $object
* @param string|null $table
* @return bool
* @throws RepositoryException
*/
public function deleteEntity(EntityInterface $object, string $table = null) : bool;
public function deleteEntity(EntityInterface $object) : bool;
/**
* @return array