class_DatabaseConnection.php

Go to the documentation of this file.

<?php
class DatabaseConnection extends BaseMiddleware implements DatabaseConnector, Registerable {
        private $connectData = array(
                'login' => "",
                'pass'  => "",
                'dbase' => "",
                'host'  => ""
        );

        // The real database layer
        private $dbLayer = null;

        // An instance of this class
        private static $thisInstance = null;

        protected function __construct() {
                // Call parent constructor
                parent::__construct(__CLASS__);
        }

        // Create new database connection layer
        public final static function createDatabaseConnection (DebugMiddleware $debugInstance, DatabaseFrontendInterface $dbLayer) {
                // Get instance
                $dbInstance = new DatabaseConnection();

                // Set debug output handler
                $dbInstance->setDebugInstance($debugInstance);

                // Set database layer
                $dbInstance->setDatabaseLayer($dbLayer);

                // Set db instance
                self::$thisInstance = $dbInstance;

                // Return instance
                return $dbInstance;
        }

        // Get an instance of this class
        public final static function getInstance () {
                return self::$thisInstance;
        }

        // Public setter for database connection
        public final function setConnectionData ($login, $pass, $dbase, $host="localhost") {
                // Transfer connection data
                $this->connectData['login'] = (string) $login;
                $this->connectData['pass']  = (string) $pass;
                $this->connectData['dbase'] = (string) $dbase;
                $this->connectData['host']  = (string) $host;
        }

        public final function getConnectionData () {
                return $this->connectData;
        }

        public final function setDatabaseLayer (DatabaseFrontendInterface $dbLayer) {
                $this->dbLayer = $dbLayer;
        }

        public final function getIndexKey () {
                return $this->dbLayer->getIndexKey();
        }

        public function doSelectByTableCriteria ($tableName, Criteria $criteriaInstance) {
                // Connect to the database
                $this->dbLayer->connectToDatabase();

                // Get result from query
                $result = $this->dbLayer->querySelect("array", $tableName, $criteriaInstance);

                // Return the result
                return $result;
        }

        public final function getLastException () {
                $exceptionInstance = $this->dbLayer->getLastException();
                return $exceptionInstance;
        }

        public function queryInsertDataSet (StoreableCriteria $dataSetInstance) {
                // Connect to the database
                $this->dbLayer->connectToDatabase();

                // Ask the database layer
                $this->dbLayer->queryInsertDataSet($dataSetInstance);
        }

        public function queryUpdateDataSet (StoreableCriteria $dataSetInstance) {
                // Connect to the database
                $this->dbLayer->connectToDatabase();

                // Ask the database layer
                $this->dbLayer->queryUpdateDataSet($dataSetInstance);
        }

        public function getPrimaryKeyOfTable ($tableName) {
                // Connect to the database
                $this->dbLayer->connectToDatabase();

                // Ask the database layer
                $primaryKey = $this->dbLayer->getPrimaryKeyOfTable($tableName);

                // Return the value
                return $primaryKey;
        }
}

// [EOF]
?>