<?php/* vim: set expandtab tabstop=4 shiftwidth=4 foldmethod=marker: */// +----------------------------------------------------------------------+// | PHP Version 4                                                        |// +----------------------------------------------------------------------+// | Copyright (c) 1997-2004 The PHP Group                                |// +----------------------------------------------------------------------+// | This source file is subject to version 2.02 of the PHP license,      |// | that is bundled with this package in the file LICENSE, and is        |// | available at through the world-wide-web at                           |// | http://www.php.net/license/2_02.txt.                                 |// | If you did not receive a copy of the PHP license and are unable to   |// | obtain it through the world-wide-web, please send a note to          |// | license@php.net so we can mail you a copy immediately.               |// +----------------------------------------------------------------------+// | Authors: Rui Hirokawa <hirokawa@php.net>                             |// |          Stig Bakken <ssb@php.net>                                   |// | Maintainer: Daniel Convissor <danielc@php.net>                       |// +----------------------------------------------------------------------+//// $Id: pgsql.php,v 1.5 2004/06/21 08:39:38 rurban Exp $require_once 'DB/common.php';/** * Database independent query interface definition for PHP's PostgreSQL * extension. * * @package  DB * @version  $Id: pgsql.php,v 1.5 2004/06/21 08:39:38 rurban Exp $ * @category Database * @author   Rui Hirokawa <hirokawa@php.net> * @author   Stig Bakken <ssb@php.net> */class DB_pgsql extends DB_common{    // {{{ properties    var $connection;    var $phptype, $dbsyntax;    var $prepare_tokens = array();    var $prepare_types = array();    var $transaction_opcount = 0;    var $dsn = array();    var $row = array();    var $num_rows = array();    var $affected = 0;    var $autocommit = true;    var $fetchmode = DB_FETCHMODE_ORDERED;    // }}}    // {{{ constructor    function DB_pgsql()    {        $this->DB_common();        $this->phptype = 'pgsql';        $this->dbsyntax = 'pgsql';        $this->features = array(            'prepare' => false,            'pconnect' => true,            'transactions' => true,            'limit' => 'alter'        );        $this->errorcode_map = array(        );    }    // }}}    // {{{ connect()    /**     * Connect to a database and log in as the specified user.     *     * @param $dsn the data source name (see DB::parseDSN for syntax)     * @param $persistent (optional) whether the connection should     *        be persistent     *     * @return int DB_OK on success, a DB error code on failure.     */    function connect($dsninfo, $persistent = false)    {        if (!DB::assertExtension('pgsql')) {            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);        }        $this->dsn = $dsninfo;        $protocol = $dsninfo['protocol'] ? $dsninfo['protocol'] : 'tcp';        $connstr = '';        if ($protocol == 'tcp') {            if ($dsninfo['hostspec']) {                $connstr .= 'host=' . $dsninfo['hostspec'];            }            if ($dsninfo['port']) {                $connstr .= ' port=' . $dsninfo['port'];            }        } elseif ($protocol == 'unix') {            // Allow for pg socket in non-standard locations.            if ($dsninfo['socket']) {                $connstr .= 'host=' . $dsninfo['socket'];            }        }        if ($dsninfo['database']) {            $connstr .= ' dbname=\'' . addslashes($dsninfo['database']) . '\'';        }        if ($dsninfo['username']) {            $connstr .= ' user=\'' . addslashes($dsninfo['username']) . '\'';        }        if ($dsninfo['password']) {            $connstr .= ' password=\'' . addslashes($dsninfo['password']) . '\'';        }        if (isset($dsninfo['options'])) {            $connstr .= ' options=' . $dsninfo['options'];        }        if (isset($dsninfo['tty'])) {            $connstr .= ' tty=' . $dsninfo['tty'];        }        $connect_function = $persistent ? 'pg_pconnect' : 'pg_connect';        // catch error        ob_start();        $conn = $connect_function($connstr);        $error = ob_get_contents();        ob_end_clean();        if ($conn == false) {            return $this->raiseError(DB_ERROR_CONNECT_FAILED, null,                                     null, null, strip_tags($error));        }        $this->connection = $conn;        return DB_OK;    }    // }}}    // {{{ disconnect()    /**     * Log out and disconnect from the database.     *     * @return bool true on success, false if not connected.     */    function disconnect()    {        $ret = @pg_close($this->connection);        $this->connection = null;        return $ret;    }    // }}}    // {{{ simpleQuery()    /**     * Send a query to PostgreSQL and return the results as a     * PostgreSQL resource identifier.     *     * @param $query the SQL query     *     * @return int returns a valid PostgreSQL result for successful SELECT     * queries, DB_OK for other successful queries.  A DB error code     * is returned on failure.     */    function simpleQuery($query)    {        $ismanip = DB::isManip($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 which queries that should return data, and which        // should return an error code only.        if ($ismanip) {            $this->affected = @pg_cmdtuples($result);            return DB_OK;        } elseif (preg_match('/^\s*\(?\s*(SELECT(?!\s+INTO)|EXPLAIN|SHOW)\s/si', $query)) {            /* 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            */            $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;    }    // }}}    // {{{ errorCode()    /**     * Determine 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(                '/(([Rr]elation|[Ss]equence|[Tt]able)( [\"\'].*[\"\'])? does not exist|[Cc]lass ".+" not found)$/' => DB_ERROR_NOSUCHTABLE,                '/[Cc]olumn [\"\'].*[\"\'] does not exist/' => DB_ERROR_NOSUCHFIELD,                '/[Rr]elation [\"\'].*[\"\'] already exists|[Cc]annot insert a duplicate key into (a )?unique index.*/' => DB_ERROR_ALREADY_EXISTS,                '/(divide|division) by zero$/'          => DB_ERROR_DIVZERO,                '/pg_atoi: error in .*: can\'t parse /' => DB_ERROR_INVALID_NUMBER,                '/invalid input syntax for integer/'    => DB_ERROR_INVALID_NUMBER,                '/ttribute [\"\'].*[\"\'] not found$|[Rr]elation [\"\'].*[\"\'] does not have attribute [\"\'].*[\"\']/' => DB_ERROR_NOSUCHFIELD,                '/parser: parse error at or near \"/'   => DB_ERROR_SYNTAX,                '/syntax error at/'                     => DB_ERROR_SYNTAX,                '/violates not-null constraint/'        => DB_ERROR_CONSTRAINT_NOT_NULL,                '/violates [\w ]+ constraint/'          => DB_ERROR_CONSTRAINT,                '/referential integrity violation/'     => DB_ERROR_CONSTRAINT            );        }        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;    }    // }}}    // {{{ fetchInto()    /**     * Fetch a row and insert the data into an existing array.     *     * Formating of the array and the data therein are configurable.     * See DB_result::fetchInto() for more information.     *     * @param resource $result    query result identifier     * @param array    $arr       (reference) array where data from the row     *                            should be placed     * @param int      $fetchmode how the resulting array should be indexed     * @param int      $rownum    the row number to fetch     *     * @return mixed DB_OK on success, null when end of result set is     *               reached or on failure     *     * @see DB_result::fetchInto()     * @access private     */    function fetchInto($result, &$arr, $fetchmode, $rownum=null)    {        $rownum = ($rownum !== null) ? $rownum : $this->row[$result];        if ($rownum >= $this->num_rows[$result]) {            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) {            $err = pg_errormessage($this->connection);            if (!$err) {                return null;            }            return $this->pgsqlRaiseError();        }        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] = ++$rownum;        return DB_OK;    }    // }}}    // {{{ freeResult()    /**     * Free the internal resources associated with $result.     *     * @param $result int PostgreSQL result identifier     *     * @return bool true on success, false if $result is invalid     */    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;    }    // }}}    // {{{ quote()    /**     * @deprecated  Deprecated in release 1.6.0     * @internal     */    function quote($str) {        return $this->quoteSmart($str);    }    // }}}    // {{{ quoteSmart()    /**     * Format input so it can be safely used in a query     *     * @param mixed $in  data to be quoted     *     * @return mixed Submitted variable's type = returned value:     *               + null = the string <samp>NULL</samp>     *               + boolean = string <samp>TRUE</samp> or <samp>FALSE</samp>     *               + integer or double = the unquoted number     *               + other (including strings and numeric strings) =     *                 the data escaped according to MySQL's settings     *                 then encapsulated between single quotes     *     * @internal     */    function quoteSmart($in)    {        if (is_int($in) || is_double($in)) {            return $in;        } elseif (is_bool($in)) {            return $in ? 'TRUE' : 'FALSE';        } elseif (is_null($in)) {            return 'NULL';        } else {            return "'" . $this->escapeSimple($in) . "'";        }    }    // }}}    // {{{ escapeSimple()    /**     * Escape a string according to the current DBMS's standards     *     * PostgreSQL treats a backslash as an escape character, so they are     * removed.     *     * Not using pg_escape_string() yet because it requires PostgreSQL     * to be at version 7.2 or greater.     *     * @param string $str  the string to be escaped     *     * @return string  the escaped string     *     * @internal     */    function escapeSimple($str) {        return str_replace("'", "''", str_replace('\\', '\\\\', $str));    }    // }}}    // {{{ numCols()    /**     * Get the number of columns in a result set.     *     * @param $result resource PostgreSQL result identifier     *     * @return int the number of columns per row in $result     */    function numCols($result)    {        $cols = @pg_numfields($result);        if (!$cols) {            return $this->pgsqlRaiseError();        }        return $cols;    }    // }}}    // {{{ numRows()