WebSVN – Applications.papyrus – Diff – /trunk/api/pear/DB/oci8.php


<?php
 
/* vim: set expandtab tabstop=4 shiftwidth=4 softtabstop=4: */
 
/**
 * The PEAR DB driver for PHP's oci8 extension
 * for interacting with Oracle databases
 *
 * PHP versions 4 and 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     James L. Pine <jlp@valinux.com>
 * @author     Daniel Convissor <danielc@php.net>
 * @copyright  1997-2005 The PHP Group
 * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
 * @version    CVS: $Id: oci8.php,v 1.2 2005-09-20 17:01:22 ddelon Exp $
 * @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 oci8 extension
 * for interacting with Oracle databases
 *
 * Definitely works with versions 8 and 9 of Oracle.
 *
 * These methods overload the ones declared in DB_common.
 *
 * Be aware...  OCIError() only appears to return anything when given a
 * statement, so functions return the generic DB_ERROR instead of more
 * useful errors that have to do with feedback from the database.
 *
 * @category   Database
 * @package    DB
 * @author     James L. Pine <jlp@valinux.com>
 * @author     Daniel Convissor <danielc@php.net>
 * @copyright  1997-2005 The PHP Group
 * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
 * @version    Release: @package_version@
 * @link       http://pear.php.net/package/DB
 */
class DB_oci8 extends DB_common
{
    // {{{ properties
 
    /**
     * The DB driver type (mysql, oci8, odbc, etc.)
     * @var string
     */
    var $phptype = 'oci8';
 
    /**
     * The database syntax variant to be used (db2, access, etc.), if any
     * @var string
     */
    var $dbsyntax = 'oci8';
 
    /**
     * 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'      => '5.0.0',
        'numrows'       => 'subquery',
        'pconnect'      => true,
        'prepare'       => true,
        'ssl'           => false,
        'transactions'  => true,
    );
 
    /**
     * A mapping of native error codes to DB error codes
     * @var array
     */
    var $errorcode_map = array(
        1    => DB_ERROR_CONSTRAINT,
        900  => DB_ERROR_SYNTAX,
        904  => DB_ERROR_NOSUCHFIELD,
        913  => DB_ERROR_VALUE_COUNT_ON_ROW,
        921  => DB_ERROR_SYNTAX,
        923  => DB_ERROR_SYNTAX,
        942  => DB_ERROR_NOSUCHTABLE,
        955  => DB_ERROR_ALREADY_EXISTS,
        1400 => DB_ERROR_CONSTRAINT_NOT_NULL,
        1401 => DB_ERROR_INVALID,
        1407 => DB_ERROR_CONSTRAINT_NOT_NULL,
        1418 => DB_ERROR_NOT_FOUND,
        1476 => DB_ERROR_DIVZERO,
        1722 => DB_ERROR_INVALID_NUMBER,
        2289 => DB_ERROR_NOSUCHTABLE,
        2291 => DB_ERROR_CONSTRAINT,
        2292 => DB_ERROR_CONSTRAINT,
        2449 => DB_ERROR_CONSTRAINT,
    );
 
    /**
     * 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;
 
    /**
     * Stores the $data passed to execute() in the oci8 driver
     *
     * Gets reset to array() when simpleQuery() is run.
     *
     * Needed in case user wants to call numRows() after prepare/execute
     * was used.
     *
     * @var array
     * @access private
     */
    var $_data = array();
 
    /**
     * The result or statement handle from the most recently executed query
     * @var resource
     */
    var $last_stmt;
 
    /**
     * Is the given prepared statement a data manipulation query?
     * @var array
     * @access private
     */
    var $manip_query = array();
 
 
    // }}}
    // {{{ constructor
 
    /**
     * This constructor calls <kbd>$this->DB_common()</kbd>
     *
     * @return void
     */
    function DB_oci8()
    {
        $this->DB_common();
    }
 
    // }}}
    // {{{ connect()
 
    /**
     * Connect to the database server, log in and open the database
     *
     * Don't call this method directly.  Use DB::connect() instead.
     *
     * If PHP is at version 5.0.0 or greater:
     *   + Generally, oci_connect() or oci_pconnect() are used.
     *   + But if the new_link DSN option is set to true, oci_new_connect()
     *     is used.
     *
     * When using PHP version 4.x, OCILogon() or OCIPLogon() are used.
     *
     * PEAR DB's oci8 driver supports the following extra DSN options:
     *   + charset       The character set to be used on the connection.
     *                    Only used if PHP is at version 5.0.0 or greater
     *                    and the Oracle server is at 9.2 or greater.
     *                    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 since PEAR DB 1.7.0.
     *
     * @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.
     */
    function connect($dsn, $persistent = false)
    {
        if (!PEAR::loadExtension('oci8')) {
            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
        }
 
        $this->dsn = $dsn;
        if ($dsn['dbsyntax']) {
            $this->dbsyntax = $dsn['dbsyntax'];
        }
 
        if (function_exists('oci_connect')) {
            if (isset($dsn['new_link'])
                && ($dsn['new_link'] == 'true' || $dsn['new_link'] === true))
            {
                $connect_function = 'oci_new_connect';
            } else {
                $connect_function = $persistent ? 'oci_pconnect'
                                    : 'oci_connect';
            }
 
            // Backwards compatibility with DB < 1.7.0
            if (empty($dsn['database']) && !empty($dsn['hostspec'])) {
                $db = $dsn['hostspec'];
            } else {
                $db = $dsn['database'];
            }
 
            $char = empty($dsn['charset']) ? null : $dsn['charset'];
            $this->connection = @$connect_function($dsn['username'],
                                                   $dsn['password'],
                                                   $db,
                                                   $char);
            $error = OCIError();
            if (!empty($error) && $error['code'] == 12541) {
                // Couldn't find TNS listener.  Try direct connection.
                $this->connection = @$connect_function($dsn['username'],
                                                       $dsn['password'],
                                                       null,
                                                       $char);
            }
        } else {
            $connect_function = $persistent ? 'OCIPLogon' : 'OCILogon';
            if ($dsn['hostspec']) {
                $this->connection = @$connect_function($dsn['username'],
                                                       $dsn['password'],
                                                       $dsn['hostspec']);
            } elseif ($dsn['username'] || $dsn['password']) {
                $this->connection = @$connect_function($dsn['username'],
                                                       $dsn['password']);
            }
        }
 
        if (!$this->connection) {
            $error = OCIError();
            $error = (is_array($error)) ? $error['message'] : null;
            return $this->raiseError(DB_ERROR_CONNECT_FAILED,
                                     null, null, null,
                                     $error);
        }
        return DB_OK;
    }
 
    // }}}
    // {{{ disconnect()
 
    /**
     * Disconnects from the database server
     *
     * @return bool  TRUE on success, FALSE on failure
     */
    function disconnect()
    {
        if (function_exists('oci_close')) {
            $ret = @oci_close($this->connection);
        } else {
            $ret = @OCILogOff($this->connection);
        }
        $this->connection = null;
        return $ret;
    }
 
    // }}}
    // {{{ simpleQuery()
 
    /**
     * Sends a query to the database server
     *
     * To determine how many rows of a result set get buffered using
     * ocisetprefetch(), see the "result_buffering" option in setOptions().
     * This option was added in Release 1.7.0.
     *
     * @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)
    {
        $this->_data = array();
        $this->last_parameters = array();
        $this->last_query = $query;
        $query = $this->modifyQuery($query);
        $result = @OCIParse($this->connection, $query);
        if (!$result) {
            return $this->oci8RaiseError();
        }
        if ($this->autocommit) {
            $success = @OCIExecute($result,OCI_COMMIT_ON_SUCCESS);
        } else {
            $success = @OCIExecute($result,OCI_DEFAULT);
        }
        if (!$success) {
            return $this->oci8RaiseError($result);
        }
        $this->last_stmt = $result;
        if (DB::isManip($query)) {
            return DB_OK;
        } else {
            @ocisetprefetch($result, $this->options['result_buffering']);
            return $result;
        }
    }
 
    // }}}
    // {{{ nextResult()
 
    /**
     * Move the internal oracle result pointer to the next available result
     *
     * @param a valid oci8 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)
    {
        if ($rownum !== null) {
            return $this->raiseError(DB_ERROR_NOT_CAPABLE);
        }
        if ($fetchmode & DB_FETCHMODE_ASSOC) {
            $moredata = @OCIFetchInto($result,$arr,OCI_ASSOC+OCI_RETURN_NULLS+OCI_RETURN_LOBS);
            if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE &&
                $moredata)
            {
                $arr = array_change_key_case($arr, CASE_LOWER);
            }
        } else {
            $moredata = OCIFetchInto($result,$arr,OCI_RETURN_NULLS+OCI_RETURN_LOBS);
        }
        if (!$moredata) {
            return null;
        }
        if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {
            $this->_rtrimArrayValues($arr);
        }
        if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {
            $this->_convertNullArrayValuesToEmpty($arr);
        }
        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)
    {
        return @OCIFreeStatement($result);
    }
 
    /**
     * Frees the internal resources associated with a prepared query
     *
     * @param resource $stmt           the prepared statement's resource
     * @param bool     $free_resource  should the PHP resource be freed too?
     *                                  Use false if you need to get data
     *                                  from the result set later.
     *
     * @return bool  TRUE on success, FALSE if $result is invalid
     *
     * @see DB_oci8::prepare()
     */
    function freePrepared($stmt, $free_resource = true)
    {
        if (!is_resource($stmt)) {
            return false;
        }
        if ($free_resource) {
            @ocifreestatement($stmt);
        }
        if (isset($this->prepare_types[(int)$stmt])) {
            unset($this->prepare_types[(int)$stmt]);
            unset($this->manip_query[(int)$stmt]);
        } else {
            return false;
        }
        return true;
    }
 
    // }}}
    // {{{ numRows()
 
    /**
     * Gets the number of rows in a result set
     *
     * Only works if the DB_PORTABILITY_NUMROWS portability option
     * is turned on.
     *
     * 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(), DB_common::setOption()
     */
    function numRows($result)
    {
        // emulate numRows for Oracle.  yuck.
        if ($this->options['portability'] & DB_PORTABILITY_NUMROWS &&
            $result === $this->last_stmt)
        {
            $countquery = 'SELECT COUNT(*) FROM ('.$this->last_query.')';
            $save_query = $this->last_query;
            $save_stmt = $this->last_stmt;
 
            if (count($this->_data)) {
                $smt = $this->prepare('SELECT COUNT(*) FROM ('.$this->last_query.')');
                $count = $this->execute($smt, $this->_data);
            } else {
                $count =& $this->query($countquery);
            }
 
            if (DB::isError($count) ||
                DB::isError($row = $count->fetchRow(DB_FETCHMODE_ORDERED)))
            {
                $this->last_query = $save_query;
                $this->last_stmt = $save_stmt;
                return $this->raiseError(DB_ERROR_NOT_CAPABLE);
            }
            return $row[0];
        }
        return $this->raiseError(DB_ERROR_NOT_CAPABLE);
    }
 
    // }}}
    // {{{ 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 = @OCINumCols($result);
        if (!$cols) {
            return $this->oci8RaiseError($result);
        }
        return $cols;
    }
 
    // }}}
    // {{{ prepare()
 
    /**
     * Prepares a query for multiple execution with execute().
     *
     * With oci8, this is emulated.
     *
     * prepare() requires a generic query as string like <code>
     *    INSERT INTO numbers VALUES (?, ?, ?)
     * </code>.  The <kbd>?</kbd> characters are placeholders.
     *
     * Three types of placeholders can be used:
     *   + <kbd>?</kbd>  a quoted scalar value, i.e. strings, integers
     *   + <kbd>!</kbd>  value is inserted 'as is'
     *   + <kbd>&</kbd>  requires a file name.  The file's contents get
     *                     inserted into the query (i.e. saving binary
     *                     data in a db)
     *
     * Use backslashes to escape placeholder characters if you don't want
     * them to be interpreted as placeholders.  Example: <code>
     *    "UPDATE foo SET col=? WHERE col='over \& under'"
     * </code>
     *
     * @param string $query  the query to be prepared
     *
     * @return mixed  DB statement resource on success. DB_Error on failure.
     *
     * @see DB_oci8::execute()
     */
    function prepare($query)
    {
        $tokens   = preg_split('/((?<!\\\)[&?!])/', $query, -1,
                               PREG_SPLIT_DELIM_CAPTURE);
        $binds    = count($tokens) - 1;
        $token    = 0;
        $types    = array();
        $newquery = '';
 
        foreach ($tokens as $key => $val) {
            switch ($val) {
                case '?':
                    $types[$token++] = DB_PARAM_SCALAR;
                    unset($tokens[$key]);
                    break;
                case '&':
                    $types[$token++] = DB_PARAM_OPAQUE;
                    unset($tokens[$key]);
                    break;
                case '!':
                    $types[$token++] = DB_PARAM_MISC;
                    unset($tokens[$key]);
                    break;
                default:
                    $tokens[$key] = preg_replace('/\\\([&?!])/', "\\1", $val);
                    if ($key != $binds) {
                        $newquery .= $tokens[$key] . ':bind' . $token;
                    } else {
                        $newquery .= $tokens[$key];
                    }
            }
        }
 
        $this->last_query = $query;
        $newquery = $this->modifyQuery($newquery);
        if (!$stmt = @OCIParse($this->connection, $newquery)) {
            return $this->oci8RaiseError();
        }
        $this->prepare_types[(int)$stmt] = $types;
        $this->manip_query[(int)$stmt] = DB::isManip($query);
        return $stmt;
    }
 
    // }}}
    // {{{ execute()
 
    /**
     * Executes a DB statement prepared with prepare().
     *
     * To determine how many rows of a result set get buffered using
     * ocisetprefetch(), see the "result_buffering" option in setOptions().
     * This option was added in Release 1.7.0.
     *
     * @param resource  $stmt  a DB statement resource returned from prepare()
     * @param mixed  $data  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 for non-array items or the
     *                      quantity of elements in the array.
     *
     * @return mixed  returns an oic8 result resource for successful SELECT
     *                queries, DB_OK for other successful queries.
     *                A DB error object is returned on failure.
     *
     * @see DB_oci8::prepare()
     */
    function &execute($stmt, $data = array())
    {
        $data = (array)$data;
        $this->last_parameters = $data;
        $this->_data = $data;
 
        $types =& $this->prepare_types[(int)$stmt];
        if (count($types) != count($data)) {
            $tmp =& $this->raiseError(DB_ERROR_MISMATCH);
            return $tmp;
        }
 
        $i = 0;
        foreach ($data as $key => $value) {
            if ($types[$i] == DB_PARAM_MISC) {
                /*
                 * Oracle doesn't seem to have the ability to pass a
                 * parameter along unchanged, so strip off quotes from start
                 * and end, plus turn two single quotes to one single quote,
                 * in order to avoid the quotes getting escaped by
                 * Oracle and ending up in the database.
                 */
                $data[$key] = preg_replace("/^'(.*)'$/", "\\1", $data[$key]);
                $data[$key] = str_replace("''", "'", $data[$key]);
            } elseif ($types[$i] == DB_PARAM_OPAQUE) {
                $fp = @fopen($data[$key], 'rb');
                if (!$fp) {
                    $tmp =& $this->raiseError(DB_ERROR_ACCESS_VIOLATION);
                    return $tmp;
                }
                $data[$key] = fread($fp, filesize($data[$key]));
                fclose($fp);
            }
            if (!@OCIBindByName($stmt, ':bind' . $i, $data[$key], -1)) {
                $tmp = $this->oci8RaiseError($stmt);
                return $tmp;
            }
            $i++;
        }
        if ($this->autocommit) {
            $success = @OCIExecute($stmt, OCI_COMMIT_ON_SUCCESS);
        } else {
            $success = @OCIExecute($stmt, OCI_DEFAULT);
        }
        if (!$success) {
            $tmp = $this->oci8RaiseError($stmt);
            return $tmp;
        }
        $this->last_stmt = $stmt;
        if ($this->manip_query[(int)$stmt]) {
            $tmp = DB_OK;
        } else {
            @ocisetprefetch($stmt, $this->options['result_buffering']);
            $tmp =& new DB_result($this, $stmt);
        }
        return $tmp;
    }
 
    // }}}
    // {{{ 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)
    {
        $this->autocommit = (bool)$onoff;;
        return DB_OK;
    }
 
    // }}}
    // {{{ commit()
 
    /**
     * Commits the current transaction
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     */
    function commit()
    {
        $result = @OCICommit($this->connection);
        if (!$result) {
            return $this->oci8RaiseError();
        }
        return DB_OK;
    }
 
    // }}}
    // {{{ rollback()
 
    /**
     * Reverts the current transaction
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     */
    function rollback()
    {
        $result = @OCIRollback($this->connection);
        if (!$result) {
            return $this->oci8RaiseError();
        }
        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()
    {
        if ($this->last_stmt === false) {
            return $this->oci8RaiseError();
        }
        $result = @OCIRowCount($this->last_stmt);
        if ($result === false) {
            return $this->oci8RaiseError($this->last_stmt);
        }
        return $result;
    }
 
    // }}}
    // {{{ modifyQuery()
 
    /**
     * Changes a query string for various DBMS specific reasons
     *
     * "SELECT 2+2" must be "SELECT 2+2 FROM dual" in Oracle.
     *
     * @param string $query  the query string to modify
     *
     * @return string  the modified query string
     *
     * @access protected
     */
    function modifyQuery($query)
    {
        if (preg_match('/^\s*SELECT/i', $query) &&
            !preg_match('/\sFROM\s/i', $query)) {
            $query .= ' FROM dual';
        }
        return $query;
    }
 
    // }}}
    // {{{ 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())
    {
        // Let Oracle return the name of the columns instead of
        // coding a "home" SQL parser
 
        if (count($params)) {
            $result = $this->prepare("SELECT * FROM ($query) "
                                     . 'WHERE NULL = NULL');
            $tmp =& $this->execute($result, $params);
        } else {
            $q_fields = "SELECT * FROM ($query) WHERE NULL = NULL";
 
            if (!$result = @OCIParse($this->connection, $q_fields)) {
                $this->last_query = $q_fields;
                return $this->oci8RaiseError();
            }
            if (!@OCIExecute($result, OCI_DEFAULT)) {
                $this->last_query = $q_fields;
                return $this->oci8RaiseError($result);
            }
        }
 
        $ncols = OCINumCols($result);
        $cols  = array();
        for ( $i = 1; $i <= $ncols; $i++ ) {
            $cols[] = '"' . OCIColumnName($result, $i) . '"';
        }
        $fields = implode(', ', $cols);
        // XXX Test that (tip by John Lim)
        //if (preg_match('/^\s*SELECT\s+/is', $query, $match)) {
        //    // Introduce the FIRST_ROWS Oracle query optimizer
        //    $query = substr($query, strlen($match[0]), strlen($query));
        //    $query = "SELECT /* +FIRST_ROWS */ " . $query;
        //}
 
        // Construct the query
        // more at: http://marc.theaimsgroup.com/?l=php-db&m=99831958101212&w=2
        // Perhaps this could be optimized with the use of Unions
        $query = "SELECT $fields FROM".
                 "  (SELECT rownum as linenum, $fields FROM".
                 "      ($query)".
                 '  WHERE rownum <= '. ($from + $count) .
                 ') WHERE linenum >= ' . ++$from;
        return $query;
    }
 
    // }}}
    // {{{ 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_oci8::createSequence(), DB_oci8::dropSequence()
     */
    function nextId($seq_name, $ondemand = true)
    {
        $seqname = $this->getSequenceName($seq_name);
        $repeat = 0;
        do {
            $this->expectError(DB_ERROR_NOSUCHTABLE);
            $result =& $this->query("SELECT ${seqname}.nextval FROM dual");
            $this->popExpect();
            if ($ondemand && DB::isError($result) &&
                $result->getCode() == DB_ERROR_NOSUCHTABLE) {
                $repeat = 1;
                $result = $this->createSequence($seq_name);
                if (DB::isError($result)) {
                    return $this->raiseError($result);
                }
            } else {
                $repeat = 0;
            }
        } while ($repeat);
        if (DB::isError($result)) {
            return $this->raiseError($result);
        }
        $arr = $result->fetchRow(DB_FETCHMODE_ORDERED);
        return $arr[0];
    }
 
    /**
     * 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_oci8::nextID(), DB_oci8::dropSequence()
     */
    function createSequence($seq_name)
    {
        return $this->query('CREATE SEQUENCE '
                            . $this->getSequenceName($seq_name));
    }
 
    // }}}
    // {{{ 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_oci8::nextID(), DB_oci8::createSequence()
     */
    function dropSequence($seq_name)
    {
        return $this->query('DROP SEQUENCE '
                            . $this->getSequenceName($seq_name));
    }
 
    // }}}
    // {{{ oci8RaiseError()
 
    /**
     * 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_oci8::errorNative(), DB_oci8::errorCode()
     */
    function oci8RaiseError($errno = null)
    {
        if ($errno === null) {
            $error = @OCIError($this->connection);
            return $this->raiseError($this->errorCode($error['code']),
                                     null, null, null, $error['message']);
        } elseif (is_resource($errno)) {
            $error = @OCIError($errno);
            return $this->raiseError($this->errorCode($error['code']),
                                     null, null, null, $error['message']);
        }
        return $this->raiseError($this->errorCode($errno));
    }
 
    // }}}
    // {{{ errorNative()
 
    /**
     * Gets the DBMS' native error code produced by the last query
     *
     * @return int  the DBMS' error code.  FALSE if the code could not be
     *               determined
     */
    function errorNative()
    {
        if (is_resource($this->last_stmt)) {
            $error = @OCIError($this->last_stmt);
        } else {
            $error = @OCIError($this->connection);
        }
        if (is_array($error)) {
            return $error['code'];
        }
        return false;
    }
 
    // }}}
    // {{{ tableInfo()
 
    /**
     * Returns information about a table or a result set
     *
     * NOTE: only supports 'table' and 'flags' if <var>$result</var>
     * is a table name.
     *
     * NOTE: flags won't contain index information.
     *
     * @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 ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) {
            $case_func = 'strtolower';
        } else {
            $case_func = 'strval';
        }
 
        $res = array();
 
        if (is_string($result)) {
            /*
             * Probably received a table name.
             * Create a result resource identifier.
             */
            $result = strtoupper($result);
            $q_fields = 'SELECT column_name, data_type, data_length, '
                        . 'nullable '
                        . 'FROM user_tab_columns '
                        . "WHERE table_name='$result' ORDER BY column_id";
 
            $this->last_query = $q_fields;
 
            if (!$stmt = @OCIParse($this->connection, $q_fields)) {
                return $this->oci8RaiseError(DB_ERROR_NEED_MORE_DATA);
            }
            if (!@OCIExecute($stmt, OCI_DEFAULT)) {
                return $this->oci8RaiseError($stmt);
            }
 
            $i = 0;
            while (@OCIFetch($stmt)) {
                $res[$i] = array(
                    'table' => $case_func($result),
                    'name'  => $case_func(@OCIResult($stmt, 1)),
                    'type'  => @OCIResult($stmt, 2),
                    'len'   => @OCIResult($stmt, 3),
                    'flags' => (@OCIResult($stmt, 4) == 'N') ? 'not_null' : '',
                );
                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;
                }
                $i++;
            }
 
            if ($mode) {
                $res['num_fields'] = $i;
            }
            @OCIFreeStatement($stmt);
 
        } else {
            if (isset($result->result)) {
                /*
                 * Probably received a result object.
                 * Extract the result resource identifier.
                 */
                $result = $result->result;
            }
 
            $res = array();
 
            if ($result === $this->last_stmt) {
                $count = @OCINumCols($result);
                if ($mode) {
                    $res['num_fields'] = $count;
                }
                for ($i = 0; $i < $count; $i++) {
                    $res[$i] = array(
                        'table' => '',
                        'name'  => $case_func(@OCIColumnName($result, $i+1)),
                        'type'  => @OCIColumnType($result, $i+1),
                        'len'   => @OCIColumnSize($result, $i+1),
                        'flags' => '',
                    );
                    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;
                    }
                }
            } else {
                return $this->raiseError(DB_ERROR_NOT_CAPABLE);
            }
        }
        return $res;
    }
 
    // }}}
    // {{{ 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 table_name FROM user_tables';
            case 'synonyms':
                return 'SELECT synonym_name FROM user_synonyms';
            default:
                return null;
        }
    }
 
    // }}}
 
}
 
/*
 * Local variables:
 * tab-width: 4
 * c-basic-offset: 4
 * End:
 */
 
?>

Rev 320	Rev 443
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 oci8 extension`	6	`* The PEAR DB driver for PHP's oci8 extension`
7	`* for interacting with Oracle databases`	7	`* for interacting with Oracle databases`
8	`*`	8	`*`
9	`* PHP versions 4 and 5`	9	`* PHP versions 4 and 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 James L. Pine <jlp@valinux.com>`	19	`* @author James L. Pine <jlp@valinux.com>`
20	`* @author Daniel Convissor <danielc@php.net>`	20	`* @author Daniel Convissor <danielc@php.net>`
21	`* @copyright 1997-2005 The PHP Group`	21	`* @copyright 1997-2005 The PHP Group`
22	`* @license http://www.php.net/license/3_0.txt PHP License 3.0`	22	`* @license http://www.php.net/license/3_0.txt PHP License 3.0`
23	`* @version CVS: $Id: oci8.php,v 1.1 2005-03-30 08:50:33 jpm Exp $`	23	`* @version CVS: $Id: oci8.php,v 1.2 2005-09-20 17:01:22 ddelon Exp $`
24	`* @link http://pear.php.net/package/DB`	24	`* @link http://pear.php.net/package/DB`
25	`*/`	25	`*/`
26		26
27	`/**`	27	`/**`
28	`* Obtain the DB_common class so it can be extended from`	28	`* Obtain the DB_common class so it can be extended from`
29	`*/`	29	`*/`
30	`require_once 'DB/common.php';`	30	`require_once 'DB/common.php';`
31		31
32	`/**`	32	`/**`
33	`* The methods PEAR DB uses to interact with PHP's oci8 extension`	33	`* The methods PEAR DB uses to interact with PHP's oci8 extension`
34	`* for interacting with Oracle databases`	34	`* for interacting with Oracle databases`
35	`*`	35	`*`
36	`* Definitely works with versions 8 and 9 of Oracle.`	36	`* Definitely works with versions 8 and 9 of Oracle.`
37	`*`	37	`*`
38	`* These methods overload the ones declared in DB_common.`	38	`* These methods overload the ones declared in DB_common.`
39	`*`	39	`*`
40	`* Be aware... OCIError() only appears to return anything when given a`	40	`* Be aware... OCIError() only appears to return anything when given a`
41	`* statement, so functions return the generic DB_ERROR instead of more`	41	`* statement, so functions return the generic DB_ERROR instead of more`
42	`* useful errors that have to do with feedback from the database.`	42	`* useful errors that have to do with feedback from the database.`
43	`*`	43	`*`
44	`* @category Database`	44	`* @category Database`
45	`* @package DB`	45	`* @package DB`
46	`* @author James L. Pine <jlp@valinux.com>`	46	`* @author James L. Pine <jlp@valinux.com>`
47	`* @author Daniel Convissor <danielc@php.net>`	47	`* @author Daniel Convissor <danielc@php.net>`
48	`* @copyright 1997-2005 The PHP Group`	48	`* @copyright 1997-2005 The PHP Group`
49	`* @license http://www.php.net/license/3_0.txt PHP License 3.0`	49	`* @license http://www.php.net/license/3_0.txt PHP License 3.0`
50	`* @version Release: 1.7.5`	50	`* @version Release: @package_version@`
51	`* @link http://pear.php.net/package/DB`	51	`* @link http://pear.php.net/package/DB`
52	`*/`	52	`*/`
53	`class DB_oci8 extends DB_common`	53	`class DB_oci8 extends DB_common`
54	`{`	54	`{`
55	`// {{{ properties`	55	`// {{{ properties`
56		56
57	`/**`	57	`/**`
58	`* The DB driver type (mysql, oci8, odbc, etc.)`	58	`* The DB driver type (mysql, oci8, odbc, etc.)`
59	`* @var string`	59	`* @var string`
60	`*/`	60	`*/`
61	`var $phptype = 'oci8';`	61	`var $phptype = 'oci8';`
62		62
63	`/**`	63	`/**`
64	`* The database syntax variant to be used (db2, access, etc.), if any`	64	`* The database syntax variant to be used (db2, access, etc.), if any`
65	`* @var string`	65	`* @var string`
66	`*/`	66	`*/`
67	`var $dbsyntax = 'oci8';`	67	`var $dbsyntax = 'oci8';`
68		68
69	`/**`	69	`/**`
70	`* The capabilities of this DB implementation`	70	`* The capabilities of this DB implementation`
71	`*`	71	`*`
72	`* The 'new_link' element contains the PHP version that first provided`	72	`* The 'new_link' element contains the PHP version that first provided`
73	`* new_link support for this DBMS. Contains false if it's unsupported.`	73	`* new_link support for this DBMS. Contains false if it's unsupported.`
74	`*`	74	`*`
75	`* Meaning of the 'limit' element:`	75	`* Meaning of the 'limit' element:`
76	`* + 'emulate' = emulate with fetch row by number`	76	`* + 'emulate' = emulate with fetch row by number`
77	`* + 'alter' = alter the query`	77	`* + 'alter' = alter the query`
78	`* + false = skip rows`	78	`* + false = skip rows`
79	`*`	79	`*`
80	`* @var array`	80	`* @var array`
81	`*/`	81	`*/`
82	`var $features = array(`	82	`var $features = array(`
83	`'limit' => 'alter',`	83	`'limit' => 'alter',`
84	`'new_link' => '5.0.0',`	84	`'new_link' => '5.0.0',`
85	`'numrows' => 'subquery',`	85	`'numrows' => 'subquery',`
86	`'pconnect' => true,`	86	`'pconnect' => true,`
87	`'prepare' => true,`	87	`'prepare' => true,`
88	`'ssl' => false,`	88	`'ssl' => false,`
89	`'transactions' => true,`	89	`'transactions' => true,`
90	`);`	90	`);`
91		91
92	`/**`	92	`/**`
93	`* A mapping of native error codes to DB error codes`	93	`* A mapping of native error codes to DB error codes`
94	`* @var array`	94	`* @var array`
95	`*/`	95	`*/`
96	`var $errorcode_map = array(`	96	`var $errorcode_map = array(`
97	`1 => DB_ERROR_CONSTRAINT,`	97	`1 => DB_ERROR_CONSTRAINT,`
98	`900 => DB_ERROR_SYNTAX,`	98	`900 => DB_ERROR_SYNTAX,`
99	`904 => DB_ERROR_NOSUCHFIELD,`	99	`904 => DB_ERROR_NOSUCHFIELD,`
100	`913 => DB_ERROR_VALUE_COUNT_ON_ROW,`	100	`913 => DB_ERROR_VALUE_COUNT_ON_ROW,`
101	`921 => DB_ERROR_SYNTAX,`	101	`921 => DB_ERROR_SYNTAX,`
102	`923 => DB_ERROR_SYNTAX,`	102	`923 => DB_ERROR_SYNTAX,`
103	`942 => DB_ERROR_NOSUCHTABLE,`	103	`942 => DB_ERROR_NOSUCHTABLE,`
104	`955 => DB_ERROR_ALREADY_EXISTS,`	104	`955 => DB_ERROR_ALREADY_EXISTS,`
105	`1400 => DB_ERROR_CONSTRAINT_NOT_NULL,`	105	`1400 => DB_ERROR_CONSTRAINT_NOT_NULL,`
106	`1401 => DB_ERROR_INVALID,`	106	`1401 => DB_ERROR_INVALID,`
107	`1407 => DB_ERROR_CONSTRAINT_NOT_NULL,`	107	`1407 => DB_ERROR_CONSTRAINT_NOT_NULL,`
108	`1418 => DB_ERROR_NOT_FOUND,`	108	`1418 => DB_ERROR_NOT_FOUND,`
109	`1476 => DB_ERROR_DIVZERO,`	109	`1476 => DB_ERROR_DIVZERO,`
110	`1722 => DB_ERROR_INVALID_NUMBER,`	110	`1722 => DB_ERROR_INVALID_NUMBER,`
111	`2289 => DB_ERROR_NOSUCHTABLE,`	111	`2289 => DB_ERROR_NOSUCHTABLE,`
112	`2291 => DB_ERROR_CONSTRAINT,`	112	`2291 => DB_ERROR_CONSTRAINT,`
113	`2292 => DB_ERROR_CONSTRAINT,`	113	`2292 => DB_ERROR_CONSTRAINT,`
114	`2449 => DB_ERROR_CONSTRAINT,`	114	`2449 => DB_ERROR_CONSTRAINT,`
115	`);`	115	`);`
116		116
117	`/**`	117	`/**`
118	`* The raw database connection created by PHP`	118	`* The raw database connection created by PHP`
119	`* @var resource`	119	`* @var resource`
120	`*/`	120	`*/`
121	`var $connection;`	121	`var $connection;`
122		122
123	`/**`	123	`/**`
124	`* The DSN information for connecting to a database`	124	`* The DSN information for connecting to a database`
125	`* @var array`	125	`* @var array`
126	`*/`	126	`*/`
127	`var $dsn = array();`	127	`var $dsn = array();`
128		128
129		129
130	`/**`	130	`/**`
131	`* Should data manipulation queries be committed automatically?`	131	`* Should data manipulation queries be committed automatically?`
132	`* @var bool`	132	`* @var bool`
133	`* @access private`	133	`* @access private`
134	`*/`	134	`*/`
135	`var $autocommit = true;`	135	`var $autocommit = true;`
136		136
137	`/**`	137	`/**`
138	`* Stores the $data passed to execute() in the oci8 driver`	138	`* Stores the $data passed to execute() in the oci8 driver`
139	`*`	139	`*`
140	`* Gets reset to array() when simpleQuery() is run.`	140	`* Gets reset to array() when simpleQuery() is run.`
141	`*`	141	`*`
142	`* Needed in case user wants to call numRows() after prepare/execute`	142	`* Needed in case user wants to call numRows() after prepare/execute`
143	`* was used.`	143	`* was used.`
144	`*`	144	`*`
145	`* @var array`	145	`* @var array`
146	`* @access private`	146	`* @access private`
147	`*/`	147	`*/`
148	`var $_data = array();`	148	`var $_data = array();`
149		149
150	`/**`	150	`/**`
151	`* The result or statement handle from the most recently executed query`	151	`* The result or statement handle from the most recently executed query`
152	`* @var resource`	152	`* @var resource`
153	`*/`	153	`*/`
154	`var $last_stmt;`	154	`var $last_stmt;`
155		155
156	`/**`	156	`/**`
157	`* Is the given prepared statement a data manipulation query?`	157	`* Is the given prepared statement a data manipulation query?`
158	`* @var array`	158	`* @var array`
159	`* @access private`	159	`* @access private`
160	`*/`	160	`*/`
161	`var $manip_query = array();`	161	`var $manip_query = array();`
162		162
163		163
164	`// }}}`	164	`// }}}`
165	`// {{{ constructor`	165	`// {{{ constructor`
166		166
167	`/**`	167	`/**`
168	`* This constructor calls <kbd>$this->DB_common()</kbd>`	168	`* This constructor calls <kbd>$this->DB_common()</kbd>`
169	`*`	169	`*`
170	`* @return void`	170	`* @return void`
171	`*/`	171	`*/`
172	`function DB_oci8()`	172	`function DB_oci8()`
173	`{`	173	`{`
174	`$this->DB_common();`	174	`$this->DB_common();`
175	`}`	175	`}`
176		176
177	`// }}}`	177	`// }}}`
178	`// {{{ connect()`	178	`// {{{ connect()`
179		179
180	`/**`	180	`/**`
181	`* Connect to the database server, log in and open the database`	181	`* Connect to the database server, log in and open the database`
182	`*`	182	`*`
183	`* Don't call this method directly. Use DB::connect() instead.`	183	`* Don't call this method directly. Use DB::connect() instead.`
184	`*`	184	`*`
185	`* If PHP is at version 5.0.0 or greater:`	185	`* If PHP is at version 5.0.0 or greater:`
186	`* + Generally, oci_connect() or oci_pconnect() are used.`	186	`* + Generally, oci_connect() or oci_pconnect() are used.`
187	`* + But if the new_link DSN option is set to true, oci_new_connect()`	187	`* + But if the new_link DSN option is set to true, oci_new_connect()`
188	`* is used.`	188	`* is used.`
189	`*`	189	`*`
190	`* When using PHP version 4.x, OCILogon() or OCIPLogon() are used.`	190	`* When using PHP version 4.x, OCILogon() or OCIPLogon() are used.`
191	`*`	191	`*`
192	`* PEAR DB's oci8 driver supports the following extra DSN options:`	192	`* PEAR DB's oci8 driver supports the following extra DSN options:`
193	`* + charset The character set to be used on the connection.`	193	`* + charset The character set to be used on the connection.`
194	`* Only used if PHP is at version 5.0.0 or greater`	194	`* Only used if PHP is at version 5.0.0 or greater`
195	`* and the Oracle server is at 9.2 or greater.`	195	`* and the Oracle server is at 9.2 or greater.`
196	`* Available since PEAR DB 1.7.0.`	196	`* Available since PEAR DB 1.7.0.`
197	`* + new_link If set to true, causes subsequent calls to`	197	`* + new_link If set to true, causes subsequent calls to`
198	`* connect() to return a new connection link`	198	`* connect() to return a new connection link`
199	`* instead of the existing one. WARNING: this is`	199	`* instead of the existing one. WARNING: this is`
200	`* not portable to other DBMS's.`	200	`* not portable to other DBMS's.`
201	`* Available since PEAR DB 1.7.0.`	201	`* Available since PEAR DB 1.7.0.`
202	`*`	202	`*`
203	`* @param array $dsn the data source name`	203	`* @param array $dsn the data source name`
204	`* @param bool $persistent should the connection be persistent?`	204	`* @param bool $persistent should the connection be persistent?`
205	`*`	205	`*`
206	`* @return int DB_OK on success. A DB_Error object on failure.`	206	`* @return int DB_OK on success. A DB_Error object on failure.`
207	`*/`	207	`*/`
208	`function connect($dsn, $persistent = false)`	208	`function connect($dsn, $persistent = false)`
209	`{`	209	`{`
210	`if (!PEAR::loadExtension('oci8')) {`	210	`if (!PEAR::loadExtension('oci8')) {`
211	`return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);`	211	`return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);`
212	`}`	212	`}`
213		213
214	`$this->dsn = $dsn;`	214	`$this->dsn = $dsn;`
215	`if ($dsn['dbsyntax']) {`	215	`if ($dsn['dbsyntax']) {`
216	`$this->dbsyntax = $dsn['dbsyntax'];`	216	`$this->dbsyntax = $dsn['dbsyntax'];`
217	`}`	217	`}`
218		218
219	`if (function_exists('oci_connect')) {`	219	`if (function_exists('oci_connect')) {`
220	`if (isset($dsn['new_link'])`	220	`if (isset($dsn['new_link'])`
221	`&& ($dsn['new_link'] == 'true' \|\| $dsn['new_link'] === true))`	221	`&& ($dsn['new_link'] == 'true' \|\| $dsn['new_link'] === true))`
222	`{`	222	`{`
223	`$connect_function = 'oci_new_connect';`	223	`$connect_function = 'oci_new_connect';`
224	`} else {`	224	`} else {`
225	`$connect_function = $persistent ? 'oci_pconnect'`	225	`$connect_function = $persistent ? 'oci_pconnect'`
226	`: 'oci_connect';`	226	`: 'oci_connect';`
227	`}`	227	`}`
-		228
-		229	`// Backwards compatibility with DB < 1.7.0`
-		230	`if (empty($dsn['database']) && !empty($dsn['hostspec'])) {`
-		231	`$db = $dsn['hostspec'];`
-		232	`} else {`
-		233	`$db = $dsn['database'];`
-		234	`}`
-		235
228	`$char = empty($dsn['charset']) ? null : $dsn['charset'];`	236	`$char = empty($dsn['charset']) ? null : $dsn['charset'];`
229	`$this->connection = @$connect_function($dsn['username'],`	237	`$this->connection = @$connect_function($dsn['username'],`
230	`$dsn['password'],`	238	`$dsn['password'],`
231	`$dsn['database'],`	239	`$db,`
232	`$char);`	240	`$char);`
233	`$error = OCIError();`	241	`$error = OCIError();`
234	`if (!empty($error) && $error['code'] == 12541) {`	242	`if (!empty($error) && $error['code'] == 12541) {`
235	`// Couldn't find TNS listener. Try direct connection.`	243	`// Couldn't find TNS listener. Try direct connection.`
236	`$this->connection = @$connect_function($dsn['username'],`	244	`$this->connection = @$connect_function($dsn['username'],`
237	`$dsn['password'],`	245	`$dsn['password'],`
238	`null,`	246	`null,`
239	`$char);`	247	`$char);`
240	`}`	248	`}`
241	`} else {`	249	`} else {`
242	`$connect_function = $persistent ? 'OCIPLogon' : 'OCILogon';`	250	`$connect_function = $persistent ? 'OCIPLogon' : 'OCILogon';`
243	`if ($dsn['hostspec']) {`	251	`if ($dsn['hostspec']) {`
244	`$this->connection = @$connect_function($dsn['username'],`	252	`$this->connection = @$connect_function($dsn['username'],`
245	`$dsn['password'],`	253	`$dsn['password'],`
246	`$dsn['hostspec']);`	254	`$dsn['hostspec']);`
247	`} elseif ($dsn['username'] \|\| $dsn['password']) {`	255	`} elseif ($dsn['username'] \|\| $dsn['password']) {`
248	`$this->connection = @$connect_function($dsn['username'],`	256	`$this->connection = @$connect_function($dsn['username'],`
249	`$dsn['password']);`	257	`$dsn['password']);`
250	`}`	258	`}`
251	`}`	259	`}`
252		260
253	`if (!$this->connection) {`	261	`if (!$this->connection) {`
254	`$error = OCIError();`	262	`$error = OCIError();`
255	`$error = (is_array($error)) ? $error['message'] : null;`	263	`$error = (is_array($error)) ? $error['message'] : null;`
256	`return $this->raiseError(DB_ERROR_CONNECT_FAILED,`	264	`return $this->raiseError(DB_ERROR_CONNECT_FAILED,`
257	`null, null, null,`	265	`null, null, null,`
258	`$error);`	266	`$error);`
259	`}`	267	`}`
260	`return DB_OK;`	268	`return DB_OK;`
261	`}`	269	`}`
262		270
263	`// }}}`	271	`// }}}`
264	`// {{{ disconnect()`	272	`// {{{ disconnect()`
265		273
266	`/**`	274	`/**`
267	`* Disconnects from the database server`	275	`* Disconnects from the database server`
268	`*`	276	`*`
269	`* @return bool TRUE on success, FALSE on failure`	277	`* @return bool TRUE on success, FALSE on failure`
270	`*/`	278	`*/`
271	`function disconnect()`	279	`function disconnect()`
272	`{`	280	`{`
273	`if (function_exists('oci_close')) {`	281	`if (function_exists('oci_close')) {`
274	`$ret = @oci_close($this->connection);`	282	`$ret = @oci_close($this->connection);`
275	`} else {`	283	`} else {`
276	`$ret = @OCILogOff($this->connection);`	284	`$ret = @OCILogOff($this->connection);`
277	`}`	285	`}`
278	`$this->connection = null;`	286	`$this->connection = null;`
279	`return $ret;`	287	`return $ret;`
280	`}`	288	`}`
281		289
282	`// }}}`	290	`// }}}`
283	`// {{{ simpleQuery()`	291	`// {{{ simpleQuery()`
284		292
285	`/**`	293	`/**`
286	`* Sends a query to the database server`	294	`* Sends a query to the database server`
287	`*`	295	`*`
288	`* To determine how many rows of a result set get buffered using`	296	`* To determine how many rows of a result set get buffered using`
289	`* ocisetprefetch(), see the "result_buffering" option in setOptions().`	297	`* ocisetprefetch(), see the "result_buffering" option in setOptions().`
290	`* This option was added in Release 1.7.0.`	298	`* This option was added in Release 1.7.0.`
291	`*`	299	`*`
292	`* @param string the SQL query string`	300	`* @param string the SQL query string`
293	`*`	301	`*`
294	`* @return mixed + a PHP result resrouce for successful SELECT queries`	302	`* @return mixed + a PHP result resrouce for successful SELECT queries`
295	`* + the DB_OK constant for other successful queries`	303	`* + the DB_OK constant for other successful queries`
296	`* + a DB_Error object on failure`	304	`* + a DB_Error object on failure`
297	`*/`	305	`*/`
298	`function simpleQuery($query)`	306	`function simpleQuery($query)`
299	`{`	307	`{`
300	`$this->_data = array();`	308	`$this->_data = array();`
301	`$this->last_parameters = array();`	309	`$this->last_parameters = array();`
302	`$this->last_query = $query;`	310	`$this->last_query = $query;`
303	`$query = $this->modifyQuery($query);`	311	`$query = $this->modifyQuery($query);`
304	`$result = @OCIParse($this->connection, $query);`	312	`$result = @OCIParse($this->connection, $query);`
305	`if (!$result) {`	313	`if (!$result) {`
306	`return $this->oci8RaiseError();`	314	`return $this->oci8RaiseError();`
307	`}`	315	`}`
308	`if ($this->autocommit) {`	316	`if ($this->autocommit) {`
309	`$success = @OCIExecute($result,OCI_COMMIT_ON_SUCCESS);`	317	`$success = @OCIExecute($result,OCI_COMMIT_ON_SUCCESS);`
310	`} else {`	318	`} else {`
311	`$success = @OCIExecute($result,OCI_DEFAULT);`	319	`$success = @OCIExecute($result,OCI_DEFAULT);`
312	`}`	320	`}`
313	`if (!$success) {`	321	`if (!$success) {`
314	`return $this->oci8RaiseError($result);`	322	`return $this->oci8RaiseError($result);`
315	`}`	323	`}`
316	`$this->last_stmt = $result;`	324	`$this->last_stmt = $result;`
317	`if (DB::isManip($query)) {`	325	`if (DB::isManip($query)) {`
318	`return DB_OK;`	326	`return DB_OK;`
319	`} else {`	327	`} else {`
320	`@ocisetprefetch($result, $this->options['result_buffering']);`	328	`@ocisetprefetch($result, $this->options['result_buffering']);`
321	`return $result;`	329	`return $result;`
322	`}`	330	`}`
323	`}`	331	`}`
324		332
325	`// }}}`	333	`// }}}`
326	`// {{{ nextResult()`	334	`// {{{ nextResult()`
327		335
328	`/**`	336	`/**`
329	`* Move the internal oracle result pointer to the next available result`	337	`* Move the internal oracle result pointer to the next available result`
330	`*`	338	`*`
331	`* @param a valid oci8 result resource`	339	`* @param a valid oci8 result resource`
332	`*`	340	`*`
333	`* @access public`	341	`* @access public`
334	`*`	342	`*`
335	`* @return true if a result is available otherwise return false`	343	`* @return true if a result is available otherwise return false`
336	`*/`	344	`*/`
337	`function nextResult($result)`	345	`function nextResult($result)`
338	`{`	346	`{`
339	`return false;`	347	`return false;`
340	`}`	348	`}`
341		349
342	`// }}}`	350	`// }}}`
343	`// {{{ fetchInto()`	351	`// {{{ fetchInto()`
344		352
345	`/**`	353	`/**`
346	`* Places a row from the result set into the given array`	354	`* Places a row from the result set into the given array`
347	`*`	355	`*`
348	`* Formating of the array and the data therein are configurable.`	356	`* Formating of the array and the data therein are configurable.`
349	`* See DB_result::fetchInto() for more information.`	357	`* See DB_result::fetchInto() for more information.`
350	`*`	358	`*`
351	`* This method is not meant to be called directly. Use`	359	`* This method is not meant to be called directly. Use`
352	`* DB_result::fetchInto() instead. It can't be declared "protected"`	360	`* DB_result::fetchInto() instead. It can't be declared "protected"`
353	`* because DB_result is a separate object.`	361	`* because DB_result is a separate object.`
354	`*`	362	`*`
355	`* @param resource $result the query result resource`	363	`* @param resource $result the query result resource`
356	`* @param array $arr the referenced array to put the data in`	364	`* @param array $arr the referenced array to put the data in`
357	`* @param int $fetchmode how the resulting array should be indexed`	365	`* @param int $fetchmode how the resulting array should be indexed`
358	`* @param int $rownum the row number to fetch (0 = first row)`	366	`* @param int $rownum the row number to fetch (0 = first row)`
359	`*`	367	`*`
360	`* @return mixed DB_OK on success, NULL when the end of a result set is`	368	`* @return mixed DB_OK on success, NULL when the end of a result set is`
361	`* reached or on failure`	369	`* reached or on failure`
362	`*`	370	`*`
363	`* @see DB_result::fetchInto()`	371	`* @see DB_result::fetchInto()`
364	`*/`	372	`*/`
365	`function fetchInto($result, &$arr, $fetchmode, $rownum = null)`	373	`function fetchInto($result, &$arr, $fetchmode, $rownum = null)`
366	`{`	374	`{`
367	`if ($rownum !== null) {`	375	`if ($rownum !== null) {`
368	`return $this->raiseError(DB_ERROR_NOT_CAPABLE);`	376	`return $this->raiseError(DB_ERROR_NOT_CAPABLE);`
369	`}`	377	`}`
370	`if ($fetchmode & DB_FETCHMODE_ASSOC) {`	378	`if ($fetchmode & DB_FETCHMODE_ASSOC) {`
371	`$moredata = @OCIFetchInto($result,$arr,OCI_ASSOC+OCI_RETURN_NULLS+OCI_RETURN_LOBS);`	379	`$moredata = @OCIFetchInto($result,$arr,OCI_ASSOC+OCI_RETURN_NULLS+OCI_RETURN_LOBS);`
372	`if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE &&`	380	`if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE &&`
373	`$moredata)`	381	`$moredata)`
374	`{`	382	`{`
375	`$arr = array_change_key_case($arr, CASE_LOWER);`	383	`$arr = array_change_key_case($arr, CASE_LOWER);`
376	`}`	384	`}`
377	`} else {`	385	`} else {`
378	`$moredata = OCIFetchInto($result,$arr,OCI_RETURN_NULLS+OCI_RETURN_LOBS);`	386	`$moredata = OCIFetchInto($result,$arr,OCI_RETURN_NULLS+OCI_RETURN_LOBS);`
379	`}`	387	`}`
380	`if (!$moredata) {`	388	`if (!$moredata) {`
381	`return null;`	389	`return null;`
382	`}`	390	`}`
383	`if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {`	391	`if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {`
384	`$this->_rtrimArrayValues($arr);`	392	`$this->_rtrimArrayValues($arr);`
385	`}`	393	`}`
386	`if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {`	394	`if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {`
387	`$this->_convertNullArrayValuesToEmpty($arr);`	395	`$this->_convertNullArrayValuesToEmpty($arr);`
388	`}`	396	`}`
389	`return DB_OK;`	397	`return DB_OK;`
390	`}`	398	`}`
391		399
392	`// }}}`	400	`// }}}`
393	`// {{{ freeResult()`	401	`// {{{ freeResult()`
394		402
395	`/**`	403	`/**`
396	`* Deletes the result set and frees the memory occupied by the result set`	404	`* Deletes the result set and frees the memory occupied by the result set`
397	`*`	405	`*`
398	`* This method is not meant to be called directly. Use`	406	`* This method is not meant to be called directly. Use`
399	`* DB_result::free() instead. It can't be declared "protected"`	407	`* DB_result::free() instead. It can't be declared "protected"`
400	`* because DB_result is a separate object.`	408	`* because DB_result is a separate object.`
401	`*`	409	`*`
402	`* @param resource $result PHP's query result resource`	410	`* @param resource $result PHP's query result resource`
403	`*`	411	`*`
404	`* @return bool TRUE on success, FALSE if $result is invalid`	412	`* @return bool TRUE on success, FALSE if $result is invalid`
405	`*`	413	`*`
406	`* @see DB_result::free()`	414	`* @see DB_result::free()`
407	`*/`	415	`*/`
408	`function freeResult($result)`	416	`function freeResult($result)`
409	`{`	417	`{`
410	`return @OCIFreeStatement($result);`	418	`return @OCIFreeStatement($result);`
411	`}`	419	`}`
412		420
413	`/**`	421	`/**`
414	`* Frees the internal resources associated with a prepared query`	422	`* Frees the internal resources associated with a prepared query`
415	`*`	423	`*`
416	`* @param resource $stmt the prepared statement's resource`	424	`* @param resource $stmt the prepared statement's resource`
417	`* @param bool $free_resource should the PHP resource be freed too?`	425	`* @param bool $free_resource should the PHP resource be freed too?`
418	`* Use false if you need to get data`	426	`* Use false if you need to get data`
419	`* from the result set later.`	427	`* from the result set later.`
420	`*`	428	`*`
421	`* @return bool TRUE on success, FALSE if $result is invalid`	429	`* @return bool TRUE on success, FALSE if $result is invalid`
422	`*`	430	`*`
423	`* @see DB_oci8::prepare()`	431	`* @see DB_oci8::prepare()`
424	`*/`	432	`*/`
425	`function freePrepared($stmt, $free_resource = true)`	433	`function freePrepared($stmt, $free_resource = true)`
426	`{`	434	`{`
427	`if (!is_resource($stmt)) {`	435	`if (!is_resource($stmt)) {`
428	`return false;`	436	`return false;`
429	`}`	437	`}`
430	`if ($free_resource) {`	438	`if ($free_resource) {`
431	`@ocifreestatement($stmt);`	439	`@ocifreestatement($stmt);`
432	`}`	440	`}`
433	`if (isset($this->prepare_types[(int)$stmt])) {`	441	`if (isset($this->prepare_types[(int)$stmt])) {`
434	`unset($this->prepare_types[(int)$stmt]);`	442	`unset($this->prepare_types[(int)$stmt]);`
435	`unset($this->manip_query[(int)$stmt]);`	443	`unset($this->manip_query[(int)$stmt]);`
436	`} else {`	444	`} else {`
437	`return false;`	445	`return false;`
438	`}`	446	`}`
439	`return true;`	447	`return true;`
440	`}`	448	`}`
441		449
442	`// }}}`	450	`// }}}`
443	`// {{{ numRows()`	451	`// {{{ numRows()`
444		452
445	`/**`	453	`/**`
446	`* Gets the number of rows in a result set`	454	`* Gets the number of rows in a result set`
447	`*`	455	`*`
448	`* Only works if the DB_PORTABILITY_NUMROWS portability option`	456	`* Only works if the DB_PORTABILITY_NUMROWS portability option`
449	`* is turned on.`	457	`* is turned on.`
450	`*`	458	`*`
451	`* This method is not meant to be called directly. Use`	459	`* This method is not meant to be called directly. Use`
452	`* DB_result::numRows() instead. It can't be declared "protected"`	460	`* DB_result::numRows() instead. It can't be declared "protected"`
453	`* because DB_result is a separate object.`	461	`* because DB_result is a separate object.`
454	`*`	462	`*`
455	`* @param resource $result PHP's query result resource`	463	`* @param resource $result PHP's query result resource`
456	`*`	464	`*`
457	`* @return int the number of rows. A DB_Error object on failure.`	465	`* @return int the number of rows. A DB_Error object on failure.`
458	`*`	466	`*`
459	`* @see DB_result::numRows(), DB_common::setOption()`	467	`* @see DB_result::numRows(), DB_common::setOption()`
460	`*/`	468	`*/`
461	`function numRows($result)`	469	`function numRows($result)`
462	`{`	470	`{`
463	`// emulate numRows for Oracle. yuck.`	471	`// emulate numRows for Oracle. yuck.`
464	`if ($this->options['portability'] & DB_PORTABILITY_NUMROWS &&`	472	`if ($this->options['portability'] & DB_PORTABILITY_NUMROWS &&`
465	`$result === $this->last_stmt)`	473	`$result === $this->last_stmt)`
466	`{`	474	`{`
467	`$countquery = 'SELECT COUNT(*) FROM ('.$this->last_query.')';`	475	`$countquery = 'SELECT COUNT(*) FROM ('.$this->last_query.')';`
468	`$save_query = $this->last_query;`	476	`$save_query = $this->last_query;`
469	`$save_stmt = $this->last_stmt;`	477	`$save_stmt = $this->last_stmt;`
470		478
471	`if (count($this->_data)) {`	479	`if (count($this->_data)) {`
472	`$smt = $this->prepare('SELECT COUNT(*) FROM ('.$this->last_query.')');`	480	`$smt = $this->prepare('SELECT COUNT(*) FROM ('.$this->last_query.')');`
473	`$count = $this->execute($smt, $this->_data);`	481	`$count = $this->execute($smt, $this->_data);`
474	`} else {`	482	`} else {`
475	`$count =& $this->query($countquery);`	483	`$count =& $this->query($countquery);`
476	`}`	484	`}`
477		485
478	`if (DB::isError($count) \|\|`	486	`if (DB::isError($count) \|\|`
479	`DB::isError($row = $count->fetchRow(DB_FETCHMODE_ORDERED)))`	487	`DB::isError($row = $count->fetchRow(DB_FETCHMODE_ORDERED)))`
480	`{`	488	`{`
481	`$this->last_query = $save_query;`	489	`$this->last_query = $save_query;`
482	`$this->last_stmt = $save_stmt;`	490	`$this->last_stmt = $save_stmt;`
483	`return $this->raiseError(DB_ERROR_NOT_CAPABLE);`	491	`return $this->raiseError(DB_ERROR_NOT_CAPABLE);`
484	`}`	492	`}`
485	`return $row[0];`	493	`return $row[0];`
486	`}`	494	`}`
487	`return $this->raiseError(DB_ERROR_NOT_CAPABLE);`	495	`return $this->raiseError(DB_ERROR_NOT_CAPABLE);`
488	`}`	496	`}`
489		497
490	`// }}}`	498	`// }}}`
491	`// {{{ numCols()`	499	`// {{{ numCols()`
492		500

Subversion Repositories Applications.papyrus

(root)/trunk/api/pear/DB/oci8.php – Rev 320 → 443