EmmetBlue / Emmet-Blue

src/Core/Connection/Adapters/SQLServer.php

Indentation +93 added lines, -93 removed lines

@@ -21,110 +21,110 @@
  */
 class SQlServer implements ConnectableInterface
 {
-    /**
-     * @var string $dsn
-     */
-    protected $dsn;
+	/**
+	 * @var string $dsn
+	 */
+	protected $dsn;
 
-    /**
-     * @var \PDO $connectionObject
-     */
-    protected $connectionObject;
+	/**
+	 * @var \PDO $connectionObject
+	 */
+	protected $connectionObject;
 
-    /**
-     * @var array loginData
-     */
-    private $loginData = [];
+	/**
+	 * @var array loginData
+	 */
+	private $loginData = [];
 
-    /**
-     * Setter for the DSN string {@see $dsn}
-     *
-     * MSSQl Server DSN Structure: sqlsrv:Server={srv};Database={db}"
-     * `$dsnArray[0] = {srv}`
-     * `$dsnArray[1] = {db}`
-     * Attributes = [2 - infinity]
-     *
-     * @param array $dsnArray
-     * @return void
-     */
-    public function setDsn(array $dsnArray)
-    {
-        $this->dsn = $dsnArray;
-    }
+	/**
+	 * Setter for the DSN string {@see $dsn}
+	 *
+	 * MSSQl Server DSN Structure: sqlsrv:Server={srv};Database={db}"
+	 * `$dsnArray[0] = {srv}`
+	 * `$dsnArray[1] = {db}`
+	 * Attributes = [2 - infinity]
+	 *
+	 * @param array $dsnArray
+	 * @return void
+	 */
+	public function setDsn(array $dsnArray)
+	{
+		$this->dsn = $dsnArray;
+	}
 
-    /**
-     * Establishes connection
-     *
-     * @param string $username
-     * @param string $password optional
-     * @throws \EmmetBlue\Core\Exception\SQLException
-     * @return void
-     */
-    public function connect(string $username, string $password="")
-    {
-        $server = $this->dsn[0];
-        $database = $this->dsn[1];
+	/**
+	 * Establishes connection
+	 *
+	 * @param string $username
+	 * @param string $password optional
+	 * @throws \EmmetBlue\Core\Exception\SQLException
+	 * @return void
+	 */
+	public function connect(string $username, string $password="")
+	{
+		$server = $this->dsn[0];
+		$database = $this->dsn[1];
 
-        $this->loginData['username'] = $username;
-        $this->loginData['password'] = $password;
+		$this->loginData['username'] = $username;
+		$this->loginData['password'] = $password;
 
-        try
-        {
-            $this->connectionObject = new \PDO("sqlsrv:Server=$server;Database=$database;ConnectionPooling=0", $username, $password);
-        }
-        catch (\PDOException $e)
-        {
-            throw new SQLException("Unable to connect to database", 400, $e);  
-        }
+		try
+		{
+			$this->connectionObject = new \PDO("sqlsrv:Server=$server;Database=$database;ConnectionPooling=0", $username, $password);
+		}
+		catch (\PDOException $e)
+		{
+			throw new SQLException("Unable to connect to database", 400, $e);  
+		}
 
-        $dsn = $this->dsn;
-        unset($dsn[0], $dsn[1]);
+		$dsn = $this->dsn;
+		unset($dsn[0], $dsn[1]);
         
-        foreach ($dsn as $attribute)
-        {
-            foreach ($attribute as $key=>$value)
-            {
-                $this->connectionObject->setAttribute($key, $value);
-            }
-        }
-    }
+		foreach ($dsn as $attribute)
+		{
+			foreach ($attribute as $key=>$value)
+			{
+				$this->connectionObject->setAttribute($key, $value);
+			}
+		}
+	}
 
-    /**
-     * Returns an instance a pdo intance of the connection object
-     *
-     * @return \PDO
-     */
-    public function getConnection() : \PDO
-    {
-        if ($this->connectionObject instanceof \PDO)
-        {
-            return $this->connectionObject;
-        }
+	/**
+	 * Returns an instance a pdo intance of the connection object
+	 *
+	 * @return \PDO
+	 */
+	public function getConnection() : \PDO
+	{
+		if ($this->connectionObject instanceof \PDO)
+		{
+			return $this->connectionObject;
+		}
 
-        $this->connect(
-            $this->loginData['username'] ?? '',
-            $this->loginData['password'] ?? ''
-        );
+		$this->connect(
+			$this->loginData['username'] ?? '',
+			$this->loginData['password'] ?? ''
+		);
 
-        return $this->connectionObject;
-    }
+		return $this->connectionObject;
+	}
 
-    /**
-     * Closes connection
-     */
-    public function disableConnection()
-    {
-        $this->connectionObject = null;
-    }
+	/**
+	 * Closes connection
+	 */
+	public function disableConnection()
+	{
+		$this->connectionObject = null;
+	}
 
-    /**
-     * Sets attributes for the PDO object
-     *
-     * @param \PDO $attribute
-     * @param \PDO $value
-     */
-    public function setAttribute(\PDO $attribute, \PDO $value)
-    {
-         $this->connectionObject->setAttribute($attribute, $value);
-    }
+	/**
+	 * Sets attributes for the PDO object
+	 *
+	 * @param \PDO $attribute
+	 * @param \PDO $value
+	 */
+	public function setAttribute(\PDO $attribute, \PDO $value)
+	{
+		 $this->connectionObject->setAttribute($attribute, $value);
+	}
 }

src/Core/Factory/ElasticSearchClientFactory.php

Indentation +2 added lines, -2 removed lines

@@ -24,9 +24,9 @@
 	{
 		$configJson = file_get_contents("bin/configs/elasticsearch-config.json");
 
-        $config = json_decode($configJson);
+		$config = json_decode($configJson);
 
-        self::$clientObject = \Elasticsearch\ClientBuilder::create()->setHosts($config)->build();
+		self::$clientObject = \Elasticsearch\ClientBuilder::create()->setHosts($config)->build();
 	}
 
 	public static function getClient()

src/Core/Factory/HTTPRequestFactory.php

Indentation +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
 	{
 		$configJson = file_get_contents("bin/configs/http-headers-config.json");
 
-        self::$headers = json_decode($configJson, true);
+		self::$headers = json_decode($configJson, true);
 	}
 
 	public static function get($url, $extraHeaders = [])

src/Core/CustomFileNameGenerator.php

Indentation +20 added lines, -20 removed lines

@@ -6,27 +6,27 @@
 
 class CustomFileNameGenerator implements \FileUpload\FileNameGenerator\FileNameGenerator
 {
-    protected $generator;
+	protected $generator;
 
-    /**
-     * @param string|callable|Closure $nameGenerator
-     */
-    public function __construct($nameGenerator)
-    {
-        $this->generator = $nameGenerator;
-    }
+	/**
+	 * @param string|callable|Closure $nameGenerator
+	 */
+	public function __construct($nameGenerator)
+	{
+		$this->generator = $nameGenerator;
+	}
 
-    public function getFileName($source_name, $type, $tmp_name, $index, $content_range, FileUpload $upload)
-    {
-        $sourceNameArray = explode(".", $source_name);
-        $ext = $sourceNameArray[count($sourceNameArray) - 1];
-        if (is_string($this->generator) && !is_callable($this->generator)) {
-            return $this->generator.".".$ext;
-        }
+	public function getFileName($source_name, $type, $tmp_name, $index, $content_range, FileUpload $upload)
+	{
+		$sourceNameArray = explode(".", $source_name);
+		$ext = $sourceNameArray[count($sourceNameArray) - 1];
+		if (is_string($this->generator) && !is_callable($this->generator)) {
+			return $this->generator.".".$ext;
+		}
 
-        return call_user_func_array(
-            $this->generator,
-            func_get_args()
-        );
-    }
+		return call_user_func_array(
+			$this->generator,
+			func_get_args()
+		);
+	}
 }

src/Core/Builder/QueryBuilder/QueryBuilder.php

Indentation +165 added lines, -165 removed lines

@@ -20,169 +20,169 @@
  */
 class QueryBuilder implements BuildableInterface
 {
-    /**
-     * @var string Global Sql Statement
-     */
-    private $sqlStatement;
-
-    /**
-     * @var string SPACE
-     */
-    const SPACE = ' ';
-
-    /**
-     * @param string | null $sqlStatement SQL Statement to be processed by the build method
-     *
-     * @throws {@todo Write exception class}
-     */
-    public function __construct(string $sqlStatement = null)
-    {
-        self::setSqlStatement($sqlStatement);
-    }
-
-    /**
-     * Returns the string value of the global sqlStatement variable.
-     *
-     * @return string
-     */
-    private function getSqlStatement()
-    {
-        return $this->sqlStatement;
-    }
-
-    /**
-     * Sets/Modifies the value of the global sqlStatement variable.
-     *
-     * @param string $sqlStatement to set/replace global equivalent to.
-     *
-     * @return null
-     */
-    private function setSqlStatement(string $sqlStatement = null)
-    {
-        $this->sqlStatement = $sqlStatement;
-    }
-
-    /**
-     * Builds a QueryBuilder object.
-     * {@see QueryBuildableInterface}.
-     *
-     * @param string | null $sqlStringToAppend
-     *
-     * @throws {@todo Create exceptions}
-     *
-     * @return QueryBuilder new instance of the QueryBuilder object.
-     */
-    public function build(string $sqlStringToAppend) : BuildableInterface
-    {
-        $separator = (empty(self::getSqlStatement())) ? '' : self::SPACE;
-        $newSqlString = self::getSqlStatement().$separator.$sqlStringToAppend;
-        self::setSqlStatement($newSqlString);
-
-        return $this;
-    }
-
-    /**
-     * returns a `built sql` when the QueryBuilder object is casted to a string.
-     *
-     * @return string
-     */
-    public function __toString()
-    {
-        return self::getSqlStatement();
-    }
-
-    /**
-     * Implodes an array into a string.
-     *
-     * @param array  $arrayToImplode
-     * @param string $delimiter      Optional.
-     *
-     * @return string
-     */
-    protected function getImplodedString(array $arrayToImplode, string $delimiter = ',') : string
-    {
-        return implode($delimiter, $arrayToImplode);
-    }
-
-    /**
-     * Implodes an array into a string while keeping track of the keys.
-     *
-     * @param array  $arrayToImplode
-     * @param string $delimiter Optional.
-     *
-     * @return string
-     */
-    protected function getImplodedStringWithKeys(array $arrayToImplode, string $keyDelimiter='=', string $delimiter = ',') : string
-    {
-        $implodedStrings = []; 
-
-        foreach ($arrayToImplode as $key=>$value)
-        {
-            $implodedStrings[] = $key.$keyDelimiter.$value;
-        }
-
-        return implode($delimiter, $implodedStrings);
-    }
-
-    /**
-     * Wraps a string with specified characters.
-     *
-     * @param string      $strBefore
-     * @param string|null $strAfter
-     * @param string      $strToWrap
-     *
-     * @return string
-     */
-    public static function wrapString(string $strToWrap, string $strBefore, string $strAfter = null) : string
-    {
-        return $strBefore.$strToWrap.(is_null($strAfter) ? $strBefore : $strAfter);
-    }
-
-    /**
-     * {@inheritdoc}
-     *
-     * @param string $condition
-     *
-     * @return \EmmetBlue\Core\Builder\BuildableInterface
-     */
-    public function where(string $condition)
-    {
-        $whereString = "WHERE $condition";
-
-        $this->queryBuilder = $this->queryBuilder->build($whereString);
-
-        return $this;
-    }
-
-    /**
-     * {@inheritdoc}
-     *
-     * @param string $condition
-     *
-     * @return \EmmetBlue\Core\Builder\BuildableInterface
-     */
-    public function andWhere(string $condition)
-    {
-         $whereString = "AND $condition";
-
-        $this->queryBuilder = $this->queryBuilder->build($whereString);
-
-        return $this;
-    }
-
-    /**
-     * {@inheritdoc}
-     *
-     * @param string $condition
-     *
-     * @return \EmmetBlue\Core\Builder\BuildableInterface
-     */
-    public function orWhere(string $condition)
-    {
-         $whereString = "OR $condition";
-
-        $this->queryBuilder = $this->queryBuilder->build($whereString);
-
-        return $this;
-    }
+	/**
+	 * @var string Global Sql Statement
+	 */
+	private $sqlStatement;
+
+	/**
+	 * @var string SPACE
+	 */
+	const SPACE = ' ';
+
+	/**
+	 * @param string | null $sqlStatement SQL Statement to be processed by the build method
+	 *
+	 * @throws {@todo Write exception class}
+	 */
+	public function __construct(string $sqlStatement = null)
+	{
+		self::setSqlStatement($sqlStatement);
+	}
+
+	/**
+	 * Returns the string value of the global sqlStatement variable.
+	 *
+	 * @return string
+	 */
+	private function getSqlStatement()
+	{
+		return $this->sqlStatement;
+	}
+
+	/**
+	 * Sets/Modifies the value of the global sqlStatement variable.
+	 *
+	 * @param string $sqlStatement to set/replace global equivalent to.
+	 *
+	 * @return null
+	 */
+	private function setSqlStatement(string $sqlStatement = null)
+	{
+		$this->sqlStatement = $sqlStatement;
+	}
+
+	/**
+	 * Builds a QueryBuilder object.
+	 * {@see QueryBuildableInterface}.
+	 *
+	 * @param string | null $sqlStringToAppend
+	 *
+	 * @throws {@todo Create exceptions}
+	 *
+	 * @return QueryBuilder new instance of the QueryBuilder object.
+	 */
+	public function build(string $sqlStringToAppend) : BuildableInterface
+	{
+		$separator = (empty(self::getSqlStatement())) ? '' : self::SPACE;
+		$newSqlString = self::getSqlStatement().$separator.$sqlStringToAppend;
+		self::setSqlStatement($newSqlString);
+
+		return $this;
+	}
+
+	/**
+	 * returns a `built sql` when the QueryBuilder object is casted to a string.
+	 *
+	 * @return string
+	 */
+	public function __toString()
+	{
+		return self::getSqlStatement();
+	}
+
+	/**
+	 * Implodes an array into a string.
+	 *
+	 * @param array  $arrayToImplode
+	 * @param string $delimiter      Optional.
+	 *
+	 * @return string
+	 */
+	protected function getImplodedString(array $arrayToImplode, string $delimiter = ',') : string
+	{
+		return implode($delimiter, $arrayToImplode);
+	}
+
+	/**
+	 * Implodes an array into a string while keeping track of the keys.
+	 *
+	 * @param array  $arrayToImplode
+	 * @param string $delimiter Optional.
+	 *
+	 * @return string
+	 */
+	protected function getImplodedStringWithKeys(array $arrayToImplode, string $keyDelimiter='=', string $delimiter = ',') : string
+	{
+		$implodedStrings = []; 
+
+		foreach ($arrayToImplode as $key=>$value)
+		{
+			$implodedStrings[] = $key.$keyDelimiter.$value;
+		}
+
+		return implode($delimiter, $implodedStrings);
+	}
+
+	/**
+	 * Wraps a string with specified characters.
+	 *
+	 * @param string      $strBefore
+	 * @param string|null $strAfter
+	 * @param string      $strToWrap
+	 *
+	 * @return string
+	 */
+	public static function wrapString(string $strToWrap, string $strBefore, string $strAfter = null) : string
+	{
+		return $strBefore.$strToWrap.(is_null($strAfter) ? $strBefore : $strAfter);
+	}
+
+	/**
+	 * {@inheritdoc}
+	 *
+	 * @param string $condition
+	 *
+	 * @return \EmmetBlue\Core\Builder\BuildableInterface
+	 */
+	public function where(string $condition)
+	{
+		$whereString = "WHERE $condition";
+
+		$this->queryBuilder = $this->queryBuilder->build($whereString);
+
+		return $this;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 *
+	 * @param string $condition
+	 *
+	 * @return \EmmetBlue\Core\Builder\BuildableInterface
+	 */
+	public function andWhere(string $condition)
+	{
+		 $whereString = "AND $condition";
+
+		$this->queryBuilder = $this->queryBuilder->build($whereString);
+
+		return $this;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 *
+	 * @param string $condition
+	 *
+	 * @return \EmmetBlue\Core\Builder\BuildableInterface
+	 */
+	public function orWhere(string $condition)
+	{
+		 $whereString = "OR $condition";
+
+		$this->queryBuilder = $this->queryBuilder->build($whereString);
+
+		return $this;
+	}
 }

src/Core/Factory/DatabaseQueryFactory.php

Indentation +34 added lines, -34 removed lines

@@ -27,46 +27,46 @@
  */
 class DatabaseQueryFactory
 {
-    public static function insert(string $table, array $data)
-    {
-        $insertBuilder = (new Builder("QueryBuilder","Insert"))->getBuilder();
-        $columns = [];
-        $values = [];
+	public static function insert(string $table, array $data)
+	{
+		$insertBuilder = (new Builder("QueryBuilder","Insert"))->getBuilder();
+		$columns = [];
+		$values = [];
 
-        foreach ($data as $index=>$datum)
-        {
-            $columns[] = $index;
-            $values[] = $datum;
-        }
+		foreach ($data as $index=>$datum)
+		{
+			$columns[] = $index;
+			$values[] = $datum;
+		}
 
-        $columns = "(".implode(", ", $columns).")";
-        $values =    "(".implode(", ", $values).")";
-        $insertBuilder->into($table.$columns);
+		$columns = "(".implode(", ", $columns).")";
+		$values =    "(".implode(", ", $values).")";
+		$insertBuilder->into($table.$columns);
 
-        $query = (string)$insertBuilder." VALUES ".$values;
-        // die($query);
-        try
-        {
-            $parts = explode(".", $table);
-            $schemaName = $parts[0];
-            $tableName = $parts[1];
+		$query = (string)$insertBuilder." VALUES ".$values;
+		// die($query);
+		try
+		{
+			$parts = explode(".", $table);
+			$schemaName = $parts[0];
+			$tableName = $parts[1];
 
-            $connection = DBConnectionFactory::getConnection();
+			$connection = DBConnectionFactory::getConnection();
 
-            $result = $connection->prepare((string)$query)->execute();
+			$result = $connection->prepare((string)$query)->execute();
 
-            DatabaseLog::log(Session::get('USER_ID'), Constant::EVENT_INSERT, $schemaName, $tableName, $query);
+			DatabaseLog::log(Session::get('USER_ID'), Constant::EVENT_INSERT, $schemaName, $tableName, $query);
 
-            $lastInsertId = ($connection->query("SELECT CAST(COALESCE(SCOPE_IDENTITY(), @@IDENTITY) AS int) as id")->fetchColumn());
+			$lastInsertId = ($connection->query("SELECT CAST(COALESCE(SCOPE_IDENTITY(), @@IDENTITY) AS int) as id")->fetchColumn());
 
-            return [$result, "lastInsertId"=>$lastInsertId];
-        }
-        catch (\PDOException $e)
-        {
-            throw new SQLException(sprintf(
-                "%s",
-                $e->getMessage()
-            ), Constant::UNDEFINED);
-        }
-    }
+			return [$result, "lastInsertId"=>$lastInsertId];
+		}
+		catch (\PDOException $e)
+		{
+			throw new SQLException(sprintf(
+				"%s",
+				$e->getMessage()
+			), Constant::UNDEFINED);
+		}
+	}
 }
\ No newline at end of file

src/Core/DirtChecker.php

Indentation +52 added lines, -52 removed lines

@@ -17,65 +17,65 @@
  */
 class DirtChecker
 {
-    public $dirtFilterConditions = [">", "<", "="];
+	public $dirtFilterConditions = [">", "<", "="];
 
-    public $workingValue;
-    public $conditionValue;
-    public $workingConditions = [];
+	public $workingValue;
+	public $conditionValue;
+	public $workingConditions = [];
 
-    public function __construct(string $value, string $conditionValue, array $conditions = [])
-    {
-        $this->workingValue = $value;
-        $this->conditionValue = $conditionValue;
+	public function __construct(string $value, string $conditionValue, array $conditions = [])
+	{
+		$this->workingValue = $value;
+		$this->conditionValue = $conditionValue;
 
-        if (!empty($conditions)){
-            foreach ($conditions as $value) {
-                if (!in_array($value, $this->dirtFilterConditions)){
-                    throw new \Exception("Invalid Dirt Filter Condition Provided: ".$value);
-                }
-            }
-            $this->workingConditions = $conditions;
-        }
-        else {
-            $this->workingConditions = $this->dirtFilterConditions;
-        }
-    }
+		if (!empty($conditions)){
+			foreach ($conditions as $value) {
+				if (!in_array($value, $this->dirtFilterConditions)){
+					throw new \Exception("Invalid Dirt Filter Condition Provided: ".$value);
+				}
+			}
+			$this->workingConditions = $conditions;
+		}
+		else {
+			$this->workingConditions = $this->dirtFilterConditions;
+		}
+	}
 
-    public function isDirty() : bool
-    {
-        $explodedString = explode(" ", $this->workingValue);
-        foreach ($explodedString as $string){
-            foreach ($this->workingConditions as $condition){
-                $switchValue = false;
-                switch ($condition) {
-                    case '=':
-                        $switchValue = strpos($string, $this->conditionValue) !== false;
-                        break;
-                    case '>':
-                        $string = self::turnToNumber($string);
-                        $_condition = self::turnToNumber($this->conditionValue);
+	public function isDirty() : bool
+	{
+		$explodedString = explode(" ", $this->workingValue);
+		foreach ($explodedString as $string){
+			foreach ($this->workingConditions as $condition){
+				$switchValue = false;
+				switch ($condition) {
+					case '=':
+						$switchValue = strpos($string, $this->conditionValue) !== false;
+						break;
+					case '>':
+						$string = self::turnToNumber($string);
+						$_condition = self::turnToNumber($this->conditionValue);
 
-                        $switchValue = $string > $_condition;
-                        break;
-                    case '<':
-                        $string = self::turnToNumber($string);
-                        $_condition = self::turnToNumber($this->conditionValue);
+						$switchValue = $string > $_condition;
+						break;
+					case '<':
+						$string = self::turnToNumber($string);
+						$_condition = self::turnToNumber($this->conditionValue);
 
-                        $switchValue = $string < $_condition;
-                        break;
-                }
+						$switchValue = $string < $_condition;
+						break;
+				}
 
-                if (!$switchValue) {
-                    return true;
-                }
-            }
-        }
+				if (!$switchValue) {
+					return true;
+				}
+			}
+		}
 
-        return false;
-    }
+		return false;
+	}
 
-    private function turnToNumber(string $string) : float 
-    {
-        return (float) filter_var($string, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION | FILTER_FLAG_ALLOW_THOUSAND);
-    }
+	private function turnToNumber(string $string) : float 
+	{
+		return (float) filter_var($string, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION | FILTER_FLAG_ALLOW_THOUSAND);
+	}
 }

src/Core/Exception/UnallowedOperationException.php

Indentation +5 added lines, -5 removed lines

@@ -20,10 +20,10 @@
  */
 class UnallowedOperationException extends Exception
 {
-    public function __construct(string $message, int $databaseUser)
-    {
-        parent::__construct($message, 0, null);
+	public function __construct(string $message, int $databaseUser)
+	{
+		parent::__construct($message, 0, null);
         
-        $this->log($databaseUser, Constant::ERROR_404, Constant::ERROR_NORMAL);
-    }
+		$this->log($databaseUser, Constant::ERROR_404, Constant::ERROR_NORMAL);
+	}
 }

src/Core/Connection/Adapters/MySQL.php

Indentation +88 added lines, -88 removed lines

@@ -21,105 +21,105 @@
  */
 class MySQL implements ConnectableInterface
 {
-    /**
-     * @var string $dsn
-     */
-    protected $dsn;
+	/**
+	 * @var string $dsn
+	 */
+	protected $dsn;
 
-    /**
-     * @var \PDO $connectionObject
-     */
-    protected $connectionObject;
+	/**
+	 * @var \PDO $connectionObject
+	 */
+	protected $connectionObject;
 
-    /**
-     * @var array loginData
-     */
-    private $loginData = [];
+	/**
+	 * @var array loginData
+	 */
+	private $loginData = [];
 
-    /**
-     * Setter for the DSN string {@see $dsn}
-     *
-     * @param array $dsnArray
-     * @return void
-     */
-    public function setDsn(array $dsnArray)
-    {
-        $this->dsn = $dsnArray;
-    }
+	/**
+	 * Setter for the DSN string {@see $dsn}
+	 *
+	 * @param array $dsnArray
+	 * @return void
+	 */
+	public function setDsn(array $dsnArray)
+	{
+		$this->dsn = $dsnArray;
+	}
 
-    /**
-     * Establishes connection
-     *
-     * @param string $username
-     * @param string $password optional
-     * @throws \EmmetBlue\Core\Exception\SQLException
-     * @return void
-     */
-    public function connect(string $username, string $password="")
-    {
-        $host = $this->dsn[0];
-        $database = $this->dsn[1];
+	/**
+	 * Establishes connection
+	 *
+	 * @param string $username
+	 * @param string $password optional
+	 * @throws \EmmetBlue\Core\Exception\SQLException
+	 * @return void
+	 */
+	public function connect(string $username, string $password="")
+	{
+		$host = $this->dsn[0];
+		$database = $this->dsn[1];
 
-        $this->loginData['username'] = $username;
-        $this->loginData['password'] = $password;
+		$this->loginData['username'] = $username;
+		$this->loginData['password'] = $password;
 
-        try
-        {
-            $this->connectionObject = new \PDO("mysql:host=$host;dbname=$database;", $username, $password);
-        }
-        catch (\PDOException $e)
-        {
-            throw new SQLException("Unable to connect to database", 400, $e);  
-        }
+		try
+		{
+			$this->connectionObject = new \PDO("mysql:host=$host;dbname=$database;", $username, $password);
+		}
+		catch (\PDOException $e)
+		{
+			throw new SQLException("Unable to connect to database", 400, $e);  
+		}
 
-        $dsn = $this->dsn;
-        unset($dsn[0], $dsn[1]);
+		$dsn = $this->dsn;
+		unset($dsn[0], $dsn[1]);
         
-        foreach ($dsn as $attribute)
-        {
-            foreach ($attribute as $key=>$value)
-            {
-                $this->connectionObject->setAttribute($key, $value);
-            }
-        }
-    }
+		foreach ($dsn as $attribute)
+		{
+			foreach ($attribute as $key=>$value)
+			{
+				$this->connectionObject->setAttribute($key, $value);
+			}
+		}
+	}
 
-    /**
-     * Returns an instance a pdo intance of the connection object
-     *
-     * @return \PDO
-     */
-    public function getConnection() : \PDO
-    {
-        if ($this->connectionObject instanceof \PDO)
-        {
-            return $this->connectionObject;
-        }
+	/**
+	 * Returns an instance a pdo intance of the connection object
+	 *
+	 * @return \PDO
+	 */
+	public function getConnection() : \PDO
+	{
+		if ($this->connectionObject instanceof \PDO)
+		{
+			return $this->connectionObject;
+		}
 
-        $this->connect(
-            $this->loginData['username'] ?? '',
-            $this->loginData['password'] ?? ''
-        );
+		$this->connect(
+			$this->loginData['username'] ?? '',
+			$this->loginData['password'] ?? ''
+		);
 
-        return $this->connectionObject;
-    }
+		return $this->connectionObject;
+	}
 
-    /**
-     * Closes connection
-     */
-    public function disableConnection()
-    {
-        $this->connectionObject = null;
-    }
+	/**
+	 * Closes connection
+	 */
+	public function disableConnection()
+	{
+		$this->connectionObject = null;
+	}
 
-    /**
-     * Sets attributes for the PDO object
-     *
-     * @param \PDO $attribute
-     * @param \PDO $value
-     */
-    public function setAttribute(\PDO $attribute, \PDO $value)
-    {
-         $this->connectionObject->setAttribute($attribute, $value);
-    }
+	/**
+	 * Sets attributes for the PDO object
+	 *
+	 * @param \PDO $attribute
+	 * @param \PDO $value
+	 */
+	public function setAttribute(\PDO $attribute, \PDO $value)
+	{
+		 $this->connectionObject->setAttribute($attribute, $value);
+	}
 }