Model::create() - Code Metrics - Inspection of "Checkpoint 2" - andela-joyebanji/PotatoORM - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#4)

by Oyebanji Jacob

created 2016-03-16 11:08 UTC

Model::create() A

↳ Parent: Model

Complexity

Conditions	2
Paths	2

Size

Total Lines	22
Code Lines	16

Duplication

Lines	7
Ratio	31.82 %

Importance

Changes	2
Bugs	1	Features	1

Metric	Value
c	2
b	1
f	1
dl	7
loc	22
rs	9.2
cc	2
eloc	16
nc	2
nop	0

<?php

namespace Pyjac\ORM;

use Doctrine\Common\Inflector\Inflector;
use PDO;
use Pyjac\ORM\Exception\ModelNotFoundException;

abstract class Model implements ModelInterface
{
    protected $properties = [];

    /**
     * Store instance of database connection used.
     *
     * @var [type]
     */
    protected $databaseConnection;

     /**
      *  The id of the model.
      *
      * @property string $id
      */

     /**
      * Create a model instance.
      */
     public function __construct(DatabaseConnectionInterface $databaseConnection = null)
     {
         if ($databaseConnection == null) {
             $this->databaseConnection = DatabaseConnection::getInstance()->databaseConnection;
         }
         $this->databaseConnection = $databaseConnection;
     }

    /**
     * Sets into $properties the $key => $value pairs.
     *
     * @param string $key
     * @param string $val
     */
    public function __set($key, $val)
    {
        $this->properties[$key] = $val;
    }

    /**
     * @param string $key
     *
     * @return array
     */
    public function __get($key)
    {
        return $this->properties[$key];
    }

     /**
      * Get all the model properties.
      *
      * @return array
      */
     public function getProperties()
     {
         return $this->properties;
     }

     /**
      * Set model properties.
      */
     public function setProperties(array $properties)
     {
         $this->properties = $properties;
     }

    /**
     * Pluralize the name of the child class.
     *
     * @return string
     */
    public function getTableName()
    {
        $className = explode('\\', get_called_class());

        return Inflector::pluralize(strtolower(end($className)));
    }

    /**
     * Find the particular model with the passed id.
     *
     * @param int $id
     *
     * @return object
     */
    public static function find($id)
    {
        $model = new static();

        return $model->get($id);
    }

    /**
     * Get the particular model with the passed id.
     *
     * @param int $id
     *
     * @return object
     */
    public function get($id)
    {
        $sql = "SELECT * FROM {$this->getTableName()} WHERE id={$id}";
        $sqlStatement = $this->databaseConnection->prepare($sql);

        $sqlStatement->setFetchMode(PDO::FETCH_CLASS, get_called_class());
        $sqlStatement->execute();
        if ($sqlStatement->rowCount() < 1) {
            throw new ModelNotFoundException($id);
        }

        return $sqlStatement->fetch();
    }

    /**
     * Get all the models from the database.
     *
     * @return array
     */
    public static function getAll()
    {
        $model = new static();

        return $model->all();
    }

    /**
     * Returns all the models from the database.
     *
     * @return array
     */
    public function all()
    {
        $sql = "SELECT * FROM {$this->getTableName()}";
        $sqlStatement = $this->databaseConnection->prepare($sql);

        $sqlStatement->execute();

        return $sqlStatement->fetchAll(PDO::FETCH_CLASS);
    }

    /**
     * Update the model in the database.
     *
     * @return int
     */
    public function update()
    {
        $bindNameParameters = [];
        $sqlUpdate = 'UPDATE '.$this->getTableName().' SET ';
        foreach ($this->properties as $columnName => $columnValue) {

            if ($columnName == 'id') {
                continue;
            }
            $bindColumnName = ':'.$columnName;
            $sqlUpdate .= "$columnName = $bindColumnName,";
            $bindNameParameters[$bindColumnName] = $columnValue;
        }
        //Remove the last comma in sql command then join it to the other query part.
        $sqlUpdate = substr($sqlUpdate, 0, -1).' WHERE id = :id';
        $sqlStatement = $this->databaseConnection->prepare($sqlUpdate);

        $bindNameParameters[':id'] = $this->properties['id'];
        $sqlStatement->execute($bindNameParameters);

        return $sqlStatement->rowCount();
    }

    /**
     * Insert the model values into the database.
     *
     * @return int
     */
    public function create()
    {
        $columnNames = '';
        $columnValues = '';
        $bindNameParameters = [];
        $sqlCreate = 'INSERT'.' INTO '.$this->getTableName().' (';
        foreach ($this->properties as $columnName => $columnValue) {

            $bindColumnName = ':'.$columnName;
            $columnNames .= $columnName.',';
            $columnValues .= $bindColumnName.',';
            $bindNameParameters[$bindColumnName] = $columnValue;
        }
        // Remove ending comma and whitespace.
        $columnNames = substr($columnNames, 0, -1);
        $columnValues = substr($columnValues, 0, -1);

        $sqlCreate .= $columnNames.') VALUES ('.$columnValues.')';
        $sqlStatement = $this->databaseConnection->prepare($sqlCreate);

        $sqlStatement->execute($bindNameParameters);

        return $sqlStatement->rowCount();
    }

    /**
     * Save the model data to the database.
     *
     * @return bool
     */
    public function save()
    {
        return isset($this->properties['id']) ? $this->update() : $this->create();
    }

    /**
     * Delete a model from the database.
     *
     * @param int $id
     *
     * @return bool
     */
    public static function destroy($id)
    {
        $model = new static();

        return $model->delete($id);
    }

    /**
     * Delete model from the database.
     *
     * @param int $id
     *
     * @return bool
     */
    public function delete($id)
    {
        $sql = 'DELETE'.' FROM '.self::getTableName().' WHERE id = '.$id;
        $sqlStatment = $this->databaseConnection->prepare($sql);

        $sqlStatment->execute();

        return ($sqlStatment->rowCount() > 0) ? true : false;
    }
}


1		<?php
2
3		namespace Pyjac\ORM;
4
5		use Doctrine\Common\Inflector\Inflector;
6		use PDO;
7		use Pyjac\ORM\Exception\ModelNotFoundException;
8
9		abstract class Model implements ModelInterface
10		{
11		protected $properties = [];
12
13		/**
14		* Store instance of database connection used.
15		*
16		* @var [type]
17		*/
18		protected $databaseConnection;
19
20		/**
21		* The id of the model.
22		*
23		* @property string $id
24		*/
25
26		/**
27		* Create a model instance.
28		*/
29		public function __construct(DatabaseConnectionInterface $databaseConnection = null)
30		{
31		if ($databaseConnection == null) {
32		$this->databaseConnection = DatabaseConnection::getInstance()->databaseConnection;
33		}
34		$this->databaseConnection = $databaseConnection;
35		}
36
37		/**
38		* Sets into $properties the $key => $value pairs.
39		*
40		* @param string $key
41		* @param string $val
42		*/
43		public function __set($key, $val)
44		{
45		$this->properties[$key] = $val;
46		}
47
48		/**
49		* @param string $key
50		*
51		* @return array
52		*/
53		public function __get($key)
54		{
55		return $this->properties[$key];
56		}
57
58		/**
59		* Get all the model properties.
60		*
61		* @return array
62		*/
63		public function getProperties()
64		{
65		return $this->properties;
66		}
67
68		/**
69		* Set model properties.
70		*/
71		public function setProperties(array $properties)
72		{
73		$this->properties = $properties;
74		}
75
76		/**
77		* Pluralize the name of the child class.
78		*
79		* @return string
80		*/
81		public function getTableName()
82		{
83		$className = explode('\\', get_called_class());
84
85		return Inflector::pluralize(strtolower(end($className)));
86		}
87
88		/**
89		* Find the particular model with the passed id.
90		*
91		* @param int $id
92		*
93		* @return object
94		*/
95		public static function find($id)
96		{
97		$model = new static();
98
99		return $model->get($id);
100		}
101
102		/**
103		* Get the particular model with the passed id.
104		*
105		* @param int $id
106		*
107		* @return object
108		*/
109		public function get($id)
110		{
111		$sql = "SELECT * FROM {$this->getTableName()} WHERE id={$id}";
112		$sqlStatement = $this->databaseConnection->prepare($sql);
		0 ignored issues – show Bug introduced 2016-03-05 15:05 UTC by Report Bug Copy Issue Report The method `prepare()` does not seem to exist on `object<Pyjac\ORM\DatabaseConnectionInterface>`. This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces. This is most likely a typographical error or the method has been renamed. Loading history...
113		$sqlStatement->setFetchMode(PDO::FETCH_CLASS, get_called_class());
114		$sqlStatement->execute();
115		if ($sqlStatement->rowCount() < 1) {
116		throw new ModelNotFoundException($id);
117		}
118
119		return $sqlStatement->fetch();
120		}
121
122		/**
123		* Get all the models from the database.
124		*
125		* @return array
126		*/
127		public static function getAll()
128		{
129		$model = new static();
130
131		return $model->all();
132		}
133
134		/**
135		* Returns all the models from the database.
136		*
137		* @return array
138		*/
139		public function all()
140		{
141		$sql = "SELECT * FROM {$this->getTableName()}";
142		$sqlStatement = $this->databaseConnection->prepare($sql);
		0 ignored issues – show Bug introduced 2016-03-05 15:05 UTC by Report Bug Copy Issue Report The method `prepare()` does not seem to exist on `object<Pyjac\ORM\DatabaseConnectionInterface>`. This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces. This is most likely a typographical error or the method has been renamed. Loading history...
143		$sqlStatement->execute();
144
145		return $sqlStatement->fetchAll(PDO::FETCH_CLASS);
146		}
147
148		/**
149		* Update the model in the database.
150		*
151		* @return int
152		*/
153		public function update()
154		{
155		$bindNameParameters = [];
156		$sqlUpdate = 'UPDATE '.$this->getTableName().' SET ';
157	View Code Duplication	foreach ($this->properties as $columnName => $columnValue) {
		0 ignored issues – show Duplication introduced 2016-03-05 15:05 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
158		if ($columnName == 'id') {
159		continue;
160		}
161		$bindColumnName = ':'.$columnName;
162		$sqlUpdate .= "$columnName = $bindColumnName,";
163		$bindNameParameters[$bindColumnName] = $columnValue;
164		}
165		//Remove the last comma in sql command then join it to the other query part.
166		$sqlUpdate = substr($sqlUpdate, 0, -1).' WHERE id = :id';
167		$sqlStatement = $this->databaseConnection->prepare($sqlUpdate);
		0 ignored issues – show Bug introduced 2016-03-05 12:41 UTC by Report Bug Copy Issue Report The method `prepare()` does not seem to exist on `object<Pyjac\ORM\DatabaseConnectionInterface>`. This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces. This is most likely a typographical error or the method has been renamed. Loading history...
168		$bindNameParameters[':id'] = $this->properties['id'];
169		$sqlStatement->execute($bindNameParameters);
170
171		return $sqlStatement->rowCount();
172		}
173
174		/**
175		* Insert the model values into the database.
176		*
177		* @return int
178		*/
179		public function create()
180		{
181		$columnNames = '';
182		$columnValues = '';
183		$bindNameParameters = [];
184		$sqlCreate = 'INSERT'.' INTO '.$this->getTableName().' (';
185	View Code Duplication	foreach ($this->properties as $columnName => $columnValue) {
		0 ignored issues – show Duplication introduced 2016-03-05 15:05 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
186		$bindColumnName = ':'.$columnName;
187		$columnNames .= $columnName.',';
188		$columnValues .= $bindColumnName.',';
189		$bindNameParameters[$bindColumnName] = $columnValue;
190		}
191		// Remove ending comma and whitespace.
192		$columnNames = substr($columnNames, 0, -1);
193		$columnValues = substr($columnValues, 0, -1);
194
195		$sqlCreate .= $columnNames.') VALUES ('.$columnValues.')';
196		$sqlStatement = $this->databaseConnection->prepare($sqlCreate);
		0 ignored issues – show Bug introduced 2016-03-05 12:41 UTC by Report Bug Copy Issue Report The method `prepare()` does not seem to exist on `object<Pyjac\ORM\DatabaseConnectionInterface>`. This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces. This is most likely a typographical error or the method has been renamed. Loading history...
197		$sqlStatement->execute($bindNameParameters);
198
199		return $sqlStatement->rowCount();
200		}
201
202		/**
203		* Save the model data to the database.
204		*
205		* @return bool
206		*/
207		public function save()
208		{
209		return isset($this->properties['id']) ? $this->update() : $this->create();
210		}
211
212		/**
213		* Delete a model from the database.
214		*
215		* @param int $id
216		*
217		* @return bool
218		*/
219		public static function destroy($id)
220		{
221		$model = new static();
222
223		return $model->delete($id);
224		}
225
226		/**
227		* Delete model from the database.
228		*
229		* @param int $id
230		*
231		* @return bool
232		*/
233		public function delete($id)
234		{
235		$sql = 'DELETE'.' FROM '.self::getTableName().' WHERE id = '.$id;
236		$sqlStatment = $this->databaseConnection->prepare($sql);
		0 ignored issues – show Bug introduced 2016-03-05 12:41 UTC by Report Bug Copy Issue Report The method `prepare()` does not seem to exist on `object<Pyjac\ORM\DatabaseConnectionInterface>`. This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces. This is most likely a typographical error or the method has been renamed. Loading history...
237		$sqlStatment->execute();
238
239		return ($sqlStatment->rowCount() > 0) ? true : false;
240		}
241		}
242

andela-joyebanji / PotatoORM

Pull Request — master (#4)

Model::create() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like