@@ -93,20 +93,20 @@ discard block |
||
| 93 | 93 | $parts = preg_split('/(?=[A-Z])/', $key, -1, PREG_SPLIT_NO_EMPTY); |
| 94 | 94 | if (strtolower($parts[0]) == 'own') { |
| 95 | 95 | if (strtolower($parts[2]) == 'list') { |
| 96 | - return Managers::recordManager()->find(strtolower($parts[1]))->where($this->getName() . '_id = "' . $this->_id . '"')->get(); |
|
| 96 | + return Managers::recordManager()->find(strtolower($parts[1]))->where($this->getName().'_id = "'.$this->_id.'"')->get(); |
|
| 97 | 97 | } |
| 98 | 98 | } |
| 99 | 99 | if (strtolower($parts[0]) == 'shared') { |
| 100 | 100 | if (strtolower($parts[2]) == 'list') { |
| 101 | - $rel_table = Managers::tableManager()->tableExists($this->table . '_' . strtolower($parts[1])) ? $this->table . '_' . strtolower($parts[1]) : strtolower($parts[1]) . '_' . $this->table; |
|
| 102 | - $relations = Managers::recordManager()->find($rel_table)->where($this->getName() . '_id = "' . $this->_id . '"')->get(); |
|
| 101 | + $rel_table = Managers::tableManager()->tableExists($this->table.'_'.strtolower($parts[1])) ? $this->table.'_'.strtolower($parts[1]) : strtolower($parts[1]).'_'.$this->table; |
|
| 102 | + $relations = Managers::recordManager()->find($rel_table)->where($this->getName().'_id = "'.$this->_id.'"')->get(); |
|
| 103 | 103 | $rel_ids = ''; |
| 104 | 104 | foreach ($relations as $relation) { |
| 105 | - $key = strtolower($parts[1]) . '_id'; |
|
| 106 | - $rel_ids .= "'" . $relation->$key . "',"; |
|
| 105 | + $key = strtolower($parts[1]).'_id'; |
|
| 106 | + $rel_ids .= "'".$relation->$key."',"; |
|
| 107 | 107 | } |
| 108 | 108 | $rel_ids = substr($rel_ids, 0, -1); |
| 109 | - return Managers::recordManager()->find(strtolower($parts[1]))->where('id IN (' . $rel_ids . ')')->get(); |
|
| 109 | + return Managers::recordManager()->find(strtolower($parts[1]))->where('id IN ('.$rel_ids.')')->get(); |
|
| 110 | 110 | } |
| 111 | 111 | } |
| 112 | 112 | } |
@@ -115,8 +115,8 @@ discard block |
||
| 115 | 115 | return $this->properties[$key]; |
| 116 | 116 | } |
| 117 | 117 | |
| 118 | - if (array_key_exists($key . '_id', $this->properties)) { |
|
| 119 | - return Managers::recordManager()->getById(Managers::modelManager()->create($key), $this->properties[$key . '_id']); |
|
| 118 | + if (array_key_exists($key.'_id', $this->properties)) { |
|
| 119 | + return Managers::recordManager()->getById(Managers::modelManager()->create($key), $this->properties[$key.'_id']); |
|
| 120 | 120 | } |
| 121 | 121 | |
| 122 | 122 | throw new Exception\KeyNotFoundException(); |
@@ -36,7 +36,7 @@ discard block |
||
| 36 | 36 | */ |
| 37 | 37 | private bool $useUUID = false; |
| 38 | 38 | |
| 39 | - public function __construct(Connection $connection , bool $useUUID = false) |
|
| 39 | + public function __construct(Connection $connection, bool $useUUID = false) |
|
| 40 | 40 | { |
| 41 | 41 | $this->connection = $connection; |
| 42 | 42 | $this->platform = $this->connection->getDatabasePlatform(); |
@@ -49,10 +49,10 @@ discard block |
||
| 49 | 49 | |
| 50 | 50 | public function registerEvents() |
| 51 | 51 | { |
| 52 | - Event::subscribeTo('model.save', function ($model) { |
|
| 52 | + Event::subscribeTo('model.save', function($model) { |
|
| 53 | 53 | return $this->save($model); |
| 54 | 54 | }); |
| 55 | - Event::subscribeTo('model.delete', function ($model) { |
|
| 55 | + Event::subscribeTo('model.delete', function($model) { |
|
| 56 | 56 | return $this->delete($model); |
| 57 | 57 | }); |
| 58 | 58 | } |
@@ -65,7 +65,7 @@ discard block |
||
| 65 | 65 | * @param array $params |
| 66 | 66 | * @return integer |
| 67 | 67 | */ |
| 68 | - public function exec(string $sql, array $params=array()): int |
|
| 68 | + public function exec(string $sql, array $params = array()): int |
|
| 69 | 69 | { |
| 70 | 70 | return $this->connection->executeStatement($sql, $params); |
| 71 | 71 | } |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | * @param array $params |
| 78 | 78 | * @return array |
| 79 | 79 | */ |
| 80 | - public function getAll(string $sql, array $params=[]): array |
|
| 80 | + public function getAll(string $sql, array $params = []): array |
|
| 81 | 81 | { |
| 82 | 82 | return $this->connection->executeQuery($sql, $params)->fetchAllAssociative(); |
| 83 | 83 | } |
@@ -259,11 +259,11 @@ discard block |
||
| 259 | 259 | /** |
| 260 | 260 | * Get collection of all records from table |
| 261 | 261 | */ |
| 262 | - public function get(String $table,mixed $id = null) : Model|Collection |
|
| 262 | + public function get(String $table, mixed $id = null) : Model | Collection |
|
| 263 | 263 | { |
| 264 | 264 | // For backward compatibility reason |
| 265 | - if($id != null){ |
|
| 266 | - return $this->getOne($table,$id); |
|
| 265 | + if ($id != null) { |
|
| 266 | + return $this->getOne($table, $id); |
|
| 267 | 267 | } |
| 268 | 268 | |
| 269 | 269 | return Managers::recordManager()->getAll($table); |
@@ -10,7 +10,6 @@ |
||
| 10 | 10 | class ModelManager { |
| 11 | 11 | /** |
| 12 | 12 | * Creates and return models |
| 13 | - |
|
| 14 | 13 | */ |
| 15 | 14 | function create(string $name): Model |
| 16 | 15 | { |
@@ -67,15 +67,15 @@ |
||
| 67 | 67 | } |
| 68 | 68 | |
| 69 | 69 | /** |
| 70 | - * Get single record by id |
|
| 71 | - * |
|
| 72 | - */ |
|
| 70 | + * Get single record by id |
|
| 71 | + * |
|
| 72 | + */ |
|
| 73 | 73 | public function getById(Model $model, mixed $id): Model |
| 74 | 74 | { |
| 75 | 75 | $query = (new QueryBuilder($this->connection)) |
| 76 | - ->select('*') |
|
| 77 | - ->from($model->getName(), 't') |
|
| 78 | - ->where("t.id = '".$id."'"); |
|
| 76 | + ->select('*') |
|
| 77 | + ->from($model->getName(), 't') |
|
| 78 | + ->where("t.id = '".$id."'"); |
|
| 79 | 79 | $result = $this->connection->executeQuery($query)->fetchAssociative(); |
| 80 | 80 | $result = $result ? $result : []; |
| 81 | 81 | return $model->setProperties($result)->setLoaded(); |
@@ -72,7 +72,7 @@ |
||
| 72 | 72 | */ |
| 73 | 73 | public function getById(Model $model, mixed $id): Model |
| 74 | 74 | { |
| 75 | - $query = (new QueryBuilder($this->connection)) |
|
| 75 | + $query = (new QueryBuilder($this->connection)) |
|
| 76 | 76 | ->select('*') |
| 77 | 77 | ->from($model->getName(), 't') |
| 78 | 78 | ->where("t.id = '".$id."'"); |
@@ -68,7 +68,7 @@ |
||
| 68 | 68 | { |
| 69 | 69 | $table = new Table($model->getName()); |
| 70 | 70 | if ($this->isUsingUUID) { |
| 71 | - $table->addColumn('id', 'string', ['length' => 36, 'notnull' => true,]); |
|
| 71 | + $table->addColumn('id', 'string', ['length' => 36, 'notnull' => true, ]); |
|
| 72 | 72 | } else { |
| 73 | 73 | $table->addColumn("id", "integer", array("unsigned" => true, "autoincrement" => true)); |
| 74 | 74 | } |
@@ -8,7 +8,7 @@ |
||
| 8 | 8 | class QueryBuilder extends \Doctrine\DBAL\Query\QueryBuilder |
| 9 | 9 | { |
| 10 | 10 | private string $table; |
| 11 | - private array $relations= []; |
|
| 11 | + private array $relations = []; |
|
| 12 | 12 | |
| 13 | 13 | public function __construct(\Doctrine\DBAL\Connection $connection) |
| 14 | 14 | { |
@@ -8,7 +8,7 @@ discard block |
||
| 8 | 8 | use Scrawler\Arca\Manager\TableManager; |
| 9 | 9 | |
| 10 | 10 | |
| 11 | -class Managers{ |
|
| 11 | +class Managers { |
|
| 12 | 12 | private static TableManager $tableManager; |
| 13 | 13 | private static RecordManager $recordManager; |
| 14 | 14 | |
@@ -19,9 +19,9 @@ discard block |
||
| 19 | 19 | |
| 20 | 20 | } |
| 21 | 21 | |
| 22 | - public static function create(Connection $connection, bool $isUsingUUID = false){ |
|
| 23 | - self::$tableManager = new TableManager($connection,$isUsingUUID); |
|
| 24 | - self::$recordManager = new RecordManager($connection,$isUsingUUID); |
|
| 22 | + public static function create(Connection $connection, bool $isUsingUUID = false) { |
|
| 23 | + self::$tableManager = new TableManager($connection, $isUsingUUID); |
|
| 24 | + self::$recordManager = new RecordManager($connection, $isUsingUUID); |
|
| 25 | 25 | self::$modelManager = new ModelManager(); |
| 26 | 26 | } |
| 27 | 27 | |
@@ -10,12 +10,12 @@ discard block |
||
| 10 | 10 | { |
| 11 | 11 | private static $database; |
| 12 | 12 | |
| 13 | - public static function connect(array $connectionParams,$isUsingUUID = false) |
|
| 13 | + public static function connect(array $connectionParams, $isUsingUUID = false) |
|
| 14 | 14 | { |
| 15 | 15 | |
| 16 | 16 | if (self::$database == null) { |
| 17 | 17 | $connection = \Doctrine\DBAL\DriverManager::getConnection($connectionParams); |
| 18 | - self::$database = new DB($connection,$isUsingUUID); |
|
| 18 | + self::$database = new DB($connection, $isUsingUUID); |
|
| 19 | 19 | return self::$database; |
| 20 | 20 | } |
| 21 | 21 | |
@@ -47,7 +47,7 @@ discard block |
||
| 47 | 47 | return self::getDB()->exec($sql); |
| 48 | 48 | } |
| 49 | 49 | |
| 50 | - public static function delete($model){ |
|
| 50 | + public static function delete($model) { |
|
| 51 | 51 | return self::getDB()->delete($model); |
| 52 | 52 | } |
| 53 | 53 | |