Home | Classes | Modules | Annotated | Hierarchy | Functions | Files

MySQLConnection.php

Go to the documentation of this file.

<?php
/*
 *  $Id: MySQLConnection.php,v 1.16 2004/03/20 04:16:49 hlellelid Exp $
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * This software consists of voluntary contributions made by many individuals
 * and is licensed under the LGPL. For more information please see
 * <http://creole.phpdb.org>.
 */
 
require_once 'creole/Connection.php';
require_once 'creole/common/ConnectionCommon.php';
include_once 'creole/drivers/mysql/MySQLResultSet.php';

class MySQLConnection extends ConnectionCommon implements Connection {

    private $database;
    
    function connect($dsninfo, $flags = 0)
    {
        if (!extension_loaded('mysql')) {
            throw new SQLException('mysql extension not loaded');
        }

        $this->dsn = $dsninfo;
        $this->flags = $flags;
        
        $persistent = ($flags & Creole::PERSISTENT) === Creole::PERSISTENT;

        if (isset($dsninfo['protocol']) && $dsninfo['protocol'] == 'unix') {
            $dbhost = ':' . $dsninfo['socket'];
        } else {
            $dbhost = $dsninfo['hostspec'] ? $dsninfo['hostspec'] : 'localhost';
            if (!empty($dsninfo['port'])) {
                $dbhost .= ':' . $dsninfo['port'];
            }
        }
        $user = $dsninfo['username'];
        $pw = $dsninfo['password'];

        $connect_function = $persistent ? 'mysql_pconnect' : 'mysql_connect';

        @ini_set('track_errors', true);
        if ($dbhost && $user && $pw) {
            $conn = @$connect_function($dbhost, $user, $pw);
        } elseif ($dbhost && $user) {
            $conn = @$connect_function($dbhost, $user);
        } elseif ($dbhost) {
            $conn = @$connect_function($dbhost);
        } else {
            $conn = false;
        }
        @ini_restore('track_errors');
        if (empty($conn)) {
            if (($err = @mysql_error()) != '') {
                throw new SQLException("connect failed", $err);
            } elseif (empty($php_errormsg)) {
                throw new SQLException("connect failed");
            } else {
                throw new SQLException("connect failed", $php_errormsg);
            }
        }

        if ($dsninfo['database']) {
            if (!@mysql_select_db($dsninfo['database'], $conn)) {
               switch(mysql_errno($conn)) {
                        case 1049:
                            $exc = new SQLException("no such database", mysql_error($conn));         
                        break;
                        case 1044:
                            $exc = new SQLException("access violation", mysql_error($conn));
                        break;
                        default:
                           $exc = new SQLException("cannot select database", mysql_error($conn));
                }
                
                throw $exc;
                
            }
            // fix to allow calls to different databases in the same script
            $this->database = $dsninfo['database'];
        }

        $this->dblink = $conn;
        
    }    
    
    public function getDatabaseInfo()
    {
        require_once 'creole/drivers/mysql/metadata/MySQLDatabaseInfo.php';
        return new MySQLDatabaseInfo($this);
    }
    
    public function getIdGenerator()
    {
        require_once 'creole/drivers/mysql/MySQLIdGenerator.php';
        return new MySQLIdGenerator($this);
    }
    
    public function prepareStatement($sql) 
    {
        require_once 'creole/drivers/mysql/MySQLPreparedStatement.php';
        return new MySQLPreparedStatement($this, $sql);
    }
    
    public function prepareCall($sql) {
        throw new SQLException('MySQL does not support stored procedures.');
    }
    
    public function createStatement()
    {
        require_once 'creole/drivers/mysql/MySQLStatement.php';
        return new MySQLStatement($this);
    }
        
    function close()
    {
        $ret = mysql_close($this->dblink);
        $this->dblink = null;
        return $ret;
    }
    
    function executeQuery($sql, $fetchmode = null)
    {
        $this->lastQuery = $sql;
        if ($this->database) {
            if (!@mysql_select_db($this->database, $this->dblink)) {
                throw new SQLException('No database selected', mysql_error($this->dblink));
            }
        }
        $result = @mysql_query($sql, $this->dblink);
        if (!$result) {
            throw new SQLException('Could not execute query', mysql_error($this->dblink), $sql);
        }
        return new MySQLResultSet($this, $result, $fetchmode);
    }
    
    function executeUpdate($sql)
    {    
        $this->lastQuery = $sql;

        if ($this->database) {
            if (!@mysql_select_db($this->database, $this->dblink)) {
                    throw new SQLException('No database selected', mysql_error($this->dblink));
            }
        }
        
        if (!$this->autocommit) {
            if ($this->transactionOpcount == 0) {
                $result = @mysql_query('SET AUTOCOMMIT=0', $this->dblink);
                $result = @mysql_query('BEGIN', $this->dblink);
                if (!$result) {
                    throw new SQLException('Could not begin transaction', mysql_error($this->dblink));
                }
            }
            $this->transactionOpcount++;
        }
        
        $result = @mysql_query($sql, $this->dblink);
        if (!$result) {
            throw new SQLException('Could not execute update', mysql_error($this->dblink), $sql);
        }        
        return (int) mysql_affected_rows($this->dblink);
    }

    function commit()
    {
        if ($this->transactionOpcount > 0) {
            if ($this->database) {
                if (!@mysql_select_db($this->database, $this->dblink)) {
                     throw new SQLException('No database selected', mysql_error($this->dblink));
                }
            }
            $result = @mysql_query('COMMIT', $this->dblink);
            $result = @mysql_query('SET AUTOCOMMIT=1', $this->dblink);
            $this->transactionOpcount = 0;
            if (!$result) {
                throw new SQLException('Can not commit transaction', mysql_error($this->dblink));                
            }
        }
    }

    function rollback()
    {
        if ($this->transactionOpcount > 0) {
            if ($this->database) {
                if (!@mysql_select_db($this->database, $this->dblink)) {
                    throw new SQLException('No database selected', mysql_error($this->dblink));
                }
            }
            $result = @mysql_query('ROLLBACK', $this->dblink);
            $result = @mysql_query('SET AUTOCOMMIT=1', $this->dblink);
            $this->transactionOpcount = 0;
            if (!$result) {
                throw new SQLException('Could not rollback transaction', mysql_error($this->dblink));
            }
        }
    }

    function getUpdateCount()
    {
        return (int) @mysql_affected_rows($this->dblink);
    }
    
}

---

This file is part of the Creole[php5] library.