hfw / db

src/DB/AttributesTrait.php

Spacing +6 added lines, -6 removed lines

@@ -34,7 +34,7 @@ 
     /**
      * @return scalar[]
      */
-    public function getAttributes (): array {
+    public function getAttributes(): array {
         return $this->attributes ?? [];
     }
 
@@ -42,7 +42,7 @@ 
      * @param mixed $attr
      * @return bool
      */
-    public function offsetExists ($attr): bool {
+    public function offsetExists($attr): bool {
         return isset($this->attributes[$attr]);
     }
 
@@ -50,7 +50,7 @@ 
      * @param mixed $attr
      * @return null|scalar
      */
-    public function offsetGet ($attr) {
+    public function offsetGet($attr) {
         return $this->attributes[$attr] ?? null;
     }
 
@@ -58,7 +58,7 @@ 
      * @param mixed $attr
      * @param null|scalar $value
      */
-    public function offsetSet ($attr, $value): void {
+    public function offsetSet($attr, $value): void {
         if (isset($attr)) {
             if (isset($value)) {
                 assert(is_scalar($value));
@@ -80,7 +80,7 @@ 
     /**
      * @param mixed $attr
      */
-    public function offsetUnset ($attr): void {
+    public function offsetUnset($attr): void {
         unset($this->attributes[$attr]);
     }
 
@@ -88,7 +88,7 @@ 
      * @param scalar[] $attributes
      * @return $this
      */
-    public function setAttributes (array $attributes) {
+    public function setAttributes(array $attributes) {
         $this->attributes = array_filter($attributes, 'is_scalar');
         return $this;
     }

Braces +2 added lines, -4 removed lines

@@ -63,12 +63,10 @@
             if (isset($value)) {
                 assert(is_scalar($value));
                 $this->attributes[$attr] = $value;
-            }
-            else {
+            } else {
                 $this->offsetUnset($attr);
             }
-        }
-        else {
+        } else {
             // appending must not be null.
             // even though missing numeric offsets would yield null when fetched individually,
             // getAttributes() would not have them.

src/DB/Record.php

Spacing +32 added lines, -32 removed lines

@@ -138,7 +138,7 @@ 
      * @param string|EntityInterface $class Class or prototype instance.
      * @return Record
      */
-    public static function fromClass (DB $db, $class) {
+    public static function fromClass(DB $db, $class) {
         $rClass = new ReflectionClass($class);
         assert($rClass->isInstantiable());
         $columns = [];
@@ -169,7 +169,7 @@ 
      * @param string[] $properties Property names.
      * @param EAV[] $eav Keyed by property name.
      */
-    public function __construct (DB $db, EntityInterface $proto, string $table, array $properties, array $eav = []) {
+    public function __construct(DB $db, EntityInterface $proto, string $table, array $properties, array $eav = []) {
         parent::__construct($db, $table, $properties);
         $this->proto = $proto;
         $this->utc = new DateTimeZone('UTC');
@@ -208,7 +208,7 @@ 
      * @param ReflectionProperty $rProp
      * @return null|string Storage type, or `null` for unknown.
      */
-    protected function __construct_getType (string $prop, ReflectionProperty $rProp): ?string {
+    protected function __construct_getType(string $prop, ReflectionProperty $rProp): ?string {
         return $this->__construct_getType_fromReflection($prop, $rProp)
             ?? $this->__construct_getType_fromVar($prop, $rProp);
     }
@@ -220,7 +220,7 @@ 
      * @param ReflectionProperty $rProp
      * @return null|string
      */
-    protected function __construct_getType_fromReflection (string $prop, ReflectionProperty $rProp): ?string {
+    protected function __construct_getType_fromReflection(string $prop, ReflectionProperty $rProp): ?string {
         if ($rType = $rProp->getType() and $rType instanceof ReflectionNamedType) {
             $type = $rType->getName();
             if (isset(static::SCALARS[$type])) {
@@ -240,7 +240,7 @@ 
      * @param ReflectionProperty $rProp
      * @return null|string
      */
-    protected function __construct_getType_fromVar (string $prop, ReflectionProperty $rProp): ?string {
+    protected function __construct_getType_fromVar(string $prop, ReflectionProperty $rProp): ?string {
         if (preg_match(static::RX_VAR, $rProp->getDocComment(), $var)) {
             $type = preg_replace(static::RX_NULL, '', $var['type']); // remove null
             if (isset(static::SCALARS[$type])) {
@@ -266,7 +266,7 @@ 
      * @param ReflectionProperty $rProp
      * @return null|bool
      */
-    protected function __construct_isNullable (string $prop, ReflectionProperty $rProp): ?bool {
+    protected function __construct_isNullable(string $prop, ReflectionProperty $rProp): ?bool {
         return $this->__construct_isNullable_fromReflection($prop, $rProp)
             ?? $this->__construct_isNullable_fromVar($prop, $rProp);
     }
@@ -276,7 +276,7 @@ 
      * @param ReflectionProperty $rProp
      * @return null|bool
      */
-    protected function __construct_isNullable_fromReflection (string $prop, ReflectionProperty $rProp): ?bool {
+    protected function __construct_isNullable_fromReflection(string $prop, ReflectionProperty $rProp): ?bool {
         if ($rType = $rProp->getType()) {
             return $rType->allowsNull();
         }
@@ -288,7 +288,7 @@ 
      * @param ReflectionProperty $rProp
      * @return null|bool
      */
-    protected function __construct_isNullable_fromVar (string $prop, ReflectionProperty $rProp): ?bool {
+    protected function __construct_isNullable_fromVar(string $prop, ReflectionProperty $rProp): ?bool {
         if (preg_match(static::RX_VAR, $rProp->getDocComment(), $var)) {
             preg_replace(static::RX_NULL, '', $var['type'], -1, $nullable);
             return (bool)$nullable;
@@ -302,7 +302,7 @@ 
      * @param Statement $statement
      * @return EntityInterface[] Keyed by ID
      */
-    public function fetchAll (Statement $statement): array {
+    public function fetchAll(Statement $statement): array {
         return iterator_to_array($this->fetchEach($statement));
     }
 
@@ -313,7 +313,7 @@ 
      * @param Statement $statement
      * @return Generator|EntityInterface[] Keyed by ID
      */
-    public function fetchEach (Statement $statement) {
+    public function fetchEach(Statement $statement) {
         do {
             $entities = [];
             for ($i = 0; $i < 256 and false !== $row = $statement->fetch(); $i++) {
@@ -335,7 +335,7 @@ 
      * @param array[] $eavMatch `[eav property => attribute => value]`
      * @return Select|EntityInterface[]
      */
-    public function findAll (array $match, array $eavMatch = []) {
+    public function findAll(array $match, array $eavMatch = []) {
         $select = $this->loadAll();
         foreach ($match as $a => $b) {
             $select->where($this->db->match($this[$a] ?? $a, $b));
@@ -354,21 +354,21 @@ 
      * @param array $eavMatch `[eav property => attribute => value]`
      * @return null|EntityInterface
      */
-    public function findFirst (array $match, array $eavMatch = []) {
+    public function findFirst(array $match, array $eavMatch = []) {
         return $this->findAll($match, $eavMatch)->limit(1)->getFirst();
     }
 
     /**
      * @return string
      */
-    final public function getClass (): string {
+    final public function getClass(): string {
         return get_class($this->proto);
     }
 
     /**
      * @return EAV[]
      */
-    public function getEav () {
+    public function getEav() {
         return $this->eav;
     }
 
@@ -377,14 +377,14 @@ 
      *
      * @return string[]
      */
-    final public function getProperties (): array {
+    final public function getProperties(): array {
         return array_keys($this->properties);
     }
 
     /**
      * @return EntityInterface
      */
-    public function getProto () {
+    public function getProto() {
         return $this->proto;
     }
 
@@ -396,7 +396,7 @@ 
      * @param string $property
      * @return string
      */
-    final public function getType (string $property): string {
+    final public function getType(string $property): string {
         return $this->types[$property];
     }
 
@@ -407,7 +407,7 @@ 
      *
      * @return string[]
      */
-    final public function getTypes (): array {
+    final public function getTypes(): array {
         return $this->types;
     }
 
@@ -415,7 +415,7 @@ 
      * @param EntityInterface $entity
      * @return array
      */
-    protected function getValues (EntityInterface $entity): array {
+    protected function getValues(EntityInterface $entity): array {
         $values = [];
         foreach (array_keys($this->columns) as $name) {
             $value = $this->properties[$name]->getValue($entity);
@@ -439,7 +439,7 @@ 
      * @param array|object $hydrated
      * @return scalar
      */
-    protected function getValues_dehydrate (string $to, string $from, $hydrated) {
+    protected function getValues_dehydrate(string $to, string $from, $hydrated) {
         unset($from); // we don't need it here but it's given for posterity
         switch ($to) {
             case 'DateTime':
@@ -454,7 +454,7 @@ 
      * @param string $property
      * @return bool
      */
-    final public function isNullable (string $property): bool {
+    final public function isNullable(string $property): bool {
         return $this->nullable[$property];
     }
 
@@ -464,7 +464,7 @@ 
      * @param int $id
      * @return null|EntityInterface
      */
-    public function load (int $id) {
+    public function load(int $id) {
         $statement = $this->cache(__FUNCTION__, function() {
             return $this->select()->where('id = ?')->prepare();
         });
@@ -484,7 +484,7 @@ 
      *
      * @return Select|EntityInterface[]
      */
-    public function loadAll () {
+    public function loadAll() {
         return $this->select()->setFetcher(function(Statement $statement) {
             yield from $this->fetchEach($statement);
         });
@@ -495,7 +495,7 @@ 
      *
      * @param EntityInterface[] $entities
      */
-    protected function loadEav (array $entities): void {
+    protected function loadEav(array $entities): void {
         $ids = array_keys($entities);
         foreach ($this->eav as $name => $eav) {
             foreach ($eav->loadAll($ids) as $id => $values) {
@@ -510,7 +510,7 @@ 
      * @param EntityInterface $entity
      * @return int ID
      */
-    public function save (EntityInterface $entity): int {
+    public function save(EntityInterface $entity): int {
         if (!$entity->getId()) {
             $this->saveInsert($entity);
         }
@@ -524,7 +524,7 @@ 
     /**
      * @param EntityInterface $entity
      */
-    protected function saveEav (EntityInterface $entity): void {
+    protected function saveEav(EntityInterface $entity): void {
         $id = $entity->getId();
         foreach ($this->eav as $name => $eav) {
             // may be null to skip
@@ -540,7 +540,7 @@ 
      *
      * @param EntityInterface $entity
      */
-    protected function saveInsert (EntityInterface $entity): void {
+    protected function saveInsert(EntityInterface $entity): void {
         $statement = $this->cache(__FUNCTION__, function() {
             $slots = $this->db->slots(array_keys($this->columns));
             unset($slots['id']);
@@ -559,7 +559,7 @@ 
      *
      * @param EntityInterface $entity
      */
-    protected function saveUpdate (EntityInterface $entity): void {
+    protected function saveUpdate(EntityInterface $entity): void {
         $statement = $this->cache(__FUNCTION__, function() {
             $slots = $this->db->slotsEqual(array_keys($this->columns));
             unset($slots['id']);
@@ -574,7 +574,7 @@ 
      * @param EntityInterface $proto
      * @return $this
      */
-    public function setProto (EntityInterface $proto) {
+    public function setProto(EntityInterface $proto) {
         $this->proto = $proto;
         return $this;
     }
@@ -586,7 +586,7 @@ 
      * @param mixed $value
      * @return mixed
      */
-    protected function setType (string $property, $value) {
+    protected function setType(string $property, $value) {
         if (isset($value)) {
             // complex?
             if (isset($this->hydration[$property])) {
@@ -610,7 +610,7 @@ 
      * @param scalar $dehydrated
      * @return array|object
      */
-    protected function setType_hydrate (string $to, string $from, $dehydrated) {
+    protected function setType_hydrate(string $to, string $from, $dehydrated) {
         switch ($from) {
             case 'DateTime':
                 /**
@@ -633,7 +633,7 @@ 
      * @param EntityInterface $entity
      * @param array $values
      */
-    protected function setValues (EntityInterface $entity, array $values): void {
+    protected function setValues(EntityInterface $entity, array $values): void {
         foreach ($values as $name => $value) {
             if (isset($this->properties[$name])) {
                 $this->properties[$name]->setValue($entity, $this->setType($name, $value));

Braces +3 added lines, -6 removed lines

@@ -147,8 +147,7 @@ 
             $doc = $rProp->getDocComment();
             if (preg_match(static::RX_IS_COLUMN, $doc)) {
                 $columns[] = $rProp->getName();
-            }
-            elseif (preg_match(static::RX_EAV, $doc, $eav)) {
+            } elseif (preg_match(static::RX_EAV, $doc, $eav)) {
                 preg_match(static::RX_EAV_VAR, $doc, $var);
                 $type = $var['type'] ?? 'string';
                 $type = static::SCALARS[$type] ?? 'string';
@@ -513,8 +512,7 @@ 
     public function save (EntityInterface $entity): int {
         if (!$entity->getId()) {
             $this->saveInsert($entity);
-        }
-        else {
+        } else {
             $this->saveUpdate($entity);
         }
         $this->saveEav($entity);
@@ -637,8 +635,7 @@ 
         foreach ($values as $name => $value) {
             if (isset($this->properties[$name])) {
                 $this->properties[$name]->setValue($entity, $this->setType($name, $value));
-            }
-            else {
+            } else {
                 // attempt to set unknown fields directly on the instance.
                 $entity->{$name} = $value;
             }

src/DB/Schema.php

Spacing +25 added lines, -25 removed lines

@@ -143,16 +143,16 @@ 
         // bool
         'BOOLEAN' => 'bool',
         // int
-        'BIGINT' => 'int',  // mysql
+        'BIGINT' => 'int', // mysql
         'INTEGER' => 'int', // sqlite (must be this type to allow AUTOINCREMENT)
         // float
         'DOUBLE PRECISION' => 'float',
         // string <= 255
         'VARCHAR(255)' => 'string',
         // string <= 64k
-        'TEXT' => 'String',     // @var String
+        'TEXT' => 'String', // @var String
         // string > 64k
-        'BLOB' => 'STRING',     // @var STRING (sqlite)
+        'BLOB' => 'STRING', // @var STRING (sqlite)
         'LONGBLOB' => 'STRING', // @var STRING (mysql)
         // DateTime
         'DATETIME' => 'DateTime',
@@ -220,7 +220,7 @@ 
     /**
      * @param DB $db
      */
-    public function __construct (DB $db) {
+    public function __construct(DB $db) {
         $this->db = $db;
         $this->colDefs ??= self::COLUMN_DEFINITIONS[$db->getDriver()];
     }
@@ -233,7 +233,7 @@ 
      * @param int $type
      * @return $this
      */
-    public function addColumn (string $table, string $column, int $type = self::T_STRING_NULL) {
+    public function addColumn(string $table, string $column, int $type = self::T_STRING_NULL) {
         $type = $this->colDefs[$type & self::T_MASK];
         $this->db->exec("ALTER TABLE {$table} ADD COLUMN {$column} {$type}");
         unset($this->tables[$table]);
@@ -259,7 +259,7 @@ 
      * @param array[] $constraints `[ <TABLE_CONST> => spec ]`
      * @return $this
      */
-    public function createTable (string $table, array $columns, array $constraints = []) {
+    public function createTable(string $table, array $columns, array $constraints = []) {
         $defs = $this->toColumnDefinitions($columns);
 
         /** @var string[] $pk */
@@ -295,7 +295,7 @@ 
      * @param string $column
      * @return $this
      */
-    public function dropColumn (string $table, string $column) {
+    public function dropColumn(string $table, string $column) {
         $this->db->exec("ALTER TABLE {$table} DROP COLUMN {$column}");
         unset($this->tables[$table]);
         return $this;
@@ -306,7 +306,7 @@ 
      *
      * @param string $table
      */
-    public function dropTable (string $table): void {
+    public function dropTable(string $table): void {
         $this->db->exec("DROP TABLE IF EXISTS {$table}");
         unset($this->tables[$table]);
     }
@@ -325,7 +325,7 @@ 
      * @param string $column
      * @return array[] Keyed by name.
      */
-    public function getColumnInfo (string $table): array {
+    public function getColumnInfo(string $table): array {
         if ($this->db->isSQLite()) {
             $info = $this->db->query("PRAGMA table_info({$table})")->fetchAll();
             return array_combine(array_column($info, 'name'), array_map(fn(array $each) => [
@@ -345,7 +345,7 @@ 
     /**
      * @return DB
      */
-    public function getDb () {
+    public function getDb() {
         return $this->db;
     }
 
@@ -353,7 +353,7 @@ 
      * @param string $name
      * @return null|Table
      */
-    public function getTable (string $name) {
+    public function getTable(string $name) {
         if (!isset($this->tables[$name])) {
             if ($this->db->isSQLite()) {
                 $info = $this->db->query("PRAGMA table_info({$name})")->fetchAll();
@@ -376,7 +376,7 @@ 
      * @param string $table
      * @return bool
      */
-    final public function offsetExists ($table): bool {
+    final public function offsetExists($table): bool {
         return (bool)$this->offsetGet($table);
     }
 
@@ -386,7 +386,7 @@ 
      * @param string $table
      * @return null|Table
      */
-    public function offsetGet ($table) {
+    public function offsetGet($table) {
         return $this->getTable($table);
     }
 
@@ -395,7 +395,7 @@ 
      * @param $value
      * @throws LogicException
      */
-    final public function offsetSet ($offset, $value) {
+    final public function offsetSet($offset, $value) {
         throw new LogicException('The schema cannot be altered this way.');
     }
 
@@ -403,7 +403,7 @@ 
      * @param $offset
      * @throws LogicException
      */
-    final public function offsetUnset ($offset) {
+    final public function offsetUnset($offset) {
         throw new LogicException('The schema cannot be altered this way.');
     }
 
@@ -415,7 +415,7 @@ 
      * @param string $newName
      * @return $this
      */
-    public function renameColumn (string $table, string $oldName, string $newName) {
+    public function renameColumn(string $table, string $oldName, string $newName) {
         $this->db->exec("ALTER TABLE {$table} RENAME COLUMN {$oldName} TO {$newName}");
         unset($this->tables[$table]);
         return $this;
@@ -428,7 +428,7 @@ 
      * @param string $newName
      * @return $this
      */
-    public function renameTable (string $oldName, string $newName) {
+    public function renameTable(string $oldName, string $newName) {
         $this->db->exec("ALTER TABLE {$oldName} RENAME TO {$newName}");
         unset($this->tables[$oldName]);
         return $this;
@@ -440,7 +440,7 @@ 
      * @param int[] $types
      * @return int[]
      */
-    protected function sortColumns (array $types): array {
+    protected function sortColumns(array $types): array {
         uksort($types, function(string $a, string $b) use ($types) {
             // descending type constant, ascending name
             return $types[$b] <=> $types[$a] ?: $a <=> $b;
@@ -452,7 +452,7 @@ 
      * @param int[] $columns `[ name => <I_CONST> | <T_CONST> ]`
      * @return string[]
      */
-    protected function toColumnDefinitions (array $columns): array {
+    protected function toColumnDefinitions(array $columns): array {
         assert(count($columns) > 0);
         $columns = $this->sortColumns($columns);
         $defs = [];
@@ -478,7 +478,7 @@ 
      * @param Column $foreign
      * @return string
      */
-    protected function toForeignKeyConstraint (string $table, string $local, int $type, Column $foreign): string {
+    protected function toForeignKeyConstraint(string $table, string $local, int $type, Column $foreign): string {
         return sprintf(
             'CONSTRAINT %s FOREIGN KEY (%s) REFERENCES %s(%s) ON UPDATE CASCADE ON DELETE %s',
             $this->toForeignKeyConstraint_name($table, $local),
@@ -496,7 +496,7 @@ 
      * @param string $column
      * @return string
      */
-    protected function toForeignKeyConstraint_name (string $table, string $column): string {
+    protected function toForeignKeyConstraint_name(string $table, string $column): string {
         return 'FK_' . $table . '__' . $column;
     }
 
@@ -505,7 +505,7 @@ 
      * @param string[] $columns
      * @return string
      */
-    protected function toPrimaryKeyConstraint (string $table, array $columns): string {
+    protected function toPrimaryKeyConstraint(string $table, array $columns): string {
         return sprintf(
             'CONSTRAINT %s PRIMARY KEY (%s)',
             $this->toPrimaryKeyConstraint_name($table, $columns),
@@ -520,7 +520,7 @@ 
      * @param string[] $columns
      * @return string
      */
-    protected function toPrimaryKeyConstraint_name (string $table, array $columns): string {
+    protected function toPrimaryKeyConstraint_name(string $table, array $columns): string {
         sort($columns, SORT_STRING);
         return 'PK_' . $table . '__' . implode('__', $columns);
     }
@@ -530,7 +530,7 @@ 
      * @param string[] $columns
      * @return string
      */
-    protected function toUniqueKeyConstraint (string $table, array $columns): string {
+    protected function toUniqueKeyConstraint(string $table, array $columns): string {
         return sprintf(
             'CONSTRAINT %s UNIQUE (%s)',
             $this->toUniqueKeyConstraint_name($table, $columns),
@@ -545,7 +545,7 @@ 
      * @param string[] $columns
      * @return string
      */
-    protected function toUniqueKeyConstraint_name (string $table, array $columns): string {
+    protected function toUniqueKeyConstraint_name(string $table, array $columns): string {
         sort($columns, SORT_STRING);
         return 'UQ_' . $table . '__' . implode('__', $columns);
     }

src/DB/EAV.php

Spacing +8 added lines, -8 removed lines

@@ -23,7 +23,7 @@ 
      * @param string $name
      * @param string $type
      */
-    public function __construct (DB $db, string $name, string $type = 'string') {
+    public function __construct(DB $db, string $name, string $type = 'string') {
         parent::__construct($db, $name, ['entity', 'attribute', 'value']);
         $this->type = $type;
     }
@@ -35,7 +35,7 @@ 
      * @param string $attribute
      * @return bool
      */
-    public function exists (int $id, string $attribute): bool {
+    public function exists(int $id, string $attribute): bool {
         $statement = $this->cache(__FUNCTION__, function() {
             return $this->select(['COUNT(*) > 0'])->where('entity = ? AND attribute = ?')->prepare();
         });
@@ -53,7 +53,7 @@ 
      * @param array $match `[attribute => value]`. If empty, selects all IDs for entities having at least one attribute.
      * @return Select
      */
-    public function findAll (array $match) {
+    public function findAll(array $match) {
         $select = $this->select([$this['entity']]);
         $prior = $this;
         foreach ($match as $attribute => $value) {
@@ -72,7 +72,7 @@ 
     /**
      * @return string
      */
-    final public function getType (): string {
+    final public function getType(): string {
         return $this->type;
     }
 
@@ -82,7 +82,7 @@ 
      * @param int $id
      * @return scalar[] `[attribute => value]`
      */
-    public function load (int $id): array {
+    public function load(int $id): array {
         $statement = $this->cache(__FUNCTION__, function() {
             $select = $this->select(['attribute', 'value']);
             $select->where('entity = ?');
@@ -98,7 +98,7 @@ 
      * @param int[] $ids
      * @return scalar[][] `[id => attribute => value]
      */
-    public function loadAll (array $ids): array {
+    public function loadAll(array $ids): array {
         if (empty($ids)) {
             return [];
         }
@@ -126,7 +126,7 @@ 
      * @param array $values `[attribute => value]`
      * @return $this
      */
-    public function save (int $id, array $values) {
+    public function save(int $id, array $values) {
         // delete stale
         $this->delete([
             $this['entity']->isEqual($id),
@@ -166,7 +166,7 @@ 
      * @param scalar $value
      * @return scalar
      */
-    protected function setType ($value) {
+    protected function setType($value) {
         settype($value, $this->type);
         return $value;
     }