Pyjac\ORM\Model

Complexity

Total Complexity

20

Size/Duplication

Total Lines	209
Duplicated Lines	6.22 %

Coupling/Cohesion

Components	1
Dependencies	1

14 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__set()	0	4	1
A	__get()	0	4	1
A	getProperties()	0	4	1
A	getTableName()	0	6	1
A	find()	0	5	1
A	get()	0	11	2
A	getAll()	0	5	1
A	all()	0	9	1
A	update()	6	20	3
A	create()	7	23	2
A	save()	0	4	2
A	destroy()	0	5	1
A	delete()	0	7	2

<?php 

namespace Pyjac\ORM;

abstract class Model implements ModelInterface
{

   
    protected  $properties = [];

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

    /**
     * Create a model instance.
     * 
     */
     public function __construct()
    {
        $this->databaseConnection = DatabaseConnection::getInstance()->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;
     }
    /**
    * Gets the name of the child class with a 's'.
    *
    * @return string
    */
    public function getTableName()
    {
        $className = explode('\\', get_called_class());
        $table = strtolower(end($className) .'s');
        return $table;
    }
    /**
    * 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($this->databaseConnection::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()}";
        $row = $this->databaseConnection->prepare($sql);
        $row->execute();
       
        return $row->fetchAll($this->databaseConnection::FETCH_CLASS);

    }
    /** 
     * Update the model in the database.
     * 
     * @return int
    */
    private function update()
    {
       
        $columnNames = "";

$columnNames is not used, you could remove the assignment.

        $columnValues = "";

$columnValues is not used, you could remove the assignment.

        $bindNameParameters = [];
        $sqlUpdate = "UPDATE " . $this->getTableName() . " SET " ;
        foreach ($this->properties as $columnName => $columnValue) {

This code seems to be duplicated across your project.

            if($key == 'id') continue;

The variable $key does not exist. Did you forget to declare it?

            $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);
        $sqlStatement->bindValue(":id", $this->properties['id']);
        $sqlStatement->execute($bindNameParameters);
        return $sqlStatement->rowCount();
    }

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

This code seems to be duplicated across your project.

            $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 boolean
     */
    public function save()
    {
        return $this->id ? $this->update() : $this->create();

The property id does not exist on object<Pyjac\ORM\Model>. Since you implemented __get, maybe consider adding a @property annotation.

    }

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

    /**
     * Delete model from the database.
     * 
     * @param  int $id
     * @return boolean
     */
    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;
    }

}