andela-tolotin / Potato-ORM

src/Database/DatabaseHandler.php

Indentation +158 added lines, -158 removed lines

@@ -18,131 +18,131 @@ 
 
 class DatabaseHandler {
 
-    private $tableFields;
-    private $dbHelperInstance;
-    private $dbConnection;
-    private $model;
+	private $tableFields;
+	private $dbHelperInstance;
+	private $dbConnection;
+	private $model;
     
-    /**
-     * This is a constructor; a default method  that will be called automatically during class instantiation
-     */
-    public function __construct($modelClassName, $dbConn = Null) 
-    {
-        if (is_null($dbConn)) {
-            $this->dbConnection = new DatabaseConnection();
-
-        } else {
-            $this->dbConnection = $dbConn;
-
-        }
+	/**
+	 * This is a constructor; a default method  that will be called automatically during class instantiation
+	 */
+	public function __construct($modelClassName, $dbConn = Null) 
+	{
+		if (is_null($dbConn)) {
+			$this->dbConnection = new DatabaseConnection();
+
+		} else {
+			$this->dbConnection = $dbConn;
+
+		}
         
-        $this->model = $modelClassName;
-     }
+		$this->model = $modelClassName;
+	 }
      
-    /**
-     * This method create a record and store it in a table row
-     * @params associative array, string tablename
-     * @return boolean true or false
-     */
-    public function create($associative1DArray, $tableName, $dbConn = Null) 
-    {
-        $tableFields = $this->getColumnNames($this->model, $this->dbConnection);
-
-        $unexpectedFields = self::checkIfMagicSetterContainsIsSameAsClassModel($tableFields, $associative1DArray);
+	/**
+	 * This method create a record and store it in a table row
+	 * @params associative array, string tablename
+	 * @return boolean true or false
+	 */
+	public function create($associative1DArray, $tableName, $dbConn = Null) 
+	{
+		$tableFields = $this->getColumnNames($this->model, $this->dbConnection);
+
+		$unexpectedFields = self::checkIfMagicSetterContainsIsSameAsClassModel($tableFields, $associative1DArray);
       
-      if (count($unexpectedFields) > 0) {
-          throw TableFieldUndefinedException::reportUnknownTableField($unexpectedFields,"needs to be created as a table field");
-      }
+	  if (count($unexpectedFields) > 0) {
+		  throw TableFieldUndefinedException::reportUnknownTableField($unexpectedFields,"needs to be created as a table field");
+	  }
 
-      unset($associative1DArray[0]);
+	  unset($associative1DArray[0]);
 
-      if (is_null($dbConn)) {
-          $dbConn = $this->dbConnection;
+	  if (is_null($dbConn)) {
+		  $dbConn = $this->dbConnection;
 
-      }
+	  }
 
-      return $this->insertRecord($dbConn, $tableName, $associative1DArray);
+	  return $this->insertRecord($dbConn, $tableName, $associative1DArray);
 
-    }
+	}
     
-    /**
-     * This method runs the insertion query
-     * @param  $dbConn           
-     * @param  $tableName          
-     * @param  $associative1DArray 
-     * @return boolean true         
-     */
-    private function  insertRecord($dbConn, $tableName, $associative1DArray) 
-    {
-        $insertQuery = 'INSERT INTO '.$tableName;
+	/**
+	 * This method runs the insertion query
+	 * @param  $dbConn           
+	 * @param  $tableName          
+	 * @param  $associative1DArray 
+	 * @return boolean true         
+	 */
+	private function  insertRecord($dbConn, $tableName, $associative1DArray) 
+	{
+		$insertQuery = 'INSERT INTO '.$tableName;
 
-        $TableValues = implode(',',array_keys($associative1DArray));
+		$TableValues = implode(',',array_keys($associative1DArray));
 
-        foreach ($associative1DArray as $field => $value) {
-            $FormValues[] = "'".trim(addslashes($value))."'";
-        }
+		foreach ($associative1DArray as $field => $value) {
+			$FormValues[] = "'".trim(addslashes($value))."'";
+		}
 
-        $splittedTableValues = implode(',', $FormValues);
+		$splittedTableValues = implode(',', $FormValues);
 
-        $insertQuery.= ' ('.$TableValues.')';
-        $insertQuery.= ' VALUES ('.$splittedTableValues.')';
+		$insertQuery.= ' ('.$TableValues.')';
+		$insertQuery.= ' VALUES ('.$splittedTableValues.')';
 
-        $executeQuery = $dbConn->exec($insertQuery);
+		$executeQuery = $dbConn->exec($insertQuery);
 
-        if ($executeQuery) {
-            return true;
-        }
+		if ($executeQuery) {
+			return true;
+		}
 
-        return false;
+		return false;
 
-        throw NoRecordInsertionException::checkNoRecordAddedException("Record not inserted successfully");
-      }
+		throw NoRecordInsertionException::checkNoRecordAddedException("Record not inserted successfully");
+	  }
 
-    /**
-     * This method updates any table by supplying 3 parameter
-     * @params: $updateParams, $tableName, $associative1DArray
-     * @return boolean true or false
-     */
-    public function update(array $updateParams, $tableName, $associative1DArray, $dbConn = null)
-    {
-        $sql = "";
+	/**
+	 * This method updates any table by supplying 3 parameter
+	 * @params: $updateParams, $tableName, $associative1DArray
+	 * @return boolean true or false
+	 */
+	public function update(array $updateParams, $tableName, $associative1DArray, $dbConn = null)
+	{
+		$sql = "";
 
-        if (is_null($dbConn)) {
-            $dbConn = $this->dbConnection;
-        }
+		if (is_null($dbConn)) {
+			$dbConn = $this->dbConnection;
+		}
 
-        $updateSql = "UPDATE `$tableName` SET ";
+		$updateSql = "UPDATE `$tableName` SET ";
 
-        unset($associative1DArray['id']);
+		unset($associative1DArray['id']);
 
-        $unexpectedFields = self::checkIfMagicSetterContainsIsSameAsClassModel($this->getColumnNames($this->model, $this->dbConnection), $associative1DArray);
+		$unexpectedFields = self::checkIfMagicSetterContainsIsSameAsClassModel($this->getColumnNames($this->model, $this->dbConnection), $associative1DArray);
 
-        if (count($unexpectedFields) > 0) {
-            throw TableFieldUndefinedException::reportUnknownTableField($unexpectedFields, "needs to be created as a table field");
-        }
+		if (count($unexpectedFields) > 0) {
+			throw TableFieldUndefinedException::reportUnknownTableField($unexpectedFields, "needs to be created as a table field");
+		}
 
-        foreach ($associative1DArray as $field => $value) {
-            $sql .= "`$field` = '$value'".",";
-        }
+		foreach ($associative1DArray as $field => $value) {
+			$sql .= "`$field` = '$value'".",";
+		}
 
-        $updateSql .= $this->prepareUpdateQuery($sql);
+		$updateSql .= $this->prepareUpdateQuery($sql);
 
-        foreach ($updateParams as $key => $val) {
-            $updateSql .= " WHERE $key = $val";
-        }
+		foreach ($updateParams as $key => $val) {
+			$updateSql .= " WHERE $key = $val";
+		}
 
-        $stmt = $dbConn->prepare($updateSql);
+		$stmt = $dbConn->prepare($updateSql);
 
-        $boolResponse = $stmt->execute();
+		$boolResponse = $stmt->execute();
 
-        if ($boolResponse) {
-            return true;
-        }
+		if ($boolResponse) {
+			return true;
+		}
 
-        return false;
+		return false;
 
-        throw NoRecordUpdateException::checkNoRecordUpdateException("Record not updated successfully");
-    }
+		throw NoRecordUpdateException::checkNoRecordUpdateException("Record not updated successfully");
+	}
     
   /**
    * This method retrieves record from a table
@@ -151,32 +151,32 @@ 
    */
    public static function read($id, $tableName, $dbConn = null)
    {
-       $tableData = [];
+	   $tableData = [];
 
-       if (is_null($dbConn)) {
-           $dbConn = new DatabaseConnection();
-       }
+	   if (is_null($dbConn)) {
+		   $dbConn = new DatabaseConnection();
+	   }
 
-       $sql = $id ? 'SELECT * FROM '.$tableName.' WHERE id = '.$id : 'SELECT * FROM '.$tableName;
+	   $sql = $id ? 'SELECT * FROM '.$tableName.' WHERE id = '.$id : 'SELECT * FROM '.$tableName;
 
-       try {
-           $stmt = $dbConn->prepare($sql);
-           $stmt->bindValue(':table', $tableName);
-           $stmt->bindValue(':id', $id);
-           $stmt->execute();
+	   try {
+		   $stmt = $dbConn->prepare($sql);
+		   $stmt->bindValue(':table', $tableName);
+		   $stmt->bindValue(':id', $id);
+		   $stmt->execute();
 
-       } catch (PDOException $e) {
-        return  $e->getMessage();
+	   } catch (PDOException $e) {
+		return  $e->getMessage();
 
-       }
+	   }
 
-       $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
+	   $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
 
-       foreach ($results as $result) {
-           array_push($tableData, $result);
-       }
+	   foreach ($results as $result) {
+		   array_push($tableData, $result);
+	   }
 
-       return $tableData;
+	   return $tableData;
 
    }
    
@@ -187,20 +187,20 @@ 
    */
   public static function delete($id, $tableName, $dbConn = null)
   {
-      if (is_null($dbConn)) {
-          $dbConn = new DatabaseConnection();
-      }
+	  if (is_null($dbConn)) {
+		  $dbConn = new DatabaseConnection();
+	  }
 
-      $sql = 'DELETE FROM '.$tableName.' WHERE id = '.$id;
+	  $sql = 'DELETE FROM '.$tableName.' WHERE id = '.$id;
 
-      $boolResponse = $dbConn->exec($sql);
+	  $boolResponse = $dbConn->exec($sql);
 
-      if ($boolResponse) {
-        return true;
+	  if ($boolResponse) {
+		return true;
 
-      }
+	  }
 
-      throw NoRecordDeletionException::checkNoRecordDeleteException("Record not deleted successfully");
+	  throw NoRecordDeletionException::checkNoRecordDeleteException("Record not deleted successfully");
   }
   
   /**
@@ -211,15 +211,15 @@ 
    */
   public static function checkIfMagicSetterContainsIsSameAsClassModel(array $tableColumn, array $userSetterArray)
   {
-      $unexpectedFields = [];
+	  $unexpectedFields = [];
 
-      foreach ($userSetterArray as $key => $val) {
-          if (!in_array($key,$tableColumn)) {
-              $unexpectedFields[] = $key;
-          }
-      }
+	  foreach ($userSetterArray as $key => $val) {
+		  if (!in_array($key,$tableColumn)) {
+			  $unexpectedFields[] = $key;
+		  }
+	  }
 
-      return $unexpectedFields;
+	  return $unexpectedFields;
 
   }
   
@@ -230,13 +230,13 @@ 
    */
   public function prepareUpdateQuery($sql)
   {
-      $splittedQuery = explode(",",$sql);
+	  $splittedQuery = explode(",",$sql);
 
-      array_pop($splittedQuery);
+	  array_pop($splittedQuery);
 
-      $mergeData = implode(",",$splittedQuery);
+	  $mergeData = implode(",",$splittedQuery);
 
-      return $mergeData;
+	  return $mergeData;
 
   }
   
@@ -249,26 +249,26 @@ 
    */
   public function findAndWhere($params, $tableName, $dbConn = null)
   {
-      if (is_null($dbConn)) {
-          $dbConn = $this->dbConnection;
-      }
+	  if (is_null($dbConn)) {
+		  $dbConn = $this->dbConnection;
+	  }
 
-      if (is_array($params) && !empty($params)) {
-          $sql = "SELECT * FROM ".$tableName;
+	  if (is_array($params) && !empty($params)) {
+		  $sql = "SELECT * FROM ".$tableName;
 
-          foreach ($params as $key => $val) {
-              $sql .= " WHERE `$key` = '$val'";
-          }
+		  foreach ($params as $key => $val) {
+			  $sql .= " WHERE `$key` = '$val'";
+		  }
 
-          $statement = $dbConn->prepare($sql);
-          $statement->execute();
+		  $statement = $dbConn->prepare($sql);
+		  $statement->execute();
 
-          $returnedRowNumbers = $statement->rowCount();
+		  $returnedRowNumbers = $statement->rowCount();
           
-          return $returnedRowNumbers ? true : false;
-      }
+		  return $returnedRowNumbers ? true : false;
+	  }
 
-      throw EmptyArrayException::checkEmptyArrayException("Array Expected: parameter passed to this function is not an array");
+	  throw EmptyArrayException::checkEmptyArrayException("Array Expected: parameter passed to this function is not an array");
   }
   
   /**
@@ -279,25 +279,25 @@ 
    */
  public function getColumnNames($table, $dbConn = null) 
  {
-     $tableFields = [];
+	 $tableFields = [];
      
-     if (is_null($dbConn)) {
-         $dbConn = $this->dbConnection;
-     }
+	 if (is_null($dbConn)) {
+		 $dbConn = $this->dbConnection;
+	 }
 
-     $sql = "SHOW COLUMNS FROM ".$table;
+	 $sql = "SHOW COLUMNS FROM ".$table;
      
-     $stmt = $dbConn->prepare($sql);
-     $stmt->bindValue(':table', $table, PDO::PARAM_STR);
-     $stmt->execute();
+	 $stmt = $dbConn->prepare($sql);
+	 $stmt->bindValue(':table', $table, PDO::PARAM_STR);
+	 $stmt->execute();
 
-     $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
+	 $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
      
-     foreach ($results as $result) {
-         array_push($tableFields, $result['Field']);
-     }
+	 foreach ($results as $result) {
+		 array_push($tableFields, $result['Field']);
+	 }
 
-     return $tableFields;
+	 return $tableFields;
      
    }