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


<?php

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

/**
 * The PEAR DB driver for PHP's sybase extension
 * for interacting with Sybase 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     Sterling Hughes <sterling@php.net>
 * @author     Antônio Carlos Venâncio Júnior <floripa@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: sybase.php,v 1.87 2007/09/21 13:40:42 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 sybase extension
 * for interacting with Sybase databases
 *
 * These methods overload the ones declared in DB_common.
 *
 * WARNING:  This driver may fail with multiple connections under the
 * same user/pass/host and different databases.
 *
 * @category   Database
 * @package    DB
 * @author     Sterling Hughes <sterling@php.net>
 * @author     Antônio Carlos Venâncio Júnior <floripa@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_sybase extends DB_common
{
    // {{{ properties

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

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

    /**
     * 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'         => 'emulate',
        'new_link'      => false,
        'numrows'       => true,
        'pconnect'      => true,
        'prepare'       => false,
        'ssl'           => false,
        'transactions'  => true,
    );

    /**
     * A mapping of native error codes to DB error codes
     * @var array
     */
    var $errorcode_map = array(
    );

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

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


    /**
     * Should data manipulation queries be committed automatically?
     * @var bool
     * @access private
     */
    var $autocommit = true;

    /**
     * The quantity of transactions begun
     *
     * {@internal  While this is private, it can't actually be designated
     * private in PHP 5 because it is directly accessed in the test suite.}}
     *
     * @var integer
     * @access private
     */
    var $transaction_opcount = 0;

    /**
     * The database specified in the DSN
     *
     * It's a fix to allow calls to different databases in the same script.
     *
     * @var string
     * @access private
     */
    var $_db = '';


    // }}}
    // {{{ constructor

    /**
     * This constructor calls <kbd>$this->DB_common()</kbd>
     *
     * @return void
     */
    function DB_sybase()
    {
        $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 sybase driver supports the following extra DSN options:
     *   + appname       The application name to use on this connection.
     *                   Available since PEAR DB 1.7.0.
     *   + charset       The character set to use on this connection.
     *                   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('sybase') &&
            !PEAR::loadExtension('sybase_ct'))
        {
            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
        }

        $this->dsn = $dsn;
        if ($dsn['dbsyntax']) {
            $this->dbsyntax = $dsn['dbsyntax'];
        }

        $dsn['hostspec'] = $dsn['hostspec'] ? $dsn['hostspec'] : 'localhost';
        $dsn['password'] = !empty($dsn['password']) ? $dsn['password'] : false;
        $dsn['charset'] = isset($dsn['charset']) ? $dsn['charset'] : false;
        $dsn['appname'] = isset($dsn['appname']) ? $dsn['appname'] : false;

        $connect_function = $persistent ? 'sybase_pconnect' : 'sybase_connect';

        if ($dsn['username']) {
            $this->connection = @$connect_function($dsn['hostspec'],
                                                   $dsn['username'],
                                                   $dsn['password'],
                                                   $dsn['charset'],
                                                   $dsn['appname']);
        } else {
            return $this->raiseError(DB_ERROR_CONNECT_FAILED,
                                     null, null, null,
                                     'The DSN did not contain a username.');
        }

        if (!$this->connection) {
            return $this->raiseError(DB_ERROR_CONNECT_FAILED,
                                     null, null, null,
                                     @sybase_get_last_message());
        }

        if ($dsn['database']) {
            if (!@sybase_select_db($dsn['database'], $this->connection)) {
                return $this->raiseError(DB_ERROR_NODBSELECTED,
                                         null, null, null,
                                         @sybase_get_last_message());
            }
            $this->_db = $dsn['database'];
        }

        return DB_OK;
    }

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

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

    // }}}
    // {{{ simpleQuery()

    /**
     * Sends a query to the database server
     *
     * @param string  the SQL query string
     *
     * @return mixed  + a PHP result resrouce for successful SELECT queries
     *                + the DB_OK constant for other successful queries
     *                + a DB_Error object on failure
     */
    function simpleQuery($query)
    {
        $ismanip = $this->_checkManip($query);
        $this->last_query = $query;
        if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {
            return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);
        }
        $query = $this->modifyQuery($query);
        if (!$this->autocommit && $ismanip) {
            if ($this->transaction_opcount == 0) {
                $result = @sybase_query('BEGIN TRANSACTION', $this->connection);
                if (!$result) {
                    return $this->sybaseRaiseError();
                }
            }
            $this->transaction_opcount++;
        }
        $result = @sybase_query($query, $this->connection);
        if (!$result) {
            return $this->sybaseRaiseError();
        }
        if (is_resource($result)) {
            return $result;
        }
        // Determine which queries that should return data, and which
        // should return an error code only.
        return $ismanip ? DB_OK : $result;
    }

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

    /**
     * Move the internal sybase result pointer to the next available result
     *
     * @param a valid sybase 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) {
            if (!@sybase_data_seek($result, $rownum)) {
                return null;
            }
        }
        if ($fetchmode & DB_FETCHMODE_ASSOC) {
            if (function_exists('sybase_fetch_assoc')) {
                $arr = @sybase_fetch_assoc($result);
            } else {
                if ($arr = @sybase_fetch_array($result)) {
                    foreach ($arr as $key => $value) {
                        if (is_int($key)) {
                            unset($arr[$key]);
                        }
                    }
                }
            }
            if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE && $arr) {
                $arr = array_change_key_case($arr, CASE_LOWER);
            }
        } else {
            $arr = @sybase_fetch_row($result);
        }
        if (!$arr) {
            return null;
        }
        if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {
            $this->_rtrimArrayValues($arr);
        }
        if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {
            $this->_convertNullArrayValuesToEmpty($arr);
        }
        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) ? sybase_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 = @sybase_num_fields($result);
        if (!$cols) {
            return $this->sybaseRaiseError();
        }
        return $cols;
    }

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

    /**
     * Gets the number of rows in a result set
     *
     * This method is not meant to be called directly.  Use
     * DB_result::numRows() instead.  It can't be declared "protected"
     * because DB_result is a separate object.
     *
     * @param resource $result  PHP's query result resource
     *
     * @return int  the number of rows.  A DB_Error object on failure.
     *
     * @see DB_result::numRows()
     */
    function numRows($result)
    {
        $rows = @sybase_num_rows($result);
        if ($rows === false) {
            return $this->sybaseRaiseError();
        }
        return $rows;
    }

    // }}}
    // {{{ 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_query_manip) {
            $result = @sybase_affected_rows($this->connection);
        } else {
            $result = 0;
        }
        return $result;
     }

    // }}}
    // {{{ 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_sybase::createSequence(), DB_sybase::dropSequence()
     */
    function nextId($seq_name, $ondemand = true)
    {
        $seqname = $this->getSequenceName($seq_name);
        if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {
            return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);
        }
        $repeat = 0;
        do {
            $this->pushErrorHandling(PEAR_ERROR_RETURN);
            $result = $this->query("INSERT INTO $seqname (vapor) VALUES (0)");
            $this->popErrorHandling();
            if ($ondemand && DB::isError($result) &&
                ($result->getCode() == DB_ERROR || $result->getCode() == DB_ERROR_NOSUCHTABLE))
            {
                $repeat = 1;
                $result = $this->createSequence($seq_name);
                if (DB::isError($result)) {
                    return $this->raiseError($result);
                }
            } elseif (!DB::isError($result)) {
                $result = $this->query("SELECT @@IDENTITY FROM $seqname");
                $repeat = 0;
            } else {
                $repeat = false;
            }
        } while ($repeat);
        if (DB::isError($result)) {
            return $this->raiseError($result);
        }
        $result = $result->fetchRow(DB_FETCHMODE_ORDERED);
        return $result[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_sybase::nextID(), DB_sybase::dropSequence()
     */
    function createSequence($seq_name)
    {
        return $this->query('CREATE TABLE '
                            . $this->getSequenceName($seq_name)
                            . ' (id numeric(10, 0) IDENTITY NOT NULL,'
                            . ' vapor int NULL)');
    }

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

    // }}}
    // {{{ quoteFloat()

    /**
     * Formats a float value for use within a query in a locale-independent
     * manner.
     *
     * @param float the float value to be quoted.
     * @return string the quoted string.
     * @see DB_common::quoteSmart()
     * @since Method available since release 1.7.8.
     */
    function quoteFloat($float) {
        return $this->escapeSimple(str_replace(',', '.', strval(floatval($float))));
    }
     
    // }}}
    // {{{ autoCommit()

    /**
     * Enables or disables automatic commits
     *
     * @param bool $onoff  true turns it on, false turns it off
     *
     * @return int  DB_OK on success.  A DB_Error object if the driver
     *               doesn't support auto-committing transactions.
     */
    function autoCommit($onoff = false)
    {
        // XXX if $this->transaction_opcount > 0, we should probably
        // issue a warning here.
        $this->autocommit = $onoff ? true : false;
        return DB_OK;
    }

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

    /**
     * Commits the current transaction
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     */
    function commit()
    {
        if ($this->transaction_opcount > 0) {
            if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {
                return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);
            }
            $result = @sybase_query('COMMIT', $this->connection);
            $this->transaction_opcount = 0;
            if (!$result) {
                return $this->sybaseRaiseError();
            }
        }
        return DB_OK;
    }

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

    /**
     * Reverts the current transaction
     *
     * @return int  DB_OK on success.  A DB_Error object on failure.
     */
    function rollback()
    {
        if ($this->transaction_opcount > 0) {
            if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {
                return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);
            }
            $result = @sybase_query('ROLLBACK', $this->connection);
            $this->transaction_opcount = 0;
            if (!$result) {
                return $this->sybaseRaiseError();
            }
        }
        return DB_OK;
    }

    // }}}
    // {{{ sybaseRaiseError()

    /**
     * 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_sybase::errorNative(), DB_sybase::errorCode()
     */
    function sybaseRaiseError($errno = null)
    {
        $native = $this->errorNative();
        if ($errno === null) {
            $errno = $this->errorCode($native);
        }
        return $this->raiseError($errno, null, null, null, $native);
    }

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

    /**
     * Gets the DBMS' native error message produced by the last query
     *
     * @return string  the DBMS' error message
     */
    function errorNative()
    {
        return @sybase_get_last_message();
    }

    // }}}
    // {{{ errorCode()

    /**
     * Determines PEAR::DB error code from the database's text error message.
     *
     * @param  string  $errormsg  error message returned from the database
     * @return integer  an error number from a DB error constant
     */
    function errorCode($errormsg)
    {
        static $error_regexps;
       
        // PHP 5.2+ prepends the function name to $php_errormsg, so we need
        // this hack to work around it, per bug #9599.
        $errormsg = preg_replace('/^sybase[a-z_]+\(\): /', '', $errormsg);
       
        if (!isset($error_regexps)) {
            $error_regexps = array(
                '/Incorrect syntax near/'
                    => DB_ERROR_SYNTAX,
                '/^Unclosed quote before the character string [\"\'].*[\"\']\./'
                    => DB_ERROR_SYNTAX,
                '/Implicit conversion (from datatype|of NUMERIC value)/i'
                    => DB_ERROR_INVALID_NUMBER,
                '/Cannot drop the table [\"\'].+[\"\'], because it doesn\'t exist in the system catalogs\./'
                    => DB_ERROR_NOSUCHTABLE,
                '/Only the owner of object [\"\'].+[\"\'] or a user with System Administrator \(SA\) role can run this command\./'
                    => DB_ERROR_ACCESS_VIOLATION,
                '/^.+ permission denied on object .+, database .+, owner .+/'
                    => DB_ERROR_ACCESS_VIOLATION,
                '/^.* permission denied, database .+, owner .+/'
                    => DB_ERROR_ACCESS_VIOLATION,
                '/[^.*] not found\./'
                    => DB_ERROR_NOSUCHTABLE,
                '/There is already an object named/'
                    => DB_ERROR_ALREADY_EXISTS,
                '/Invalid column name/'
                    => DB_ERROR_NOSUCHFIELD,
                '/does not allow null values/'
                    => DB_ERROR_CONSTRAINT_NOT_NULL,
                '/Command has been aborted/'
                    => DB_ERROR_CONSTRAINT,
                '/^Cannot drop the index .* because it doesn\'t exist/i'
                    => DB_ERROR_NOT_FOUND,
                '/^There is already an index/i'
                    => DB_ERROR_ALREADY_EXISTS,
                '/^There are fewer columns in the INSERT statement than values specified/i'
                    => DB_ERROR_VALUE_COUNT_ON_ROW,
                '/Divide by zero/i'
                    => DB_ERROR_DIVZERO,
            );
        }

        foreach ($error_regexps as $regexp => $code) {
            if (preg_match($regexp, $errormsg)) {
                return $code;
            }
        }
        return DB_ERROR;
    }

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

    /**
     * Returns information about a table or a result set
     *
     * NOTE: only supports 'table' and 'flags' if <var>$result</var>
     * is a table name.
     *
     * @param object|string  $result  DB_result object from a query or a
     *                                 string containing the name of a table.
     *                                 While this also accepts a query result
     *                                 resource identifier, this behavior is
     *                                 deprecated.
     * @param int            $mode    a valid tableInfo mode
     *
     * @return array  an associative array with the information requested.
     *                 A DB_Error object on failure.
     *
     * @see DB_common::tableInfo()
     * @since Method available since Release 1.6.0
     */
    function tableInfo($result, $mode = null)
    {
        if (is_string($result)) {
            /*
             * Probably received a table name.
             * Create a result resource identifier.
             */
            if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {
                return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);
            }
            $id = @sybase_query("SELECT * FROM $result WHERE 1=0",
                                $this->connection);
            $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->sybaseRaiseError(DB_ERROR_NEED_MORE_DATA);
        }

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

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

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

        for ($i = 0; $i < $count; $i++) {
            $f = @sybase_fetch_field($id, $i);
            // column_source is often blank
            $res[$i] = array(
                'table' => $got_string
                           ? $case_func($result)
                           : $case_func($f->column_source),
                'name'  => $case_func($f->name),
                'type'  => $f->type,
                'len'   => $f->max_length,
                'flags' => '',
            );
            if ($res[$i]['table']) {
                $res[$i]['flags'] = $this->_sybase_field_flags(
                        $res[$i]['table'], $res[$i]['name']);
            }
            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) {
            @sybase_free_result($id);
        }
        return $res;
    }

    // }}}
    // {{{ _sybase_field_flags()

    /**
     * Get the flags for a field
     *
     * Currently supports:
     *  + <samp>unique_key</samp>    (unique index, unique check or primary_key)
     *  + <samp>multiple_key</samp>  (multi-key index)
     *
     * @param string  $table   the table name
     * @param string  $column  the field name
     *
     * @return string  space delimited string of flags.  Empty string if none.
     *
     * @access private
     */
    function _sybase_field_flags($table, $column)
    {
        static $tableName = null;
        static $flags = array();

        if ($table != $tableName) {
            $flags = array();
            $tableName = $table;

            /* We're running sp_helpindex directly because it doesn't exist in
             * older versions of ASE -- unfortunately, we can't just use
             * DB::isError() because the user may be using callback error
             * handling. */
            $res = @sybase_query("sp_helpindex $table", $this->connection);

            if ($res === false || $res === true) {
                // Fake a valid response for BC reasons.
                return '';
            }

            while (($val = sybase_fetch_assoc($res)) !== false) {
                if (!isset($val['index_keys'])) {
                    /* No useful information returned. Break and be done with
                     * it, which preserves the pre-1.7.9 behaviour. */
                    break;
                }

                $keys = explode(', ', trim($val['index_keys']));

                if (sizeof($keys) > 1) {
                    foreach ($keys as $key) {
                        $this->_add_flag($flags[$key], 'multiple_key');
                    }
                }

                if (strpos($val['index_description'], 'unique')) {
                    foreach ($keys as $key) {
                        $this->_add_flag($flags[$key], 'unique_key');
                    }
                }
            }

            sybase_free_result($res);

        }

        if (array_key_exists($column, $flags)) {
            return(implode(' ', $flags[$column]));
        }

        return '';
    }

    // }}}
    // {{{ _add_flag()

    /**
     * Adds a string to the flags array if the flag is not yet in there
     * - if there is no flag present the array is created
     *
     * @param array  $array  reference of flags array to add a value to
     * @param mixed  $value  value to add to the flag array
     *
     * @return void
     *
     * @access private
     */
    function _add_flag(&$array, $value)
    {
        if (!is_array($array)) {
            $array = array($value);
        } elseif (!in_array($value, $array)) {
            array_push($array, $value);
        }
    }

    // }}}
    // {{{ 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 name FROM sysobjects WHERE type = 'U'"
                       . ' ORDER BY name';
            case 'views':
                return "SELECT name FROM sysobjects WHERE type = 'V'";
            default:
                return null;
        }
    }

    // }}}

}

/*
 * 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 sybase extension	6	* The PEAR DB driver for PHP's sybase extension
7	* for interacting with Sybase databases	7	* for interacting with Sybase 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 Sterling Hughes <sterling@php.net>	19	* @author Sterling Hughes <sterling@php.net>
20	* @author Antônio Carlos Venâncio Júnior <floripa@php.net>	20	* @author Antônio Carlos Venâncio Júnior <floripa@php.net>
21	* @author Daniel Convissor <danielc@php.net>	21	* @author Daniel Convissor <danielc@php.net>
22	* @copyright 1997-2007 The PHP Group	22	* @copyright 1997-2007 The PHP Group
23	* @license http://www.php.net/license/3_0.txt PHP License 3.0	23	* @license http://www.php.net/license/3_0.txt PHP License 3.0
24	* @version CVS: $Id: sybase.php,v 1.87 2007/09/21 13:40:42 aharvey Exp $	24	* @version CVS: $Id: sybase.php,v 1.87 2007/09/21 13:40:42 aharvey Exp $
25	* @link http://pear.php.net/package/DB	25	* @link http://pear.php.net/package/DB
26	*/	26	*/
27		27
28	/**	28	/**
29	* Obtain the DB_common class so it can be extended from	29	* Obtain the DB_common class so it can be extended from
30	*/	30	*/
31	require_once 'DB/common.php';	31	require_once 'DB/common.php';
32		32
33	/**	33	/**
34	* The methods PEAR DB uses to interact with PHP's sybase extension	34	* The methods PEAR DB uses to interact with PHP's sybase extension
35	* for interacting with Sybase databases	35	* for interacting with Sybase databases
36	*	36	*
37	* These methods overload the ones declared in DB_common.	37	* These methods overload the ones declared in DB_common.
38	*	38	*
39	* WARNING: This driver may fail with multiple connections under the	39	* WARNING: This driver may fail with multiple connections under the
40	* same user/pass/host and different databases.	40	* same user/pass/host and different databases.
41	*	41	*
42	* @category Database	42	* @category Database
43	* @package DB	43	* @package DB
44	* @author Sterling Hughes <sterling@php.net>	44	* @author Sterling Hughes <sterling@php.net>
45	* @author Antônio Carlos Venâncio Júnior <floripa@php.net>	45	* @author Antônio Carlos Venâncio Júnior <floripa@php.net>
46	* @author Daniel Convissor <danielc@php.net>	46	* @author Daniel Convissor <danielc@php.net>
47	* @copyright 1997-2007 The PHP Group	47	* @copyright 1997-2007 The PHP Group
48	* @license http://www.php.net/license/3_0.txt PHP License 3.0	48	* @license http://www.php.net/license/3_0.txt PHP License 3.0
49	* @version Release: 1.7.13	49	* @version Release: 1.7.13
50	* @link http://pear.php.net/package/DB	50	* @link http://pear.php.net/package/DB
51	*/	51	*/
52	class DB_sybase extends DB_common	52	class DB_sybase extends DB_common
53	{	53	{
54	// {{{ properties	54	// {{{ properties
55		55
56	/**	56	/**
57	* The DB driver type (mysql, oci8, odbc, etc.)	57	* The DB driver type (mysql, oci8, odbc, etc.)
58	* @var string	58	* @var string
59	*/	59	*/
60	var $phptype = 'sybase';	60	var $phptype = 'sybase';
61		61
62	/**	62	/**
63	* The database syntax variant to be used (db2, access, etc.), if any	63	* The database syntax variant to be used (db2, access, etc.), if any
64	* @var string	64	* @var string
65	*/	65	*/
66	var $dbsyntax = 'sybase';	66	var $dbsyntax = 'sybase';
67		67
68	/**	68	/**
69	* The capabilities of this DB implementation	69	* The capabilities of this DB implementation
70	*	70	*
71	* The 'new_link' element contains the PHP version that first provided	71	* The 'new_link' element contains the PHP version that first provided
72	* new_link support for this DBMS. Contains false if it's unsupported.	72	* new_link support for this DBMS. Contains false if it's unsupported.
73	*	73	*
74	* Meaning of the 'limit' element:	74	* Meaning of the 'limit' element:
75	* + 'emulate' = emulate with fetch row by number	75	* + 'emulate' = emulate with fetch row by number
76	* + 'alter' = alter the query	76	* + 'alter' = alter the query
77	* + false = skip rows	77	* + false = skip rows
78	*	78	*
79	* @var array	79	* @var array
80	*/	80	*/
81	var $features = array(	81	var $features = array(
82	'limit' => 'emulate',	82	'limit' => 'emulate',
83	'new_link' => false,	83	'new_link' => false,
84	'numrows' => true,	84	'numrows' => true,
85	'pconnect' => true,	85	'pconnect' => true,
86	'prepare' => false,	86	'prepare' => false,
87	'ssl' => false,	87	'ssl' => false,
88	'transactions' => true,	88	'transactions' => true,
89	);	89	);
90		90
91	/**	91	/**
92	* A mapping of native error codes to DB error codes	92	* A mapping of native error codes to DB error codes
93	* @var array	93	* @var array
94	*/	94	*/
95	var $errorcode_map = array(	95	var $errorcode_map = array(
96	);	96	);
97		97
98	/**	98	/**
99	* The raw database connection created by PHP	99	* The raw database connection created by PHP
100	* @var resource	100	* @var resource
101	*/	101	*/
102	var $connection;	102	var $connection;
103		103
104	/**	104	/**
105	* The DSN information for connecting to a database	105	* The DSN information for connecting to a database
106	* @var array	106	* @var array
107	*/	107	*/
108	var $dsn = array();	108	var $dsn = array();
109		109
110		110
111	/**	111	/**
112	* Should data manipulation queries be committed automatically?	112	* Should data manipulation queries be committed automatically?
113	* @var bool	113	* @var bool
114	* @access private	114	* @access private
115	*/	115	*/
116	var $autocommit = true;	116	var $autocommit = true;
117		117
118	/**	118	/**
119	* The quantity of transactions begun	119	* The quantity of transactions begun
120	*	120	*
121	* {@internal While this is private, it can't actually be designated	121	* {@internal While this is private, it can't actually be designated
122	* private in PHP 5 because it is directly accessed in the test suite.}}	122	* private in PHP 5 because it is directly accessed in the test suite.}}
123	*	123	*
124	* @var integer	124	* @var integer
125	* @access private	125	* @access private
126	*/	126	*/
127	var $transaction_opcount = 0;	127	var $transaction_opcount = 0;
128		128
129	/**	129	/**
130	* The database specified in the DSN	130	* The database specified in the DSN
131	*	131	*
132	* It's a fix to allow calls to different databases in the same script.	132	* It's a fix to allow calls to different databases in the same script.
133	*	133	*
134	* @var string	134	* @var string
135	* @access private	135	* @access private
136	*/	136	*/
137	var $_db = '';	137	var $_db = '';
138		138
139		139
140	// }}}	140	// }}}
141	// {{{ constructor	141	// {{{ constructor
142		142
143	/**	143	/**
144	* This constructor calls <kbd>$this->DB_common()</kbd>	144	* This constructor calls <kbd>$this->DB_common()</kbd>
145	*	145	*
146	* @return void	146	* @return void
147	*/	147	*/
148	function DB_sybase()	148	function DB_sybase()
149	{	149	{
150	$this->DB_common();	150	$this->DB_common();
151	}	151	}
152		152
153	// }}}	153	// }}}
154	// {{{ connect()	154	// {{{ connect()
155		155
156	/**	156	/**
157	* Connect to the database server, log in and open the database	157	* Connect to the database server, log in and open the database
158	*	158	*
159	* Don't call this method directly. Use DB::connect() instead.	159	* Don't call this method directly. Use DB::connect() instead.
160	*	160	*
161	* PEAR DB's sybase driver supports the following extra DSN options:	161	* PEAR DB's sybase driver supports the following extra DSN options:
162	* + appname The application name to use on this connection.	162	* + appname The application name to use on this connection.
163	* Available since PEAR DB 1.7.0.	163	* Available since PEAR DB 1.7.0.
164	* + charset The character set to use on this connection.	164	* + charset The character set to use on this connection.
165	* Available since PEAR DB 1.7.0.	165	* Available since PEAR DB 1.7.0.
166	*	166	*
167	* @param array $dsn the data source name	167	* @param array $dsn the data source name
168	* @param bool $persistent should the connection be persistent?	168	* @param bool $persistent should the connection be persistent?
169	*	169	*
170	* @return int DB_OK on success. A DB_Error object on failure.	170	* @return int DB_OK on success. A DB_Error object on failure.
171	*/	171	*/
172	function connect($dsn, $persistent = false)	172	function connect($dsn, $persistent = false)
173	{	173	{
174	if (!PEAR::loadExtension('sybase') &&	174	if (!PEAR::loadExtension('sybase') &&
175	!PEAR::loadExtension('sybase_ct'))	175	!PEAR::loadExtension('sybase_ct'))
176	{	176	{
177	return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);	177	return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
178	}	178	}
179		179
180	$this->dsn = $dsn;	180	$this->dsn = $dsn;
181	if ($dsn['dbsyntax']) {	181	if ($dsn['dbsyntax']) {
182	$this->dbsyntax = $dsn['dbsyntax'];	182	$this->dbsyntax = $dsn['dbsyntax'];
183	}	183	}
184		184
185	$dsn['hostspec'] = $dsn['hostspec'] ? $dsn['hostspec'] : 'localhost';	185	$dsn['hostspec'] = $dsn['hostspec'] ? $dsn['hostspec'] : 'localhost';
186	$dsn['password'] = !empty($dsn['password']) ? $dsn['password'] : false;	186	$dsn['password'] = !empty($dsn['password']) ? $dsn['password'] : false;
187	$dsn['charset'] = isset($dsn['charset']) ? $dsn['charset'] : false;	187	$dsn['charset'] = isset($dsn['charset']) ? $dsn['charset'] : false;
188	$dsn['appname'] = isset($dsn['appname']) ? $dsn['appname'] : false;	188	$dsn['appname'] = isset($dsn['appname']) ? $dsn['appname'] : false;
189		189
190	$connect_function = $persistent ? 'sybase_pconnect' : 'sybase_connect';	190	$connect_function = $persistent ? 'sybase_pconnect' : 'sybase_connect';
191		191
192	if ($dsn['username']) {	192	if ($dsn['username']) {
193	$this->connection = @$connect_function($dsn['hostspec'],	193	$this->connection = @$connect_function($dsn['hostspec'],
194	$dsn['username'],	194	$dsn['username'],
195	$dsn['password'],	195	$dsn['password'],
196	$dsn['charset'],	196	$dsn['charset'],
197	$dsn['appname']);	197	$dsn['appname']);
198	} else {	198	} else {
199	return $this->raiseError(DB_ERROR_CONNECT_FAILED,	199	return $this->raiseError(DB_ERROR_CONNECT_FAILED,
200	null, null, null,	200	null, null, null,
201	'The DSN did not contain a username.');	201	'The DSN did not contain a username.');
202	}	202	}
203		203
204	if (!$this->connection) {	204	if (!$this->connection) {
205	return $this->raiseError(DB_ERROR_CONNECT_FAILED,	205	return $this->raiseError(DB_ERROR_CONNECT_FAILED,
206	null, null, null,	206	null, null, null,
207	@sybase_get_last_message());	207	@sybase_get_last_message());
208	}	208	}
209		209
210	if ($dsn['database']) {	210	if ($dsn['database']) {
211	if (!@sybase_select_db($dsn['database'], $this->connection)) {	211	if (!@sybase_select_db($dsn['database'], $this->connection)) {
212	return $this->raiseError(DB_ERROR_NODBSELECTED,	212	return $this->raiseError(DB_ERROR_NODBSELECTED,
213	null, null, null,	213	null, null, null,
214	@sybase_get_last_message());	214	@sybase_get_last_message());
215	}	215	}
216	$this->_db = $dsn['database'];	216	$this->_db = $dsn['database'];
217	}	217	}
218		218
219	return DB_OK;	219	return DB_OK;
220	}	220	}
221		221
222	// }}}	222	// }}}
223	// {{{ disconnect()	223	// {{{ disconnect()
224		224
225	/**	225	/**
226	* Disconnects from the database server	226	* Disconnects from the database server
227	*	227	*
228	* @return bool TRUE on success, FALSE on failure	228	* @return bool TRUE on success, FALSE on failure
229	*/	229	*/
230	function disconnect()	230	function disconnect()
231	{	231	{
232	$ret = @sybase_close($this->connection);	232	$ret = @sybase_close($this->connection);
233	$this->connection = null;	233	$this->connection = null;
234	return $ret;	234	return $ret;
235	}	235	}
236		236
237	// }}}	237	// }}}
238	// {{{ simpleQuery()	238	// {{{ simpleQuery()
239		239
240	/**	240	/**
241	* Sends a query to the database server	241	* Sends a query to the database server
242	*	242	*
243	* @param string the SQL query string	243	* @param string the SQL query string
244	*	244	*
245	* @return mixed + a PHP result resrouce for successful SELECT queries	245	* @return mixed + a PHP result resrouce for successful SELECT queries
246	* + the DB_OK constant for other successful queries	246	* + the DB_OK constant for other successful queries
247	* + a DB_Error object on failure	247	* + a DB_Error object on failure
248	*/	248	*/
249	function simpleQuery($query)	249	function simpleQuery($query)
250	{	250	{
251	$ismanip = $this->_checkManip($query);	251	$ismanip = $this->_checkManip($query);
252	$this->last_query = $query;	252	$this->last_query = $query;
253	if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {	253	if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {
254	return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);	254	return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);
255	}	255	}
256	$query = $this->modifyQuery($query);	256	$query = $this->modifyQuery($query);
257	if (!$this->autocommit && $ismanip) {	257	if (!$this->autocommit && $ismanip) {
258	if ($this->transaction_opcount == 0) {	258	if ($this->transaction_opcount == 0) {
259	$result = @sybase_query('BEGIN TRANSACTION', $this->connection);	259	$result = @sybase_query('BEGIN TRANSACTION', $this->connection);
260	if (!$result) {	260	if (!$result) {
261	return $this->sybaseRaiseError();	261	return $this->sybaseRaiseError();
262	}	262	}
263	}	263	}
264	$this->transaction_opcount++;	264	$this->transaction_opcount++;
265	}	265	}
266	$result = @sybase_query($query, $this->connection);	266	$result = @sybase_query($query, $this->connection);
267	if (!$result) {	267	if (!$result) {
268	return $this->sybaseRaiseError();	268	return $this->sybaseRaiseError();
269	}	269	}
270	if (is_resource($result)) {	270	if (is_resource($result)) {
271	return $result;	271	return $result;
272	}	272	}
273	// Determine which queries that should return data, and which	273	// Determine which queries that should return data, and which
274	// should return an error code only.	274	// should return an error code only.
275	return $ismanip ? DB_OK : $result;	275	return $ismanip ? DB_OK : $result;
276	}	276	}
277		277
278	// }}}	278	// }}}
279	// {{{ nextResult()	279	// {{{ nextResult()
280		280
281	/**	281	/**
282	* Move the internal sybase result pointer to the next available result	282	* Move the internal sybase result pointer to the next available result
283	*	283	*
284	* @param a valid sybase result resource	284	* @param a valid sybase result resource
285	*	285	*
286	* @access public	286	* @access public
287	*	287	*
288	* @return true if a result is available otherwise return false	288	* @return true if a result is available otherwise return false
289	*/	289	*/
290	function nextResult($result)	290	function nextResult($result)
291	{	291	{
292	return false;	292	return false;
293	}	293	}
294		294
295	// }}}	295	// }}}
296	// {{{ fetchInto()	296	// {{{ fetchInto()
297		297
298	/**	298	/**
299	* Places a row from the result set into the given array	299	* Places a row from the result set into the given array
300	*	300	*
301	* Formating of the array and the data therein are configurable.	301	* Formating of the array and the data therein are configurable.
302	* See DB_result::fetchInto() for more information.	302	* See DB_result::fetchInto() for more information.
303	*	303	*
304	* This method is not meant to be called directly. Use	304	* This method is not meant to be called directly. Use
305	* DB_result::fetchInto() instead. It can't be declared "protected"	305	* DB_result::fetchInto() instead. It can't be declared "protected"
306	* because DB_result is a separate object.	306	* because DB_result is a separate object.
307	*	307	*
308	* @param resource $result the query result resource	308	* @param resource $result the query result resource
309	* @param array $arr the referenced array to put the data in	309	* @param array $arr the referenced array to put the data in
310	* @param int $fetchmode how the resulting array should be indexed	310	* @param int $fetchmode how the resulting array should be indexed
311	* @param int $rownum the row number to fetch (0 = first row)	311	* @param int $rownum the row number to fetch (0 = first row)
312	*	312	*
313	* @return mixed DB_OK on success, NULL when the end of a result set is	313	* @return mixed DB_OK on success, NULL when the end of a result set is
314	* reached or on failure	314	* reached or on failure
315	*	315	*
316	* @see DB_result::fetchInto()	316	* @see DB_result::fetchInto()
317	*/	317	*/
318	function fetchInto($result, &$arr, $fetchmode, $rownum = null)	318	function fetchInto($result, &$arr, $fetchmode, $rownum = null)
319	{	319	{
320	if ($rownum !== null) {	320	if ($rownum !== null) {
321	if (!@sybase_data_seek($result, $rownum)) {	321	if (!@sybase_data_seek($result, $rownum)) {
322	return null;	322	return null;
323	}	323	}
324	}	324	}
325	if ($fetchmode & DB_FETCHMODE_ASSOC) {	325	if ($fetchmode & DB_FETCHMODE_ASSOC) {
326	if (function_exists('sybase_fetch_assoc')) {	326	if (function_exists('sybase_fetch_assoc')) {
327	$arr = @sybase_fetch_assoc($result);	327	$arr = @sybase_fetch_assoc($result);
328	} else {	328	} else {
329	if ($arr = @sybase_fetch_array($result)) {	329	if ($arr = @sybase_fetch_array($result)) {
330	foreach ($arr as $key => $value) {	330	foreach ($arr as $key => $value) {
331	if (is_int($key)) {	331	if (is_int($key)) {
332	unset($arr[$key]);	332	unset($arr[$key]);
333	}	333	}
334	}	334	}
335	}	335	}
336	}	336	}
337	if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE && $arr) {	337	if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE && $arr) {
338	$arr = array_change_key_case($arr, CASE_LOWER);	338	$arr = array_change_key_case($arr, CASE_LOWER);
339	}	339	}
340	} else {	340	} else {
341	$arr = @sybase_fetch_row($result);	341	$arr = @sybase_fetch_row($result);
342	}	342	}
343	if (!$arr) {	343	if (!$arr) {
344	return null;	344	return null;
345	}	345	}
346	if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {	346	if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {
347	$this->_rtrimArrayValues($arr);	347	$this->_rtrimArrayValues($arr);
348	}	348	}
349	if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {	349	if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {
350	$this->_convertNullArrayValuesToEmpty($arr);	350	$this->_convertNullArrayValuesToEmpty($arr);
351	}	351	}
352	return DB_OK;	352	return DB_OK;
353	}	353	}
354		354
355	// }}}	355	// }}}
356	// {{{ freeResult()	356	// {{{ freeResult()
357		357
358	/**	358	/**
359	* Deletes the result set and frees the memory occupied by the result set	359	* Deletes the result set and frees the memory occupied by the result set
360	*	360	*
361	* This method is not meant to be called directly. Use	361	* This method is not meant to be called directly. Use
362	* DB_result::free() instead. It can't be declared "protected"	362	* DB_result::free() instead. It can't be declared "protected"
363	* because DB_result is a separate object.	363	* because DB_result is a separate object.
364	*	364	*
365	* @param resource $result PHP's query result resource	365	* @param resource $result PHP's query result resource
366	*	366	*
367	* @return bool TRUE on success, FALSE if $result is invalid	367	* @return bool TRUE on success, FALSE if $result is invalid
368	*	368	*
369	* @see DB_result::free()	369	* @see DB_result::free()
370	*/	370	*/
371	function freeResult($result)	371	function freeResult($result)
372	{	372	{
373	return is_resource($result) ? sybase_free_result($result) : false;	373	return is_resource($result) ? sybase_free_result($result) : false;
374	}	374	}
375		375
376	// }}}	376	// }}}
377	// {{{ numCols()	377	// {{{ numCols()
378		378
379	/**	379	/**
380	* Gets the number of columns in a result set	380	* Gets the number of columns in a result set
381	*	381	*
382	* This method is not meant to be called directly. Use	382	* This method is not meant to be called directly. Use
383	* DB_result::numCols() instead. It can't be declared "protected"	383	* DB_result::numCols() instead. It can't be declared "protected"
384	* because DB_result is a separate object.	384	* because DB_result is a separate object.
385	*	385	*
386	* @param resource $result PHP's query result resource	386	* @param resource $result PHP's query result resource
387	*	387	*
388	* @return int the number of columns. A DB_Error object on failure.	388	* @return int the number of columns. A DB_Error object on failure.
389	*	389	*
390	* @see DB_result::numCols()	390	* @see DB_result::numCols()
391	*/	391	*/
392	function numCols($result)	392	function numCols($result)
393	{	393	{
394	$cols = @sybase_num_fields($result);	394	$cols = @sybase_num_fields($result);
395	if (!$cols) {	395	if (!$cols) {
396	return $this->sybaseRaiseError();	396	return $this->sybaseRaiseError();
397	}	397	}
398	return $cols;	398	return $cols;
399	}	399	}
400		400
401	// }}}	401	// }}}
402	// {{{ numRows()	402	// {{{ numRows()
403		403
404	/**	404	/**
405	* Gets the number of rows in a result set	405	* Gets the number of rows in a result set
406	*	406	*
407	* This method is not meant to be called directly. Use	407	* This method is not meant to be called directly. Use
408	* DB_result::numRows() instead. It can't be declared "protected"	408	* DB_result::numRows() instead. It can't be declared "protected"
409	* because DB_result is a separate object.	409	* because DB_result is a separate object.
410	*	410	*
411	* @param resource $result PHP's query result resource	411	* @param resource $result PHP's query result resource
412	*	412	*
413	* @return int the number of rows. A DB_Error object on failure.	413	* @return int the number of rows. A DB_Error object on failure.
414	*	414	*
415	* @see DB_result::numRows()	415	* @see DB_result::numRows()
416	*/	416	*/
417	function numRows($result)	417	function numRows($result)
418	{	418	{
419	$rows = @sybase_num_rows($result);	419	$rows = @sybase_num_rows($result);
420	if ($rows === false) {	420	if ($rows === false) {
421	return $this->sybaseRaiseError();	421	return $this->sybaseRaiseError();
422	}	422	}
423	return $rows;	423	return $rows;
424	}	424	}
425		425
426	// }}}	426	// }}}
427	// {{{ affectedRows()	427	// {{{ affectedRows()
428		428
429	/**	429	/**
430	* Determines the number of rows affected by a data maniuplation query	430	* Determines the number of rows affected by a data maniuplation query
431	*	431	*
432	* 0 is returned for queries that don't manipulate data.	432	* 0 is returned for queries that don't manipulate data.
433	*	433	*
434	* @return int the number of rows. A DB_Error object on failure.	434	* @return int the number of rows. A DB_Error object on failure.
435	*/	435	*/
436	function affectedRows()	436	function affectedRows()
437	{	437	{
438	if ($this->_last_query_manip) {	438	if ($this->_last_query_manip) {
439	$result = @sybase_affected_rows($this->connection);	439	$result = @sybase_affected_rows($this->connection);
440	} else {	440	} else {
441	$result = 0;	441	$result = 0;
442	}	442	}
443	return $result;	443	return $result;
444	}	444	}
445		445
446	// }}}	446	// }}}
447	// {{{ nextId()	447	// {{{ nextId()
448		448
449	/**	449	/**
450	* Returns the next free id in a sequence	450	* Returns the next free id in a sequence
451	*	451	*
452	* @param string $seq_name name of the sequence	452	* @param string $seq_name name of the sequence
453	* @param boolean $ondemand when true, the seqence is automatically	453	* @param boolean $ondemand when true, the seqence is automatically
454	* created if it does not exist	454	* created if it does not exist
455	*	455	*
456	* @return int the next id number in the sequence.	456	* @return int the next id number in the sequence.
457	* A DB_Error object on failure.	457	* A DB_Error object on failure.
458	*	458	*
459	* @see DB_common::nextID(), DB_common::getSequenceName(),	459	* @see DB_common::nextID(), DB_common::getSequenceName(),
460	* DB_sybase::createSequence(), DB_sybase::dropSequence()	460	* DB_sybase::createSequence(), DB_sybase::dropSequence()
461	*/	461	*/
462	function nextId($seq_name, $ondemand = true)	462	function nextId($seq_name, $ondemand = true)
463	{	463	{
464	$seqname = $this->getSequenceName($seq_name);	464	$seqname = $this->getSequenceName($seq_name);
465	if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {	465	if ($this->_db && !@sybase_select_db($this->_db, $this->connection)) {
466	return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);	466	return $this->sybaseRaiseError(DB_ERROR_NODBSELECTED);
467	}	467	}
468	$repeat = 0;	468	$repeat = 0;
469	do {	469	do {
470	$this->pushErrorHandling(PEAR_ERROR_RETURN);	470	$this->pushErrorHandling(PEAR_ERROR_RETURN);
471	$result = $this->query("INSERT INTO $seqname (vapor) VALUES (0)");	471	$result = $this->query("INSERT INTO $seqname (vapor) VALUES (0)");
472	$this->popErrorHandling();	472	$this->popErrorHandling();
473	if ($ondemand && DB::isError($result) &&	473	if ($ondemand && DB::isError($result) &&
474	($result->getCode() == DB_ERROR \|\| $result->getCode() == DB_ERROR_NOSUCHTABLE))	474	($result->getCode() == DB_ERROR \|\| $result->getCode() == DB_ERROR_NOSUCHTABLE))
475	{	475	{
476	$repeat = 1;	476	$repeat = 1;
477	$result = $this->createSequence($seq_name);	477	$result = $this->createSequence($seq_name);
478	if (DB::isError($result)) {	478	if (DB::isError($result)) {
479	return $this->raiseError($result);	479	return $this->raiseError($result);
480	}	480	}
481	} elseif (!DB::isError($result)) {	481	} elseif (!DB::isError($result)) {
482	$result = $this->query("SELECT @@IDENTITY FROM $seqname");	482	$result = $this->query("SELECT @@IDENTITY FROM $seqname");
483	$repeat = 0;	483	$repeat = 0;
484	} else {	484	} else {
485	$repeat = false;	485	$repeat = false;
486	}	486	}
487	} while ($repeat);	487	} while ($repeat);
488	if (DB::isError($result)) {	488	if (DB::isError($result)) {
489	return $this->raiseError($result);	489	return $this->raiseError($result);
490	}	490	}
491	$result = $result->fetchRow(DB_FETCHMODE_ORDERED);	491	$result = $result->fetchRow(DB_FETCHMODE_ORDERED);
492	return $result[0];	492	return $result[0];
493	}	493	}
494		494
495	/**	495	/**
496	* Creates a new sequence	496	* Creates a new sequence
497	*	497	*
498	* @param string $seq_name name of the new sequence	498	* @param string $seq_name name of the new sequence
499	*	499	*
500	* @return int DB_OK on success. A DB_Error object on failure.	500	* @return int DB_OK on success. A DB_Error object on failure.

Хранилища Subversion ant

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