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

20250622#1

Browse Source
This commit is contained in:
User
2025-06-22 01:05:12 +03:00
parent 35026bb223
commit f42bc7751a
20 changed files with 10 additions and 427 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
composer.json
View File

@@ -9,6 +9,7 @@
],
"require": {
"php": "^8.1",
"rmphp/odm": "^1.0",
"ext-mysqli": "*"
},
"autoload": {

6
src/AbstractMysqlRepository.php
View File

@@ -2,12 +2,12 @@
namespace Rmphp\Storage;
use Rmphp\Storage\Entity\EntityInterface;
use Rmphp\Storage\Exception\RepositoryException;
use Rmphp\ODM\AbstractRepository;
use Rmphp\Storage\Mysql\MysqlRepositoryInterface;
use Rmphp\Storage\Mysql\MysqlResultData;
use Rmphp\Storage\Mysql\MysqlStorageInterface;
use Rmphp\Storage\Repository\AbstractRepository;
use Rmphp\Storage\Repository\EntityInterface;
use Rmphp\Storage\Repository\RepositoryException;
abstract class AbstractMysqlRepository extends AbstractRepository implements MysqlRepositoryInterface {

14
src/Attribute/Data.php
View File

@@ -1,14 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_CLASS)]
class Data {
public function __construct(
public bool $ignorEmpty = false,
) {}
}

8
src/Attribute/DataIgnorEmpty.php
View File

@@ -1,8 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_CLASS)]
class DataIgnorEmpty {}

14
src/Attribute/Entity.php
View File

@@ -1,14 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_CLASS)]
class Entity {
public function __construct(
public bool $noReturnIfNull = false,
) {}
}

8
src/Attribute/EntityNoReturnIfNull.php
View File

@@ -1,8 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_CLASS)]
class EntityNoReturnIfNull {}

16
src/Attribute/Property.php
View File

@@ -1,16 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_PROPERTY)]
class Property {
public function __construct(
public ?string $keyName = null,
public bool $noReturn = false,
public bool $noReturnIfNull = false,
) {}
}

8
src/Attribute/PropertyNoReturn.php
View File

@@ -1,8 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_PROPERTY)]
class PropertyNoReturn {}

8
src/Attribute/PropertyNoReturnIfNull.php
View File

@@ -1,8 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_PROPERTY)]
class PropertyNoReturnIfNull {}

15
src/Attribute/ValueObject.php
View File

@@ -1,15 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_CLASS)]
class ValueObject {
public function __construct(
public ?string $propertyName = null,
public bool $firstProperty = false
) {}
}

8
src/Attribute/ValueObjectFirstProperty.php
View File

@@ -1,8 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_CLASS)]
class ValueObjectFirstProperty {}

14
src/Attribute/ValueObjectPropertyName.php
View File

@@ -1,14 +0,0 @@
<?php
namespace Rmphp\Storage\Attribute;
use Attribute;
#[Attribute(Attribute::TARGET_CLASS)]
class ValueObjectPropertyName {
public function __construct(
public ?string $name = null,
) {}
}

134
src/Component/AbstractDataObject.php
View File

@@ -1,134 +0,0 @@
<?php
namespace Rmphp\Storage\Component;
use Exception;
use ReflectionClass;
use ReflectionException;
use Rmphp\Storage\Attribute\Data;
use Rmphp\Storage\Attribute\DataIgnorEmpty;
abstract class AbstractDataObject {
private static array $stack = [];
protected static array $constructorEmptyAvailableClasses = [];
protected static array $classes = [];
protected static array $attributeObjects = [];
/**
* @param ReflectionClass $class
* @param object $object
* @param array $data
* @param bool $update
* @param bool $withEmpty
* @return mixed
* @throws Exception
*/
protected static function fillObject(ReflectionClass $class, object $object, array $data, bool $update = false, bool $withEmpty = true) : mixed {
try {
if(!isset(self::$attributeObjects[$class->getName()][0])){
self::$attributeObjects[$class->getName()][0] = !empty($class->getAttributes(Data::class))
? $class->getAttributes(Data::class)[0]->newInstance()
: new Data();
}
/** @var Data $dataAttributes */
$dataAttributes = self::$attributeObjects[$class->getName()][0];
if(!empty($class->getAttributes(DataIgnorEmpty::class))) $dataAttributes->ignorEmpty = true;
$value = [];
foreach($class->getProperties() as $property){
$prop[$property->getName()] = ($property->hasType()) ? $property->getType()->getName() : "";
// значение в массиве по ключю с именем свойства
if(array_key_exists($property->getName(), $data)){
$value[$property->getName()] = $data[$property->getName()];
}
// значение в массиве по ключю с именем свойства в snake case
elseif(array_key_exists(strtolower(preg_replace("'([A-Z])'", "_$1", $property->getName())), $data)){
$value[$property->getName()] = $data[strtolower(preg_replace("'([A-Z])'", "_$1", $property->getName()))];
}
elseif($update) {
continue;
}
// если есть внутренний метод (приоритетная обработка)
if($class->hasMethod('set'.ucfirst($property->getName()))) {
$object->{'set'.ucfirst($property->getName())}($value[$property->getName()] ?? null);
$case[$property->getName()] = 'Method set'.ucfirst($property->getName());
}
// Если тип свойства класс (valueObject)
elseif($property->hasType() && class_exists($property->getType()->getName())) {
// значение объект
if(isset($value[$property->getName()]) && is_object($value[$property->getName()])){
$object->{$property->getName()} = $value[$property->getName()];
$case[$property->getName()] = 'VO: Object';
}
// значение не пустое
elseif(isset($value[$property->getName()]) && $value[$property->getName()] !== ""){
$object->{$property->getName()} = new ($property->getType()->getName())($value[$property->getName()]);
$case[$property->getName()] = 'VO: NewInstance';
}
// Значения нет и VO может быть без параметров
elseif(($withEmpty && empty($dataAttributes->ignorEmpty)) && self::isEmptyAvailable($property->getType()->getName())) {
$object->{$property->getName()} = new ($property->getType()->getName())();
$case[$property->getName()] = 'VO: Without params';
}
}
// Базовые типы при наличии значения
elseif(array_key_exists($property->getName(), $value)){
if(!$property->hasType()){
$object->{$property->getName()} = $value[$property->getName()];
$case[$property->getName()] = 'Base: Hasn`t type';
}
elseif(in_array($property->getType()->getName(), ['float', 'int'])){
if(is_numeric($value[$property->getName()])) $object->{$property->getName()} = $value[$property->getName()];
$case[$property->getName()] = 'Base: Number';
}
elseif($property->getType()->getName() == 'bool'){
$object->{$property->getName()} = (bool)$value[$property->getName()];
$case[$property->getName()] = 'Base: Boolean';
}
elseif(isset($value[$property->getName()])){
$object->{$property->getName()} = $value[$property->getName()];
$case[$property->getName()] = 'Base: NotNull';
}
elseif($property->getType()->allowsNull()){
$object->{$property->getName()} = $value[$property->getName()];
$case[$property->getName()] = 'Base: Null';
}
}
}
self::$stack[$object::class." #".spl_object_id($object)]['properties'] = $prop ?? [];
self::$stack[$object::class." #".spl_object_id($object)]['values'] = $value;
self::$stack[$object::class." #".spl_object_id($object)]['matchCase'] = $case ?? [];
self::$stack[$object::class." #".spl_object_id($object)]['object'] = $object;
return $object;
}
catch (ReflectionException $exception) {
throw new Exception($exception->getMessage());
}
}
/**
* @throws ReflectionException
*/
private static function isEmptyAvailable(string $class) : bool {
if(isset(self::$constructorEmptyAvailableClasses[$class])) return self::$constructorEmptyAvailableClasses[$class];
if(!$constructor = (new \ReflectionClass($class))->getConstructor()) return self::$constructorEmptyAvailableClasses[$class] = false;
foreach($constructor->getParameters() as $param){
if(!$param->isDefaultValueAvailable()){
return self::$constructorEmptyAvailableClasses[$class] = false;
}
}
return self::$constructorEmptyAvailableClasses[$class] = true;
}
/**
* @return array
*/
protected function getFillObjectStack() : array {
return self::$stack;
}
}

4
src/Mysql/MysqlRepositoryInterface.php
View File

@@ -8,8 +8,8 @@
namespace Rmphp\Storage\Mysql;
use Rmphp\Storage\Entity\EntityInterface;
use Rmphp\Storage\Exception\RepositoryException;
use Rmphp\Storage\Repository\EntityInterface;
use Rmphp\Storage\Repository\RepositoryException;
use Rmphp\Storage\Repository\RepositoryInterface;
interface MysqlRepositoryInterface extends RepositoryInterface {

2
src/Entity/AbstractEntity.php → src/Repository/AbstractEntity.php
View File

@@ -1,6 +1,6 @@
<?php
namespace Rmphp\Storage\Entity;
namespace Rmphp\Storage\Repository;
abstract class AbstractEntity implements EntityInterface {

169
src/Repository/AbstractRepository.php
View File

@@ -1,169 +0,0 @@
<?php
namespace Rmphp\Storage\Repository;
use Exception;
use ReflectionClass;
use Rmphp\Storage\Attribute\Entity;
use Rmphp\Storage\Attribute\EntityNoReturnIfNull;
use Rmphp\Storage\Attribute\Property;
use Rmphp\Storage\Attribute\PropertyNoReturn;
use Rmphp\Storage\Attribute\PropertyNoReturnIfNull;
use Rmphp\Storage\Attribute\ValueObject;
use Rmphp\Storage\Attribute\ValueObjectFirstProperty;
use Rmphp\Storage\Attribute\ValueObjectPropertyName;
use Rmphp\Storage\Component\AbstractDataObject;
use Rmphp\Storage\Exception\RepositoryException;
abstract class AbstractRepository extends AbstractDataObject implements RepositoryInterface {
/** @inheritDoc */
public function getProperties(object $object, callable $method = null) : array {
try{
$class = get_class($object);
if(!isset(self::$classes[$class])) self::$classes[$class] = new ReflectionClass($class);
if(!isset(self::$attributeObjects[$class][0])){
self::$attributeObjects[$class][0] = !empty(self::$classes[$class]->getAttributes(Entity::class))
? self::$classes[$class]->getAttributes(Entity::class)[0]->newInstance()
: new Entity();
}
/** @var Entity $entityAttributes */
$entityAttributes = self::$attributeObjects[$class][0];
if(!empty(self::$classes[$class]->getAttributes(EntityNoReturnIfNull::class))) $entityAttributes->noReturnIfNull = true;
$fieldValue = [];
foreach(self::$classes[$class]->getProperties() as $property){
if(!isset(self::$attributeObjects[$class][$property->getName()])){
self::$attributeObjects[$class][$property->getName()] = !empty($property->getAttributes(Property::class))
? $property->getAttributes(Property::class)[0]->newInstance()
: new Property();
}
/** @var Property $propertyAttributes */
$propertyAttributes = self::$attributeObjects[$class][$property->getName()];
if(!empty($property->getAttributes(PropertyNoReturnIfNull::class))) $propertyAttributes->noReturnIfNull = true;
if(!empty($property->getAttributes(PropertyNoReturn::class)) || !empty($propertyAttributes->noReturn)) continue;
if($property->isInitialized($object)) {
if(is_array($property->getValue($object))) continue;
if(self::$classes[$class]->hasMethod('get'.ucfirst($property->getName()))){
$fieldValue[$property->getName()] = $object->{'get'.ucfirst($property->getName())}($property->getValue($object));
}
elseif($property->hasType() && class_exists($property->getType()->getName())){
$valueObjectClass = get_class($property->getValue($object));
if(!isset(self::$classes[$valueObjectClass])) self::$classes[$valueObjectClass] = new ReflectionClass($valueObjectClass);
if(!isset(self::$attributeObjects[$valueObjectClass])){
self::$attributeObjects[$valueObjectClass] = !empty(self::$classes[$valueObjectClass]->getAttributes(ValueObject::class))
? self::$classes[$valueObjectClass]->getAttributes(ValueObject::class)[0]->newInstance()
: new ValueObject();
if(!empty(self::$classes[$valueObjectClass]->getAttributes(ValueObjectFirstProperty::class))) {
self::$attributeObjects[$valueObjectClass]->firstProperty = true;
}
if(!empty(self::$classes[$valueObjectClass]->getAttributes(ValueObjectPropertyName::class))) {
$propertyName = self::$classes[$valueObjectClass]->getAttributes(ValueObjectPropertyName::class)[0]->newInstance();
if(isset($propertyName->name)) self::$attributeObjects[$valueObjectClass]->propertyName = $propertyName->name;
}
}
$valueObjectAttributes = self::$attributeObjects[$valueObjectClass];
if(!empty($valueObjectAttributes->propertyName) && self::$classes[$valueObjectClass]->hasProperty($valueObjectAttributes->propertyName)){
if(self::$classes[$valueObjectClass]->getProperty($valueObjectAttributes->propertyName)->isInitialized($property->getValue($object))){
$fieldValue[$property->getName()] = self::$classes[$valueObjectClass]->getProperty($valueObjectAttributes->propertyName)->getValue($property->getValue($object));
}
}
elseif(!empty($valueObjectAttributes->firstProperty) && count(self::$classes[$valueObjectClass]->getProperties()) > 0){
if(self::$classes[$valueObjectClass]->getProperties()[0]->isInitialized($property->getValue($object))){
$fieldValue[$property->getName()] = self::$classes[$valueObjectClass]->getProperties()[0]->getValue($property->getValue($object));
}
}
elseif(self::$classes[$valueObjectClass]->hasMethod('getValue')){
$fieldValue[$property->getName()] = $property->getValue($object)->getValue();
}
}
elseif(is_bool($property->getValue($object))){
$fieldValue[$property->getName()] = (int)$property->getValue($object);
}
else{
$fieldValue[$property->getName()] = $property->getValue($object);
}
if(!isset($fieldValue[$property->getName()]) && (!empty($propertyAttributes->noReturnIfNull) || !empty($entityAttributes->noReturnIfNull))) continue;
if(array_key_exists($property->getName(), $fieldValue) && false !== $fieldValue[$property->getName()]) {
$columnName = !empty($propertyAttributes->keyName) ? $propertyAttributes->keyName : strtolower(preg_replace("'([A-Z])'", "_$1", $property->getName()));
$out[$columnName] = $fieldValue[$property->getName()];
}
}
}
return (isset($method)) ? array_map($method, $out ?? []) : $out ?? [];
}
catch (\ReflectionException $exception) {
throw new RepositoryException($exception->getMessage());
}
}
/**
* @inheritDoc
* @throws RepositoryException
*/
public function createFromData(string $class, array|object $data, bool $withEmpty = true) : object {
try {
if(!isset(self::$classes[$class])) self::$classes[$class] = new ReflectionClass($class);
return self::fillObject(self::$classes[$class], new $class, (is_object($data)) ? get_object_vars($data) : $data, false, $withEmpty);
}
catch (Exception $exception) {
throw new RepositoryException($exception->getMessage());
}
}
/**
* @inheritDoc
* @throws RepositoryException
*/
public function updateFromData(object $object, array|object $data, bool $withEmpty = true) : object {
try {
$class = get_class($object);
if(!isset(self::$classes[$class])) self::$classes[$class] = new ReflectionClass($class);
return self::fillObject(self::$classes[$class], clone $object, (is_object($data)) ? get_object_vars($data) : $data, true, $withEmpty);
}
catch (Exception $exception) {
throw new RepositoryException($exception->getMessage());
}
}
/**
* @return array
*/
public function getRepositoryStack() : array {
return $this->getFillObjectStack();
}
/**
* @return array
*/
public function getClassesCache() : array {
return self::$classes;
}
/**
* @return array
*/
public function getAttributesObjectsCache() : array {
return self::$attributeObjects;
}
/**
* @return array
*/
public function getConstructorEmptyAvailableClassesCache() : array {
return self::$constructorEmptyAvailableClasses;
}
}

2
src/Entity/EntityInterface.php → src/Repository/EntityInterface.php
View File

@@ -6,7 +6,7 @@
* Time: 3:58
*/
namespace Rmphp\Storage\Entity;
namespace Rmphp\Storage\Repository;
interface EntityInterface {

2
src/Exception/RepositoryException.php → src/Repository/RepositoryException.php
View File

@@ -1,6 +1,6 @@
<?php
namespace Rmphp\Storage\Exception;
namespace Rmphp\Storage\Repository;
use Throwable;

2
src/Repository/RepositoryInterface.php
View File

@@ -9,8 +9,6 @@
namespace Rmphp\Storage\Repository;
use Rmphp\Storage\Exception\RepositoryException;
interface RepositoryInterface {
/**

2
src/Entity/ValueObjectInterface.php → src/Repository/ValueObjectInterface.php
View File

@@ -1,6 +1,6 @@
<?php
namespace Rmphp\Storage\Entity;
namespace Rmphp\Storage\Repository;
interface ValueObjectInterface {