hfw / db

src/DB/EntityInterface.php

Spacing +1 added lines, -1 removed lines

@@ -10,5 +10,5 @@
     /**
      * @return int
      */
-    public function getId (): int;
+    public function getId(): int;
 }
\ No newline at end of file

src/DB/AbstractAccess.php

Spacing +2 added lines, -2 removed lines

@@ -26,7 +26,7 @@ 
     /**
      * @param DB $db
      */
-    public function __construct (DB $db) {
+    public function __construct(DB $db) {
         $this->db = $db;
     }
 
@@ -37,7 +37,7 @@ 
      * @param Closure $prepare `():PDOStatement`
      * @return PDOStatement
      */
-    protected function cache (string $key, Closure $prepare): PDOStatement {
+    protected function cache(string $key, Closure $prepare): PDOStatement {
         return $this->_cache[$key] ?? $this->_cache[$key] = $prepare->__invoke();
     }
 

src/DB/Record.php

Spacing +16 added lines, -16 removed lines

@@ -63,7 +63,7 @@ 
      * @param DB $db
      * @param string $class
      */
-    public function __construct (DB $db, string $class) {
+    public function __construct(DB $db, string $class) {
         $this->db = $db;
         $this->class = $class;
         try {
@@ -109,7 +109,7 @@ 
      * @param PDOStatement $statement
      * @return EntityInterface[] Enumerated
      */
-    public function fetchAll (PDOStatement $statement): array {
+    public function fetchAll(PDOStatement $statement): array {
         $entities = [];
         foreach ($statement->fetchAll() as $row) {
             $clone = clone $this->proto;
@@ -129,7 +129,7 @@ 
      * @param array[] $eavMatch Additional `[eav property => attribute => mixed]`
      * @return Select
      */
-    public function find (array $match, array $eavMatch = []): Select {
+    public function find(array $match, array $eavMatch = []): Select {
         $select = $this->select();
         foreach ($match as $column => $value) {
             $select->where($this->db->match($column, $value));
@@ -144,7 +144,7 @@ 
     /**
      * @return string
      */
-    final public function getClass (): string {
+    final public function getClass(): string {
         return $this->class;
     }
 
@@ -152,14 +152,14 @@ 
      * @param string $property
      * @return EAV
      */
-    final public function getEav ($property): EAV {
+    final public function getEav($property): EAV {
         return $this->eav[$property];
     }
 
     /**
      * @return EntityInterface
      */
-    public function getProto (): EntityInterface {
+    public function getProto(): EntityInterface {
         return $this->proto;
     }
 
@@ -167,7 +167,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) {
             $values[$name] = $this->properties[$name]->getValue($entity);
@@ -181,7 +181,7 @@ 
      * @param int $id
      * @return null|EntityInterface
      */
-    public function load ($id): ?EntityInterface {
+    public function load($id): ?EntityInterface {
         $load = $this->cache(__FUNCTION__, function() {
             return $this->select()->where('id=:id')->prepare();
         });
@@ -200,7 +200,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) {
@@ -215,7 +215,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);
         }
@@ -229,7 +229,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) {
             $values = $this->properties[$name]->getValue($entity);
@@ -244,7 +244,7 @@ 
      *
      * @param EntityInterface $entity
      */
-    protected function saveInsert (EntityInterface $entity): void {
+    protected function saveInsert(EntityInterface $entity): void {
         $insert = $this->cache(__FUNCTION__, function() {
             $slots = SQL::slots(array_keys($this->columns));
             unset($slots['id']);
@@ -263,7 +263,7 @@ 
      *
      * @param EntityInterface $entity
      */
-    protected function saveUpdate (EntityInterface $entity): void {
+    protected function saveUpdate(EntityInterface $entity): void {
         $this->cache(__FUNCTION__, function() {
             $slots = SQL::slots(array_keys($this->columns));
             unset($slots['id']);
@@ -278,7 +278,7 @@ 
      * @param array $columns Defaults to all columns.
      * @return Select
      */
-    public function select (array $columns = []): Select {
+    public function select(array $columns = []): Select {
         $select = parent::select($columns);
         $select->setFetcher(function(PDOStatement $statement) {
             return $this->fetchAll($statement);
@@ -290,7 +290,7 @@ 
      * @param EntityInterface $proto
      * @return $this
      */
-    public function setProto (EntityInterface $proto) {
+    public function setProto(EntityInterface $proto) {
         $this->proto = $proto;
         return $this;
     }
@@ -299,7 +299,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) {
             settype($value, $this->types[$name]);
             $this->properties[$name]->setValue($entity, $value);

src/DB/AttributesTrait.php

Spacing +6 added lines, -6 removed lines

@@ -22,7 +22,7 @@ 
     /**
      * @return array
      */
-    public function getAttributes (): array {
+    public function getAttributes(): array {
         return $this->attributes ?: [];
     }
 
@@ -30,7 +30,7 @@ 
      * @param $offset
      * @return bool
      */
-    public function offsetExists ($offset): bool {
+    public function offsetExists($offset): bool {
         return $this->attributes and array_key_exists($offset, $this->attributes);
     }
 
@@ -38,7 +38,7 @@ 
      * @param $offset
      * @return mixed Returns `NULL` for nonexistent attributes.
      */
-    public function offsetGet ($offset) {
+    public function offsetGet($offset) {
         return $this->attributes[$offset] ?? null;
     }
 
@@ -46,14 +46,14 @@ 
      * @param $offset
      * @param $value
      */
-    public function offsetSet ($offset, $value): void {
+    public function offsetSet($offset, $value): void {
         $this->attributes[$offset] = $value;
     }
 
     /**
      * @param $offset
      */
-    public function offsetUnset ($offset): void {
+    public function offsetUnset($offset): void {
         unset($this->attributes[$offset]);
     }
 
@@ -61,7 +61,7 @@ 
      * @param array $attributes
      * @return $this
      */
-    public function setAttributes (array $attributes) {
+    public function setAttributes(array $attributes) {
         $this->attributes = $attributes;
         return $this;
     }

src/DB/Statement.php

Spacing +2 added lines, -2 removed lines

@@ -13,7 +13,7 @@ 
     /**
      * Required by PDO, and must be protected.
      */
-    protected function __construct () { }
+    protected function __construct() { }
 
     /**
      * PHP returns `false` instead of throwing if too many arguments were given.
@@ -23,7 +23,7 @@ 
      * @return bool
      * @throws PDOException
      */
-    public function execute ($args = null) {
+    public function execute($args = null) {
         if ($result = !parent::execute($args)) {
             $info = $this->errorInfo();
             if ($info[0] == 0) {

src/DB.php

Spacing +15 added lines, -15 removed lines

@@ -47,7 +47,7 @@ 
      * @param string $passwd
      * @param array $options
      */
-    public function __construct ($dsn, $username = null, $passwd = null, $options = null) {
+    public function __construct($dsn, $username = null, $passwd = null, $options = null) {
         parent::__construct(...func_get_args());
         $this->setAttribute(self::ATTR_ERRMODE, self::ERRMODE_EXCEPTION);
         $this->setAttribute(self::ATTR_DEFAULT_FETCH_MODE, self::FETCH_ASSOC);
@@ -63,7 +63,7 @@ 
      * @param string $sql
      * @return int
      */
-    public function exec ($sql) {
+    public function exec($sql) {
         $this->logger->__invoke($sql);
         return parent::exec($sql);
     }
@@ -73,7 +73,7 @@ 
      *
      * @return string
      */
-    final public function getDriver () {
+    final public function getDriver() {
         return $this->getAttribute(self::ATTR_DRIVER_NAME);
     }
 
@@ -83,7 +83,7 @@ 
      * @param string $interface
      * @return Junction
      */
-    public function getJunction ($interface) {
+    public function getJunction($interface) {
         if (!isset($this->junctions[$interface])) {
             $this->junctions[$interface] = new Junction($this, $interface);
         }
@@ -96,7 +96,7 @@ 
      * @param string|EntityInterface $class
      * @return Record
      */
-    public function getRecord ($class) {
+    public function getRecord($class) {
         if (is_object($class)) {
             $class = get_class($class);
         }
@@ -128,7 +128,7 @@ 
      * @param string|array|Select|Closure $b
      * @return string|string[] Same type as `$a`, keys are not preserved.
      */
-    public function match ($a, $b = null) {
+    public function match($a, $b = null) {
         if (is_array($a)) {
             return array_map([$this, __FUNCTION__], array_keys($a), $a);
         }
@@ -145,7 +145,7 @@ 
      * @param string $access Class or interface name.
      * @return bool
      */
-    public function offsetExists ($access) {
+    public function offsetExists($access) {
         return (bool)$this->offsetGet($access);
     }
 
@@ -153,7 +153,7 @@ 
      * @param string $access Class or interface name.
      * @return Record|Junction|null
      */
-    public function offsetGet ($access) {
+    public function offsetGet($access) {
         if (class_exists($access)) {
             return $this->getRecord($access);
         }
@@ -170,7 +170,7 @@ 
      * @param void $value
      * @throws LogicException
      */
-    final public function offsetSet ($access, $value) {
+    final public function offsetSet($access, $value) {
         throw new LogicException('The schema cannot be altered by ArrayAccess.');
     }
 
@@ -180,7 +180,7 @@ 
      * @param void $access
      * @throws LogicException
      */
-    final public function offsetUnset ($access) {
+    final public function offsetUnset($access) {
         $this->offsetSet($access, null);
     }
 
@@ -191,7 +191,7 @@ 
      * @param array $options
      * @return PDOStatement
      */
-    public function prepare ($sql, $options = null) {
+    public function prepare($sql, $options = null) {
         $this->logger->__invoke($sql);
         return parent::prepare(...func_get_args());
     }
@@ -205,7 +205,7 @@ 
      * @param array $ctorargs
      * @return PDOStatement
      */
-    public function query ($sql, $mode = PDO::ATTR_DEFAULT_FETCH_MODE, $arg3 = null, array $ctorargs = []) {
+    public function query($sql, $mode = PDO::ATTR_DEFAULT_FETCH_MODE, $arg3 = null, array $ctorargs = []) {
         $this->logger->__invoke($sql);
         return parent::query(...func_get_args());
     }
@@ -228,7 +228,7 @@ 
      * @param int $type Ignored.
      * @return mixed
      */
-    public function quote ($value, $type = null) {
+    public function quote($value, $type = null) {
         if ($value instanceof Column) {
             return (string)$value;
         }
@@ -253,14 +253,14 @@ 
      * @param EntityInterface $entity
      * @return int ID
      */
-    public function save (EntityInterface $entity) {
+    public function save(EntityInterface $entity) {
         return $this->getRecord($entity)->save($entity);
     }
 
     /**
      * @param Closure $logger
      */
-    public function setLogger (Closure $logger) {
+    public function setLogger(Closure $logger) {
         $this->logger = $logger;
     }
 }
\ No newline at end of file

src/DB/Table.php

Spacing +12 added lines, -12 removed lines

@@ -30,7 +30,7 @@ 
      * @param string $name
      * @param string[] $columns
      */
-    public function __construct (DB $db, $name, array $columns) {
+    public function __construct(DB $db, $name, array $columns) {
         parent::__construct($db);
         $this->name = $name;
         foreach ($columns as $column) {
@@ -43,7 +43,7 @@ 
      *
      * @return string
      */
-    final public function __toString (): string {
+    final public function __toString(): string {
         return $this->name;
     }
 
@@ -53,7 +53,7 @@ 
      * @param array $values
      * @return int Rows affected.
      */
-    public function apply (array $values): int {
+    public function apply(array $values): int {
         $columns = implode(',', array_keys($values));
         $values = implode(',', $this->db->quote($values));
         switch ($this->db->getDriver()) {
@@ -72,7 +72,7 @@ 
      * @param array $match
      * @return int Rows affected.
      */
-    public function delete (array $match): int {
+    public function delete(array $match): int {
         $match = SQL::all($this->db->match($match));
         return $this->db->exec("DELETE FROM {$this} WHERE {$match}");
     }
@@ -80,14 +80,14 @@ 
     /**
      * @return Column[]
      */
-    final public function getColumns (): array {
+    final public function getColumns(): array {
         return $this->columns;
     }
 
     /**
      * @return string
      */
-    final public function getName (): string {
+    final public function getName(): string {
         return $this->name;
     }
 
@@ -97,7 +97,7 @@ 
      * @param array $values
      * @return int Insertion ID.
      */
-    public function insert (array $values): int {
+    public function insert(array $values): int {
         $columns = implode(',', array_keys($values));
         $values = implode(',', $this->db->quote($values));
         $this->db->exec("INSERT INTO {$this} ($columns) VALUES ($values)");
@@ -108,7 +108,7 @@ 
      * @param string $name
      * @return bool
      */
-    public function offsetExists ($name): bool {
+    public function offsetExists($name): bool {
         return isset($this->columns[$name]);
     }
 
@@ -116,7 +116,7 @@ 
      * @param string $name
      * @return Column
      */
-    public function offsetGet ($name): Column {
+    public function offsetGet($name): Column {
         return $this->columns[$name];
     }
 
@@ -126,7 +126,7 @@ 
      * @param string[] $columns Defaults to all columns.
      * @return Select
      */
-    public function select (array $columns = []): Select {
+    public function select(array $columns = []): Select {
         if (!$columns) {
             $columns = $this->columns;
         }
@@ -139,7 +139,7 @@ 
      * @param string $name
      * @return Table
      */
-    public function setName (string $name) {
+    public function setName(string $name) {
         $clone = clone $this;
         $clone->name = $name;
         foreach ($this->columns as $name => $column) {
@@ -157,7 +157,7 @@ 
      * @param array $match
      * @return int Rows affected.
      */
-    public function update (array $values, array $match): int {
+    public function update(array $values, array $match): int {
         $values = implode(', ', SQL::isEqual($this->db->quote($values)));
         $match = SQL::all($this->db->match($match));
         return $this->db->exec("UPDATE {$this} SET {$values} WHERE {$match}");

src/DB/Select.php

Spacing +23 added lines, -23 removed lines

@@ -75,7 +75,7 @@ 
      * @param string|Select $table
      * @param array $columns Strings or {@link Column}. Keys are used for aliasing.
      */
-    public function __construct (DB $db, $table, array $columns) {
+    public function __construct(DB $db, $table, array $columns) {
         parent::__construct($db);
         if ($table instanceof Select) {
             $table = $table->toSubquery();
@@ -91,7 +91,7 @@ 
     /**
      * Gives the clone a new alias.
      */
-    public function __clone () {
+    public function __clone() {
         $this->alias = uniqid('_') . "__{$this->table}";
     }
 
@@ -99,7 +99,7 @@ 
      * @param array $args
      * @return PDOStatement
      */
-    public function __invoke (array $args = []) {
+    public function __invoke(array $args = []) {
         return $this->execute($args);
     }
 
@@ -108,7 +108,7 @@ 
      *
      * @return string
      */
-    public function __toString (): string {
+    public function __toString(): string {
         return $this->alias;
     }
 
@@ -118,7 +118,7 @@ 
      * @param array $args Execution arguments.
      * @return int
      */
-    public function count (array $args = []): int {
+    public function count(array $args = []): int {
         $clone = clone $this;
         $clone->setColumns(['COUNT(*)']);
         return (int)$clone->execute($args)->fetchColumn();
@@ -130,7 +130,7 @@ 
      * @param array $args
      * @return PDOStatement
      */
-    public function execute (array $args = []): PDOStatement {
+    public function execute(array $args = []): PDOStatement {
         $statement = $this->prepare();
         $statement->execute($args);
         return $statement;
@@ -144,21 +144,21 @@ 
      * @param array $args Execution arguments.
      * @return array
      */
-    public function fetchAll (array $args = []): array {
+    public function fetchAll(array $args = []): array {
         return $this->fetcher->__invoke($this->execute($args));
     }
 
     /**
      * @return string
      */
-    final public function getAlias (): string {
+    final public function getAlias(): string {
         return $this->alias;
     }
 
     /**
      * @return Closure
      */
-    public function getFetcher (): Closure {
+    public function getFetcher(): Closure {
         return $this->fetcher;
     }
 
@@ -169,7 +169,7 @@ 
      *
      * @return ArrayIterator
      */
-    public function getIterator () {
+    public function getIterator() {
         return new ArrayIterator($this->fetchAll());
     }
 
@@ -179,7 +179,7 @@ 
      * @param string $column
      * @return $this
      */
-    public function group ($column) {
+    public function group($column) {
         $this->_group[] = $column;
         return $this;
     }
@@ -190,7 +190,7 @@ 
      * @param string $condition
      * @return $this
      */
-    public function having ($condition) {
+    public function having($condition) {
         $this->_having[] = $condition;
         return $this;
     }
@@ -203,7 +203,7 @@ 
      * @param string $type
      * @return $this
      */
-    public function join ($table, $condition, $type = 'INNER') {
+    public function join($table, $condition, $type = 'INNER') {
         if ($table instanceof Select) {
             $table = $table->toSubquery();
         }
@@ -218,7 +218,7 @@ 
      * @param int $offset
      * @return $this
      */
-    public function limit ($limit, $offset = 0) {
+    public function limit($limit, $offset = 0) {
         $this->_limit = " LIMIT {$limit}";
         if ($offset) {
             $this->_limit .= " OFFSET {$offset}";
@@ -232,7 +232,7 @@ 
      * @param string $name Name or alias if used.
      * @return bool
      */
-    public function offsetExists ($name): bool {
+    public function offsetExists($name): bool {
         return isset($this->columns[$name]);
     }
 
@@ -242,7 +242,7 @@ 
      * @param string $name Name or alias if used.
      * @return Column
      */
-    public function offsetGet ($name): Column {
+    public function offsetGet($name): Column {
         return new Column($this->db, $name, $this->alias);
     }
 
@@ -252,7 +252,7 @@ 
      * @param string $order
      * @return $this
      */
-    public function order ($order) {
+    public function order($order) {
         $this->_order = " ORDER BY {$order}";
         return $this;
     }
@@ -260,7 +260,7 @@ 
     /**
      * @return PDOStatement
      */
-    public function prepare (): PDOStatement {
+    public function prepare(): PDOStatement {
         return $this->db->prepare($this->toSql());
     }
 
@@ -270,7 +270,7 @@ 
      * @param array $columns Strings or {@link Column}. Keys are used for aliasing.
      * @return $this
      */
-    public function setColumns (array $columns) {
+    public function setColumns(array $columns) {
         $this->columns = [];
         foreach ($columns as $alias => $column) {
             if ($column instanceof Column) {
@@ -294,7 +294,7 @@ 
      * @param Closure $fetcher
      * @return $this
      */
-    public function setFetcher (Closure $fetcher) {
+    public function setFetcher(Closure $fetcher) {
         $this->fetcher = $fetcher;
         return $this;
     }
@@ -302,7 +302,7 @@ 
     /**
      * @return string
      */
-    public function toSql (): string {
+    public function toSql(): string {
         $columns = [];
         foreach ($this->columns as $alias => $column) {
             if ($alias !== $column) {
@@ -336,7 +336,7 @@ 
      *
      * @return string
      */
-    public function toSubquery (): string {
+    public function toSubquery(): string {
         return "({$this->toSql()}) AS {$this->getAlias()}";
     }
 
@@ -346,7 +346,7 @@ 
      * @param string $condition
      * @return $this
      */
-    public function where ($condition) {
+    public function where($condition) {
         $this->_where[] = $condition;
         return $this;
     }

src/DB/EAV.php

Spacing +7 added lines, -7 removed lines

@@ -18,7 +18,7 @@ 
      * @param Record $record The entity's storage access.
      * @param $name
      */
-    public function __construct (Record $record, $name) {
+    public function __construct(Record $record, $name) {
         $this->record = $record;
         parent::__construct($record->db, $name, ['entity', 'attribute', 'value']);
     }
@@ -29,7 +29,7 @@ 
      * @param int $id
      * @return int
      */
-    public function count (int $id): int {
+    public function count(int $id): int {
         $count = $this->cache(__FUNCTION__, function() {
             return $this->select(['COUNT(*)'])->where('entity=?')->prepare();
         });
@@ -44,7 +44,7 @@ 
      * @param string $attribute
      * @return bool
      */
-    public function exists (int $id, string $attribute): bool {
+    public function exists(int $id, string $attribute): bool {
         $exists = $this->cache(__FUNCTION__, function() {
             return $this->select(['COUNT(*) > 0'])->where('entity=:e AND attribute=:a')->prepare();
         });
@@ -61,7 +61,7 @@ 
      * @param array $match `[attribute => value]`. If empty, selects all IDs for entities having at least one attribute.
      * @return Select
      */
-    public function find (array $match): Select {
+    public function find(array $match): Select {
         $select = $this->select([$this['entity']]);
         $prior = $this;
         foreach ($match as $attribute => $value) {
@@ -83,7 +83,7 @@ 
      * @param int $id
      * @return array `[attribute => value]`
      */
-    public function load (int $id): array {
+    public function load(int $id): array {
         $load = $this->cache(__FUNCTION__, function() {
             return $this->select(['attribute', 'value'])->where('entity=?')->prepare();
         });
@@ -97,7 +97,7 @@ 
      * @param int[] $ids
      * @return array[] `[id => attribute => value]
      */
-    public function loadAll (array $ids): array {
+    public function loadAll(array $ids): array {
         if (count($ids) === 1) {
             return [current($ids) => $this->load(current($ids))];
         }
@@ -118,7 +118,7 @@ 
      * @param array $values `[attribute => value]`
      * @return $this
      */
-    public function save (int $id, array $values) {
+    public function save(int $id, array $values) {
         $this->delete([
             $this['entity']->isEqual($id),
             $this['attribute']->isNotEqual(array_keys($values))