Home | Classes | Modules | Annotated | Functions | Files

PgSQLConnection.php

Go to the documentation of this file.

<?php
/*
 *  $Id: PgSQLConnection.php,v 1.2 2004/04/28 19:33:53 micha 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 
{        
  var $result;
  
  function connect($dsninfo, $flags = 0)
  {    
    if (!extension_loaded('pgsql')) {
      return new SQLException(CREOLE_ERROR_EXTENSION_NOT_FOUND, '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) {
      return new SQLException(CREOLE_ERROR_CONNECT_FAILED, 'Could not connect', $php_errormsg, $connstr);
    }
    
    $this->dblink = $conn;        
    return true;
  }

  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) {
      return new SQLException(CREOLE_ERROR, '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) {
          return new SQLException(CREOLE_ERROR, 'Could not begin transaction', pg_last_error($this->dblink));
        }
      }
      $this->transactionOpcount++;
    }        
    
    $this->result = @pg_query($this->dblink, $sql);
    if (!$this->result) {
        return new SQLException(CREOLE_ERROR, '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) {
        return new SQLException('Could not commit transaction', pg_last_error($this->dblink));
      }
    }
    
    return true;
  }

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

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

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

---

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