WebSVN – lars-tiefland.prado – /framework/Data/TDbConnection.php

<?php
/**
 * TDbConnection class file
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @link http://www.pradosoft.com/
 * @copyright Copyright &copy; 2005-2008 PradoSoft
 * @license http://www.pradosoft.com/license/
 * @version $Id: TDbConnection.php 2505 2008-08-27 15:06:25Z tof $
 * @package System.Data
 */

Prado::using('System.Data.TDbTransaction');
Prado::using('System.Data.TDbCommand');

/**
 * TDbConnection class
 *
 * TDbConnection represents a connection to a database.
 *
 * TDbConnection works together with {@link TDbCommand}, {@link TDbDataReader}
 * and {@link TDbTransaction} to provide data access to various DBMS
 * in a common set of APIs. They are a thin wrapper of the {@link http://www.php.net/manual/en/ref.pdo.php PDO}
 * PHP extension.
 *
 * To establish a connection, set {@link setActive Active} to true after
 * specifying {@link setConnectionString ConnectionString}, {@link setUsername Username}
 * and {@link setPassword Password}.
 *
 * Since 3.1.2, the connection charset can be set (for MySQL and PostgreSQL databases only) 
 * using the {@link setCharset Charset} property. The value of this property is database dependant.
 * e.g. for mysql, you can use 'latin1' for cp1252 West European, 'utf8' for unicode, ... 
 * 
 * The following example shows how to create a TDbConnection instance and establish
 * the actual connection:
 * <code>
 * $connection=new TDbConnection($dsn,$username,$password);
 * $connection->Active=true;
 * </code>
 *
 * After the DB connection is established, one can execute an SQL statement like the following:
 * <code>
 * $command=$connection->createCommand($sqlStatement);
 * $command->execute();   // a non-query SQL statement execution
 * // or execute an SQL query and fetch the result set
 * $reader=$command->query();
 *
 * // each $row is an array representing a row of data
 * foreach($reader as $row) ...
 * </code>
 *
 * One can do prepared SQL execution and bind parameters to the prepared SQL:
 * <code>
 * $command=$connection->createCommand($sqlStatement);
 * $command->bindParameter($name1,$value1);
 * $command->bindParameter($name2,$value2);
 * $command->execute();
 * </code>
 *
 * To use transaction, do like the following:
 * <code>
 * $transaction=$connection->beginTransaction();
 * try
 * {
 *    $connection->createCommand($sql1)->execute();
 *    $connection->createCommand($sql2)->execute();
 *    //.... other SQL executions
 *    $transaction->commit();
 * }
 * catch(Exception $e)
 * {
 *    $transaction->rollBack();
 * }
 * </code>
 *
 * TDbConnection provides a set of methods to support setting and querying
 * of certain DBMS attributes, such as {@link getNullConversion NullConversion}.
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @version $Id: TDbConnection.php 2505 2008-08-27 15:06:25Z tof $
 * @package System.Data
 * @since 3.0
 */
class TDbConnection extends TComponent
{
        private $_dsn='';
        private $_username='';
        private $_password='';
        private $_charset='';
        private $_attributes=array();
        private $_active=false;
        private $_pdo=null;
        private $_transaction;

        /**
         * Constructor.
         * Note, the DB connection is not established when this connection
         * instance is created. Set {@link setActive Active} property to true
         * to establish the connection.
         * Since 3.1.2, you can set the charset for MySql connection
         * 
         * @param string The Data Source Name, or DSN, contains the information required to connect to the database.
         * @param string The user name for the DSN string.
         * @param string The password for the DSN string.
         * @param string Charset used for DB Connection (MySql & pgsql only). If not set, will use the default charset of your database server
         * @see http://www.php.net/manual/en/function.PDO-construct.php
         */
        public function __construct($dsn='',$username='',$password='', $charset='')
        {
                $this->_dsn=$dsn;
                $this->_username=$username;
                $this->_password=$password;
                $this->_charset=$charset;
        }

        /**
         * Close the connection when serializing.
         */
        public function __sleep()
        {
                $this->close();
                return array_keys(get_object_vars($this));
        }

        /**
         * @return array list of available PDO drivers
         * @see http://www.php.net/manual/en/function.PDO-getAvailableDrivers.php
         */
        public static function getAvailableDrivers()
        {
                return PDO::getAvailableDrivers();
        }

        /**
         * @return boolean whether the DB connection is established
         */
        public function getActive()
        {
                return $this->_active;
        }

        /**
         * Open or close the DB connection.
         * @param boolean whether to open or close DB connection
         * @throws TDbException if connection fails
         */
        public function setActive($value)
        {
                $value=TPropertyValue::ensureBoolean($value);
                if($value!==$this->_active)
                {
                        if($value)
                                $this->open();
                        else
                                $this->close();
                }
        }

        /**
         * Opens DB connection if it is currently not
         * @throws TDbException if connection fails
         */
        protected function open()
        {
                if($this->_pdo===null)
                {
                        try
                        {
                                $this->_pdo=new PDO($this->getConnectionString(),$this->getUsername(),
                                                                        $this->getPassword(),$this->_attributes);
                                // This attribute is only useful for PDO::MySql driver. 
                                // Ignore the warning if a driver doesn't understand this.
                                @$this->_pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, true);
                                $this->_pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
                                $this->_active=true;
                                $this->setConnectionCharset();
                        }
                        catch(PDOException $e)
                        {
                                throw new TDbException('dbconnection_open_failed',$e->getMessage());
                        }
                }
        }

        /**
         * Closes the currently active DB connection.
         * It does nothing if the connection is already closed.
         */
        protected function close()
        {
                $this->_pdo=null;
                $this->_active=false;
        }

        /*
         * Set the database connection charset.
         * Only MySql databases are supported for now. 
         * @since 3.1.2
         */
        protected function setConnectionCharset()
        {
                if ($this->_charset === '' || $this->_active === false)
                        return;
                switch ($this->_pdo->getAttribute(PDO::ATTR_DRIVER_NAME))
                {
                        case 'mysql':
                                $stmt = $this->_pdo->prepare('SET CHARACTER SET ?');
                        break;
                        case 'pgsql':
                                $stmt = $this->_pdo->prepare('SET client_encoding TO ?');
                        break;
                }
                $stmt->execute(array($this->_charset));
        }
                
        /**
         * @return string The Data Source Name, or DSN, contains the information required to connect to the database.
         */
        public function getConnectionString()
        {
                return $this->_dsn;
        }

        /**
         * @param string The Data Source Name, or DSN, contains the information required to connect to the database.
         * @see http://www.php.net/manual/en/function.PDO-construct.php
         */
        public function setConnectionString($value)
        {
                $this->_dsn=$value;
        }

        /**
         * @return string the username for establishing DB connection. Defaults to empty string.
         */
        public function getUsername()
        {
                return $this->_username;
        }

        /**
         * @param string the username for establishing DB connection
         */
        public function setUsername($value)
        {
                $this->_username=$value;
        }

        /**
         * @return string the password for establishing DB connection. Defaults to empty string.
         */
        public function getPassword()
        {
                return $this->_password;
        }

        /**
         * @param string the password for establishing DB connection
         */
        public function setPassword($value)
        {
                $this->_password=$value;
        }

        /**
         * @return string the charset used for database connection. Defaults to emtpy string.
         */
        public function getCharset ()
        {
                return $this>_charset;
        }
        
        /**
         * @param string the charset used for database connection
         */
        public function setCharset ($value)
        {
                $this->_charset=$value;
                $this->setConnectionCharset();
        }
        
        /**
         * @return PDO the PDO instance, null if the connection is not established yet
         */
        public function getPdoInstance()
        {
                return $this->_pdo;
        }

        /**
         * Creates a command for execution.
         * @param string SQL statement associated with the new command.
         * @return TDbCommand the DB command
         * @throws TDbException if the connection is not active
         */
        public function createCommand($sql)
        {
                if($this->getActive())
                        return new TDbCommand($this,$sql);
                else
                        throw new TDbException('dbconnection_connection_inactive');
        }

        /**
         * @return TDbTransaction the currently active transaction. Null if no active transaction.
         */
        public function getCurrentTransaction()
        {
                if($this->_transaction!==null)
                {
                        if($this->_transaction->getActive())
                                return $this->_transaction;
                }
                return null;
        }

        /**
         * Starts a transaction.
         * @return TDbTransaction the transaction initiated
         * @throws TDbException if the connection is not active
         */
        public function beginTransaction()
        {
                if($this->getActive())
                {
                        $this->_pdo->beginTransaction();
                        return $this->_transaction=new TDbTransaction($this);
                }
                else
                        throw new TDbException('dbconnection_connection_inactive');
        }

        /**
         * Returns the ID of the last inserted row or sequence value.
         * @param string name of the sequence object (required by some DBMS)
         * @return string the row ID of the last row inserted, or the last value retrieved from the sequence object
         * @see http://www.php.net/manual/en/function.PDO-lastInsertId.php
         */
        public function getLastInsertID($sequenceName='')
        {
                if($this->getActive())
                        return $this->_pdo->lastInsertId($sequenceName);
                else
                        throw new TDbException('dbconnection_connection_inactive');
        }

        /**
         * Quotes a string for use in a query.
         * @param string string to be quoted
         * @return string the properly quoted string
         * @see http://www.php.net/manual/en/function.PDO-quote.php
         */
        public function quoteString($str)
        {
                if($this->getActive())
                        return $this->_pdo->quote($str);
                else
                        throw new TDbException('dbconnection_connection_inactive');
        }

        /**
         * @return TDbColumnCaseMode the case of the column names
         */
        public function getColumnCase()
        {
                switch($this->getAttribute(PDO::ATTR_CASE))
                {
                        case PDO::CASE_NATURAL:
                                return TDbColumnCaseMode::Preserved;
                        case PDO::CASE_LOWER:
                                return TDbColumnCaseMode::LowerCase;
                        case PDO::CASE_UPPER:
                                return TDbColumnCaseMode::UpperCase;
                }
        }

        /**
         * @param TDbColumnCaseMode the case of the column names
         */
        public function setColumnCase($value)
        {
                switch(TPropertyValue::ensureEnum($value,'TDbColumnCaseMode'))
                {
                        case TDbColumnCaseMode::Preserved:
                                $value=PDO::CASE_NATURAL;
                                break;
                        case TDbColumnCaseMode::LowerCase:
                                $value=PDO::CASE_LOWER;
                                break;
                        case TDbColumnCaseMode::UpperCase:
                                $value=PDO::CASE_UPPER;
                                break;
                }
                $this->setAttribute(PDO::ATTR_CASE,$value);
        }

        /**
         * @return TDbNullConversionMode how the null and empty strings are converted
         */
        public function getNullConversion()
        {
                switch($this->getAttribute(PDO::ATTR_ORACLE_NULLS))
                {
                        case PDO::NULL_NATURAL:
                                return TDbNullConversionMode::Preserved;
                        case PDO::NULL_EMPTY_STRING:
                                return TDbNullConversionMode::EmptyStringToNull;
                        case PDO::NULL_TO_STRING:
                                return TDbNullConversionMode::NullToEmptyString;
                }
        }

        /**
         * @param TDbNullConversionMode how the null and empty strings are converted
         */
        public function setNullConversion($value)
        {
                switch(TPropertyValue::ensureEnum($value,'TDbNullConversionMode'))
                {
                        case TDbNullConversionMode::Preserved:
                                $value=PDO::NULL_NATURAL;
                                break;
                        case TDbNullConversionMode::EmptyStringToNull:
                                $value=PDO::NULL_EMPTY_STRING;
                                break;
                        case TDbNullConversionMode::NullToEmptyString:
                                $value=PDO::NULL_TO_STRING;
                                break;
                }
                $this->setAttribute(PDO::ATTR_ORACLE_NULLS,$value);
        }

        /**
         * @return boolean whether creating or updating a DB record will be automatically committed.
         * Some DBMS (such as sqlite) may not support this feature.
         */
        public function getAutoCommit()
        {
                return $this->getAttribute(PDO::ATTR_AUTOCOMMIT);
        }

        /**
         * @param boolean whether creating or updating a DB record will be automatically committed.
         * Some DBMS (such as sqlite) may not support this feature.
         */
        public function setAutoCommit($value)
        {
                $this->setAttribute(PDO::ATTR_AUTOCOMMIT,TPropertyValue::ensureBoolean($value));
        }

        /**
         * @return boolean whether the connection is persistent or not
         * Some DBMS (such as sqlite) may not support this feature.
         */
        public function getPersistent()
        {
                return $this->getAttribute(PDO::ATTR_PERSISTENT);
        }

        /**
         * @param boolean whether the connection is persistent or not
         * Some DBMS (such as sqlite) may not support this feature.
         */
        public function setPersistent($value)
        {
                return $this->setAttribute(PDO::ATTR_PERSISTENT,TPropertyValue::ensureBoolean($value));
        }

        /**
         * @return string name of the DB driver
         */
        public function getDriverName()
        {
                return $this->getAttribute(PDO::ATTR_DRIVER_NAME);
        }

        /**
         * @return string the version information of the DB driver
         */
        public function getClientVersion()
        {
                return $this->getAttribute(PDO::ATTR_CLIENT_VERSION);
        }

        /**
         * @return string the status of the connection
         * Some DBMS (such as sqlite) may not support this feature.
         */
        public function getConnectionStatus()
        {
                return $this->getAttribute(PDO::ATTR_CONNECTION_STATUS);
        }

        /**
         * @return boolean whether the connection performs data prefetching
         */
        public function getPrefetch()
        {
                return $this->getAttribute(PDO::ATTR_PREFETCH);
        }

        /**
         * @return string the information of DBMS server
         */
        public function getServerInfo()
        {
                return $this->getAttribute(PDO::ATTR_SERVER_INFO);
        }

        /**
         * @return string the version information of DBMS server
         */
        public function getServerVersion()
        {
                return $this->getAttribute(PDO::ATTR_SERVER_VERSION);
        }

        /**
         * @return int timeout settings for the connection
         */
        public function getTimeout()
        {
                return $this->getAttribute(PDO::ATTR_TIMEOUT);
        }

        /**
         * Obtains a specific DB connection attribute information.
         * @param int the attribute to be queried
         * @return mixed the corresponding attribute information
         * @see http://www.php.net/manual/en/function.PDO-getAttribute.php
         */
        public function getAttribute($name)
        {
                if($this->getActive())
                        return $this->_pdo->getAttribute($name);
                else
                        throw new TDbException('dbconnection_connection_inactive');
        }

        /**
         * Sets an attribute on the database connection.
         * @param int the attribute to be set
         * @param mixed the attribute value
         * @see http://www.php.net/manual/en/function.PDO-setAttribute.php
         */
        public function setAttribute($name,$value)
        {
                if($this->_pdo instanceof PDO)
                        $this->_pdo->setAttribute($name,$value);
                else
                        $this->_attributes[$name]=$value;
        }
}

/**
 * TDbColumnCaseMode
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @version $Id: TDbConnection.php 2505 2008-08-27 15:06:25Z tof $
 * @package System.Data
 * @since 3.0
 */
class TDbColumnCaseMode extends TEnumerable
{
        /**
         * Column name cases are kept as is from the database
         */
        const Preserved='Preserved';
        /**
         * Column names are converted to lower case
         */
        const LowerCase='LowerCase';
        /**
         * Column names are converted to upper case
         */
        const UpperCase='UpperCase';
}

/**
 * TDbNullConversionMode
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @version $Id: TDbConnection.php 2505 2008-08-27 15:06:25Z tof $
 * @package System.Data
 * @since 3.0
 */
class TDbNullConversionMode extends TEnumerable
{
        /**
         * No conversion is performed for null and empty values.
         */
        const Preserved='Preserved';
        /**
         * NULL is converted to empty string
         */
        const NullToEmptyString='NullToEmptyString';
        /**
         * Empty string is converted to NULL
         */
        const EmptyStringToNull='EmptyStringToNull';
}

?>
Subversion-Projekte lars-tiefland.prado

(root)/framework/Data/TDbConnection.php @ 16 – Revision 1
