WebSVN - ant - Различия - Редакция 2 и 3


<?php

/* vim: set expandtab tabstop=4 shiftwidth=4 softtabstop=4: */

/**
 * The PEAR DB driver for PHP's odbc extension
 * for interacting with databases via ODBC connections
 *
 * 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     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: odbc.php,v 1.81 2007/07/06 05:19:21 aharvey 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 odbc extension
 * for interacting with databases via ODBC connections
 *
 * These methods overload the ones declared in DB_common.
 *
 * More info on ODBC errors could be found here:
 * http://msdn.microsoft.com/library/default.asp?url=/library/en-us/trblsql/tr_err_odbc_5stz.asp
 *
 * @category   Database
 * @package    DB
 * @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.7.13
 * @link       http://pear.php.net/package/DB
 */
class DB_odbc extends DB_common
{
    // {{{ properties

    /**
     * The DB driver type (mysql, oci8, odbc, etc.)
     * @var string
     */
    var $phptype = 'odbc';

    /**
     * The database syntax variant to be used (db2, access, etc.), if any
     * @var string
     */
    var $dbsyntax = 'sql92';

    /**
     * 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
     *
     * NOTE: The feature set of the following drivers are different than
     * the default:
     *   + solid: 'transactions' = true
     *   + navision: 'limit' = false
     *
     * @var array
     */
    var $features = array(
        'limit'         => 'emulate',
        'new_link'      => false,
        'numrows'       => true,
        'pconnect'      => true,
        'prepare'       => false,
        'ssl'           => false,
        'transactions'  => false,
    );

    /**
     * A mapping of native error codes to DB error codes
     * @var array
     */
    var $errorcode_map = array(
        '01004' => DB_ERROR_TRUNCATED,
        '07001' => DB_ERROR_MISMATCH,
        '21S01' => DB_ERROR_VALUE_COUNT_ON_ROW,
        '21S02' => DB_ERROR_MISMATCH,
        '22001' => DB_ERROR_INVALID,
        '22003' => DB_ERROR_INVALID_NUMBER,
        '22005' => DB_ERROR_INVALID_NUMBER,
        '22008' => DB_ERROR_INVALID_DATE,
        '22012' => DB_ERROR_DIVZERO,
        '23000' => DB_ERROR_CONSTRAINT,
        '23502' => DB_ERROR_CONSTRAINT_NOT_NULL,
        '23503' => DB_ERROR_CONSTRAINT,
        '23504' => DB_ERROR_CONSTRAINT,
        '23505' => DB_ERROR_CONSTRAINT,
        '24000' => DB_ERROR_INVALID,
        '34000' => DB_ERROR_INVALID,
        '37000' => DB_ERROR_SYNTAX,
        '42000' => DB_ERROR_SYNTAX,
        '42601' => DB_ERROR_SYNTAX,
        'IM001' => DB_ERROR_UNSUPPORTED,
        'S0000' => DB_ERROR_NOSUCHTABLE,
        'S0001' => DB_ERROR_ALREADY_EXISTS,
        'S0002' => DB_ERROR_NOSUCHTABLE,
        'S0011' => DB_ERROR_ALREADY_EXISTS,
        'S0012' => DB_ERROR_NOT_FOUND,
        'S0021' => DB_ERROR_ALREADY_EXISTS,
        'S0022' => DB_ERROR_NOSUCHFIELD,
        'S1009' => DB_ERROR_INVALID,
        'S1090' => DB_ERROR_INVALID,
        'S1C00' => DB_ERROR_NOT_CAPABLE,
    );

    /**
     * The raw database connection created by PHP
     * @var resource
     */
    var $connection;

    /**
     * The DSN information for connecting to a database
     * @var array
     */
    var $dsn = array();


    /**
     * The number of rows affected by a data manipulation query
     * @var integer
     * @access private
     */
    var $affected = 0;


    // }}}
    // {{{ constructor

    /**
     * This constructor calls <kbd>$this->DB_common()</kbd>
     *
     * @return void
     */
    function DB_odbc()
    {
        $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.
     *
     * PEAR DB's odbc driver supports the following extra DSN options:
     *   + cursor  The type of cursor to be used for this connection.
     *
     * @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('odbc')) {
            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
        }

        $this->dsn = $dsn;
        if ($dsn['dbsyntax']) {
            $this->dbsyntax = $dsn['dbsyntax'];
        }
        switch ($this->dbsyntax) {
            case 'access':
            case 'db2':
            case 'solid':
                $this->features['transactions'] = true;
                break;
            case 'navision':
                $this->features['limit'] = false;
        }

        /*
         * This is hear for backwards compatibility. Should have been using
         * 'database' all along, but prior to 1.6.0RC3 'hostspec' was used.
         */
        if ($dsn['database']) {
            $odbcdsn = $dsn['database'];
        } elseif ($dsn['hostspec']) {
            $odbcdsn = $dsn['hostspec'];
        } else {
            $odbcdsn = 'localhost';
        }

        $connect_function = $persistent ? 'odbc_pconnect' : 'odbc_connect';

        if (empty($dsn['cursor'])) {
            $this->connection = @$connect_function($odbcdsn, $dsn['username'],
                                                   $dsn['password']);
        } else {
            $this->connection = @$connect_function($odbcdsn, $dsn['username'],
                                                   $dsn['password'],
                                                   $dsn['cursor']);
        }

        if (!is_resource($this->connection)) {
            return $this->raiseError(DB_ERROR_CONNECT_FAILED,
                                     null, null, null,
                                     $this->errorNative());
        }
        return DB_OK;
    }

    // }}}
    // {{{ disconnect()

    /**
     * Disconnects from the database server
     *
     * @return bool  TRUE on success, FALSE on failure
     */
    function disconnect()
    {
        $err = @odbc_close($this->connection);
        $this->connection = null;
        return $err;
    }

    // }}}
    // {{{ 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)
    {
        $this->last_query = $query;
        $query = $this->modifyQuery($query);
        $result = @odbc_exec($this->connection, $query);
        if (!$result) {
            return $this->odbcRaiseError(); // XXX ERRORMSG
        }
        // Determine which queries that should return data, and which
        // should return an error code only.
        if ($this->_checkManip($query)) {
            $this->affected = $result; // For affectedRows()
            return DB_OK;
        }
        $this->affected = 0;
        return $result;
    }

    // }}}
    // {{{ nextResult()

    /**
     * Move the internal odbc 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 @odbc_next_result($result);
    }

    // }}}
    // {{{ 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)
    {
        $arr = array();
        if ($rownum !== null) {
            $rownum++; // ODBC first row is 1
            if (version_compare(phpversion(), '4.2.0', 'ge')) {
                $cols = @odbc_fetch_into($result, $arr, $rownum);
            } else {
                $cols = @odbc_fetch_into($result, $rownum, $arr);
            }
        } else {
            $cols = @odbc_fetch_into($result, $arr);
        }
        if (!$cols) {
            return null;
        }
        if ($fetchmode !== DB_FETCHMODE_ORDERED) {
            for ($i = 0; $i < count($arr); $i++) {
                $colName = @odbc_field_name($result, $i+1);
                $a[$colName] = $arr[$i];
            }
            if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) {
                $a = array_change_key_case($a, CASE_LOWER);
            }
            $arr = $a;
        }
        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 is_resource($result) ? odbc_free_result($result) : false;
    }

    // }}}
    // {{{ 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 = @odbc_num_fields($result);
        if (!$cols) {
            return $this->odbcRaiseError();
        }
        return $cols;
    }

    // }}}
    // {{{ 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 (empty($this->affected)) {  // In case of SELECT stms
            return 0;
        }
        $nrows = @odbc_num_rows($this->affected);
        if ($nrows == -1) {
            return $this->odbcRaiseError();
        }
        return $nrows;
    }

    // }}}
    // {{{ numRows()

    /**
     * Gets the number of rows in a result set
     *
     * Not all ODBC drivers support this functionality.  If they don't
     * a DB_Error object for DB_ERROR_UNSUPPORTED is returned.
     *
     * 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)
    {
        $nrows = @odbc_num_rows($result);
        if ($nrows == -1) {
            return $this->odbcRaiseError(DB_ERROR_UNSUPPORTED);
        }
        if ($nrows === false) {
            return $this->odbcRaiseError();
        }
        return $nrows;
    }

    // }}}
    // {{{ quoteIdentifier()

    /**
     * Quotes a string so it can be safely used as a table or column name
     *
     * Use 'mssql' as the dbsyntax in the DB DSN only if you've unchecked
     * "Use ANSI quoted identifiers" when setting up the ODBC data source.
     *
     * @param string $str  identifier name to be quoted
     *
     * @return string  quoted identifier string
     *
     * @see DB_common::quoteIdentifier()
     * @since Method available since Release 1.6.0
     */
    function quoteIdentifier($str)
    {
        switch ($this->dsn['dbsyntax']) {
            case 'access':
                return '[' . $str . ']';
            case 'mssql':
            case 'sybase':
                return '[' . str_replace(']', ']]', $str) . ']';
            case 'mysql':
            case 'mysqli':
                return '`' . $str . '`';
            default:
                return '"' . str_replace('"', '""', $str) . '"';
        }
    }

    // }}}
    // {{{ quote()

    /**
     * @deprecated  Deprecated in release 1.6.0
     * @internal
     */
    function quote($str)
    {
        return $this->quoteSmart($str);
    }

    // }}}
    // {{{ 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_odbc::createSequence(), DB_odbc::dropSequence()
     */
    function nextId($seq_name, $ondemand = true)
    {
        $seqname = $this->getSequenceName($seq_name);
        $repeat = 0;
        do {
            $this->pushErrorHandling(PEAR_ERROR_RETURN);
            $result = $this->query("update ${seqname} set id = id + 1");
            $this->popErrorHandling();
            if ($ondemand && DB::isError($result) &&
                $result->getCode() == DB_ERROR_NOSUCHTABLE) {
                $repeat = 1;
                $this->pushErrorHandling(PEAR_ERROR_RETURN);
                $result = $this->createSequence($seq_name);
                $this->popErrorHandling();
                if (DB::isError($result)) {
                    return $this->raiseError($result);
                }
                $result = $this->query("insert into ${seqname} (id) values(0)");
            } else {
                $repeat = 0;
            }
        } while ($repeat);

        if (DB::isError($result)) {
            return $this->raiseError($result);
        }

        $result = $this->query("select id from ${seqname}");
        if (DB::isError($result)) {
            return $result;
        }

        $row = $result->fetchRow(DB_FETCHMODE_ORDERED);
        if (DB::isError($row || !$row)) {
            return $row;
        }

        return $row[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_odbc::nextID(), DB_odbc::dropSequence()
     */
    function createSequence($seq_name)
    {
        return $this->query('CREATE TABLE '
                            . $this->getSequenceName($seq_name)
                            . ' (id integer NOT NULL,'
                            . ' PRIMARY KEY(id))');
    }

    // }}}
    // {{{ 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_odbc::nextID(), DB_odbc::createSequence()
     */
    function dropSequence($seq_name)
    {
        return $this->query('DROP TABLE ' . $this->getSequenceName($seq_name));
    }

    // }}}
    // {{{ 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)
    {
        if (!@odbc_autocommit($this->connection, $onoff)) {
            return $this->odbcRaiseError();
        }
        return DB_OK;
    }

    // }}}
    // {{{ commit()

    /**
     * Commits the current transaction
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     */
    function commit()
    {
        if (!@odbc_commit($this->connection)) {
            return $this->odbcRaiseError();
        }
        return DB_OK;
    }

    // }}}
    // {{{ rollback()

    /**
     * Reverts the current transaction
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     */
    function rollback()
    {
        if (!@odbc_rollback($this->connection)) {
            return $this->odbcRaiseError();
        }
        return DB_OK;
    }

    // }}}
    // {{{ odbcRaiseError()

    /**
     * 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_odbc::errorNative(), DB_common::errorCode()
     */
    function odbcRaiseError($errno = null)
    {
        if ($errno === null) {
            switch ($this->dbsyntax) {
                case 'access':
                    if ($this->options['portability'] & DB_PORTABILITY_ERRORS) {
                        $this->errorcode_map['07001'] = DB_ERROR_NOSUCHFIELD;
                    } else {
                        // Doing this in case mode changes during runtime.
                        $this->errorcode_map['07001'] = DB_ERROR_MISMATCH;
                    }

                    $native_code = odbc_error($this->connection);

                    // S1000 is for "General Error."  Let's be more specific.
                    if ($native_code == 'S1000') {
                        $errormsg = odbc_errormsg($this->connection);
                        static $error_regexps;
                        if (!isset($error_regexps)) {
                            $error_regexps = array(
                                '/includes related records.$/i'  => DB_ERROR_CONSTRAINT,
                                '/cannot contain a Null value/i' => DB_ERROR_CONSTRAINT_NOT_NULL,
                            );
                        }
                        foreach ($error_regexps as $regexp => $code) {
                            if (preg_match($regexp, $errormsg)) {
                                return $this->raiseError($code,
                                        null, null, null,
                                        $native_code . ' ' . $errormsg);
                            }
                        }
                        $errno = DB_ERROR;
                    } else {
                        $errno = $this->errorCode($native_code);
                    }
                    break;
                default:
                    $errno = $this->errorCode(odbc_error($this->connection));
            }
        }
        return $this->raiseError($errno, null, null, null,
                                 $this->errorNative());
    }

    // }}}
    // {{{ errorNative()

    /**
     * Gets the DBMS' native error code and message produced by the last query
     *
     * @return string  the DBMS' error code and message
     */
    function errorNative()
    {
        if (!is_resource($this->connection)) {
            return @odbc_error() . ' ' . @odbc_errormsg();
        }
        return @odbc_error($this->connection) . ' ' . @odbc_errormsg($this->connection);
    }

    // }}}
    // {{{ tableInfo()

    /**
     * Returns information about a table or a result set
     *
     * @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()
     * @since Method available since Release 1.7.0
     */
    function tableInfo($result, $mode = null)
    {
        if (is_string($result)) {
            /*
             * Probably received a table name.
             * Create a result resource identifier.
             */
            $id = @odbc_exec($this->connection, "SELECT * FROM $result");
            if (!$id) {
                return $this->odbcRaiseError();
            }
            $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->odbcRaiseError(DB_ERROR_NEED_MORE_DATA);
        }

        if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) {
            $case_func = 'strtolower';
        } else {
            $case_func = 'strval';
        }

        $count = @odbc_num_fields($id);
        $res   = array();

        if ($mode) {
            $res['num_fields'] = $count;
        }

        for ($i = 0; $i < $count; $i++) {
            $col = $i + 1;
            $res[$i] = array(
                'table' => $got_string ? $case_func($result) : '',
                'name'  => $case_func(@odbc_field_name($id, $col)),
                'type'  => @odbc_field_type($id, $col),
                'len'   => @odbc_field_len($id, $col),
                '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;
            }
        }

        // free the result only if we were called on a table
        if ($got_string) {
            @odbc_free_result($id);
        }
        return $res;
    }

    // }}}
    // {{{ getSpecialQuery()

    /**
     * Obtains the query string needed for listing a given type of objects
     *
     * Thanks to symbol1@gmail.com and Philippe.Jausions@11abacus.com.
     *
     * @param string $type  the kind of objects you want to retrieve
     *
     * @return string  the list of objects requested
     *
     * @access protected
     * @see DB_common::getListOf()
     * @since Method available since Release 1.7.0
     */
    function getSpecialQuery($type)
    {
        switch ($type) {
            case 'databases':
                if (!function_exists('odbc_data_source')) {
                    return null;
                }
                $res = @odbc_data_source($this->connection, SQL_FETCH_FIRST);
                if (is_array($res)) {
                    $out = array($res['server']);
                    while($res = @odbc_data_source($this->connection,
                                                   SQL_FETCH_NEXT))
                    {
                        $out[] = $res['server'];
                    }
                    return $out;
                } else {
                    return $this->odbcRaiseError();
                }
                break;
            case 'tables':
            case 'schema.tables':
                $keep = 'TABLE';
                break;
            case 'views':
                $keep = 'VIEW';
                break;
            default:
                return null;
        }

        /*
         * Removing non-conforming items in the while loop rather than
         * in the odbc_tables() call because some backends choke on this:
         *     odbc_tables($this->connection, '', '', '', 'TABLE')
         */
        $res  = @odbc_tables($this->connection);
        if (!$res) {
            return $this->odbcRaiseError();
        }
        $out = array();
        while ($row = odbc_fetch_array($res)) {
            if ($row['TABLE_TYPE'] != $keep) {
                continue;
            }
            if ($type == 'schema.tables') {
                $out[] = $row['TABLE_SCHEM'] . '.' . $row['TABLE_NAME'];
            } else {
                $out[] = $row['TABLE_NAME'];
            }
        }
        return $out;
    }

    // }}}

}

/*
 * Local variables:
 * tab-width: 4
 * c-basic-offset: 4
 * End:
 */

?>
 

Редакция 2	Редакция 3
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 odbc extension	6	* The PEAR DB driver for PHP's odbc extension
7	* for interacting with databases via ODBC connections	7	* for interacting with databases via ODBC connections
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 Stig Bakken <ssb@php.net>	19	* @author Stig Bakken <ssb@php.net>
20	* @author Daniel Convissor <danielc@php.net>	20	* @author Daniel Convissor <danielc@php.net>
21	* @copyright 1997-2007 The PHP Group	21	* @copyright 1997-2007 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: odbc.php,v 1.81 2007/07/06 05:19:21 aharvey Exp $	23	* @version CVS: $Id: odbc.php,v 1.81 2007/07/06 05:19:21 aharvey 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 odbc extension	33	* The methods PEAR DB uses to interact with PHP's odbc extension
34	* for interacting with databases via ODBC connections	34	* for interacting with databases via ODBC connections
35	*	35	*
36	* These methods overload the ones declared in DB_common.	36	* These methods overload the ones declared in DB_common.
37	*	37	*
38	* More info on ODBC errors could be found here:	38	* More info on ODBC errors could be found here:
39	* http://msdn.microsoft.com/library/default.asp?url=/library/en-us/trblsql/tr_err_odbc_5stz.asp	39	* http://msdn.microsoft.com/library/default.asp?url=/library/en-us/trblsql/tr_err_odbc_5stz.asp
40	*	40	*
41	* @category Database	41	* @category Database
42	* @package DB	42	* @package DB
43	* @author Stig Bakken <ssb@php.net>	43	* @author Stig Bakken <ssb@php.net>
44	* @author Daniel Convissor <danielc@php.net>	44	* @author Daniel Convissor <danielc@php.net>
45	* @copyright 1997-2007 The PHP Group	45	* @copyright 1997-2007 The PHP Group
46	* @license http://www.php.net/license/3_0.txt PHP License 3.0	46	* @license http://www.php.net/license/3_0.txt PHP License 3.0
47	* @version Release: 1.7.13	47	* @version Release: 1.7.13
48	* @link http://pear.php.net/package/DB	48	* @link http://pear.php.net/package/DB
49	*/	49	*/
50	class DB_odbc extends DB_common	50	class DB_odbc extends DB_common
51	{	51	{
52	// {{{ properties	52	// {{{ properties
53		53
54	/**	54	/**
55	* The DB driver type (mysql, oci8, odbc, etc.)	55	* The DB driver type (mysql, oci8, odbc, etc.)
56	* @var string	56	* @var string
57	*/	57	*/
58	var $phptype = 'odbc';	58	var $phptype = 'odbc';
59		59
60	/**	60	/**
61	* The database syntax variant to be used (db2, access, etc.), if any	61	* The database syntax variant to be used (db2, access, etc.), if any
62	* @var string	62	* @var string
63	*/	63	*/
64	var $dbsyntax = 'sql92';	64	var $dbsyntax = 'sql92';
65		65
66	/**	66	/**
67	* The capabilities of this DB implementation	67	* The capabilities of this DB implementation
68	*	68	*
69	* The 'new_link' element contains the PHP version that first provided	69	* The 'new_link' element contains the PHP version that first provided
70	* new_link support for this DBMS. Contains false if it's unsupported.	70	* new_link support for this DBMS. Contains false if it's unsupported.
71	*	71	*
72	* Meaning of the 'limit' element:	72	* Meaning of the 'limit' element:
73	* + 'emulate' = emulate with fetch row by number	73	* + 'emulate' = emulate with fetch row by number
74	* + 'alter' = alter the query	74	* + 'alter' = alter the query
75	* + false = skip rows	75	* + false = skip rows
76	*	76	*
77	* NOTE: The feature set of the following drivers are different than	77	* NOTE: The feature set of the following drivers are different than
78	* the default:	78	* the default:
79	* + solid: 'transactions' = true	79	* + solid: 'transactions' = true
80	* + navision: 'limit' = false	80	* + navision: 'limit' = false
81	*	81	*
82	* @var array	82	* @var array
83	*/	83	*/
84	var $features = array(	84	var $features = array(
85	'limit' => 'emulate',	85	'limit' => 'emulate',
86	'new_link' => false,	86	'new_link' => false,
87	'numrows' => true,	87	'numrows' => true,
88	'pconnect' => true,	88	'pconnect' => true,
89	'prepare' => false,	89	'prepare' => false,
90	'ssl' => false,	90	'ssl' => false,
91	'transactions' => false,	91	'transactions' => false,
92	);	92	);
93		93
94	/**	94	/**
95	* A mapping of native error codes to DB error codes	95	* A mapping of native error codes to DB error codes
96	* @var array	96	* @var array
97	*/	97	*/
98	var $errorcode_map = array(	98	var $errorcode_map = array(
99	'01004' => DB_ERROR_TRUNCATED,	99	'01004' => DB_ERROR_TRUNCATED,
100	'07001' => DB_ERROR_MISMATCH,	100	'07001' => DB_ERROR_MISMATCH,
101	'21S01' => DB_ERROR_VALUE_COUNT_ON_ROW,	101	'21S01' => DB_ERROR_VALUE_COUNT_ON_ROW,
102	'21S02' => DB_ERROR_MISMATCH,	102	'21S02' => DB_ERROR_MISMATCH,
103	'22001' => DB_ERROR_INVALID,	103	'22001' => DB_ERROR_INVALID,
104	'22003' => DB_ERROR_INVALID_NUMBER,	104	'22003' => DB_ERROR_INVALID_NUMBER,
105	'22005' => DB_ERROR_INVALID_NUMBER,	105	'22005' => DB_ERROR_INVALID_NUMBER,
106	'22008' => DB_ERROR_INVALID_DATE,	106	'22008' => DB_ERROR_INVALID_DATE,
107	'22012' => DB_ERROR_DIVZERO,	107	'22012' => DB_ERROR_DIVZERO,
108	'23000' => DB_ERROR_CONSTRAINT,	108	'23000' => DB_ERROR_CONSTRAINT,
109	'23502' => DB_ERROR_CONSTRAINT_NOT_NULL,	109	'23502' => DB_ERROR_CONSTRAINT_NOT_NULL,
110	'23503' => DB_ERROR_CONSTRAINT,	110	'23503' => DB_ERROR_CONSTRAINT,
111	'23504' => DB_ERROR_CONSTRAINT,	111	'23504' => DB_ERROR_CONSTRAINT,
112	'23505' => DB_ERROR_CONSTRAINT,	112	'23505' => DB_ERROR_CONSTRAINT,
113	'24000' => DB_ERROR_INVALID,	113	'24000' => DB_ERROR_INVALID,
114	'34000' => DB_ERROR_INVALID,	114	'34000' => DB_ERROR_INVALID,
115	'37000' => DB_ERROR_SYNTAX,	115	'37000' => DB_ERROR_SYNTAX,
116	'42000' => DB_ERROR_SYNTAX,	116	'42000' => DB_ERROR_SYNTAX,
117	'42601' => DB_ERROR_SYNTAX,	117	'42601' => DB_ERROR_SYNTAX,
118	'IM001' => DB_ERROR_UNSUPPORTED,	118	'IM001' => DB_ERROR_UNSUPPORTED,
119	'S0000' => DB_ERROR_NOSUCHTABLE,	119	'S0000' => DB_ERROR_NOSUCHTABLE,
120	'S0001' => DB_ERROR_ALREADY_EXISTS,	120	'S0001' => DB_ERROR_ALREADY_EXISTS,
121	'S0002' => DB_ERROR_NOSUCHTABLE,	121	'S0002' => DB_ERROR_NOSUCHTABLE,
122	'S0011' => DB_ERROR_ALREADY_EXISTS,	122	'S0011' => DB_ERROR_ALREADY_EXISTS,
123	'S0012' => DB_ERROR_NOT_FOUND,	123	'S0012' => DB_ERROR_NOT_FOUND,
124	'S0021' => DB_ERROR_ALREADY_EXISTS,	124	'S0021' => DB_ERROR_ALREADY_EXISTS,
125	'S0022' => DB_ERROR_NOSUCHFIELD,	125	'S0022' => DB_ERROR_NOSUCHFIELD,
126	'S1009' => DB_ERROR_INVALID,	126	'S1009' => DB_ERROR_INVALID,
127	'S1090' => DB_ERROR_INVALID,	127	'S1090' => DB_ERROR_INVALID,
128	'S1C00' => DB_ERROR_NOT_CAPABLE,	128	'S1C00' => DB_ERROR_NOT_CAPABLE,
129	);	129	);
130		130
131	/**	131	/**
132	* The raw database connection created by PHP	132	* The raw database connection created by PHP
133	* @var resource	133	* @var resource
134	*/	134	*/
135	var $connection;	135	var $connection;
136		136
137	/**	137	/**
138	* The DSN information for connecting to a database	138	* The DSN information for connecting to a database
139	* @var array	139	* @var array
140	*/	140	*/
141	var $dsn = array();	141	var $dsn = array();
142		142
143		143
144	/**	144	/**
145	* The number of rows affected by a data manipulation query	145	* The number of rows affected by a data manipulation query
146	* @var integer	146	* @var integer
147	* @access private	147	* @access private
148	*/	148	*/
149	var $affected = 0;	149	var $affected = 0;
150		150
151		151
152	// }}}	152	// }}}
153	// {{{ constructor	153	// {{{ constructor
154		154
155	/**	155	/**
156	* This constructor calls <kbd>$this->DB_common()</kbd>	156	* This constructor calls <kbd>$this->DB_common()</kbd>
157	*	157	*
158	* @return void	158	* @return void
159	*/	159	*/
160	function DB_odbc()	160	function DB_odbc()
161	{	161	{
162	$this->DB_common();	162	$this->DB_common();
163	}	163	}
164		164
165	// }}}	165	// }}}
166	// {{{ connect()	166	// {{{ connect()
167		167
168	/**	168	/**
169	* Connect to the database server, log in and open the database	169	* Connect to the database server, log in and open the database
170	*	170	*
171	* Don't call this method directly. Use DB::connect() instead.	171	* Don't call this method directly. Use DB::connect() instead.
172	*	172	*
173	* PEAR DB's odbc driver supports the following extra DSN options:	173	* PEAR DB's odbc driver supports the following extra DSN options:
174	* + cursor The type of cursor to be used for this connection.	174	* + cursor The type of cursor to be used for this connection.
175	*	175	*
176	* @param array $dsn the data source name	176	* @param array $dsn the data source name
177	* @param bool $persistent should the connection be persistent?	177	* @param bool $persistent should the connection be persistent?
178	*	178	*
179	* @return int DB_OK on success. A DB_Error object on failure.	179	* @return int DB_OK on success. A DB_Error object on failure.
180	*/	180	*/
181	function connect($dsn, $persistent = false)	181	function connect($dsn, $persistent = false)
182	{	182	{
183	if (!PEAR::loadExtension('odbc')) {	183	if (!PEAR::loadExtension('odbc')) {
184	return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);	184	return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
185	}	185	}
186		186
187	$this->dsn = $dsn;	187	$this->dsn = $dsn;
188	if ($dsn['dbsyntax']) {	188	if ($dsn['dbsyntax']) {
189	$this->dbsyntax = $dsn['dbsyntax'];	189	$this->dbsyntax = $dsn['dbsyntax'];
190	}	190	}
191	switch ($this->dbsyntax) {	191	switch ($this->dbsyntax) {
192	case 'access':	192	case 'access':
193	case 'db2':	193	case 'db2':
194	case 'solid':	194	case 'solid':
195	$this->features['transactions'] = true;	195	$this->features['transactions'] = true;
196	break;	196	break;
197	case 'navision':	197	case 'navision':
198	$this->features['limit'] = false;	198	$this->features['limit'] = false;
199	}	199	}
200		200
201	/*	201	/*
202	* This is hear for backwards compatibility. Should have been using	202	* This is hear for backwards compatibility. Should have been using
203	* 'database' all along, but prior to 1.6.0RC3 'hostspec' was used.	203	* 'database' all along, but prior to 1.6.0RC3 'hostspec' was used.
204	*/	204	*/
205	if ($dsn['database']) {	205	if ($dsn['database']) {
206	$odbcdsn = $dsn['database'];	206	$odbcdsn = $dsn['database'];
207	} elseif ($dsn['hostspec']) {	207	} elseif ($dsn['hostspec']) {
208	$odbcdsn = $dsn['hostspec'];	208	$odbcdsn = $dsn['hostspec'];
209	} else {	209	} else {
210	$odbcdsn = 'localhost';	210	$odbcdsn = 'localhost';
211	}	211	}
212		212
213	$connect_function = $persistent ? 'odbc_pconnect' : 'odbc_connect';	213	$connect_function = $persistent ? 'odbc_pconnect' : 'odbc_connect';
214		214
215	if (empty($dsn['cursor'])) {	215	if (empty($dsn['cursor'])) {
216	$this->connection = @$connect_function($odbcdsn, $dsn['username'],	216	$this->connection = @$connect_function($odbcdsn, $dsn['username'],
217	$dsn['password']);	217	$dsn['password']);
218	} else {	218	} else {
219	$this->connection = @$connect_function($odbcdsn, $dsn['username'],	219	$this->connection = @$connect_function($odbcdsn, $dsn['username'],
220	$dsn['password'],	220	$dsn['password'],
221	$dsn['cursor']);	221	$dsn['cursor']);
222	}	222	}
223		223
224	if (!is_resource($this->connection)) {	224	if (!is_resource($this->connection)) {
225	return $this->raiseError(DB_ERROR_CONNECT_FAILED,	225	return $this->raiseError(DB_ERROR_CONNECT_FAILED,
226	null, null, null,	226	null, null, null,
227	$this->errorNative());	227	$this->errorNative());
228	}	228	}
229	return DB_OK;	229	return DB_OK;
230	}	230	}
231		231
232	// }}}	232	// }}}
233	// {{{ disconnect()	233	// {{{ disconnect()
234		234
235	/**	235	/**
236	* Disconnects from the database server	236	* Disconnects from the database server
237	*	237	*
238	* @return bool TRUE on success, FALSE on failure	238	* @return bool TRUE on success, FALSE on failure
239	*/	239	*/
240	function disconnect()	240	function disconnect()
241	{	241	{
242	$err = @odbc_close($this->connection);	242	$err = @odbc_close($this->connection);
243	$this->connection = null;	243	$this->connection = null;
244	return $err;	244	return $err;
245	}	245	}
246		246
247	// }}}	247	// }}}
248	// {{{ simpleQuery()	248	// {{{ simpleQuery()
249		249
250	/**	250	/**
251	* Sends a query to the database server	251	* Sends a query to the database server
252	*	252	*
253	* @param string the SQL query string	253	* @param string the SQL query string
254	*	254	*
255	* @return mixed + a PHP result resrouce for successful SELECT queries	255	* @return mixed + a PHP result resrouce for successful SELECT queries
256	* + the DB_OK constant for other successful queries	256	* + the DB_OK constant for other successful queries
257	* + a DB_Error object on failure	257	* + a DB_Error object on failure
258	*/	258	*/
259	function simpleQuery($query)	259	function simpleQuery($query)
260	{	260	{
261	$this->last_query = $query;	261	$this->last_query = $query;
262	$query = $this->modifyQuery($query);	262	$query = $this->modifyQuery($query);
263	$result = @odbc_exec($this->connection, $query);	263	$result = @odbc_exec($this->connection, $query);
264	if (!$result) {	264	if (!$result) {
265	return $this->odbcRaiseError(); // XXX ERRORMSG	265	return $this->odbcRaiseError(); // XXX ERRORMSG
266	}	266	}
267	// Determine which queries that should return data, and which	267	// Determine which queries that should return data, and which
268	// should return an error code only.	268	// should return an error code only.
269	if ($this->_checkManip($query)) {	269	if ($this->_checkManip($query)) {
270	$this->affected = $result; // For affectedRows()	270	$this->affected = $result; // For affectedRows()
271	return DB_OK;	271	return DB_OK;
272	}	272	}
273	$this->affected = 0;	273	$this->affected = 0;
274	return $result;	274	return $result;
275	}	275	}
276		276
277	// }}}	277	// }}}
278	// {{{ nextResult()	278	// {{{ nextResult()
279		279
280	/**	280	/**
281	* Move the internal odbc result pointer to the next available result	281	* Move the internal odbc result pointer to the next available result
282	*	282	*
283	* @param a valid fbsql result resource	283	* @param a valid fbsql result resource
284	*	284	*
285	* @access public	285	* @access public
286	*	286	*
287	* @return true if a result is available otherwise return false	287	* @return true if a result is available otherwise return false
288	*/	288	*/
289	function nextResult($result)	289	function nextResult($result)
290	{	290	{
291	return @odbc_next_result($result);	291	return @odbc_next_result($result);
292	}	292	}
293		293
294	// }}}	294	// }}}
295	// {{{ fetchInto()	295	// {{{ fetchInto()
296		296
297	/**	297	/**
298	* Places a row from the result set into the given array	298	* Places a row from the result set into the given array
299	*	299	*
300	* Formating of the array and the data therein are configurable.	300	* Formating of the array and the data therein are configurable.
301	* See DB_result::fetchInto() for more information.	301	* See DB_result::fetchInto() for more information.
302	*	302	*
303	* This method is not meant to be called directly. Use	303	* This method is not meant to be called directly. Use
304	* DB_result::fetchInto() instead. It can't be declared "protected"	304	* DB_result::fetchInto() instead. It can't be declared "protected"
305	* because DB_result is a separate object.	305	* because DB_result is a separate object.
306	*	306	*
307	* @param resource $result the query result resource	307	* @param resource $result the query result resource
308	* @param array $arr the referenced array to put the data in	308	* @param array $arr the referenced array to put the data in
309	* @param int $fetchmode how the resulting array should be indexed	309	* @param int $fetchmode how the resulting array should be indexed
310	* @param int $rownum the row number to fetch (0 = first row)	310	* @param int $rownum the row number to fetch (0 = first row)
311	*	311	*
312	* @return mixed DB_OK on success, NULL when the end of a result set is	312	* @return mixed DB_OK on success, NULL when the end of a result set is
313	* reached or on failure	313	* reached or on failure
314	*	314	*
315	* @see DB_result::fetchInto()	315	* @see DB_result::fetchInto()
316	*/	316	*/
317	function fetchInto($result, &$arr, $fetchmode, $rownum = null)	317	function fetchInto($result, &$arr, $fetchmode, $rownum = null)
318	{	318	{
319	$arr = array();	319	$arr = array();
320	if ($rownum !== null) {	320	if ($rownum !== null) {
321	$rownum++; // ODBC first row is 1	321	$rownum++; // ODBC first row is 1
322	if (version_compare(phpversion(), '4.2.0', 'ge')) {	322	if (version_compare(phpversion(), '4.2.0', 'ge')) {
323	$cols = @odbc_fetch_into($result, $arr, $rownum);	323	$cols = @odbc_fetch_into($result, $arr, $rownum);
324	} else {	324	} else {
325	$cols = @odbc_fetch_into($result, $rownum, $arr);	325	$cols = @odbc_fetch_into($result, $rownum, $arr);
326	}	326	}
327	} else {	327	} else {
328	$cols = @odbc_fetch_into($result, $arr);	328	$cols = @odbc_fetch_into($result, $arr);
329	}	329	}
330	if (!$cols) {	330	if (!$cols) {
331	return null;	331	return null;
332	}	332	}
333	if ($fetchmode !== DB_FETCHMODE_ORDERED) {	333	if ($fetchmode !== DB_FETCHMODE_ORDERED) {
334	for ($i = 0; $i < count($arr); $i++) {	334	for ($i = 0; $i < count($arr); $i++) {
335	$colName = @odbc_field_name($result, $i+1);	335	$colName = @odbc_field_name($result, $i+1);
336	$a[$colName] = $arr[$i];	336	$a[$colName] = $arr[$i];
337	}	337	}
338	if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) {	338	if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) {
339	$a = array_change_key_case($a, CASE_LOWER);	339	$a = array_change_key_case($a, CASE_LOWER);
340	}	340	}
341	$arr = $a;	341	$arr = $a;
342	}	342	}
343	if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {	343	if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {
344	$this->_rtrimArrayValues($arr);	344	$this->_rtrimArrayValues($arr);
345	}	345	}
346	if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {	346	if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {
347	$this->_convertNullArrayValuesToEmpty($arr);	347	$this->_convertNullArrayValuesToEmpty($arr);
348	}	348	}
349	return DB_OK;	349	return DB_OK;
350	}	350	}
351		351
352	// }}}	352	// }}}
353	// {{{ freeResult()	353	// {{{ freeResult()
354		354
355	/**	355	/**
356	* Deletes the result set and frees the memory occupied by the result set	356	* Deletes the result set and frees the memory occupied by the result set
357	*	357	*
358	* This method is not meant to be called directly. Use	358	* This method is not meant to be called directly. Use
359	* DB_result::free() instead. It can't be declared "protected"	359	* DB_result::free() instead. It can't be declared "protected"
360	* because DB_result is a separate object.	360	* because DB_result is a separate object.
361	*	361	*
362	* @param resource $result PHP's query result resource	362	* @param resource $result PHP's query result resource
363	*	363	*
364	* @return bool TRUE on success, FALSE if $result is invalid	364	* @return bool TRUE on success, FALSE if $result is invalid
365	*	365	*
366	* @see DB_result::free()	366	* @see DB_result::free()
367	*/	367	*/
368	function freeResult($result)	368	function freeResult($result)
369	{	369	{
370	return is_resource($result) ? odbc_free_result($result) : false;	370	return is_resource($result) ? odbc_free_result($result) : false;
371	}	371	}
372		372
373	// }}}	373	// }}}
374	// {{{ numCols()	374	// {{{ numCols()
375		375
376	/**	376	/**
377	* Gets the number of columns in a result set	377	* Gets the number of columns in a result set
378	*	378	*
379	* This method is not meant to be called directly. Use	379	* This method is not meant to be called directly. Use
380	* DB_result::numCols() instead. It can't be declared "protected"	380	* DB_result::numCols() instead. It can't be declared "protected"
381	* because DB_result is a separate object.	381	* because DB_result is a separate object.
382	*	382	*
383	* @param resource $result PHP's query result resource	383	* @param resource $result PHP's query result resource
384	*	384	*
385	* @return int the number of columns. A DB_Error object on failure.	385	* @return int the number of columns. A DB_Error object on failure.
386	*	386	*
387	* @see DB_result::numCols()	387	* @see DB_result::numCols()
388	*/	388	*/
389	function numCols($result)	389	function numCols($result)
390	{	390	{
391	$cols = @odbc_num_fields($result);	391	$cols = @odbc_num_fields($result);
392	if (!$cols) {	392	if (!$cols) {
393	return $this->odbcRaiseError();	393	return $this->odbcRaiseError();
394	}	394	}
395	return $cols;	395	return $cols;
396	}	396	}
397		397
398	// }}}	398	// }}}
399	// {{{ affectedRows()	399	// {{{ affectedRows()
400		400
401	/**	401	/**
402	* Determines the number of rows affected by a data maniuplation query	402	* Determines the number of rows affected by a data maniuplation query
403	*	403	*
404	* 0 is returned for queries that don't manipulate data.	404	* 0 is returned for queries that don't manipulate data.
405	*	405	*
406	* @return int the number of rows. A DB_Error object on failure.	406	* @return int the number of rows. A DB_Error object on failure.
407	*/	407	*/
408	function affectedRows()	408	function affectedRows()
409	{	409	{
410	if (empty($this->affected)) { // In case of SELECT stms	410	if (empty($this->affected)) { // In case of SELECT stms
411	return 0;	411	return 0;
412	}	412	}
413	$nrows = @odbc_num_rows($this->affected);	413	$nrows = @odbc_num_rows($this->affected);
414	if ($nrows == -1) {	414	if ($nrows == -1) {
415	return $this->odbcRaiseError();	415	return $this->odbcRaiseError();
416	}	416	}
417	return $nrows;	417	return $nrows;
418	}	418	}
419		419
420	// }}}	420	// }}}
421	// {{{ numRows()	421	// {{{ numRows()
422		422
423	/**	423	/**
424	* Gets the number of rows in a result set	424	* Gets the number of rows in a result set
425	*	425	*
426	* Not all ODBC drivers support this functionality. If they don't	426	* Not all ODBC drivers support this functionality. If they don't
427	* a DB_Error object for DB_ERROR_UNSUPPORTED is returned.	427	* a DB_Error object for DB_ERROR_UNSUPPORTED is returned.
428	*	428	*
429	* This method is not meant to be called directly. Use	429	* This method is not meant to be called directly. Use
430	* DB_result::numRows() instead. It can't be declared "protected"	430	* DB_result::numRows() instead. It can't be declared "protected"
431	* because DB_result is a separate object.	431	* because DB_result is a separate object.
432	*	432	*
433	* @param resource $result PHP's query result resource	433	* @param resource $result PHP's query result resource
434	*	434	*
435	* @return int the number of rows. A DB_Error object on failure.	435	* @return int the number of rows. A DB_Error object on failure.
436	*	436	*
437	* @see DB_result::numRows()	437	* @see DB_result::numRows()
438	*/	438	*/
439	function numRows($result)	439	function numRows($result)
440	{	440	{
441	$nrows = @odbc_num_rows($result);	441	$nrows = @odbc_num_rows($result);
442	if ($nrows == -1) {	442	if ($nrows == -1) {
443	return $this->odbcRaiseError(DB_ERROR_UNSUPPORTED);	443	return $this->odbcRaiseError(DB_ERROR_UNSUPPORTED);
444	}	444	}
445	if ($nrows === false) {	445	if ($nrows === false) {
446	return $this->odbcRaiseError();	446	return $this->odbcRaiseError();
447	}	447	}
448	return $nrows;	448	return $nrows;
449	}	449	}
450		450
451	// }}}	451	// }}}
452	// {{{ quoteIdentifier()	452	// {{{ quoteIdentifier()
453		453
454	/**	454	/**
455	* Quotes a string so it can be safely used as a table or column name	455	* Quotes a string so it can be safely used as a table or column name
456	*	456	*
457	* Use 'mssql' as the dbsyntax in the DB DSN only if you've unchecked	457	* Use 'mssql' as the dbsyntax in the DB DSN only if you've unchecked
458	* "Use ANSI quoted identifiers" when setting up the ODBC data source.	458	* "Use ANSI quoted identifiers" when setting up the ODBC data source.
459	*	459	*
460	* @param string $str identifier name to be quoted	460	* @param string $str identifier name to be quoted
461	*	461	*
462	* @return string quoted identifier string	462	* @return string quoted identifier string
463	*	463	*
464	* @see DB_common::quoteIdentifier()	464	* @see DB_common::quoteIdentifier()
465	* @since Method available since Release 1.6.0	465	* @since Method available since Release 1.6.0
466	*/	466	*/
467	function quoteIdentifier($str)	467	function quoteIdentifier($str)
468	{	468	{
469	switch ($this->dsn['dbsyntax']) {	469	switch ($this->dsn['dbsyntax']) {
470	case 'access':	470	case 'access':
471	return '[' . $str . ']';	471	return '[' . $str . ']';
472	case 'mssql':	472	case 'mssql':
473	case 'sybase':	473	case 'sybase':
474	return '[' . str_replace(']', ']]', $str) . ']';	474	return '[' . str_replace(']', ']]', $str) . ']';
475	case 'mysql':	475	case 'mysql':
476	case 'mysqli':	476	case 'mysqli':
477	return '`' . $str . '`';	477	return '`' . $str . '`';
478	default:	478	default:
479	return '"' . str_replace('"', '""', $str) . '"';	479	return '"' . str_replace('"', '""', $str) . '"';
480	}	480	}
481	}	481	}
482		482
483	// }}}	483	// }}}
484	// {{{ quote()	484	// {{{ quote()
485		485
486	/**	486	/**
487	* @deprecated Deprecated in release 1.6.0	487	* @deprecated Deprecated in release 1.6.0
488	* @internal	488	* @internal
489	*/	489	*/
490	function quote($str)	490	function quote($str)
491	{	491	{
492	return $this->quoteSmart($str);	492	return $this->quoteSmart($str);
493	}	493	}
494		494
495	// }}}	495	// }}}
496	// {{{ nextId()	496	// {{{ nextId()
497		497
498	/**	498	/**
499	* Returns the next free id in a sequence	499	* Returns the next free id in a sequence
500	*	500	*

Хранилища Subversion ant

(root)/tags/0.1alpha2/odbc.php - Редакция 2 → 3