miBadger / miBadger.ActiveRecord

src/AbstractActiveRecord.php

Doc Comments +1 added lines, -1 removed lines

@@ -155,7 +155,7 @@
 	/**
 	 * Returns the PDO.
 	 *
-	 * @return PDO the PDO.
+	 * @return \PDO the PDO.
 	 */
 	public function getPdo()
 	{

Indentation +168 added lines, -168 removed lines

@@ -17,172 +17,172 @@
  */
 abstract class AbstractActiveRecord implements ActiveRecordInterface
 {
-	/** @var \PDO The PDO object. */
-	private $pdo;
-
-	/** @var null|int The ID. */
-	private $id;
-
-	/**
-	 * Construct an abstract pdo active record with the given pdo.
-	 *
-	 * @param \PDO $pdo
-	 */
-	public function __construct(\PDO $pdo)
-	{
-		$this->pdo = $pdo;
-		$this->id = null;
-
-		// TODO enable PDO exceptions?
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function create()
-	{
-		$pdoStatement = $this->pdo->prepare($this->getCreateQuery());
-		$pdoStatement->execute($this->getActiveRecordData());
-
-		$this->id = intval($this->pdo->lastInsertId());
-		return $this;
-	}
-
-	/**
-	 * Returns the create query.
-	 *
-	 * @return string the create query.
-	 */
-	private function getCreateQuery()
-	{
-		$columns = array_keys($this->getActiveRecordData());
-		$values = [];
-
-		foreach ($columns as $key => $value) {
-			$values[] = ':' . $value;
-		}
-
-		return sprintf('INSERT INTO %s (%s) VALUES (%s)', $this->getActiveRecordName(), implode(', ', $columns), implode(', ', $values));
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function read($id)
-	{
-		$data = $this->getActiveRecordData();
-
-		$pdoStatement = $this->pdo->prepare($this->getReadQuery());
-		$pdoStatement->execute(['id' => $id]);
-		$result = $pdoStatement->fetch(\PDO::FETCH_ASSOC);
-
-		$this->id = $id;
-
-		foreach ($data as $key => &$value) {
-			$value = $result[$key];
-		}
-
-		return $this;
-	}
-
-	/**
-	 * Returns the read query.
-	 *
-	 * @return string the read query.
-	 */
-	private function getReadQuery()
-	{
-		return sprintf('SELECT * FROM `%s` WHERE `id` = :id', $this->getActiveRecordName());
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function update()
-	{
-		$pdoStatement = $this->pdo->prepare($this->getUpdateQuery());
-		$pdoStatement->execute(['id' => $this->id] + $this->getActiveRecordData());
-
-		return $this;
-	}
-
-	/**
-	 * Returns the update query.
-	 *
-	 * @return string the update query.
-	 */
-	private function getUpdateQuery()
-	{
-		$values = [];
-
-		foreach (array_keys($this->getActiveRecordData()) as $key => $value) {
-			$values[] = $value . ' = :' . $value;
-		}
-
-		return sprintf('UPDATE %s SET %s WHERE `id` = :id', $this->getActiveRecordName(), implode(', ', $values));
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function delete()
-	{
-		$pdoStatement = $this->pdo->prepare($this->getDeleteQuery());
-		$pdoStatement->execute(['id' => $this->id]);
-
-		$this->id = null;
-		return $this;
-	}
-
-	/**
-	 * Returns the delete query.
-	 *
-	 * @return string the delete query.
-	 */
-	private function getDeleteQuery()
-	{
-		return sprintf('SELECT * FROM `%s` WHERE `id` = :id', $this->getActiveRecordName());
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function exists()
-	{
-		return $this->id !== null;
-	}
-
-	/**
-	 * Returns the PDO.
-	 *
-	 * @return PDO the PDO.
-	 */
-	public function getPdo()
-	{
-		return $this->pdo;
-	}
-
-	/**
-	 * Returns the ID.
-	 *
-	 * @return null|int The ID.
-	 */
-	public function getId()
-	{
-		return $this->id;
-	}
-
-	/**
-	 * Returns the active record name.
-	 *
-	 * @return string the active record name.
-	 */
-	abstract protected function getActiveRecordName();
-
-	/**
-	 * Returns the active record data.
-	 *
-	 * @return array the active record data.
-	 */
-	abstract protected function getActiveRecordData();
+    /** @var \PDO The PDO object. */
+    private $pdo;
+
+    /** @var null|int The ID. */
+    private $id;
+
+    /**
+     * Construct an abstract pdo active record with the given pdo.
+     *
+     * @param \PDO $pdo
+     */
+    public function __construct(\PDO $pdo)
+    {
+        $this->pdo = $pdo;
+        $this->id = null;
+
+        // TODO enable PDO exceptions?
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function create()
+    {
+        $pdoStatement = $this->pdo->prepare($this->getCreateQuery());
+        $pdoStatement->execute($this->getActiveRecordData());
+
+        $this->id = intval($this->pdo->lastInsertId());
+        return $this;
+    }
+
+    /**
+     * Returns the create query.
+     *
+     * @return string the create query.
+     */
+    private function getCreateQuery()
+    {
+        $columns = array_keys($this->getActiveRecordData());
+        $values = [];
+
+        foreach ($columns as $key => $value) {
+            $values[] = ':' . $value;
+        }
+
+        return sprintf('INSERT INTO %s (%s) VALUES (%s)', $this->getActiveRecordName(), implode(', ', $columns), implode(', ', $values));
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function read($id)
+    {
+        $data = $this->getActiveRecordData();
+
+        $pdoStatement = $this->pdo->prepare($this->getReadQuery());
+        $pdoStatement->execute(['id' => $id]);
+        $result = $pdoStatement->fetch(\PDO::FETCH_ASSOC);
+
+        $this->id = $id;
+
+        foreach ($data as $key => &$value) {
+            $value = $result[$key];
+        }
+
+        return $this;
+    }
+
+    /**
+     * Returns the read query.
+     *
+     * @return string the read query.
+     */
+    private function getReadQuery()
+    {
+        return sprintf('SELECT * FROM `%s` WHERE `id` = :id', $this->getActiveRecordName());
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function update()
+    {
+        $pdoStatement = $this->pdo->prepare($this->getUpdateQuery());
+        $pdoStatement->execute(['id' => $this->id] + $this->getActiveRecordData());
+
+        return $this;
+    }
+
+    /**
+     * Returns the update query.
+     *
+     * @return string the update query.
+     */
+    private function getUpdateQuery()
+    {
+        $values = [];
+
+        foreach (array_keys($this->getActiveRecordData()) as $key => $value) {
+            $values[] = $value . ' = :' . $value;
+        }
+
+        return sprintf('UPDATE %s SET %s WHERE `id` = :id', $this->getActiveRecordName(), implode(', ', $values));
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function delete()
+    {
+        $pdoStatement = $this->pdo->prepare($this->getDeleteQuery());
+        $pdoStatement->execute(['id' => $this->id]);
+
+        $this->id = null;
+        return $this;
+    }
+
+    /**
+     * Returns the delete query.
+     *
+     * @return string the delete query.
+     */
+    private function getDeleteQuery()
+    {
+        return sprintf('SELECT * FROM `%s` WHERE `id` = :id', $this->getActiveRecordName());
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function exists()
+    {
+        return $this->id !== null;
+    }
+
+    /**
+     * Returns the PDO.
+     *
+     * @return PDO the PDO.
+     */
+    public function getPdo()
+    {
+        return $this->pdo;
+    }
+
+    /**
+     * Returns the ID.
+     *
+     * @return null|int The ID.
+     */
+    public function getId()
+    {
+        return $this->id;
+    }
+
+    /**
+     * Returns the active record name.
+     *
+     * @return string the active record name.
+     */
+    abstract protected function getActiveRecordName();
+
+    /**
+     * Returns the active record data.
+     *
+     * @return array the active record data.
+     */
+    abstract protected function getActiveRecordData();
 }

src/AbstractActiveRecordSearch.php

Indentation +50 added lines, -50 removed lines

@@ -17,65 +17,65 @@
  */
 abstract class AbstractActiveRecordSearch extends AbstractActiveRecord
 {
-	/**
-	 * {@inheritdoc}
-	 */
-	public function search($options = [])
-	{
-		$name = $this->getActiveRecordName();
-		$data = $this->getActiveRecordData();
+    /**
+     * {@inheritdoc}
+     */
+    public function search($options = [])
+    {
+        $name = $this->getActiveRecordName();
+        $data = $this->getActiveRecordData();
 
-		$pdoStatement = $this->getPdo()->prepare($this->getSearchQuery($options));
-		array_walk_recursive($options, function (&$value) use ($pdoStatement) {
-			static $index = 1;
+        $pdoStatement = $this->getPdo()->prepare($this->getSearchQuery($options));
+        array_walk_recursive($options, function (&$value) use ($pdoStatement) {
+            static $index = 1;
 
-			$pdoStatement->bindParam($index++, $value);
-		});
+            $pdoStatement->bindParam($index++, $value);
+        });
 
-		$pdoStatement->execute();
-		$result = [];
+        $pdoStatement->execute();
+        $result = [];
 
-		while ($row = $pdoStatement->fetch()) {
-			$x = new static($this->getPdo());
-			$x->id = intval($row['id']);
+        while ($row = $pdoStatement->fetch()) {
+            $x = new static($this->getPdo());
+            $x->id = intval($row['id']);
 
-			foreach ($x->getActiveRecordData() as $key => &$value) {
-				$value = $row[$key];
-			}
+            foreach ($x->getActiveRecordData() as $key => &$value) {
+                $value = $row[$key];
+            }
 
-			$result[] = $x;
-		}
+            $result[] = $x;
+        }
 
-		return $result;
-	}
+        return $result;
+    }
 
-	/**
-	 * Returns the search query with the given options.
-	 *
-	 * @param arrray $options = []
-	 * @return string the search query with the given options.
-	 */
-	private function getSearchQuery($options = [])
-	{
-		$columns = array_keys($this->getActiveRecordData());
-		$values = [];
+    /**
+     * Returns the search query with the given options.
+     *
+     * @param arrray $options = []
+     * @return string the search query with the given options.
+     */
+    private function getSearchQuery($options = [])
+    {
+        $columns = array_keys($this->getActiveRecordData());
+        $values = [];
 
-		foreach ($options as $key => $value) {
-			if (!in_array($key, $columns)) {
-				throw new ActiveRecordException('Invalid option key.');
-			}
+        foreach ($options as $key => $value) {
+            if (!in_array($key, $columns)) {
+                throw new ActiveRecordException('Invalid option key.');
+            }
 
-			if (is_int($value)) {
-				$values[] = $key . ' = ?';
-			} elseif (is_string($value)) {
-				$values[] = $key . ' LIKE ?';
-			} elseif(is_array($value) && !empty($value)) {
-				$values[] = $key . ' IN(' . implode(',', array_fill(0, count($value), '?')) . ')';
-			} else {
-				throw new ActiveRecordException('Invalid option value.');
-			}
-		}
+            if (is_int($value)) {
+                $values[] = $key . ' = ?';
+            } elseif (is_string($value)) {
+                $values[] = $key . ' LIKE ?';
+            } elseif(is_array($value) && !empty($value)) {
+                $values[] = $key . ' IN(' . implode(',', array_fill(0, count($value), '?')) . ')';
+            } else {
+                throw new ActiveRecordException('Invalid option value.');
+            }
+        }
 
-		return sprintf('SELECT * FROM %s %s %s', $this->getActiveRecordName(), empty($values) ? '' : 'WHERE', implode(' AND ', $values));
-	}
+        return sprintf('SELECT * FROM %s %s %s', $this->getActiveRecordName(), empty($values) ? '' : 'WHERE', implode(' AND ', $values));
+    }
 }

Spacing +2 added lines, -2 removed lines

@@ -26,7 +26,7 @@ 
 		$data = $this->getActiveRecordData();
 
 		$pdoStatement = $this->getPdo()->prepare($this->getSearchQuery($options));
-		array_walk_recursive($options, function (&$value) use ($pdoStatement) {
+		array_walk_recursive($options, function(&$value) use ($pdoStatement) {
 			static $index = 1;
 
 			$pdoStatement->bindParam($index++, $value);
@@ -69,7 +69,7 @@ 
 				$values[] = $key . ' = ?';
 			} elseif (is_string($value)) {
 				$values[] = $key . ' LIKE ?';
-			} elseif(is_array($value) && !empty($value)) {
+			} elseif (is_array($value) && !empty($value)) {
 				$values[] = $key . ' IN(' . implode(',', array_fill(0, count($value), '?')) . ')';
 			} else {
 				throw new ActiveRecordException('Invalid option value.');

src/ActiveRecordInterface.php

Indentation +35 added lines, -35 removed lines

@@ -19,43 +19,43 @@
  */
 interface ActiveRecordInterface
 {
-	/**
-	 * Create the record.
-	 *
-	 * @return $this
-	 * @throws ActiveRecordException on failure.
-	 */
-	public function create();
+    /**
+     * Create the record.
+     *
+     * @return $this
+     * @throws ActiveRecordException on failure.
+     */
+    public function create();
 
-	/**
-	 * Read the record with the given ID.
-	 *
-	 * @param int $id
-	 * @return $this
-	 * @throws ActiveRecordException on failure.
-	 */
-	public function read($id);
+    /**
+     * Read the record with the given ID.
+     *
+     * @param int $id
+     * @return $this
+     * @throws ActiveRecordException on failure.
+     */
+    public function read($id);
 
-	/**
-	 * Update the record.
-	 *
-	 * @return $this
-	 * @throws ActiveRecordException on failure.
-	 */
-	public function update();
+    /**
+     * Update the record.
+     *
+     * @return $this
+     * @throws ActiveRecordException on failure.
+     */
+    public function update();
 
-	/**
-	 * Delete the record.
-	 *
-	 * @return $this
-	 * @throws ActiveRecordException on failure.
-	 */
-	public function delete();
+    /**
+     * Delete the record.
+     *
+     * @return $this
+     * @throws ActiveRecordException on failure.
+     */
+    public function delete();
 
-	/**
-	 * Returns true if the record exists.
-	 *
-	 * @return bool true if the records exists.
-	 */
-	public function exists();
+    /**
+     * Returns true if the record exists.
+     *
+     * @return bool true if the records exists.
+     */
+    public function exists();
 }

src/ActiveRecordSearchInterface.php

Indentation +8 added lines, -8 removed lines

@@ -17,12 +17,12 @@
  */
 interface ActiveRecordSearchInterface extends ActiveRecordInterface
 {
-	/**
-	 * Returns the records with the given options.
-	 *
-	 * @param array $options = []
-	 * @return static[] the records with the given options.
-	 * @throws ActiveRecordException on failure.
-	 */
-	public function search($options = []);
+    /**
+     * Returns the records with the given options.
+     *
+     * @param array $options = []
+     * @return static[] the records with the given options.
+     * @throws ActiveRecordException on failure.
+     */
+    public function search($options = []);
 }