hfw / db

src/DB/Select.php

Spacing +20 added lines, -20 removed lines

@@ -79,7 +79,7 @@ 
      * @param string|Select $table
      * @param string[] $columns
      */
-    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();
@@ -95,7 +95,7 @@ 
     /**
      * Gives the clone a new alias.
      */
-    public function __clone () {
+    public function __clone() {
         $this->alias = uniqid('_') . "__{$this->table}";
     }
 
@@ -103,7 +103,7 @@ 
      * @param array $args
      * @return Statement
      */
-    public function __invoke (array $args = []): Statement {
+    public function __invoke(array $args = []): Statement {
         return $this->execute($args);
     }
 
@@ -112,7 +112,7 @@ 
      *
      * @return string
      */
-    public function __toString (): string {
+    public function __toString(): string {
         return $this->alias;
     }
 
@@ -122,7 +122,7 @@ 
      * @param array $args Execution arguments.
      * @return int
      */
-    public function count (array $args = []): int {
+    public function count(array $args = []): int {
         $clone = clone $this;
         $clone->columns = ['COUNT(*)'];
         return (int)$clone->execute($args)->fetchColumn();
@@ -134,7 +134,7 @@ 
      * @param array $args
      * @return Statement
      */
-    public function execute (array $args = []): Statement {
+    public function execute(array $args = []): Statement {
         if (!empty($args)) {
             return $this->prepare()($args);
         }
@@ -149,7 +149,7 @@ 
      * @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));
     }
 
@@ -160,7 +160,7 @@ 
      *
      * @return ArrayIterator
      */
-    public function getIterator () {
+    public function getIterator() {
         return new ArrayIterator($this->fetchAll());
     }
 
@@ -170,7 +170,7 @@ 
      * @param string $column
      * @return $this
      */
-    public function group (string $column) {
+    public function group(string $column) {
         $this->_group[] = $column;
         return $this;
     }
@@ -181,7 +181,7 @@ 
      * @param string $condition
      * @return $this
      */
-    public function having (string $condition) {
+    public function having(string $condition) {
         $this->_having[] = $condition;
         return $this;
     }
@@ -194,7 +194,7 @@ 
      * @param string $type
      * @return $this
      */
-    public function join ($table, string $condition, string $type = 'INNER') {
+    public function join($table, string $condition, string $type = 'INNER') {
         if ($table instanceof Select) {
             $table = $table->toSubquery();
         }
@@ -209,7 +209,7 @@ 
      * @param int $offset
      * @return $this
      */
-    public function limit (int $limit, int $offset = 0) {
+    public function limit(int $limit, int $offset = 0) {
         $this->_limit = $limit;
         $this->_offset = $offset;
         return $this;
@@ -221,7 +221,7 @@ 
      * @param string $name Name or alias if used.
      * @return bool
      */
-    public function offsetExists ($name): bool {
+    public function offsetExists($name): bool {
         return true;
     }
 
@@ -231,7 +231,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);
     }
 
@@ -241,7 +241,7 @@ 
      * @param string $order
      * @return $this
      */
-    public function order (string $order) {
+    public function order(string $order) {
         $this->_order = $order;
         return $this;
     }
@@ -249,7 +249,7 @@ 
     /**
      * @return Statement
      */
-    public function prepare (): Statement {
+    public function prepare(): Statement {
         return $this->db->prepare($this->toSql());
     }
 
@@ -257,7 +257,7 @@ 
      * @param Closure $fetcher
      * @return $this
      */
-    public function setFetcher (Closure $fetcher) {
+    public function setFetcher(Closure $fetcher) {
         $this->fetcher = $fetcher;
         return $this;
     }
@@ -265,7 +265,7 @@ 
     /**
      * @return string
      */
-    public function toSql (): string {
+    public function toSql(): string {
         $sql = SQL::select($this->table, $this->columns);
         foreach ($this->_join as $join) {
             $sql .= " {$join}";
@@ -283,7 +283,7 @@ 
      *
      * @return string
      */
-    public function toSubquery (): string {
+    public function toSubquery(): string {
         return "({$this->toSql()}) AS {$this->alias}";
     }
 
@@ -293,7 +293,7 @@ 
      * @param string $condition
      * @return $this
      */
-    public function where (string $condition) {
+    public function where(string $condition) {
         $this->_where[] = $condition;
         return $this;
     }

src/DB/Table.php

Spacing +11 added lines, -11 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;
     }
 
@@ -55,7 +55,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->matchArray($match));
         return $this->db->exec("DELETE FROM {$this} WHERE {$match}");
     }
@@ -63,14 +63,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;
     }
 
@@ -80,7 +80,7 @@ 
      * @param array $values
      * @return Statement
      */
-    public function insert (array $values): Statement {
+    public function insert(array $values): Statement {
         $columns = implode(',', array_keys($values));
         $values = implode(', ', $this->db->quoteArray($values));
         return $this->db->query("INSERT INTO {$this} ($columns) VALUES ($values)");
@@ -90,7 +90,7 @@ 
      * @param string $name
      * @return bool
      */
-    public function offsetExists ($name): bool {
+    public function offsetExists($name): bool {
         return isset($this->columns[$name]);
     }
 
@@ -98,7 +98,7 @@ 
      * @param string $name
      * @return Column
      */
-    public function offsetGet ($name): Column {
+    public function offsetGet($name): Column {
         return $this->columns[$name];
     }
 
@@ -108,7 +108,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;
         }
@@ -121,7 +121,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) {
@@ -139,7 +139,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->quoteArray($values)));
         $match = SQL::all($this->db->matchArray($match));
         return $this->db->exec("UPDATE {$this} SET {$values} WHERE {$match}");

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();
         });
@@ -43,7 +43,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 = ? AND attribute = ?')->prepare();
         });
@@ -59,7 +59,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) {
@@ -81,7 +81,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();
         });
@@ -94,7 +94,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))];
         }
@@ -114,7 +114,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))

src/DB/Statement.php

Spacing +5 added lines, -5 removed lines

@@ -21,7 +21,7 @@ 
      *
      * @param DB $db
      */
-    protected function __construct (DB $db) {
+    protected function __construct(DB $db) {
         $this->db = $db;
     }
 
@@ -31,7 +31,7 @@ 
      * @param array $args
      * @return $this
      */
-    public function __invoke (array $args = null) {
+    public function __invoke(array $args = null) {
         $this->execute($args);
         return $this;
     }
@@ -41,7 +41,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         return $this->queryString;
     }
 
@@ -54,7 +54,7 @@ 
      * @return bool
      * @throws ArgumentCountError
      */
-    public function execute ($args = null) {
+    public function execute($args = null) {
         $this->db->getLogger()->__invoke($this->queryString);
         if ($result = !parent::execute($args)) {
             $info = $this->errorInfo();
@@ -71,7 +71,7 @@ 
      *
      * @return int
      */
-    public function getId (): int {
+    public function getId(): int {
         return (int)$this->db->lastInsertId();
     }
 }

src/DB.php

Spacing +20 added lines, -20 removed lines

@@ -45,7 +45,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($dsn, $username, $passwd, $options);
         $this->setAttribute(self::ATTR_DEFAULT_FETCH_MODE, self::FETCH_ASSOC);
         $this->setAttribute(self::ATTR_EMULATE_PREPARES, false);
@@ -61,7 +61,7 @@ 
      * @param string $sql
      * @return int
      */
-    public function exec ($sql): int {
+    public function exec($sql): int {
         $this->logger->__invoke($sql);
         return parent::exec($sql);
     }
@@ -71,7 +71,7 @@ 
      *
      * @return string
      */
-    final public function getDriver (): string {
+    final public function getDriver(): string {
         return $this->getAttribute(self::ATTR_DRIVER_NAME);
     }
 
@@ -81,7 +81,7 @@ 
      * @param string $interface
      * @return Junction
      */
-    public function getJunction ($interface): Junction {
+    public function getJunction($interface): Junction {
         if (!isset($this->junctions[$interface])) {
             $this->junctions[$interface] = new Junction($this, $interface);
         }
@@ -91,7 +91,7 @@ 
     /**
      * @return Closure
      */
-    public function getLogger (): Closure {
+    public function getLogger(): Closure {
         return $this->logger;
     }
 
@@ -101,7 +101,7 @@ 
      * @param string|EntityInterface $class
      * @return Record
      */
-    public function getRecord ($class): Record {
+    public function getRecord($class): Record {
         if (is_object($class)) {
             $class = get_class($class);
         }
@@ -126,7 +126,7 @@ 
      * @param mixed $b
      * @return string
      */
-    public function match ($a, $b = null) {
+    public function match($a, $b = null) {
         if (is_int($a) and is_string($b)) {
             return $b;
         }
@@ -149,7 +149,7 @@ 
      * @param array $match
      * @return string[]
      */
-    public function matchArray (array $match) {
+    public function matchArray(array $match) {
         return array_map([$this, 'match'], array_keys($match), $match);
     }
 
@@ -161,7 +161,7 @@ 
      * @param mixed $match
      * @return string|string[]
      */
-    public function matchMixed ($match) {
+    public function matchMixed($match) {
         if (is_array($match)) {
             return $this->matchArray($match);
         }
@@ -172,7 +172,7 @@ 
      * @param string $access Class or interface name.
      * @return bool
      */
-    public function offsetExists ($access): bool {
+    public function offsetExists($access): bool {
         return (bool)$this->offsetGet($access);
     }
 
@@ -180,7 +180,7 @@ 
      * @param string $access Class or interface name.
      * @return null|Record|Junction
      */
-    public function offsetGet ($access) {
+    public function offsetGet($access) {
         if (class_exists($access)) {
             return $this->getRecord($access);
         }
@@ -197,7 +197,7 @@ 
      * @param void $value
      * @throws Exception
      */
-    final public function offsetSet ($access, $value): void {
+    final public function offsetSet($access, $value): void {
         throw new Exception('The schema is immutable.');
     }
 
@@ -207,7 +207,7 @@ 
      * @param void $access
      * @throws Exception
      */
-    final public function offsetUnset ($access): void {
+    final public function offsetUnset($access): void {
         $this->offsetSet($access, null);
     }
 
@@ -218,7 +218,7 @@ 
      * @param array $options
      * @return Statement
      */
-    public function prepare ($sql, $options = []): Statement {
+    public function prepare($sql, $options = []): Statement {
         $this->logger->__invoke($sql);
         /** @var Statement $statement */
         $statement = parent::prepare($sql, $options);
@@ -234,7 +234,7 @@ 
      * @param array $ctorargs
      * @return Statement
      */
-    public function query ($sql, $mode = PDO::ATTR_DEFAULT_FETCH_MODE, $arg3 = null, array $ctorargs = []): Statement {
+    public function query($sql, $mode = PDO::ATTR_DEFAULT_FETCH_MODE, $arg3 = null, array $ctorargs = []): Statement {
         $this->logger->__invoke($sql);
         /** @var Statement $statement */
         $statement = parent::query(...func_get_args());
@@ -253,7 +253,7 @@ 
      * @param int $type Ignored.
      * @return string
      */
-    public function quote ($value, $type = null) {
+    public function quote($value, $type = null) {
         if ($value instanceof ExpressionInterface) {
             return $value;
         }
@@ -273,7 +273,7 @@ 
      * @param array $values
      * @return array
      */
-    public function quoteArray (array $values): array {
+    public function quoteArray(array $values): array {
         return array_map([$this, 'quote'], $values);
     }
 
@@ -283,7 +283,7 @@ 
      * @param mixed $value
      * @return array|string
      */
-    public function quoteMixed ($value) {
+    public function quoteMixed($value) {
         if (is_array($value)) {
             return $this->quoteArray($value);
         }
@@ -296,7 +296,7 @@ 
      * @param EntityInterface $entity
      * @return int ID
      */
-    public function save (EntityInterface $entity): int {
+    public function save(EntityInterface $entity): int {
         return $this->getRecord($entity)->save($entity);
     }
 
@@ -304,7 +304,7 @@ 
      * @param Closure $logger
      * @return $this
      */
-    public function setLogger (Closure $logger) {
+    public function setLogger(Closure $logger) {
         $this->logger = $logger;
         return $this;
     }