WebSVN – Applications.gtt – Diff – /trunk/bibliotheque/pear/DB/pgsql.php


<?php
 
/* vim: set expandtab tabstop=4 shiftwidth=4 softtabstop=4: */
 
/**
 * The PEAR DB driver for PHP's pgsql extension
 * for interacting with PostgreSQL databases
 *
 * PHP version 5
 *
 * LICENSE: This source file is subject to version 3.0 of the PHP license
 * that is available through the world-wide-web at the following URI:
 * http://www.php.net/license/3_0.txt.  If you did not receive a copy of
 * the PHP License and are unable to obtain it through the web, please
 * send a note to license@php.net so we can mail you a copy immediately.
 *
 * @category   Database
 * @package    DB
 * @author     Rui Hirokawa <hirokawa@php.net>
 * @author     Stig Bakken <ssb@php.net>
 * @author     Daniel Convissor <danielc@php.net>
 * @copyright  1997-2007 The PHP Group
 * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
 * @version    CVS: $Id$
 * @link       http://pear.php.net/package/DB
 */
 
/**
 * Obtain the DB_common class so it can be extended from
 */
require_once 'DB/common.php';
 
/**
 * The methods PEAR DB uses to interact with PHP's pgsql extension
 * for interacting with PostgreSQL databases
 *
 * These methods overload the ones declared in DB_common.
 *
 * @category   Database
 * @package    DB
 * @author     Rui Hirokawa <hirokawa@php.net>
 * @author     Stig Bakken <ssb@php.net>
 * @author     Daniel Convissor <danielc@php.net>
 * @copyright  1997-2007 The PHP Group
 * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
 * @version    Release: 1.9.2
 * @link       http://pear.php.net/package/DB
 */
class DB_pgsql extends DB_common
{
    // {{{ properties
 
    /**
     * The DB driver type (mysql, oci8, odbc, etc.)
     * @var string
     */
    var $phptype = 'pgsql';
 
    /**
     * The database syntax variant to be used (db2, access, etc.), if any
     * @var string
     */
    var $dbsyntax = 'pgsql';
 
    /**
     * The capabilities of this DB implementation
     *
     * The 'new_link' element contains the PHP version that first provided
     * new_link support for this DBMS.  Contains false if it's unsupported.
     *
     * Meaning of the 'limit' element:
     *   + 'emulate' = emulate with fetch row by number
     *   + 'alter'   = alter the query
     *   + false     = skip rows
     *
     * @var array
     */
    var $features = array(
        'limit'         => 'alter',
        'new_link'      => '4.3.0',
        'numrows'       => true,
        'pconnect'      => true,
        'prepare'       => false,
        'ssl'           => true,
        'transactions'  => true,
    );
 
    /**
     * A mapping of native error codes to DB error codes
     * @var array
     */
    var $errorcode_map = array(
    );
 
    /**
     * The raw database connection created by PHP
     * @var resource
     */
    var $connection;
 
    /**
     * The DSN information for connecting to a database
     * @var array
     */
    var $dsn = array();
 
 
    /**
     * Should data manipulation queries be committed automatically?
     * @var bool
     * @access private
     */
    var $autocommit = true;
 
    /**
     * The quantity of transactions begun
     *
     * {@internal  While this is private, it can't actually be designated
     * private in PHP 5 because it is directly accessed in the test suite.}}
     *
     * @var integer
     * @access private
     */
    var $transaction_opcount = 0;
 
    /**
     * The number of rows affected by a data manipulation query
     * @var integer
     */
    var $affected = 0;
 
    /**
     * The current row being looked at in fetchInto()
     * @var array
     * @access private
     */
    var $row = array();
 
    /**
     * The number of rows in a given result set
     * @var array
     * @access private
     */
    var $_num_rows = array();
 
 
    // }}}
    // {{{ constructor
 
    /**
     * This constructor calls <kbd>parent::__construct()</kbd>
     *
     * @return void
     */
    function __construct()
    {
        parent::__construct();
    }
 
    // }}}
    // {{{ connect()
 
    /**
     * Connect to the database server, log in and open the database
     *
     * Don't call this method directly.  Use DB::connect() instead.
     *
     * PEAR DB's pgsql driver supports the following extra DSN options:
     *   + connect_timeout  How many seconds to wait for a connection to
     *                       be established.  Available since PEAR DB 1.7.0.
     *   + new_link         If set to true, causes subsequent calls to
     *                       connect() to return a new connection link
     *                       instead of the existing one.  WARNING: this is
     *                       not portable to other DBMS's.  Available only
     *                       if PHP is >= 4.3.0 and PEAR DB is >= 1.7.0.
     *   + options          Command line options to be sent to the server.
     *                       Available since PEAR DB 1.6.4.
     *   + service          Specifies a service name in pg_service.conf that
     *                       holds additional connection parameters.
     *                       Available since PEAR DB 1.7.0.
     *   + sslmode          How should SSL be used when connecting?  Values:
     *                       disable, allow, prefer or require.
     *                       Available since PEAR DB 1.7.0.
     *   + tty              This was used to specify where to send server
     *                       debug output.  Available since PEAR DB 1.6.4.
     *
     * Example of connecting to a new link via a socket:
     * <code>
     * require_once 'DB.php';
     * 
     * $dsn = 'pgsql://user:pass@unix(/tmp)/dbname?new_link=true';
     * $options = array(
     *     'portability' => DB_PORTABILITY_ALL,
     * );
     * 
     * $db = DB::connect($dsn, $options);
     * if (PEAR::isError($db)) {
     *     die($db->getMessage());
     * }
     * </code>
     *
     * @param array $dsn         the data source name
     * @param bool  $persistent  should the connection be persistent?
     *
     * @return int  DB_OK on success. A DB_Error object on failure.
     *
     * @link http://www.postgresql.org/docs/current/static/libpq.html#LIBPQ-CONNECT
     */
    function connect($dsn, $persistent = false)
    {
        if (!PEAR::loadExtension('pgsql')) {
            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
        }
 
        $this->dsn = $dsn;
        if ($dsn['dbsyntax']) {
            $this->dbsyntax = $dsn['dbsyntax'];
        }
 
        $protocol = $dsn['protocol'] ? $dsn['protocol'] : 'tcp';
 
        $params = array('');
        if ($protocol == 'tcp') {
            if ($dsn['hostspec']) {
                $params[0] .= 'host=' . $dsn['hostspec'];
            }
            if ($dsn['port']) {
                $params[0] .= ' port=' . $dsn['port'];
            }
        } elseif ($protocol == 'unix') {
            // Allow for pg socket in non-standard locations.
            if ($dsn['socket']) {
                $params[0] .= 'host=' . $dsn['socket'];
            }
            if ($dsn['port']) {
                $params[0] .= ' port=' . $dsn['port'];
            }
        }
        if ($dsn['database']) {
            $params[0] .= ' dbname=\'' . addslashes($dsn['database']) . '\'';
        }
        if ($dsn['username']) {
            $params[0] .= ' user=\'' . addslashes($dsn['username']) . '\'';
        }
        if ($dsn['password']) {
            $params[0] .= ' password=\'' . addslashes($dsn['password']) . '\'';
        }
        if (!empty($dsn['options'])) {
            $params[0] .= ' options=' . $dsn['options'];
        }
        if (!empty($dsn['tty'])) {
            $params[0] .= ' tty=' . $dsn['tty'];
        }
        if (!empty($dsn['connect_timeout'])) {
            $params[0] .= ' connect_timeout=' . $dsn['connect_timeout'];
        }
        if (!empty($dsn['sslmode'])) {
            $params[0] .= ' sslmode=' . $dsn['sslmode'];
        }
        if (!empty($dsn['service'])) {
            $params[0] .= ' service=' . $dsn['service'];
        }
 
        if (isset($dsn['new_link'])
            && ($dsn['new_link'] == 'true' || $dsn['new_link'] === true))
        {
            if (version_compare(phpversion(), '4.3.0', '>=')) {
                $params[] = PGSQL_CONNECT_FORCE_NEW;
            }
        }
 
        $connect_function = $persistent ? 'pg_pconnect' : 'pg_connect';
 
        $ini = ini_get('track_errors');
        $php_errormsg = '';
        if ($ini) {
            $this->connection = @call_user_func_array($connect_function,
                                                      $params);
        } else {
            @ini_set('track_errors', 1);
            $this->connection = @call_user_func_array($connect_function,
                                                      $params);
            @ini_set('track_errors', $ini);
        }
 
        if (!$this->connection) {
            return $this->raiseError(DB_ERROR_CONNECT_FAILED,
                                     null, null, null,
                                     $php_errormsg);
        }
        return DB_OK;
    }
 
    // }}}
    // {{{ disconnect()
 
    /**
     * Disconnects from the database server
     *
     * @return bool  TRUE on success, FALSE on failure
     */
    function disconnect()
    {
        $ret = @pg_close($this->connection);
        $this->connection = null;
        return $ret;
    }
 
    // }}}
    // {{{ simpleQuery()
 
    /**
     * Sends a query to the database server
     *
     * @param string  the SQL query string
     *
     * @return mixed  + a PHP result resrouce for successful SELECT queries
     *                + the DB_OK constant for other successful queries
     *                + a DB_Error object on failure
     */
    function simpleQuery($query)
    {
        $ismanip = $this->_checkManip($query);
        $this->last_query = $query;
        $query = $this->modifyQuery($query);
        if (!$this->autocommit && $ismanip) {
            if ($this->transaction_opcount == 0) {
                $result = @pg_exec($this->connection, 'begin;');
                if (!$result) {
                    return $this->pgsqlRaiseError();
                }
            }
            $this->transaction_opcount++;
        }
        $result = @pg_exec($this->connection, $query);
        if (!$result) {
            return $this->pgsqlRaiseError();
        }
 
        /*
         * Determine whether queries produce affected rows, result or nothing.
         *
         * This logic was introduced in version 1.1 of the file by ssb,
         * though the regex has been modified slightly since then.
         *
         * PostgreSQL commands:
         * ABORT, ALTER, BEGIN, CLOSE, CLUSTER, COMMIT, COPY,
         * CREATE, DECLARE, DELETE, DROP TABLE, EXPLAIN, FETCH,
         * GRANT, INSERT, LISTEN, LOAD, LOCK, MOVE, NOTIFY, RESET,
         * REVOKE, ROLLBACK, SELECT, SELECT INTO, SET, SHOW,
         * UNLISTEN, UPDATE, VACUUM, WITH
         */
        if ($ismanip) {
            $this->affected = @pg_affected_rows($result);
            return DB_OK;
        } elseif (preg_match('/^\s*\(*\s*(SELECT|EXPLAIN|FETCH|SHOW|WITH)\s/si',
 
 
 
 
 
                             $query))
        {
            $this->row[(int)$result] = 0; // reset the row counter.
            $numrows = $this->numRows($result);
            if (is_object($numrows)) {
                return $numrows;
            }
            $this->_num_rows[(int)$result] = $numrows;
            $this->affected = 0;
            return $result;
        } else {
            $this->affected = 0;
            return DB_OK;
        }
    }
 
    // }}}
    // {{{ nextResult()
 
    /**
     * Move the internal pgsql result pointer to the next available result
     *
     * @param a valid fbsql result resource
     *
     * @access public
     *
     * @return true if a result is available otherwise return false
     */
    function nextResult($result)
    {
        return false;
    }
 
    // }}}
    // {{{ fetchInto()
 
    /**
     * Places a row from the result set into the given array
     *
     * Formating of the array and the data therein are configurable.
     * See DB_result::fetchInto() for more information.
     *
     * This method is not meant to be called directly.  Use
     * DB_result::fetchInto() instead.  It can't be declared "protected"
     * because DB_result is a separate object.
     *
     * @param resource $result    the query result resource
     * @param array    $arr       the referenced array to put the data in
     * @param int      $fetchmode how the resulting array should be indexed
     * @param int      $rownum    the row number to fetch (0 = first row)
     *
     * @return mixed  DB_OK on success, NULL when the end of a result set is
     *                 reached or on failure
     *
     * @see DB_result::fetchInto()
     */
    function fetchInto($result, &$arr, $fetchmode, $rownum = null)
    {
        $result_int = (int)$result;
        $rownum = ($rownum !== null) ? $rownum : $this->row[$result_int];
        if ($rownum >= $this->_num_rows[$result_int]) {
            return null;
        }
        if ($fetchmode & DB_FETCHMODE_ASSOC) {
            $arr = @pg_fetch_array($result, $rownum, PGSQL_ASSOC);
            if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE && $arr) {
                $arr = array_change_key_case($arr, CASE_LOWER);
            }
        } else {
            $arr = @pg_fetch_row($result, $rownum);
        }
        if (!$arr) {
            return null;
        }
        if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {
            $this->_rtrimArrayValues($arr);
        }
        if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {
            $this->_convertNullArrayValuesToEmpty($arr);
        }
        $this->row[$result_int] = ++$rownum;
        return DB_OK;
    }
 
    // }}}
    // {{{ freeResult()
 
    /**
     * Deletes the result set and frees the memory occupied by the result set
     *
     * This method is not meant to be called directly.  Use
     * DB_result::free() instead.  It can't be declared "protected"
     * because DB_result is a separate object.
     *
     * @param resource $result  PHP's query result resource
     *
     * @return bool  TRUE on success, FALSE if $result is invalid
     *
     * @see DB_result::free()
     */
    function freeResult($result)
    {
        if (is_resource($result)) {
            unset($this->row[(int)$result]);
            unset($this->_num_rows[(int)$result]);
            $this->affected = 0;
            return @pg_freeresult($result);
        }
        return false;
    }
 
    // }}}
 
 
 
 
 
 
 
 
 
 
 
 
    // {{{ quoteBoolean()
 
    /**
     * Formats a boolean value for use within a query in a locale-independent
 
 
 
 
 
 
 
 
 
 
     * manner.
     *
     * @param boolean the boolean value to be quoted.
     * @return string the quoted string.
     * @see DB_common::quoteSmart()
     * @since Method available since release 1.7.8.
     */
 
 
 
 
    function quoteBoolean($boolean) {
 
 
 
 
 
        return $boolean ? 'TRUE' : 'FALSE';
    }
     
    // }}}
    // {{{ escapeSimple()
 
    /**
     * Escapes a string according to the current DBMS's standards
     *
     * {@internal PostgreSQL treats a backslash as an escape character,
     * so they are escaped as well.
     *
 
 
 
     * @param string $str  the string to be escaped
     *
     * @return string  the escaped string
     *
     * @see DB_common::quoteSmart()
     * @since Method available since Release 1.6.0
     */
    function escapeSimple($str)
    {
        if (function_exists('pg_escape_string')) {
            /* This fixes an undocumented BC break in PHP 5.2.0 which changed
             * the prototype of pg_escape_string. I'm not thrilled about having
             * to sniff the PHP version, quite frankly, but it's the only way
             * to deal with the problem. Revision 1.331.2.13.2.10 on
             * php-src/ext/pgsql/pgsql.c (PHP_5_2 branch) is to blame, for the
             * record. */
            if (version_compare(PHP_VERSION, '5.2.0', '>=')) {
                return pg_escape_string($this->connection, $str);
            } else {
                return pg_escape_string($str);
            }
        } else {
            return str_replace("'", "''", str_replace('\\', '\\\\', $str));
        }
    }
 
    // }}}
    // {{{ numCols()
 
    /**
     * Gets the number of columns in a result set
     *
     * This method is not meant to be called directly.  Use
     * DB_result::numCols() instead.  It can't be declared "protected"
     * because DB_result is a separate object.
     *
     * @param resource $result  PHP's query result resource
     *
     * @return int  the number of columns.  A DB_Error object on failure.
     *
     * @see DB_result::numCols()
     */
    function numCols($result)
    {
        $cols = @pg_numfields($result);
        if (!$cols) {
            return $this->pgsqlRaiseError();
        }
        return $cols;
    }
 
    // }}}
    // {{{ numRows()
 
    /**
     * Gets the number of rows in a result set
     *
     * This method is not meant to be called directly.  Use
     * DB_result::numRows() instead.  It can't be declared "protected"
     * because DB_result is a separate object.
     *
     * @param resource $result  PHP's query result resource
     *
     * @return int  the number of rows.  A DB_Error object on failure.
     *
     * @see DB_result::numRows()
     */
    function numRows($result)
    {
        $rows = @pg_numrows($result);
        if ($rows === null) {
            return $this->pgsqlRaiseError();
        }
        return $rows;
    }
 
    // }}}
    // {{{ autoCommit()
 
    /**
     * Enables or disables automatic commits
     *
     * @param bool $onoff  true turns it on, false turns it off
     *
     * @return int  DB_OK on success.  A DB_Error object if the driver
     *               doesn't support auto-committing transactions.
     */
    function autoCommit($onoff = false)
    {
        // XXX if $this->transaction_opcount > 0, we should probably
        // issue a warning here.
        $this->autocommit = $onoff ? true : false;
        return DB_OK;
    }
 
    // }}}
    // {{{ commit()
 
    /**
     * Commits the current transaction
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     */
    function commit()
    {
        if ($this->transaction_opcount > 0) {
            // (disabled) hack to shut up error messages from libpq.a
            //@fclose(@fopen("php://stderr", "w"));
            $result = @pg_exec($this->connection, 'end;');
            $this->transaction_opcount = 0;
            if (!$result) {
                return $this->pgsqlRaiseError();
            }
        }
        return DB_OK;
    }
 
    // }}}
    // {{{ rollback()
 
    /**
     * Reverts the current transaction
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     */
    function rollback()
    {
        if ($this->transaction_opcount > 0) {
            $result = @pg_exec($this->connection, 'abort;');
            $this->transaction_opcount = 0;
            if (!$result) {
                return $this->pgsqlRaiseError();
            }
        }
        return DB_OK;
    }
 
    // }}}
    // {{{ affectedRows()
 
    /**
     * Determines the number of rows affected by a data maniuplation query
     *
     * 0 is returned for queries that don't manipulate data.
     *
     * @return int  the number of rows.  A DB_Error object on failure.
     */
    function affectedRows()
    {
        return $this->affected;
    }
 
    // }}}
    // {{{ nextId()
 
    /**
     * Returns the next free id in a sequence
     *
     * @param string  $seq_name  name of the sequence
     * @param boolean $ondemand  when true, the seqence is automatically
     *                            created if it does not exist
     *
     * @return int  the next id number in the sequence.
     *               A DB_Error object on failure.
     *
     * @see DB_common::nextID(), DB_common::getSequenceName(),
     *      DB_pgsql::createSequence(), DB_pgsql::dropSequence()
     */
    function nextId($seq_name, $ondemand = true)
    {
        $seqname = $this->getSequenceName($seq_name);
        $repeat = false;
        do {
            $this->pushErrorHandling(PEAR_ERROR_RETURN);
            $result = $this->query("SELECT NEXTVAL('${seqname}')");
            $this->popErrorHandling();
            if ($ondemand && DB::isError($result) &&
                $result->getCode() == DB_ERROR_NOSUCHTABLE) {
                $repeat = true;
                $this->pushErrorHandling(PEAR_ERROR_RETURN);
                $result = $this->createSequence($seq_name);
                $this->popErrorHandling();
                if (DB::isError($result)) {
                    return $this->raiseError($result);
                }
            } else {
                $repeat = false;
            }
        } while ($repeat);
        if (DB::isError($result)) {
            return $this->raiseError($result);
        }
        $arr = $result->fetchRow(DB_FETCHMODE_ORDERED);
        $result->free();
        return $arr[0];
    }
 
    // }}}
    // {{{ createSequence()
 
    /**
     * Creates a new sequence
     *
     * @param string $seq_name  name of the new sequence
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     *
     * @see DB_common::createSequence(), DB_common::getSequenceName(),
     *      DB_pgsql::nextID(), DB_pgsql::dropSequence()
     */
    function createSequence($seq_name)
    {
        $seqname = $this->getSequenceName($seq_name);
        $result = $this->query("CREATE SEQUENCE ${seqname}");
        return $result;
    }
 
    // }}}
    // {{{ dropSequence()
 
    /**
     * Deletes a sequence
     *
     * @param string $seq_name  name of the sequence to be deleted
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     *
     * @see DB_common::dropSequence(), DB_common::getSequenceName(),
     *      DB_pgsql::nextID(), DB_pgsql::createSequence()
     */
    function dropSequence($seq_name)
    {
        return $this->query('DROP SEQUENCE '
                            . $this->getSequenceName($seq_name));
    }
 
    // }}}
    // {{{ modifyLimitQuery()
 
    /**
     * Adds LIMIT clauses to a query string according to current DBMS standards
     *
     * @param string $query   the query to modify
     * @param int    $from    the row to start to fetching (0 = the first row)
     * @param int    $count   the numbers of rows to fetch
     * @param mixed  $params  array, string or numeric data to be used in
     *                         execution of the statement.  Quantity of items
     *                         passed must match quantity of placeholders in
     *                         query:  meaning 1 placeholder for non-array
     *                         parameters or 1 placeholder per array element.
     *
     * @return string  the query string with LIMIT clauses added
     *
     * @access protected
     */
    function modifyLimitQuery($query, $from, $count, $params = array())
    {
        return "$query LIMIT $count OFFSET $from";
    }
 
    // }}}
    // {{{ pgsqlRaiseError()
 
    /**
     * Produces a DB_Error object regarding the current problem
     *
     * @param int $errno  if the error is being manually raised pass a
     *                     DB_ERROR* constant here.  If this isn't passed
     *                     the error information gathered from the DBMS.
     *
     * @return object  the DB_Error object
     *
     * @see DB_common::raiseError(),
     *      DB_pgsql::errorNative(), DB_pgsql::errorCode()
     */
    function pgsqlRaiseError($errno = null)
    {
        $native = $this->errorNative();
        if (!$native) {
            $native = 'Database connection has been lost.';
            $errno = DB_ERROR_CONNECT_FAILED;
        }
        if ($errno === null) {
            $errno = $this->errorCode($native);
        }
        return $this->raiseError($errno, null, null, null, $native);
    }
 
    // }}}
    // {{{ errorNative()
 
    /**
     * Gets the DBMS' native error message produced by the last query
     *
     * {@internal Error messages are used instead of error codes 
     * in order to support older versions of PostgreSQL.}}
     *
     * @return string  the DBMS' error message
     */
    function errorNative()
    {
        return @pg_errormessage($this->connection);
    }
 
    // }}}
    // {{{ errorCode()
 
    /**
     * Determines PEAR::DB error code from the database's text error message.
     *
     * @param  string  $errormsg  error message returned from the database
     * @return integer  an error number from a DB error constant
     */
    function errorCode($errormsg)
    {
        static $error_regexps;
        if (!isset($error_regexps)) {
            $error_regexps = array(
                '/column .* (of relation .*)?does not exist/i'
                    => DB_ERROR_NOSUCHFIELD,
                '/(relation|sequence|table).*does not exist|class .* not found/i'
                    => DB_ERROR_NOSUCHTABLE,
                '/index .* does not exist/'
                    => DB_ERROR_NOT_FOUND,
 
 
                '/relation .* already exists/i'
                    => DB_ERROR_ALREADY_EXISTS,
                '/(divide|division) by zero$/i'
                    => DB_ERROR_DIVZERO,
                '/pg_atoi: error in .*: can\'t parse /i'
                    => DB_ERROR_INVALID_NUMBER,
                '/invalid input syntax for( type)? (integer|numeric)/i'
                    => DB_ERROR_INVALID_NUMBER,
                '/value .* is out of range for type \w*int/i'
                    => DB_ERROR_INVALID_NUMBER,
                '/integer out of range/i'
                    => DB_ERROR_INVALID_NUMBER,
                '/value too long for type character/i'
                    => DB_ERROR_INVALID,
                '/attribute .* not found|relation .* does not have attribute/i'
                    => DB_ERROR_NOSUCHFIELD,
                '/column .* specified in USING clause does not exist in (left|right) table/i'
                    => DB_ERROR_NOSUCHFIELD,
                '/parser: parse error at or near/i'
                    => DB_ERROR_SYNTAX,
                '/syntax error at/'
                    => DB_ERROR_SYNTAX,
                '/column reference .* is ambiguous/i'
                    => DB_ERROR_SYNTAX,
                '/permission denied/'
                    => DB_ERROR_ACCESS_VIOLATION,
                '/violates not-null constraint/'
                    => DB_ERROR_CONSTRAINT_NOT_NULL,
                '/violates [\w ]+ constraint/'
                    => DB_ERROR_CONSTRAINT,
                '/referential integrity violation/'
                    => DB_ERROR_CONSTRAINT,
                '/more expressions than target columns/i'
                    => DB_ERROR_VALUE_COUNT_ON_ROW,
            );
        }
        foreach ($error_regexps as $regexp => $code) {
            if (preg_match($regexp, $errormsg)) {
                return $code;
            }
        }
        // Fall back to DB_ERROR if there was no mapping.
        return DB_ERROR;
    }
 
    // }}}
    // {{{ tableInfo()
 
    /**
     * Returns information about a table or a result set
     *
     * NOTE: only supports 'table' and 'flags' if <var>$result</var>
     * is a table name.
     *
     * @param object|string  $result  DB_result object from a query or a
     *                                 string containing the name of a table.
     *                                 While this also accepts a query result
     *                                 resource identifier, this behavior is
     *                                 deprecated.
     * @param int            $mode    a valid tableInfo mode
     *
     * @return array  an associative array with the information requested.
     *                 A DB_Error object on failure.
     *
     * @see DB_common::tableInfo()
     */
    function tableInfo($result, $mode = null)
    {
        if (is_string($result)) {
            /*
             * Probably received a table name.
             * Create a result resource identifier.
             */
            $id = @pg_exec($this->connection, "SELECT * FROM $result LIMIT 0");
            $got_string = true;
        } elseif (isset($result->result)) {
            /*
             * Probably received a result object.
             * Extract the result resource identifier.
             */
            $id = $result->result;
            $got_string = false;
        } else {
            /*
             * Probably received a result resource identifier.
             * Copy it.
             * Deprecated.  Here for compatibility only.
             */
            $id = $result;
            $got_string = false;
        }
 
        if (!is_resource($id)) {
            return $this->pgsqlRaiseError(DB_ERROR_NEED_MORE_DATA);
        }
 
        if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) {
            $case_func = 'strtolower';
        } else {
            $case_func = 'strval';
        }
 
        $count = @pg_numfields($id);
        $res   = array();
 
        if ($mode) {
            $res['num_fields'] = $count;
        }
 
        for ($i = 0; $i < $count; $i++) {
            $res[$i] = array(
                'table' => $got_string ? $case_func($result) : '',
                'name'  => $case_func(@pg_fieldname($id, $i)),
                'type'  => @pg_fieldtype($id, $i),
                'len'   => @pg_fieldsize($id, $i),
                'flags' => $got_string
                           ? $this->_pgFieldFlags($id, $i, $result)
                           : '',
            );
            if ($mode & DB_TABLEINFO_ORDER) {
                $res['order'][$res[$i]['name']] = $i;
            }
            if ($mode & DB_TABLEINFO_ORDERTABLE) {
                $res['ordertable'][$res[$i]['table']][$res[$i]['name']] = $i;
            }
        }
 
        // free the result only if we were called on a table
        if ($got_string) {
            @pg_freeresult($id);
        }
        return $res;
    }
 
    // }}}
    // {{{ _pgFieldFlags()
 
    /**
     * Get a column's flags
     *
     * Supports "not_null", "default_value", "primary_key", "unique_key"
     * and "multiple_key".  The default value is passed through
     * rawurlencode() in case there are spaces in it.
     *
     * @param int $resource   the PostgreSQL result identifier
     * @param int $num_field  the field number
     *
     * @return string  the flags
     *
     * @access private
     */
    function _pgFieldFlags($resource, $num_field, $table_name)
    {
        $field_name = @pg_fieldname($resource, $num_field);
 
        // Check if there's a schema in $table_name and update things
        // accordingly.
        $from = 'pg_attribute f, pg_class tab, pg_type typ';
        if (strpos($table_name, '.') !== false) {
            $from .= ', pg_namespace nsp';
            list($schema, $table) = explode('.', $table_name);
            $tableWhere = "tab.relname = '$table' AND tab.relnamespace = nsp.oid AND nsp.nspname = '$schema'";
        } else {
            $tableWhere = "tab.relname = '$table_name'";
        }
 
        $result = @pg_exec($this->connection, "SELECT f.attnotnull, f.atthasdef
                                FROM $from
                                WHERE tab.relname = typ.typname
                                AND typ.typrelid = f.attrelid
                                AND f.attname = '$field_name'
                                AND $tableWhere");
        if (@pg_numrows($result) > 0) {
            $row = @pg_fetch_row($result, 0);
            $flags  = ($row[0] == 't') ? 'not_null ' : '';
 
            if ($row[1] == 't') {
                $result = @pg_exec($this->connection, "SELECT a.adsrc
                                    FROM $from, pg_attrdef a
                                    WHERE tab.relname = typ.typname AND typ.typrelid = f.attrelid
                                    AND f.attrelid = a.adrelid AND f.attname = '$field_name'
                                    AND $tableWhere AND f.attnum = a.adnum");
                $row = @pg_fetch_row($result, 0);
                $num = preg_replace("/'(.*)'::\w+/", "\\1", $row[0]);
                $flags .= 'default_' . rawurlencode($num) . ' ';
            }
        } else {
            $flags = '';
        }
        $result = @pg_exec($this->connection, "SELECT i.indisunique, i.indisprimary, i.indkey
                                FROM $from, pg_index i
                                WHERE tab.relname = typ.typname
                                AND typ.typrelid = f.attrelid
                                AND f.attrelid = i.indrelid
                                AND f.attname = '$field_name'
                                AND $tableWhere");
        $count = @pg_numrows($result);
 
        for ($i = 0; $i < $count ; $i++) {
            $row = @pg_fetch_row($result, $i);
            $keys = explode(' ', $row[2]);
 
            if (in_array($num_field + 1, $keys)) {
                $flags .= ($row[0] == 't' && $row[1] == 'f') ? 'unique_key ' : '';
                $flags .= ($row[1] == 't') ? 'primary_key ' : '';
                if (count($keys) > 1)
                    $flags .= 'multiple_key ';
            }
        }
 
        return trim($flags);
    }
 
    // }}}
    // {{{ getSpecialQuery()
 
    /**
     * Obtains the query string needed for listing a given type of objects
     *
     * @param string $type  the kind of objects you want to retrieve
     *
     * @return string  the SQL query string or null if the driver doesn't
     *                  support the object type requested
     *
     * @access protected
     * @see DB_common::getListOf()
     */
    function getSpecialQuery($type)
    {
        switch ($type) {
            case 'tables':
                return 'SELECT c.relname AS "Name"'
                        . ' FROM pg_class c, pg_user u'
                        . ' WHERE c.relowner = u.usesysid'
                        . " AND c.relkind = 'r'"
                        . ' AND NOT EXISTS'
                        . ' (SELECT 1 FROM pg_views'
                        . '  WHERE viewname = c.relname)'
                        . " AND c.relname !~ '^(pg_|sql_)'"
                        . ' UNION'
                        . ' SELECT c.relname AS "Name"'
                        . ' FROM pg_class c'
                        . " WHERE c.relkind = 'r'"
                        . ' AND NOT EXISTS'
                        . ' (SELECT 1 FROM pg_views'
                        . '  WHERE viewname = c.relname)'
                        . ' AND NOT EXISTS'
                        . ' (SELECT 1 FROM pg_user'
                        . '  WHERE usesysid = c.relowner)'
                        . " AND c.relname !~ '^pg_'";
            case 'schema.tables':
                return "SELECT schemaname || '.' || tablename"
                        . ' AS "Name"'
                        . ' FROM pg_catalog.pg_tables'
                        . ' WHERE schemaname NOT IN'
                        . " ('pg_catalog', 'information_schema', 'pg_toast')";
            case 'schema.views':
                return "SELECT schemaname || '.' || viewname from pg_views WHERE schemaname"
                        . " NOT IN ('information_schema', 'pg_catalog')";
            case 'views':
                // Table cols: viewname | viewowner | definition
                return 'SELECT viewname from pg_views WHERE schemaname'
                        . " NOT IN ('information_schema', 'pg_catalog')";
            case 'users':
                // cols: usename |usesysid|usecreatedb|usetrace|usesuper|usecatupd|passwd  |valuntil
                return 'SELECT usename FROM pg_user';
            case 'databases':
                return 'SELECT datname FROM pg_database';
            case 'functions':
            case 'procedures':
                return 'SELECT proname FROM pg_proc WHERE proowner <> 1';
            default:
                return null;
        }
    }
 
    // }}}
    // {{{ _checkManip()
 
    /**
     * Checks if the given query is a manipulation query. This also takes into
     * account the _next_query_manip flag and sets the _last_query_manip flag
     * (and resets _next_query_manip) according to the result.
     *
     * @param string The query to check.
     *
     * @return boolean true if the query is a manipulation query, false
     * otherwise
     *
     * @access protected
     */
    function _checkManip($query)
    {
        return (preg_match('/^\s*(SAVEPOINT|RELEASE)\s+/i', $query)
                || parent::_checkManip($query));
    }
 
}
 
/*
 * Local variables:
 * tab-width: 4
 * c-basic-offset: 4
 * End:
 */
 
?>

Rev 94	Rev 187
1	`<?php`	1	`<?php`
2		2
3	`/* vim: set expandtab tabstop=4 shiftwidth=4 softtabstop=4: */`	3	`/* vim: set expandtab tabstop=4 shiftwidth=4 softtabstop=4: */`
4		4
5	`/**`	5	`/**`
6	`* The PEAR DB driver for PHP's pgsql extension`	6	`* The PEAR DB driver for PHP's pgsql extension`
7	`* for interacting with PostgreSQL databases`	7	`* for interacting with PostgreSQL databases`
8	`*`	8	`*`
9	`* PHP versions 4 and 5`	9	`* PHP version 5`
10	`*`	10	`*`
11	`* LICENSE: This source file is subject to version 3.0 of the PHP license`	11	`* LICENSE: This source file is subject to version 3.0 of the PHP license`
12	`* that is available through the world-wide-web at the following URI:`	12	`* that is available through the world-wide-web at the following URI:`
13	`* http://www.php.net/license/3_0.txt. If you did not receive a copy of`	13	`* http://www.php.net/license/3_0.txt. If you did not receive a copy of`
14	`* the PHP License and are unable to obtain it through the web, please`	14	`* the PHP License and are unable to obtain it through the web, please`
15	`* send a note to license@php.net so we can mail you a copy immediately.`	15	`* send a note to license@php.net so we can mail you a copy immediately.`
16	`*`	16	`*`
17	`* @category Database`	17	`* @category Database`
18	`* @package DB`	18	`* @package DB`
19	`* @author Rui Hirokawa <hirokawa@php.net>`	19	`* @author Rui Hirokawa <hirokawa@php.net>`
20	`* @author Stig Bakken <ssb@php.net>`	20	`* @author Stig Bakken <ssb@php.net>`
21	`* @author Daniel Convissor <danielc@php.net>`	21	`* @author Daniel Convissor <danielc@php.net>`
22	`* @copyright 1997-2005 The PHP Group`	22	`* @copyright 1997-2007 The PHP Group`
23	`* @license http://www.php.net/license/3_0.txt PHP License 3.0`	23	`* @license http://www.php.net/license/3_0.txt PHP License 3.0`
24	`* @version CVS: $Id: pgsql.php,v 1.126 2005/03/04 23:12:36 danielc Exp $`	24	`* @version CVS: $Id$`
25	`* @link http://pear.php.net/package/DB`	25	`* @link http://pear.php.net/package/DB`
26	`*/`	26	`*/`
27		27
28	`/**`	28	`/**`
29	`* Obtain the DB_common class so it can be extended from`	29	`* Obtain the DB_common class so it can be extended from`
30	`*/`	30	`*/`
31	`require_once 'DB/common.php';`	31	`require_once 'DB/common.php';`
32		32
33	`/**`	33	`/**`
34	`* The methods PEAR DB uses to interact with PHP's pgsql extension`	34	`* The methods PEAR DB uses to interact with PHP's pgsql extension`
35	`* for interacting with PostgreSQL databases`	35	`* for interacting with PostgreSQL databases`
36	`*`	36	`*`
37	`* These methods overload the ones declared in DB_common.`	37	`* These methods overload the ones declared in DB_common.`
38	`*`	38	`*`
39	`* @category Database`	39	`* @category Database`
40	`* @package DB`	40	`* @package DB`
41	`* @author Rui Hirokawa <hirokawa@php.net>`	41	`* @author Rui Hirokawa <hirokawa@php.net>`
42	`* @author Stig Bakken <ssb@php.net>`	42	`* @author Stig Bakken <ssb@php.net>`
43	`* @author Daniel Convissor <danielc@php.net>`	43	`* @author Daniel Convissor <danielc@php.net>`
44	`* @copyright 1997-2005 The PHP Group`	44	`* @copyright 1997-2007 The PHP Group`
45	`* @license http://www.php.net/license/3_0.txt PHP License 3.0`	45	`* @license http://www.php.net/license/3_0.txt PHP License 3.0`
46	`* @version Release: 1.7.6`	46	`* @version Release: 1.9.2`
47	`* @link http://pear.php.net/package/DB`	47	`* @link http://pear.php.net/package/DB`
48	`*/`	48	`*/`
49	`class DB_pgsql extends DB_common`	49	`class DB_pgsql extends DB_common`
50	`{`	50	`{`
51	`// {{{ properties`	51	`// {{{ properties`
52		52
53	`/**`	53	`/**`
54	`* The DB driver type (mysql, oci8, odbc, etc.)`	54	`* The DB driver type (mysql, oci8, odbc, etc.)`
55	`* @var string`	55	`* @var string`
56	`*/`	56	`*/`
57	`var $phptype = 'pgsql';`	57	`var $phptype = 'pgsql';`
58		58
59	`/**`	59	`/**`
60	`* The database syntax variant to be used (db2, access, etc.), if any`	60	`* The database syntax variant to be used (db2, access, etc.), if any`
61	`* @var string`	61	`* @var string`
62	`*/`	62	`*/`
63	`var $dbsyntax = 'pgsql';`	63	`var $dbsyntax = 'pgsql';`
64		64
65	`/**`	65	`/**`
66	`* The capabilities of this DB implementation`	66	`* The capabilities of this DB implementation`
67	`*`	67	`*`
68	`* The 'new_link' element contains the PHP version that first provided`	68	`* The 'new_link' element contains the PHP version that first provided`
69	`* new_link support for this DBMS. Contains false if it's unsupported.`	69	`* new_link support for this DBMS. Contains false if it's unsupported.`
70	`*`	70	`*`
71	`* Meaning of the 'limit' element:`	71	`* Meaning of the 'limit' element:`
72	`* + 'emulate' = emulate with fetch row by number`	72	`* + 'emulate' = emulate with fetch row by number`
73	`* + 'alter' = alter the query`	73	`* + 'alter' = alter the query`
74	`* + false = skip rows`	74	`* + false = skip rows`
75	`*`	75	`*`
76	`* @var array`	76	`* @var array`
77	`*/`	77	`*/`
78	`var $features = array(`	78	`var $features = array(`
79	`'limit' => 'alter',`	79	`'limit' => 'alter',`
80	`'new_link' => '4.3.0',`	80	`'new_link' => '4.3.0',`
81	`'numrows' => true,`	81	`'numrows' => true,`
82	`'pconnect' => true,`	82	`'pconnect' => true,`
83	`'prepare' => false,`	83	`'prepare' => false,`
84	`'ssl' => true,`	84	`'ssl' => true,`
85	`'transactions' => true,`	85	`'transactions' => true,`
86	`);`	86	`);`
87		87
88	`/**`	88	`/**`
89	`* A mapping of native error codes to DB error codes`	89	`* A mapping of native error codes to DB error codes`
90	`* @var array`	90	`* @var array`
91	`*/`	91	`*/`
92	`var $errorcode_map = array(`	92	`var $errorcode_map = array(`
93	`);`	93	`);`
94		94
95	`/**`	95	`/**`
96	`* The raw database connection created by PHP`	96	`* The raw database connection created by PHP`
97	`* @var resource`	97	`* @var resource`
98	`*/`	98	`*/`
99	`var $connection;`	99	`var $connection;`
100		100
101	`/**`	101	`/**`
102	`* The DSN information for connecting to a database`	102	`* The DSN information for connecting to a database`
103	`* @var array`	103	`* @var array`
104	`*/`	104	`*/`
105	`var $dsn = array();`	105	`var $dsn = array();`
106		106
107		107
108	`/**`	108	`/**`
109	`* Should data manipulation queries be committed automatically?`	109	`* Should data manipulation queries be committed automatically?`
110	`* @var bool`	110	`* @var bool`
111	`* @access private`	111	`* @access private`
112	`*/`	112	`*/`
113	`var $autocommit = true;`	113	`var $autocommit = true;`
114		114
115	`/**`	115	`/**`
116	`* The quantity of transactions begun`	116	`* The quantity of transactions begun`
117	`*`	117	`*`
118	`* {@internal While this is private, it can't actually be designated`	118	`* {@internal While this is private, it can't actually be designated`
119	`* private in PHP 5 because it is directly accessed in the test suite.}}`	119	`* private in PHP 5 because it is directly accessed in the test suite.}}`
120	`*`	120	`*`
121	`* @var integer`	121	`* @var integer`
122	`* @access private`	122	`* @access private`
123	`*/`	123	`*/`
124	`var $transaction_opcount = 0;`	124	`var $transaction_opcount = 0;`
125		125
126	`/**`	126	`/**`
127	`* The number of rows affected by a data manipulation query`	127	`* The number of rows affected by a data manipulation query`
128	`* @var integer`	128	`* @var integer`
129	`*/`	129	`*/`
130	`var $affected = 0;`	130	`var $affected = 0;`
131		131
132	`/**`	132	`/**`
133	`* The current row being looked at in fetchInto()`	133	`* The current row being looked at in fetchInto()`
134	`* @var array`	134	`* @var array`
135	`* @access private`	135	`* @access private`
136	`*/`	136	`*/`
137	`var $row = array();`	137	`var $row = array();`
138		138
139	`/**`	139	`/**`
140	`* The number of rows in a given result set`	140	`* The number of rows in a given result set`
141	`* @var array`	141	`* @var array`
142	`* @access private`	142	`* @access private`
143	`*/`	143	`*/`
144	`var $_num_rows = array();`	144	`var $_num_rows = array();`
145		145
146		146
147	`// }}}`	147	`// }}}`
148	`// {{{ constructor`	148	`// {{{ constructor`
149		149
150	`/**`	150	`/**`
151	`* This constructor calls <kbd>$this->DB_common()</kbd>`	151	`* This constructor calls <kbd>parent::__construct()</kbd>`
152	`*`	152	`*`
153	`* @return void`	153	`* @return void`
154	`*/`	154	`*/`
155	`function DB_pgsql()`	155	`function __construct()`
156	`{`	156	`{`
157	`$this->DB_common();`	157	`parent::__construct();`
158	`}`	158	`}`
159		159
160	`// }}}`	160	`// }}}`
161	`// {{{ connect()`	161	`// {{{ connect()`
162		162
163	`/**`	163	`/**`
164	`* Connect to the database server, log in and open the database`	164	`* Connect to the database server, log in and open the database`
165	`*`	165	`*`
166	`* Don't call this method directly. Use DB::connect() instead.`	166	`* Don't call this method directly. Use DB::connect() instead.`
167	`*`	167	`*`
168	`* PEAR DB's pgsql driver supports the following extra DSN options:`	168	`* PEAR DB's pgsql driver supports the following extra DSN options:`
169	`* + connect_timeout How many seconds to wait for a connection to`	169	`* + connect_timeout How many seconds to wait for a connection to`
170	`* be established. Available since PEAR DB 1.7.0.`	170	`* be established. Available since PEAR DB 1.7.0.`
171	`* + new_link If set to true, causes subsequent calls to`	171	`* + new_link If set to true, causes subsequent calls to`
172	`* connect() to return a new connection link`	172	`* connect() to return a new connection link`
173	`* instead of the existing one. WARNING: this is`	173	`* instead of the existing one. WARNING: this is`
174	`* not portable to other DBMS's. Available only`	174	`* not portable to other DBMS's. Available only`
175	`* if PHP is >= 4.3.0 and PEAR DB is >= 1.7.0.`	175	`* if PHP is >= 4.3.0 and PEAR DB is >= 1.7.0.`
176	`* + options Command line options to be sent to the server.`	176	`* + options Command line options to be sent to the server.`
177	`* Available since PEAR DB 1.6.4.`	177	`* Available since PEAR DB 1.6.4.`
178	`* + service Specifies a service name in pg_service.conf that`	178	`* + service Specifies a service name in pg_service.conf that`
179	`* holds additional connection parameters.`	179	`* holds additional connection parameters.`
180	`* Available since PEAR DB 1.7.0.`	180	`* Available since PEAR DB 1.7.0.`
181	`* + sslmode How should SSL be used when connecting? Values:`	181	`* + sslmode How should SSL be used when connecting? Values:`
182	`* disable, allow, prefer or require.`	182	`* disable, allow, prefer or require.`
183	`* Available since PEAR DB 1.7.0.`	183	`* Available since PEAR DB 1.7.0.`
184	`* + tty This was used to specify where to send server`	184	`* + tty This was used to specify where to send server`
185	`* debug output. Available since PEAR DB 1.6.4.`	185	`* debug output. Available since PEAR DB 1.6.4.`
186	`*`	186	`*`
187	`* Example of connecting to a new link via a socket:`	187	`* Example of connecting to a new link via a socket:`
188	`* <code>`	188	`* <code>`
189	`* require_once 'DB.php';`	189	`* require_once 'DB.php';`
190	`*`	190	`*`
191	`* $dsn = 'pgsql://user:pass@unix(/tmp)/dbname?new_link=true';`	191	`* $dsn = 'pgsql://user:pass@unix(/tmp)/dbname?new_link=true';`
192	`* $options = array(`	192	`* $options = array(`
193	`* 'portability' => DB_PORTABILITY_ALL,`	193	`* 'portability' => DB_PORTABILITY_ALL,`
194	`* );`	194	`* );`
195	`*`	195	`*`
196	`* $db =& DB::connect($dsn, $options);`	196	`* $db = DB::connect($dsn, $options);`
197	`* if (PEAR::isError($db)) {`	197	`* if (PEAR::isError($db)) {`
198	`* die($db->getMessage());`	198	`* die($db->getMessage());`
199	`* }`	199	`* }`
200	`* </code>`	200	`* </code>`
201	`*`	201	`*`
202	`* @param array $dsn the data source name`	202	`* @param array $dsn the data source name`
203	`* @param bool $persistent should the connection be persistent?`	203	`* @param bool $persistent should the connection be persistent?`
204	`*`	204	`*`
205	`* @return int DB_OK on success. A DB_Error object on failure.`	205	`* @return int DB_OK on success. A DB_Error object on failure.`
206	`*`	206	`*`
207	`* @link http://www.postgresql.org/docs/current/static/libpq.html#LIBPQ-CONNECT`	207	`* @link http://www.postgresql.org/docs/current/static/libpq.html#LIBPQ-CONNECT`
208	`*/`	208	`*/`
209	`function connect($dsn, $persistent = false)`	209	`function connect($dsn, $persistent = false)`
210	`{`	210	`{`
211	`if (!PEAR::loadExtension('pgsql')) {`	211	`if (!PEAR::loadExtension('pgsql')) {`
212	`return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);`	212	`return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);`
213	`}`	213	`}`
214		214
215	`$this->dsn = $dsn;`	215	`$this->dsn = $dsn;`
216	`if ($dsn['dbsyntax']) {`	216	`if ($dsn['dbsyntax']) {`
217	`$this->dbsyntax = $dsn['dbsyntax'];`	217	`$this->dbsyntax = $dsn['dbsyntax'];`
218	`}`	218	`}`
219		219
220	`$protocol = $dsn['protocol'] ? $dsn['protocol'] : 'tcp';`	220	`$protocol = $dsn['protocol'] ? $dsn['protocol'] : 'tcp';`
221		221
222	`$params = array('');`	222	`$params = array('');`
223	`if ($protocol == 'tcp') {`	223	`if ($protocol == 'tcp') {`
224	`if ($dsn['hostspec']) {`	224	`if ($dsn['hostspec']) {`
225	`$params[0] .= 'host=' . $dsn['hostspec'];`	225	`$params[0] .= 'host=' . $dsn['hostspec'];`
226	`}`	226	`}`
227	`if ($dsn['port']) {`	227	`if ($dsn['port']) {`
228	`$params[0] .= ' port=' . $dsn['port'];`	228	`$params[0] .= ' port=' . $dsn['port'];`
229	`}`	229	`}`
230	`} elseif ($protocol == 'unix') {`	230	`} elseif ($protocol == 'unix') {`
231	`// Allow for pg socket in non-standard locations.`	231	`// Allow for pg socket in non-standard locations.`
232	`if ($dsn['socket']) {`	232	`if ($dsn['socket']) {`
233	`$params[0] .= 'host=' . $dsn['socket'];`	233	`$params[0] .= 'host=' . $dsn['socket'];`
234	`}`	234	`}`
235	`if ($dsn['port']) {`	235	`if ($dsn['port']) {`
236	`$params[0] .= ' port=' . $dsn['port'];`	236	`$params[0] .= ' port=' . $dsn['port'];`
237	`}`	237	`}`
238	`}`	238	`}`
239	`if ($dsn['database']) {`	239	`if ($dsn['database']) {`
240	`$params[0] .= ' dbname=\'' . addslashes($dsn['database']) . '\'';`	240	`$params[0] .= ' dbname=\'' . addslashes($dsn['database']) . '\'';`
241	`}`	241	`}`
242	`if ($dsn['username']) {`	242	`if ($dsn['username']) {`
243	`$params[0] .= ' user=\'' . addslashes($dsn['username']) . '\'';`	243	`$params[0] .= ' user=\'' . addslashes($dsn['username']) . '\'';`
244	`}`	244	`}`
245	`if ($dsn['password']) {`	245	`if ($dsn['password']) {`
246	`$params[0] .= ' password=\'' . addslashes($dsn['password']) . '\'';`	246	`$params[0] .= ' password=\'' . addslashes($dsn['password']) . '\'';`
247	`}`	247	`}`
248	`if (!empty($dsn['options'])) {`	248	`if (!empty($dsn['options'])) {`
249	`$params[0] .= ' options=' . $dsn['options'];`	249	`$params[0] .= ' options=' . $dsn['options'];`
250	`}`	250	`}`
251	`if (!empty($dsn['tty'])) {`	251	`if (!empty($dsn['tty'])) {`
252	`$params[0] .= ' tty=' . $dsn['tty'];`	252	`$params[0] .= ' tty=' . $dsn['tty'];`
253	`}`	253	`}`
254	`if (!empty($dsn['connect_timeout'])) {`	254	`if (!empty($dsn['connect_timeout'])) {`
255	`$params[0] .= ' connect_timeout=' . $dsn['connect_timeout'];`	255	`$params[0] .= ' connect_timeout=' . $dsn['connect_timeout'];`
256	`}`	256	`}`
257	`if (!empty($dsn['sslmode'])) {`	257	`if (!empty($dsn['sslmode'])) {`
258	`$params[0] .= ' sslmode=' . $dsn['sslmode'];`	258	`$params[0] .= ' sslmode=' . $dsn['sslmode'];`
259	`}`	259	`}`
260	`if (!empty($dsn['service'])) {`	260	`if (!empty($dsn['service'])) {`
261	`$params[0] .= ' service=' . $dsn['service'];`	261	`$params[0] .= ' service=' . $dsn['service'];`
262	`}`	262	`}`
263		263
264	`if (isset($dsn['new_link'])`	264	`if (isset($dsn['new_link'])`
265	`&& ($dsn['new_link'] == 'true' \|\| $dsn['new_link'] === true))`	265	`&& ($dsn['new_link'] == 'true' \|\| $dsn['new_link'] === true))`
266	`{`	266	`{`
267	`if (version_compare(phpversion(), '4.3.0', '>=')) {`	267	`if (version_compare(phpversion(), '4.3.0', '>=')) {`
268	`$params[] = PGSQL_CONNECT_FORCE_NEW;`	268	`$params[] = PGSQL_CONNECT_FORCE_NEW;`
269	`}`	269	`}`
270	`}`	270	`}`
271		271
272	`$connect_function = $persistent ? 'pg_pconnect' : 'pg_connect';`	272	`$connect_function = $persistent ? 'pg_pconnect' : 'pg_connect';`
273		273
274	`$ini = ini_get('track_errors');`	274	`$ini = ini_get('track_errors');`
275	`$php_errormsg = '';`	275	`$php_errormsg = '';`
276	`if ($ini) {`	276	`if ($ini) {`
277	`$this->connection = @call_user_func_array($connect_function,`	277	`$this->connection = @call_user_func_array($connect_function,`
278	`$params);`	278	`$params);`
279	`} else {`	279	`} else {`
280	`ini_set('track_errors', 1);`	280	`@ini_set('track_errors', 1);`
281	`$this->connection = @call_user_func_array($connect_function,`	281	`$this->connection = @call_user_func_array($connect_function,`
282	`$params);`	282	`$params);`
283	`ini_set('track_errors', $ini);`	283	`@ini_set('track_errors', $ini);`
284	`}`	284	`}`
285		285
286	`if (!$this->connection) {`	286	`if (!$this->connection) {`
287	`return $this->raiseError(DB_ERROR_CONNECT_FAILED,`	287	`return $this->raiseError(DB_ERROR_CONNECT_FAILED,`
288	`null, null, null,`	288	`null, null, null,`
289	`$php_errormsg);`	289	`$php_errormsg);`
290	`}`	290	`}`
291	`return DB_OK;`	291	`return DB_OK;`
292	`}`	292	`}`
293		293
294	`// }}}`	294	`// }}}`
295	`// {{{ disconnect()`	295	`// {{{ disconnect()`
296		296
297	`/**`	297	`/**`
298	`* Disconnects from the database server`	298	`* Disconnects from the database server`
299	`*`	299	`*`
300	`* @return bool TRUE on success, FALSE on failure`	300	`* @return bool TRUE on success, FALSE on failure`
301	`*/`	301	`*/`
302	`function disconnect()`	302	`function disconnect()`
303	`{`	303	`{`
304	`$ret = @pg_close($this->connection);`	304	`$ret = @pg_close($this->connection);`
305	`$this->connection = null;`	305	`$this->connection = null;`
306	`return $ret;`	306	`return $ret;`
307	`}`	307	`}`
308		308
309	`// }}}`	309	`// }}}`
310	`// {{{ simpleQuery()`	310	`// {{{ simpleQuery()`
311		311
312	`/**`	312	`/**`
313	`* Sends a query to the database server`	313	`* Sends a query to the database server`
314	`*`	314	`*`
315	`* @param string the SQL query string`	315	`* @param string the SQL query string`
316	`*`	316	`*`
317	`* @return mixed + a PHP result resrouce for successful SELECT queries`	317	`* @return mixed + a PHP result resrouce for successful SELECT queries`
318	`* + the DB_OK constant for other successful queries`	318	`* + the DB_OK constant for other successful queries`
319	`* + a DB_Error object on failure`	319	`* + a DB_Error object on failure`
320	`*/`	320	`*/`
321	`function simpleQuery($query)`	321	`function simpleQuery($query)`
322	`{`	322	`{`
323	`$ismanip = DB::isManip($query);`	323	`$ismanip = $this->_checkManip($query);`
324	`$this->last_query = $query;`	324	`$this->last_query = $query;`
325	`$query = $this->modifyQuery($query);`	325	`$query = $this->modifyQuery($query);`
326	`if (!$this->autocommit && $ismanip) {`	326	`if (!$this->autocommit && $ismanip) {`
327	`if ($this->transaction_opcount == 0) {`	327	`if ($this->transaction_opcount == 0) {`
328	`$result = @pg_exec($this->connection, 'begin;');`	328	`$result = @pg_exec($this->connection, 'begin;');`
329	`if (!$result) {`	329	`if (!$result) {`
330	`return $this->pgsqlRaiseError();`	330	`return $this->pgsqlRaiseError();`
331	`}`	331	`}`
332	`}`	332	`}`
333	`$this->transaction_opcount++;`	333	`$this->transaction_opcount++;`
334	`}`	334	`}`
335	`$result = @pg_exec($this->connection, $query);`	335	`$result = @pg_exec($this->connection, $query);`
336	`if (!$result) {`	336	`if (!$result) {`
337	`return $this->pgsqlRaiseError();`	337	`return $this->pgsqlRaiseError();`
338	`}`	338	`}`
-		339
-		340	`/*`
339	`// Determine which queries that should return data, and which`	341	`* Determine whether queries produce affected rows, result or nothing.`
-		342	`*`
-		343	`* This logic was introduced in version 1.1 of the file by ssb,`
-		344	`* though the regex has been modified slightly since then.`
-		345	`*`
340	`// should return an error code only.`	346	`* PostgreSQL commands:`
-		347	`* ABORT, ALTER, BEGIN, CLOSE, CLUSTER, COMMIT, COPY,`
-		348	`* CREATE, DECLARE, DELETE, DROP TABLE, EXPLAIN, FETCH,`
-		349	`* GRANT, INSERT, LISTEN, LOAD, LOCK, MOVE, NOTIFY, RESET,`
-		350	`* REVOKE, ROLLBACK, SELECT, SELECT INTO, SET, SHOW,`
-		351	`* UNLISTEN, UPDATE, VACUUM, WITH`
-		352	`*/`
341	`if ($ismanip) {`	353	`if ($ismanip) {`
342	`$this->affected = @pg_affected_rows($result);`	354	`$this->affected = @pg_affected_rows($result);`
343	`return DB_OK;`	355	`return DB_OK;`
344	`} elseif (preg_match('/^\s\(\s*(SELECT\|EXPLAIN\|SHOW)\s/si', $query)) {`	356	`} elseif (preg_match('/^\s\(\s*(SELECT\|EXPLAIN\|FETCH\|SHOW\|WITH)\s/si',`
345	`/* PostgreSQL commands:`	-
346	`ABORT, ALTER, BEGIN, CLOSE, CLUSTER, COMMIT, COPY,`	-
347	`CREATE, DECLARE, DELETE, DROP TABLE, EXPLAIN, FETCH,`	-
348	`GRANT, INSERT, LISTEN, LOAD, LOCK, MOVE, NOTIFY, RESET,`	-
349	`REVOKE, ROLLBACK, SELECT, SELECT INTO, SET, SHOW,`	-
350	`UNLISTEN, UPDATE, VACUUM`	357	`$query))`
351	`*/`	358	`{`
352	`$this->row[(int)$result] = 0; // reset the row counter.`	359	`$this->row[(int)$result] = 0; // reset the row counter.`
353	`$numrows = $this->numRows($result);`	360	`$numrows = $this->numRows($result);`
354	`if (is_object($numrows)) {`	361	`if (is_object($numrows)) {`
355	`return $numrows;`	362	`return $numrows;`
356	`}`	363	`}`
357	`$this->_num_rows[(int)$result] = $numrows;`	364	`$this->_num_rows[(int)$result] = $numrows;`
358	`$this->affected = 0;`	365	`$this->affected = 0;`
359	`return $result;`	366	`return $result;`
360	`} else {`	367	`} else {`
361	`$this->affected = 0;`	368	`$this->affected = 0;`
362	`return DB_OK;`	369	`return DB_OK;`
363	`}`	370	`}`
364	`}`	371	`}`
365		372
366	`// }}}`	373	`// }}}`
367	`// {{{ nextResult()`	374	`// {{{ nextResult()`
368		375
369	`/**`	376	`/**`
370	`* Move the internal pgsql result pointer to the next available result`	377	`* Move the internal pgsql result pointer to the next available result`
371	`*`	378	`*`
372	`* @param a valid fbsql result resource`	379	`* @param a valid fbsql result resource`
373	`*`	380	`*`
374	`* @access public`	381	`* @access public`
375	`*`	382	`*`
376	`* @return true if a result is available otherwise return false`	383	`* @return true if a result is available otherwise return false`
377	`*/`	384	`*/`
378	`function nextResult($result)`	385	`function nextResult($result)`
379	`{`	386	`{`
380	`return false;`	387	`return false;`
381	`}`	388	`}`
382		389
383	`// }}}`	390	`// }}}`
384	`// {{{ fetchInto()`	391	`// {{{ fetchInto()`
385		392
386	`/**`	393	`/**`
387	`* Places a row from the result set into the given array`	394	`* Places a row from the result set into the given array`
388	`*`	395	`*`
389	`* Formating of the array and the data therein are configurable.`	396	`* Formating of the array and the data therein are configurable.`
390	`* See DB_result::fetchInto() for more information.`	397	`* See DB_result::fetchInto() for more information.`
391	`*`	398	`*`
392	`* This method is not meant to be called directly. Use`	399	`* This method is not meant to be called directly. Use`
393	`* DB_result::fetchInto() instead. It can't be declared "protected"`	400	`* DB_result::fetchInto() instead. It can't be declared "protected"`
394	`* because DB_result is a separate object.`	401	`* because DB_result is a separate object.`
395	`*`	402	`*`
396	`* @param resource $result the query result resource`	403	`* @param resource $result the query result resource`
397	`* @param array $arr the referenced array to put the data in`	404	`* @param array $arr the referenced array to put the data in`
398	`* @param int $fetchmode how the resulting array should be indexed`	405	`* @param int $fetchmode how the resulting array should be indexed`
399	`* @param int $rownum the row number to fetch (0 = first row)`	406	`* @param int $rownum the row number to fetch (0 = first row)`
400	`*`	407	`*`
401	`* @return mixed DB_OK on success, NULL when the end of a result set is`	408	`* @return mixed DB_OK on success, NULL when the end of a result set is`
402	`* reached or on failure`	409	`* reached or on failure`
403	`*`	410	`*`
404	`* @see DB_result::fetchInto()`	411	`* @see DB_result::fetchInto()`
405	`*/`	412	`*/`
406	`function fetchInto($result, &$arr, $fetchmode, $rownum = null)`	413	`function fetchInto($result, &$arr, $fetchmode, $rownum = null)`
407	`{`	414	`{`
408	`$result_int = (int)$result;`	415	`$result_int = (int)$result;`
409	`$rownum = ($rownum !== null) ? $rownum : $this->row[$result_int];`	416	`$rownum = ($rownum !== null) ? $rownum : $this->row[$result_int];`
410	`if ($rownum >= $this->_num_rows[$result_int]) {`	417	`if ($rownum >= $this->_num_rows[$result_int]) {`
411	`return null;`	418	`return null;`
412	`}`	419	`}`
413	`if ($fetchmode & DB_FETCHMODE_ASSOC) {`	420	`if ($fetchmode & DB_FETCHMODE_ASSOC) {`
414	`$arr = @pg_fetch_array($result, $rownum, PGSQL_ASSOC);`	421	`$arr = @pg_fetch_array($result, $rownum, PGSQL_ASSOC);`
415	`if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE && $arr) {`	422	`if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE && $arr) {`
416	`$arr = array_change_key_case($arr, CASE_LOWER);`	423	`$arr = array_change_key_case($arr, CASE_LOWER);`
417	`}`	424	`}`
418	`} else {`	425	`} else {`
419	`$arr = @pg_fetch_row($result, $rownum);`	426	`$arr = @pg_fetch_row($result, $rownum);`
420	`}`	427	`}`
421	`if (!$arr) {`	428	`if (!$arr) {`
422	`return null;`	429	`return null;`
423	`}`	430	`}`
424	`if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {`	431	`if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {`
425	`$this->_rtrimArrayValues($arr);`	432	`$this->_rtrimArrayValues($arr);`
426	`}`	433	`}`
427	`if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {`	434	`if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {`
428	`$this->_convertNullArrayValuesToEmpty($arr);`	435	`$this->_convertNullArrayValuesToEmpty($arr);`
429	`}`	436	`}`
430	`$this->row[$result_int] = ++$rownum;`	437	`$this->row[$result_int] = ++$rownum;`
431	`return DB_OK;`	438	`return DB_OK;`
432	`}`	439	`}`
433		440
434	`// }}}`	441	`// }}}`
435	`// {{{ freeResult()`	442	`// {{{ freeResult()`
436		443
437	`/**`	444	`/**`
438	`* Deletes the result set and frees the memory occupied by the result set`	445	`* Deletes the result set and frees the memory occupied by the result set`
439	`*`	446	`*`
440	`* This method is not meant to be called directly. Use`	447	`* This method is not meant to be called directly. Use`
441	`* DB_result::free() instead. It can't be declared "protected"`	448	`* DB_result::free() instead. It can't be declared "protected"`
442	`* because DB_result is a separate object.`	449	`* because DB_result is a separate object.`
443	`*`	450	`*`
444	`* @param resource $result PHP's query result resource`	451	`* @param resource $result PHP's query result resource`
445	`*`	452	`*`
446	`* @return bool TRUE on success, FALSE if $result is invalid`	453	`* @return bool TRUE on success, FALSE if $result is invalid`
447	`*`	454	`*`
448	`* @see DB_result::free()`	455	`* @see DB_result::free()`
449	`*/`	456	`*/`
450	`function freeResult($result)`	457	`function freeResult($result)`
451	`{`	458	`{`
452	`if (is_resource($result)) {`	459	`if (is_resource($result)) {`
453	`unset($this->row[(int)$result]);`	460	`unset($this->row[(int)$result]);`
454	`unset($this->_num_rows[(int)$result]);`	461	`unset($this->_num_rows[(int)$result]);`
455	`$this->affected = 0;`	462	`$this->affected = 0;`
456	`return @pg_freeresult($result);`	463	`return @pg_freeresult($result);`
457	`}`	464	`}`
458	`return false;`	465	`return false;`
459	`}`	466	`}`
460		467
461	`// }}}`	468	`// }}}`
462	`// {{{ quote()`	-
463		-
464	`/**`	-
465	`* @deprecated Deprecated in release 1.6.0`	-
466	`* @internal`	-
467	`*/`	-
468	`function quote($str)`	-
469	`{`	-
470	`return $this->quoteSmart($str);`	-
471	`}`	-
472		-
473	`// }}}`	-
474	`// {{{ quoteSmart()`	469	`// {{{ quoteBoolean()`
475		470
476	`/**`	471	`/**`
477	`* Formats input so it can be safely used in a query`	472	`* Formats a boolean value for use within a query in a locale-independent`
478	`*`	-
479	`* @param mixed $in the data to be formatted`	-
480	`*`	-
481	`* @return mixed the formatted data. The format depends on the input's`	-
482	`* PHP type:`	-
483	`* + null = the string <samp>NULL</samp>`	-
484	`* + boolean = string <samp>TRUE</samp> or <samp>FALSE</samp>`	-
485	`* + integer or double = the unquoted number`	-
486	`* + other (including strings and numeric strings) =`	-
487	`* the data escaped according to MySQL's settings`	-
488	`* then encapsulated between single quotes`	473	`* manner.`

Subversion Repositories Applications.gtt

(root)/trunk/bibliotheque/pear/DB/pgsql.php – Rev 94 → 187