adumitru68 / QueryBuilder

src/Statements/QueryStatement.php

Spacing +7 added lines, -7 removed lines

@@ -49,7 +49,7 @@ 
     /**
      * @var array
      */
-    protected $usedInstanceIds = [];
+    protected $usedInstanceIds = [ ];
 
     /**
      * @var string
@@ -63,16 +63,16 @@ 
      * @param string|QuerySelect $table
      * @throws QueryException
      */
-    public function __construct(QueryBuild $queryBuild, $table = '')
+    public function __construct( QueryBuild $queryBuild, $table = '' )
     {
 
-        $table = $this->validateTable($table);
+        $table = $this->validateTable( $table );
 
         $this->queryBuild = $queryBuild;
         $this->queryStructure = new QueryStructure();
-        $this->queryStructure->setElement(QueryStructure::TABLE, $table);
-        $this->queryStructure->setElement(QueryStructure::STATEMENT, $this->statement);
-        $this->queryStructure->setElement(QueryStructure::QUERY_TYPE, $this->queryBuild->getType());
+        $this->queryStructure->setElement( QueryStructure::TABLE, $table );
+        $this->queryStructure->setElement( QueryStructure::STATEMENT, $this->statement );
+        $this->queryStructure->setElement( QueryStructure::QUERY_TYPE, $this->queryBuild->getType() );
 
     }
 
@@ -81,7 +81,7 @@ 
      */
     public function getBindParams()
     {
-        return $this->queryStructure->getElement(QueryStructure::BIND_PARAMS);
+        return $this->queryStructure->getElement( QueryStructure::BIND_PARAMS );
     }
 
 

src/Statements/QueryStatementInterface.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
      * @param bool $replacement
      * @return string
      */
-    public function getSyntax($replacement = self::REPLACEMENT_NONE);
+    public function getSyntax( $replacement = self::REPLACEMENT_NONE );
 
     public function execute();
 

src/Statements/QueryDelete.php

Spacing +15 added lines, -15 removed lines

@@ -40,53 +40,53 @@ 
      * @param QueryBuild $queryBuild
      * @param string $table
      */
-    public function __construct(QueryBuild $queryBuild, $table = null)
+    public function __construct( QueryBuild $queryBuild, $table = null )
     {
-        parent::__construct($queryBuild, $table);
+        parent::__construct( $queryBuild, $table );
     }
 
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
+    public function getSyntax( $replacement = self::REPLACEMENT_NONE )
     {
         $syntax = array();
 
         /**
          *  Explain
          */
-        $syntax[] = $this->getExplainSyntax();
+        $syntax[ ] = $this->getExplainSyntax();
 
         /**
          * UPDATE statement
          */
-        $syntax[] = $this->statement;
+        $syntax[ ] = $this->statement;
 
         /**
          * PRIORITY
          */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
+        $syntax[ ] = $this->queryStructure->getElement( QueryStructure::PRIORITY );
 
         /**
          * TABLE update
          */
-        $syntax[] = 'FROM ' . $this->queryStructure->getElement(QueryStructure::TABLE);
+        $syntax[ ] = 'FROM ' . $this->queryStructure->getElement( QueryStructure::TABLE );
 
         /**
          * WHERE clause
          */
-        $syntax[] = $this->getWhereSyntax();
+        $syntax[ ] = $this->getWhereSyntax();
 
         /**
          * ORDER BY clause
          */
-        $syntax[] = $this->getOrderBySyntax();
+        $syntax[ ] = $this->getOrderBySyntax();
 
         /**
          * LIMIT clause
          */
-        $syntax[] = $this->getLimitSyntax();
+        $syntax[ ] = $this->getLimitSyntax();
 
-        $syntax = implode(' ', $syntax);
+        $syntax = implode( ' ', $syntax );
 
-        return $this->getSyntaxReplace($syntax, $replacement);
+        return $this->getSyntaxReplace( $syntax, $replacement );
     }
 
     /**
@@ -96,10 +96,10 @@ 
     public function execute()
     {
 
-        if ($this->queryStructure->getElement((QueryStructure::WHERE_TRIGGER)) && !count($this->queryStructure->getElement(QueryStructure::WHERE)))
-            throw new QueryException('Where or Having clause is required for this statement!', QueryException::QUERY_ERROR_DELETE_NOT_FILTER);
+        if ( $this->queryStructure->getElement( ( QueryStructure::WHERE_TRIGGER ) ) && !count( $this->queryStructure->getElement( QueryStructure::WHERE ) ) )
+            throw new QueryException( 'Where or Having clause is required for this statement!', QueryException::QUERY_ERROR_DELETE_NOT_FILTER );
 
-        return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+        return DbService::getInstance()->query( $this->getSyntax(), $this->queryStructure->getElement( QueryStructure::BIND_PARAMS ) );
 
     }
 

src/DB/DbLog.php

Spacing +25 added lines, -25 removed lines

@@ -30,7 +30,7 @@ 
      */
     private function __construct()
     {
-        $this->dateTimeZone = new \DateTimeZone('Europe/Bucharest');
+        $this->dateTimeZone = new \DateTimeZone( 'Europe/Bucharest' );
     }
 
 
@@ -38,26 +38,26 @@ 
      * @param $query
      * @param $duration
      */
-    public function writeQueryDuration($query, $duration)
+    public function writeQueryDuration( $query, $duration )
     {
-        $backtrace = end(debug_backtrace());
-        $location = $backtrace['file'] . " Line: " . $backtrace['line'];
+        $backtrace = end( debug_backtrace() );
+        $location = $backtrace[ 'file' ] . " Line: " . $backtrace[ 'line' ];
 
         $this->path = DbConfig::getInstance()->getLogPathQueryDuration(); //my comments
-        $message = "Duration: " . round($duration, 5) . "\r\n";
+        $message = "Duration: " . round( $duration, 5 ) . "\r\n";
         $message .= "Location: $location\r\n";
         $message .= "Query: $query";
-        $this->write($message);
+        $this->write( $message );
     }
 
     /**
      * @param $query
      * @param $duration
      */
-    public function writeQueryErros($query, $code, $error)
+    public function writeQueryErros( $query, $code, $error )
     {
-        $backtrace = end(debug_backtrace());
-        $location = $backtrace['file'] . " Line: " . $backtrace['line'];
+        $backtrace = end( debug_backtrace() );
+        $location = $backtrace[ 'file' ] . " Line: " . $backtrace[ 'line' ];
 
         $this->path = DbConfig::getInstance()->getLogPathErrors(); //my comments
         $message = "Query: $query" . "\r\n";
@@ -65,32 +65,32 @@ 
         $message .= "Error code : " . $code . "\r\n";
         $message .= "" . $error;
 
-        $this->write($message);
+        $this->write( $message );
     }
 
 
-    public function write($message)
+    public function write( $message )
     {
 
         $date = new \DateTime();
-        $date->setTimezone($this->dateTimeZone);
+        $date->setTimezone( $this->dateTimeZone );
 
-        $log = $this->path . $date->format('Y-m-d') . ".txt";
-        $time = $date->format('H:i:s');
+        $log = $this->path . $date->format( 'Y-m-d' ) . ".txt";
+        $time = $date->format( 'H:i:s' );
 
         $messageFormat = "[$time]\r\n$message\r\n\r\n";
 
-        if (is_dir($this->path)) {
-            if (!file_exists($log)) {
-                $fh = fopen($log, 'a+');
-                fwrite($fh, $messageFormat);
-                fclose($fh);
+        if ( is_dir( $this->path ) ) {
+            if ( !file_exists( $log ) ) {
+                $fh = fopen( $log, 'a+' );
+                fwrite( $fh, $messageFormat );
+                fclose( $fh );
             } else {
-                $this->edit($log, $messageFormat);
+                $this->edit( $log, $messageFormat );
             }
         } else {
-            if (mkdir($this->path, 0777) === true) {
-                $this->write($message);
+            if ( mkdir( $this->path, 0777 ) === true ) {
+                $this->write( $message );
             }
         }
     }
@@ -100,9 +100,9 @@ 
      * @param string $log
      * @param  string $message
      */
-    private function edit($log, $message)
+    private function edit( $log, $message )
     {
-        file_put_contents($log, $message, FILE_APPEND);
+        file_put_contents( $log, $message, FILE_APPEND );
     }
 
 
@@ -111,7 +111,7 @@ 
      */
     public static function getInstance()
     {
-        if (null === self::$instance) {
+        if ( null === self::$instance ) {
             self::$instance = new self();
         }
 

src/DB/DbService.php

Spacing +64 added lines, -64 removed lines

@@ -43,14 +43,14 @@ 
     /**
      * @var array
      */
-    private $parameters = [];
+    private $parameters = [ ];
 
     /**
      * @return DbService
      */
     public static function getInstance()
     {
-        if (null === self::$instance) {
+        if ( null === self::$instance ) {
             self::$instance = new self();
         }
 
@@ -63,17 +63,17 @@ 
      * @param int $fetchMode
      * @return array|int|null
      */
-    public function query($query, $params = null, $fetchMode = \PDO::FETCH_ASSOC)
+    public function query( $query, $params = null, $fetchMode = \PDO::FETCH_ASSOC )
     {
 
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
+        $query = trim( str_replace( "\r", " ", $query ) );
+        $statement = self::getQueryStatement( $query );
 
-        $this->queryInit($query, $params);
+        $this->queryInit( $query, $params );
 
-        if ($statement === self::QUERY_TYPE_SELECT || $statement === self::QUERY_TYPE_SHOW || $statement === self::QUERY_TYPE_DESC || $statement === self::QUERY_TYPE_EXPLAIN) {
-            return $this->sQuery->fetchAll($fetchMode);
-        } elseif ($statement === self::QUERY_TYPE_INSERT || $statement === self::QUERY_TYPE_UPDATE || $statement === self::QUERY_TYPE_DELETE) {
+        if ( $statement === self::QUERY_TYPE_SELECT || $statement === self::QUERY_TYPE_SHOW || $statement === self::QUERY_TYPE_DESC || $statement === self::QUERY_TYPE_EXPLAIN ) {
+            return $this->sQuery->fetchAll( $fetchMode );
+        } elseif ( $statement === self::QUERY_TYPE_INSERT || $statement === self::QUERY_TYPE_UPDATE || $statement === self::QUERY_TYPE_DELETE ) {
             return $this->sQuery->rowCount();
         } else {
 
@@ -85,16 +85,16 @@ 
      * @param $queryString
      * @return string
      */
-    public static function getQueryStatement($queryString)
+    public static function getQueryStatement( $queryString )
     {
-        $queryString = trim($queryString);
+        $queryString = trim( $queryString );
 
-        if ($queryString === '') {
+        if ( $queryString === '' ) {
             return self::QUERY_TYPE_EMPTY;
         }
 
-        if (preg_match('/^(select|insert|update|delete|replace|show|desc|explain)[\s]+/i', $queryString, $matches)) {
-            switch (strtolower($matches[1])) {
+        if ( preg_match( '/^(select|insert|update|delete|replace|show|desc|explain)[\s]+/i', $queryString, $matches ) ) {
+            switch ( strtolower( $matches[ 1 ] ) ) {
                 case 'select':
                     return self::QUERY_TYPE_SELECT;
                 case 'insert':
@@ -120,53 +120,53 @@ 
      * @param array $parameters
      * @throws DbException
      */
-    private function queryInit($query, $parameters = [])
+    private function queryInit( $query, $parameters = [ ] )
     {
-        $this->pdo = DbConnect::getInstance()->getConnection(self::getQueryStatement($query));
-        $startQueryTime = microtime(true);
+        $this->pdo = DbConnect::getInstance()->getConnection( self::getQueryStatement( $query ) );
+        $startQueryTime = microtime( true );
 
         try {
 
             /**
              * Prepare query
              */
-            $this->sQuery = $this->pdo->prepare($query);
+            $this->sQuery = $this->pdo->prepare( $query );
 
             /**
              * Add parameters to the parameter array
              */
-            if (self::isArrayAssoc($parameters))
-                $this->bindMore($parameters); else
-                foreach ($parameters as $key => $val)
-                    $this->parameters[] = array($key + 1, $val);
-
-            if (count($this->parameters)) {
-                foreach ($this->parameters as $param => $value) {
-                    if (is_int($value[1])) {
+            if ( self::isArrayAssoc( $parameters ) )
+                $this->bindMore( $parameters ); else
+                foreach ( $parameters as $key => $val )
+                    $this->parameters[ ] = array( $key + 1, $val );
+
+            if ( count( $this->parameters ) ) {
+                foreach ( $this->parameters as $param => $value ) {
+                    if ( is_int( $value[ 1 ] ) ) {
                         $type = \PDO::PARAM_INT;
-                    } elseif (is_bool($value[1])) {
+                    } elseif ( is_bool( $value[ 1 ] ) ) {
                         $type = \PDO::PARAM_BOOL;
-                    } elseif (is_null($value[1])) {
+                    } elseif ( is_null( $value[ 1 ] ) ) {
                         $type = \PDO::PARAM_NULL;
                     } else {
                         $type = \PDO::PARAM_STR;
                     }
-                    $this->sQuery->bindValue($value[0], $value[1], $type);
+                    $this->sQuery->bindValue( $value[ 0 ], $value[ 1 ], $type );
                 }
             }
 
             $this->sQuery->execute();
 
-            if (DbConfig::getInstance()->isEnableLogQueryDuration()) {
-                $duration = microtime(true) - $startQueryTime;
-                DbLog::getInstance()->writeQueryDuration($query, $duration);
+            if ( DbConfig::getInstance()->isEnableLogQueryDuration() ) {
+                $duration = microtime( true ) - $startQueryTime;
+                DbLog::getInstance()->writeQueryDuration( $query, $duration );
             }
 
-        } catch (\PDOException $e) {
-            if (DbConfig::getInstance()->isEnableLogErrors()) {
-                DbLog::getInstance()->writeQueryErros($query, $e->getCode(), $e->getMessage());
+        } catch ( \PDOException $e ) {
+            if ( DbConfig::getInstance()->isEnableLogErrors() ) {
+                DbLog::getInstance()->writeQueryErros( $query, $e->getCode(), $e->getMessage() );
             }
-            throw new DbException('Database error!', DbException::DB_QUERY_ERROR);
+            throw new DbException( 'Database error!', DbException::DB_QUERY_ERROR );
         }
 
         /**
@@ -179,27 +179,27 @@ 
      * @param array $arr
      * @return bool
      */
-    public static function isArrayAssoc(array $arr)
+    public static function isArrayAssoc( array $arr )
     {
-        if (array() === $arr)
+        if ( array() === $arr )
             return false;
 
-        return array_keys($arr) !== range(0, count($arr) - 1);
+        return array_keys( $arr ) !== range( 0, count( $arr ) - 1 );
     }
 
-    public function bindMore($parray)
+    public function bindMore( $parray )
     {
-        if (!count($this->parameters) && is_array($parray)) {
-            $columns = array_keys($parray);
-            foreach ($columns as $i => &$column) {
-                $this->bind($column, $parray[ $column ]);
+        if ( !count( $this->parameters ) && is_array( $parray ) ) {
+            $columns = array_keys( $parray );
+            foreach ( $columns as $i => &$column ) {
+                $this->bind( $column, $parray[ $column ] );
             }
         }
     }
 
-    public function bind($para, $value)
+    public function bind( $para, $value )
     {
-        $this->parameters[ sizeof($this->parameters) ] = [":" . $para, $value];
+        $this->parameters[ sizeof( $this->parameters ) ] = [ ":" . $para, $value ];
     }
 
     /**
@@ -207,46 +207,46 @@ 
      * @param array $params
      * @return array|null
      */
-    public function column($query, $params = null)
+    public function column( $query, $params = null )
     {
-        $this->queryInit($query, $params);
+        $this->queryInit( $query, $params );
 
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
+        $query = trim( str_replace( "\r", " ", $query ) );
+        $statement = self::getQueryStatement( $query );
 
-        if ($statement === self::QUERY_TYPE_EXPLAIN)
-            return $this->sQuery->fetchAll(\PDO::FETCH_ASSOC);
+        if ( $statement === self::QUERY_TYPE_EXPLAIN )
+            return $this->sQuery->fetchAll( \PDO::FETCH_ASSOC );
 
-        $Columns = $this->sQuery->fetchAll(\PDO::FETCH_NUM);
+        $Columns = $this->sQuery->fetchAll( \PDO::FETCH_NUM );
 
         $column = null;
 
-        foreach ($Columns as $cells) {
-            $column[] = $cells[0];
+        foreach ( $Columns as $cells ) {
+            $column[ ] = $cells[ 0 ];
         }
 
         return $column;
     }
 
-    public function row($query, $params = null, $fetchmode = \PDO::FETCH_ASSOC)
+    public function row( $query, $params = null, $fetchmode = \PDO::FETCH_ASSOC )
     {
-        $this->queryInit($query, $params);
+        $this->queryInit( $query, $params );
 
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
+        $query = trim( str_replace( "\r", " ", $query ) );
+        $statement = self::getQueryStatement( $query );
 
-        if ($statement === self::QUERY_TYPE_EXPLAIN)
-            return $this->sQuery->fetchAll(\PDO::FETCH_ASSOC);
+        if ( $statement === self::QUERY_TYPE_EXPLAIN )
+            return $this->sQuery->fetchAll( \PDO::FETCH_ASSOC );
 
-        $result = $this->sQuery->fetch($fetchmode);
+        $result = $this->sQuery->fetch( $fetchmode );
         $this->sQuery->closeCursor(); // Frees up the connection to the server so that other SQL statements may be issued,
 
         return $result;
     }
 
-    public function single($query, $params = null)
+    public function single( $query, $params = null )
     {
-        $this->queryInit($query, $params);
+        $this->queryInit( $query, $params );
         $result = $this->sQuery->fetchColumn();
         $this->sQuery->closeCursor(); // Frees up the connection to the server so that other SQL statements may be issued
 

src/DB/DbConnect.php

Spacing +20 added lines, -20 removed lines

@@ -42,8 +42,8 @@ 
      */
     public function getMasterConnection()
     {
-        if (!is_a($this->pdoMaster, \PDO::class))
-            $this->pdoMaster = $this->connect($this->config->getMasterDataConnect());
+        if ( !is_a( $this->pdoMaster, \PDO::class ) )
+            $this->pdoMaster = $this->connect( $this->config->getMasterDataConnect() );
 
         return $this->pdoMaster;
     }
@@ -53,11 +53,11 @@ 
      */
     public function getSlaveConnection()
     {
-        if (!$this->config->getReplicationEnable())
+        if ( !$this->config->getReplicationEnable() )
             return $this->getMasterConnection();
 
-        if (!is_a($this->pdoSlave, \PDO::class))
-            $this->pdoSlave = $this->connect($this->config->getSlaveDataConnect());
+        if ( !is_a( $this->pdoSlave, \PDO::class ) )
+            $this->pdoSlave = $this->connect( $this->config->getSlaveDataConnect() );
 
         return $this->pdoSlave;
     }
@@ -66,11 +66,11 @@ 
      * @param $statement
      * @return \PDO
      */
-    public function getConnection($statement)
+    public function getConnection( $statement )
     {
-        $statement = trim(strtolower($statement));
+        $statement = trim( strtolower( $statement ) );
 
-        if ($statement === DbService::QUERY_TYPE_SELECT)
+        if ( $statement === DbService::QUERY_TYPE_SELECT )
             return $this->getSlaveConnection();
 
         return $this->getMasterConnection();
@@ -80,9 +80,9 @@ 
      * @param $string
      * @return string
      */
-    public function quote($string)
+    public function quote( $string )
     {
-        return $this->getMasterConnection()->quote($string);
+        return $this->getMasterConnection()->quote( $string );
     }
 
     /**
@@ -97,20 +97,20 @@ 
      * @param $dataConnect
      * @return \PDO
      */
-    private function connect($dataConnect)
+    private function connect( $dataConnect )
     {
-        $dsn = 'mysql:dbname=' . $dataConnect["dbname"] . ';host=' . $dataConnect["host"] . '';
+        $dsn = 'mysql:dbname=' . $dataConnect[ "dbname" ] . ';host=' . $dataConnect[ "host" ] . '';
         try {
 
-            $pdo = new \PDO($dsn, $dataConnect["user"], $dataConnect["password"], array(\PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"));
+            $pdo = new \PDO( $dsn, $dataConnect[ "user" ], $dataConnect[ "password" ], array( \PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8" ) );
 
-            $pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
-            $pdo->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false);
-        } catch (\PDOException $e) {
-            if (DbConfig::getInstance()->isEnableLogErrors()) {
-                DbLog::getInstance()->writeQueryErros('Connection fail!', $e->getCode(), $e->getMessage());
+            $pdo->setAttribute( \PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION );
+            $pdo->setAttribute( \PDO::ATTR_EMULATE_PREPARES, false );
+        } catch ( \PDOException $e ) {
+            if ( DbConfig::getInstance()->isEnableLogErrors() ) {
+                DbLog::getInstance()->writeQueryErros( 'Connection fail!', $e->getCode(), $e->getMessage() );
             }
-            throw new DbException('Database connection error!', DbException::DB_CONNECTION_ERROR);
+            throw new DbException( 'Database connection error!', DbException::DB_CONNECTION_ERROR );
         }
 
         return $pdo;
@@ -122,7 +122,7 @@ 
      */
     public static function getInstance()
     {
-        if (null === self::$instance) {
+        if ( null === self::$instance ) {
             self::$instance = new self();
         }
 

src/DB/DbConfig.php

Spacing +23 added lines, -23 removed lines

@@ -60,7 +60,7 @@ 
     private function __construct()
     {
         $vendorCfg = __DIR__ . '/../../../../../vendor-cfg/qpdb_db_config.php';
-        if (file_exists($vendorCfg))
+        if ( file_exists( $vendorCfg ) )
             $this->dbConfig = require $vendorCfg; else
             $this->dbConfig = require __DIR__ . '/../../config/qpdb_db_config.php';
 
@@ -71,7 +71,7 @@ 
      * @param string $fileConfig
      * @return $this
      */
-    public function withFileConfig($fileConfig)
+    public function withFileConfig( $fileConfig )
     {
         $this->dbConfig = require $fileConfig;
         $this->buildConfig();
@@ -108,7 +108,7 @@ 
      */
     public function getLogConfig()
     {
-        return $this->dbConfig['db_log'];
+        return $this->dbConfig[ 'db_log' ];
     }
 
     /**
@@ -145,21 +145,21 @@ 
 
     public function useTablePrefix()
     {
-        if (!empty($this->dbConfig['use_table_prefix']))
-            return $this->dbConfig['use_table_prefix'];
+        if ( !empty( $this->dbConfig[ 'use_table_prefix' ] ) )
+            return $this->dbConfig[ 'use_table_prefix' ];
 
         return false;
     }
 
     public function getTablePrefix()
     {
-        return $this->dbConfig['table_prefix'];
+        return $this->dbConfig[ 'table_prefix' ];
     }
 
 
     private function buildConfig()
     {
-        $this->replicationEnable = $this->dbConfig['replicationEnable'];
+        $this->replicationEnable = $this->dbConfig[ 'replicationEnable' ];
         $this->readMasterDataConnect();
         $this->readSlaveDataConnect();
         $this->configLogger();
@@ -167,10 +167,10 @@ 
 
     private function configLogger()
     {
-        $this->enableLogErrors = $this->dbConfig['db_log']['enable_log_errors'];
-        $this->enableLogQueryDuration = $this->dbConfig['db_log']['enable_log_query_duration'];
-        $this->logPathErrors = $this->dbConfig['db_log']['log_path_errors'];
-        $this->logPathQueryDuration = $this->dbConfig['db_log']['log_path_query_duration'];
+        $this->enableLogErrors = $this->dbConfig[ 'db_log' ][ 'enable_log_errors' ];
+        $this->enableLogQueryDuration = $this->dbConfig[ 'db_log' ][ 'enable_log_query_duration' ];
+        $this->logPathErrors = $this->dbConfig[ 'db_log' ][ 'log_path_errors' ];
+        $this->logPathQueryDuration = $this->dbConfig[ 'db_log' ][ 'log_path_query_duration' ];
 
     }
 
@@ -181,19 +181,19 @@ 
     private function readMasterDataConnect()
     {
 
-        if (!isset($this->dbConfig['master_data_connect'][0]))
-            throw new DbException('Master data connect is missing', DbException::DB_ERROR_MASTER_DATA_CONNECTION_MISSING);
+        if ( !isset( $this->dbConfig[ 'master_data_connect' ][ 0 ] ) )
+            throw new DbException( 'Master data connect is missing', DbException::DB_ERROR_MASTER_DATA_CONNECTION_MISSING );
 
-        $dataConnection = $this->dbConfig['master_data_connect'];
+        $dataConnection = $this->dbConfig[ 'master_data_connect' ];
 
-        if (!$this->replicationEnable || count($dataConnection) == 1) {
-            $this->masterDataConnect = $dataConnection[0];
+        if ( !$this->replicationEnable || count( $dataConnection ) == 1 ) {
+            $this->masterDataConnect = $dataConnection[ 0 ];
 
             return true;
         }
 
-        shuffle($dataConnection);
-        $this->masterDataConnect = $dataConnection[0];
+        shuffle( $dataConnection );
+        $this->masterDataConnect = $dataConnection[ 0 ];
 
         return true;
     }
@@ -205,16 +205,16 @@ 
     private function readSlaveDataConnect()
     {
 
-        if (!isset($this->dbConfig['slave_data_connect'][0])) {
+        if ( !isset( $this->dbConfig[ 'slave_data_connect' ][ 0 ] ) ) {
             $this->slaveDataConnect = $this->masterDataConnect;
 
             return true;
         }
 
-        $dataConnection = $this->dbConfig['slave_data_connect'];
+        $dataConnection = $this->dbConfig[ 'slave_data_connect' ];
 
-        shuffle($dataConnection);
-        $this->slaveDataConnect = $dataConnection[0];
+        shuffle( $dataConnection );
+        $this->slaveDataConnect = $dataConnection[ 0 ];
 
         return true;
     }
@@ -224,7 +224,7 @@ 
      */
     public static function getInstance()
     {
-        if (null === self::$instance) {
+        if ( null === self::$instance ) {
             self::$instance = new self();
         }
 

config/qpdb_db_config.php

Spacing +4 added lines, -4 removed lines

@@ -9,19 +9,19 @@
 
     'replicationEnable' => false,
 
-    'slave_statements' => ['SELECT'],
+    'slave_statements' => [ 'SELECT' ],
 
     /**
      * if not Replication support use only first entry in master_data_connect
      */
-    'master_data_connect' => [['host' => 'localhost', 'user' => 'guser', 'password' => '1234', 'dbname' => 'classicmodels']],
+    'master_data_connect' => [ [ 'host' => 'localhost', 'user' => 'guser', 'password' => '1234', 'dbname' => 'classicmodels' ] ],
 
     /**
      * Use if replicationEnable is true. Config one or multiple slave connection
      */
-    'slave_data_connect' => [['host' => 'localhost', 'user' => 'guser', 'password' => '1234', 'dbname' => 'classicmodels'], ['host' => 'localhost', 'user' => 'guser', 'password' => '1234', 'dbname' => 'classicmodels']],
+    'slave_data_connect' => [ [ 'host' => 'localhost', 'user' => 'guser', 'password' => '1234', 'dbname' => 'classicmodels' ], [ 'host' => 'localhost', 'user' => 'guser', 'password' => '1234', 'dbname' => 'classicmodels' ] ],
 
-    'db_log' => ['enable_log_errors' => false, 'enable_log_query_duration' => false, 'log_path_errors' => $_SERVER['DOCUMENT_ROOT'] . '/tmp/db_errors/', 'log_path_query_duration' => $_SERVER['DOCUMENT_ROOT'] . '/tmp/db_query_duration/',],
+    'db_log' => [ 'enable_log_errors' => false, 'enable_log_query_duration' => false, 'log_path_errors' => $_SERVER[ 'DOCUMENT_ROOT' ] . '/tmp/db_errors/', 'log_path_query_duration' => $_SERVER[ 'DOCUMENT_ROOT' ] . '/tmp/db_query_duration/', ],
 
     'use_table_prefix' => false, 'table_prefix' => 'prefix_',