Removed base models and stores

src/PHPCensor/Store/ProjectStore.php

@@ -1,26 +1,84 @@
 <?php
-/**
- * PHPCI - Continuous Integration for PHP
- *
- * @copyright    Copyright 2014, Block 8 Limited.
- * @license      https://github.com/Block8/PHPCI/blob/master/LICENSE.md
- * @link         https://www.phptesting.org/
- */
 
 namespace PHPCensor\Store;
 
 use b8\Database;
 use PHPCensor\Model\Project;
-use PHPCensor\Store\Base\ProjectStoreBase;
+use PHPCensor\Store;
+use b8\Exception\HttpException;
 
 /**
-* Project Store
-* @author       Dan Cryer <dan@block8.co.uk>
-* @package      PHPCI
-* @subpackage   Core
-*/
-class ProjectStore extends ProjectStoreBase
+ * @author Dan Cryer <dan@block8.co.uk>
+ */
+class ProjectStore extends Store
 {
+    protected $tableName   = 'project';
+    protected $modelName   = '\PHPCensor\Model\Project';
+    protected $primaryKey  = 'id';
+
+    /**
+     * Get a Project by primary key (Id)
+     */
+    public function getByPrimaryKey($value, $useConnection = 'read')
+    {
+        return $this->getById($value, $useConnection);
+    }
+
+    /**
+     * Get a single Project by Id.
+     * @return null|Project
+     */
+    public function getById($value, $useConnection = 'read')
+    {
+        if (is_null($value)) {
+            throw new HttpException('Value passed to ' . __FUNCTION__ . ' cannot be null.');
+        }
+
+        $query = 'SELECT * FROM {{project}} WHERE {{id}} = :id LIMIT 1';
+        $stmt = Database::getConnection($useConnection)->prepareCommon($query);
+        $stmt->bindValue(':id', $value);
+
+        if ($stmt->execute()) {
+            if ($data = $stmt->fetch(\PDO::FETCH_ASSOC)) {
+                return new Project($data);
+            }
+        }
+
+        return null;
+    }
+
+    /**
+     * Get multiple Project by Title.
+     * @return array
+     */
+    public function getByTitle($value, $limit = 1000, $useConnection = 'read')
+    {
+        if (is_null($value)) {
+            throw new HttpException('Value passed to ' . __FUNCTION__ . ' cannot be null.');
+        }
+
+
+        $query = 'SELECT * FROM {{project}} WHERE {{title}} = :title LIMIT :limit';
+        $stmt = Database::getConnection($useConnection)->prepareCommon($query);
+        $stmt->bindValue(':title', $value);
+        $stmt->bindValue(':limit', (int)$limit, \PDO::PARAM_INT);
+
+        if ($stmt->execute()) {
+            $res = $stmt->fetchAll(\PDO::FETCH_ASSOC);
+
+            $map = function ($item) {
+                return new Project($item);
+            };
+            $rtn = array_map($map, $res);
+
+            $count = count($rtn);
+
+            return ['items' => $rtn, 'count' => $count];
+        } else {
+            return ['items' => [], 'count' => 0];
+        }
+    }
+
     /**
      * Returns a list of all branch names PHPCI has run builds against.
      * @param $projectId