CustomerRewardsRESTAPI/Model/Database.php

<?php
/**
 * Description of Database
 *
 * @author Mike Howard
 */
class Database {
    protected $connection = null;
    
    public function __construct()
    {
        try {
            mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
            $this->connection = new mysqli(DB_HOST, DB_USERNAME, DB_PASSWORD, DB_DATABASE_NAME);
            
            if ( mysqli_connect_errno()) {
                throw new Exception("Could not connect to database.");   
            }
        } catch (Exception $e) {
            throw new Exception($e->getMessage());   
        }			
    }
    
    public function processQuery($query = "", $params = [])
    {
        try {
            $stmt = $this->connection->prepare( $query );
            if($stmt === false) {
                throw New Exception("Unable to do prepared statement: " . $query);
            }
            if( $params ) {
                $stmt->bind_param($params[0], $params[1]);
            }
            
            $stmt->execute();
            $result = $stmt->get_result()->fetch_all(MYSQLI_ASSOC);				
            $stmt->close();
            return $result;
        } catch(Exception $e) {
            throw New Exception( $e->getMessage() );
        }
        return false;
    }
    
    public function processStatement($query = "")
    {
        try {
            //Prepare the statement
            $stmt = $this->connection->prepare($query);
            if($stmt === false) {
                throw New Exception("Unable to prepare the statement: " . $query);
            }
            
            $result = $stmt->execute();
            if($result === false) {
                throw New Exception("Unable to execute the statement: " . $query);
            }
            
            $rowCount = $this->connection->affected_rows;
            if($rowCount < 1)
            {
                throw New Exception("Statement did not return any rows: " . $query);
            }
            
            $stmt->close();
            return $rowCount;
        } catch(Exception $e) {
            throw New Exception( $e->getMessage() );
        }
        return false;
    }
    
    public function processImage($query = "") {
        try {
            $stmt = $this->connection->prepare($query);
            if($stmt === false) {
                throw New Exception("Unable to prepare the statement: " . $query);
            }

            //$stmt->bind_param("ss", $params['filename'], $params['filepath']);

            $result = $stmt->execute();
            if($result === false) {
                throw New Exception("Unable to execute the statement: " . $query);
            }
            
            $rowCount = $this->connection->affected_rows;
            if($rowCount < 1)
            {
                throw New Exception("Statement did not return any rows: " . $query);
            }
            
            $stmt->close();
            return $rowCount;
        } catch(Exception $e) {
            throw New Exception( $e->getMessage() );
        }
        return false;
    }
}