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

PgSQLConnection.php

Go to the documentation of this file.

<?php
/*
 *  $Id: PgSQLConnection.php,v 1.15 2004/03/20 04:16:50 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/pgsql/PgSQLResultSet.php';

class PgSQLConnection extends ConnectionCommon implements Connection {        
                
    private $result;
    
    function connect($dsninfo, $flags = 0)
    {    
        global $php_errormsg;
                
        if (!extension_loaded('pgsql')) {
            throw new SQLException('pgsql extension not loaded');
        }

        $this->dsn = $dsninfo;
        $this->flags = $flags;
        
        $persistent = ($flags & Creole::PERSISTENT === Creole::PERSISTENT);
                
        $protocol = (isset($dsninfo['protocol'])) ? $dsninfo['protocol'] : 'tcp';
        $connstr = '';

        if ($protocol == 'tcp') {
            if (!empty($dsninfo['hostspec'])) {
                $connstr = 'host=' . $dsninfo['hostspec'];
            }
            if (!empty($dsninfo['port'])) {
                $connstr .= ' port=' . $dsninfo['port'];
            }
        }

        if (isset($dsninfo['database'])) {
            $connstr .= ' dbname=\'' . addslashes($dsninfo['database']) . '\'';
        }
        if (!empty($dsninfo['username'])) {
            $connstr .= ' user=\'' . addslashes($dsninfo['username']) . '\'';
        }
        if (!empty($dsninfo['password'])) {
            $connstr .= ' password=\'' . addslashes($dsninfo['password']) . '\'';
        }
        if (!empty($dsninfo['options'])) {
            $connstr .= ' options=' . $dsninfo['options'];
        }
        if (!empty($dsninfo['tty'])) {
            $connstr .= ' tty=' . $dsninfo['tty'];
        }
        
        if ($persistent) {
            $conn = @pg_pconnect($connstr);
        } else {
            $conn = @pg_connect($connstr);
        }
        
        if (!$conn) {
            throw new SQLException('Could not connect', $php_errormsg, $connstr);
        }
        
        $this->dblink = $conn;        
    }

    function close()
    {
        $ret = @pg_close($this->dblink);
        $this->dblink = null;
        return $ret;
    }
    
    function executeQuery($sql, $fetchmode = null)
    {
        $this->result = @pg_query($this->dblink, $sql);
        if (!$this->result) {
            throw new SQLException('Could not execute query', pg_last_error($this->dblink), $sql);
        }
        return new PgSQLResultSet($this, $this->result, $fetchmode);
    }        

    function executeUpdate($sql)
    {            
        if (!$this->autocommit) {
            if ($this->transactionOpcount == 0) {
                $result = @pg_exec($this->dblink, "begin;");
                if (!$result) {
                    throw new SQLException('Could not begin transaction', pg_last_error($this->dblink));
                }
            }
            $this->transactionOpcount++;
        }        
        
        $this->result = @pg_query($this->dblink, $sql);
        if (!$this->result) {
            throw new SQLException('Could not execute update', pg_last_error($this->dblink), $sql);
        }        
        
        return (int) @pg_cmdtuples($this->result);     
    }

    function commit()
    {
        if ($this->transactionOpcount > 0) {            
            $result = @pg_query($this->dblink, "end;");
            $this->transactionOpcount = 0;
            if (!$result) {
                throw new SQLException('Could not commit transaction', pg_last_error($this->dblink));
            }
        }
    }

    function rollback()
    {
        if ($this->transactionOpcount > 0) {
            $result = @pg_query($this->dblink, "abort;");
            $this->transactionOpcount = 0;
            if (!$result) {
                throw new SQLException('Could not rollback transaction', pg_last_error($this->dblink));
            }
        }        
    }

    function getUpdateCount()
    {
        return (int) @pg_cmdtuples($this->result);
    }    

    
    public function getDatabaseInfo()
    {
        require_once 'creole/drivers/pgsql/metadata/PgSQLDatabaseInfo.php';
        return new PgSQLDatabaseInfo($this);
    }
    
    public function getIdGenerator()
    {
        require_once 'creole/drivers/pgsql/PgSQLIdGenerator.php';
        return new PgSQLIdGenerator($this);
    }
    
    public function prepareStatement($sql) 
    {
        require_once 'creole/drivers/pgsql/PgSQLPreparedStatement.php';
        return new PgSQLPreparedStatement($this, $sql);
    }
    
    public function prepareCall($sql) {
        throw new SQLException('PostgreSQL does not support stored procedures.');
    }
    
    public function createStatement()
    {
        require_once 'creole/drivers/pgsql/PgSQLStatement.php';
        return new PgSQLStatement($this);
    }
    
}

---

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