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


<?php

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

/**
 * The PEAR DB driver for PHP's ifx extension
 * for interacting with Informix 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     Tomas V.V.Cox <cox@idecnet.com>
 * @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: ifx.php,v 1.75 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 ifx extension
 * for interacting with Informix databases
 *
 * These methods overload the ones declared in DB_common.
 *
 * More info on Informix errors can be found at:
 * http://www.informix.com/answers/english/ierrors.htm
 *
 * TODO:
 *   - set needed env Informix vars on connect
 *   - implement native prepare/execute
 *
 * @category   Database
 * @package    DB
 * @author     Tomas V.V.Cox <cox@idecnet.com>
 * @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_ifx extends DB_common
{
    // {{{ properties

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

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

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

    /**
     * A mapping of native error codes to DB error codes
     * @var array
     */
    var $errorcode_map = array(
        '-201'    => DB_ERROR_SYNTAX,
        '-206'    => DB_ERROR_NOSUCHTABLE,
        '-217'    => DB_ERROR_NOSUCHFIELD,
        '-236'    => DB_ERROR_VALUE_COUNT_ON_ROW,
        '-239'    => DB_ERROR_CONSTRAINT,
        '-253'    => DB_ERROR_SYNTAX,
        '-268'    => DB_ERROR_CONSTRAINT,
        '-292'    => DB_ERROR_CONSTRAINT_NOT_NULL,
        '-310'    => DB_ERROR_ALREADY_EXISTS,
        '-316'    => DB_ERROR_ALREADY_EXISTS,
        '-319'    => DB_ERROR_NOT_FOUND,
        '-329'    => DB_ERROR_NODBSELECTED,
        '-346'    => DB_ERROR_CONSTRAINT,
        '-386'    => DB_ERROR_CONSTRAINT_NOT_NULL,
        '-391'    => DB_ERROR_CONSTRAINT_NOT_NULL,
        '-554'    => DB_ERROR_SYNTAX,
        '-691'    => DB_ERROR_CONSTRAINT,
        '-692'    => DB_ERROR_CONSTRAINT,
        '-703'    => DB_ERROR_CONSTRAINT_NOT_NULL,
        '-1202'   => DB_ERROR_DIVZERO,
        '-1204'   => DB_ERROR_INVALID_DATE,
        '-1205'   => DB_ERROR_INVALID_DATE,
        '-1206'   => DB_ERROR_INVALID_DATE,
        '-1209'   => DB_ERROR_INVALID_DATE,
        '-1210'   => DB_ERROR_INVALID_DATE,
        '-1212'   => DB_ERROR_INVALID_DATE,
        '-1213'   => DB_ERROR_INVALID_NUMBER,
    );

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

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


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

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

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


    // }}}
    // {{{ constructor

    /**
     * This constructor calls <kbd>$this->DB_common()</kbd>
     *
     * @return void
     */
    function DB_ifx()
    {
        $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.
     *
     * @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('informix') &&
            !PEAR::loadExtension('Informix'))
        {
            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
        }

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

        $dbhost = $dsn['hostspec'] ? '@' . $dsn['hostspec'] : '';
        $dbname = $dsn['database'] ? $dsn['database'] . $dbhost : '';
        $user = $dsn['username'] ? $dsn['username'] : '';
        $pw = $dsn['password'] ? $dsn['password'] : '';

        $connect_function = $persistent ? 'ifx_pconnect' : 'ifx_connect';

        $this->connection = @$connect_function($dbname, $user, $pw);
        if (!is_resource($this->connection)) {
            return $this->ifxRaiseError(DB_ERROR_CONNECT_FAILED);
        }
        return DB_OK;
    }

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

    /**
     * Disconnects from the database server
     *
     * @return bool  TRUE on success, FALSE on failure
     */
    function disconnect()
    {
        $ret = @ifx_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;
        $this->affected   = null;
        if (preg_match('/(SELECT|EXECUTE)/i', $query)) {    //TESTME: Use !DB::isManip()?
            // the scroll is needed for fetching absolute row numbers
            // in a select query result
            $result = @ifx_query($query, $this->connection, IFX_SCROLL);
        } else {
            if (!$this->autocommit && $ismanip) {
                if ($this->transaction_opcount == 0) {
                    $result = @ifx_query('BEGIN WORK', $this->connection);
                    if (!$result) {
                        return $this->ifxRaiseError();
                    }
                }
                $this->transaction_opcount++;
            }
            $result = @ifx_query($query, $this->connection);
        }
        if (!$result) {
            return $this->ifxRaiseError();
        }
        $this->affected = @ifx_affected_rows($result);
        // Determine which queries should return data, and which
        // should return an error code only.
        if (preg_match('/(SELECT|EXECUTE)/i', $query)) {
            return $result;
        }
        // XXX Testme: free results inside a transaction
        // may cause to stop it and commit the work?

        // Result has to be freed even with a insert or update
        @ifx_free_result($result);

        return DB_OK;
    }

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

    /**
     * Move the internal ifx result pointer to the next available result
     *
     * @param a valid fbsql result resource
     *
     * @access public
     *
     * @return true if a result is available otherwise return false
     */
    function nextResult($result)
    {
        return false;
    }

    // }}}
    // {{{ 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) {
            return $this->affected;
        } else {
            return 0;
        }
    }

    // }}}
    // {{{ 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) && ($rownum < 0)) {
            return null;
        }
        if ($rownum === null) {
            /*
             * Even though fetch_row() should return the next row  if
             * $rownum is null, it doesn't in all cases.  Bug 598.
             */
            $rownum = 'NEXT';
        } else {
            // Index starts at row 1, unlike most DBMS's starting at 0.
            $rownum++;
        }
        if (!$arr = @ifx_fetch_row($result, $rownum)) {
            return null;
        }
        if ($fetchmode !== DB_FETCHMODE_ASSOC) {
            $i=0;
            $order = array();
            foreach ($arr as $val) {
                $order[$i++] = $val;
            }
            $arr = $order;
        } elseif ($fetchmode == DB_FETCHMODE_ASSOC &&
                  $this->options['portability'] & DB_PORTABILITY_LOWERCASE)
        {
            $arr = array_change_key_case($arr, CASE_LOWER);
        }
        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;
    }

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

    // }}}
    // {{{ 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) ? ifx_free_result($result) : false;
    }

    // }}}
    // {{{ 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 = true)
    {
        // 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) {
            $result = @ifx_query('COMMIT WORK', $this->connection);
            $this->transaction_opcount = 0;
            if (!$result) {
                return $this->ifxRaiseError();
            }
        }
        return DB_OK;
    }

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

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

    // }}}
    // {{{ ifxRaiseError()

    /**
     * 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_ifx::errorNative(), DB_ifx::errorCode()
     */
    function ifxRaiseError($errno = null)
    {
        if ($errno === null) {
            $errno = $this->errorCode(ifx_error());
        }
        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()
    {
        return @ifx_error() . ' ' . @ifx_errormsg();
    }

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

    /**
     * Maps native error codes to DB's portable ones.
     *
     * Requires that the DB implementation's constructor fills
     * in the <var>$errorcode_map</var> property.
     *
     * @param  string  $nativecode  error code returned by the database
     * @return int a portable DB error code, or DB_ERROR if this DB
     * implementation has no mapping for the given error code.
     */
    function errorCode($nativecode)
    {
        if (ereg('SQLCODE=(.*)]', $nativecode, $match)) {
            $code = $match[1];
            if (isset($this->errorcode_map[$code])) {
                return $this->errorcode_map[$code];
            }
        }
        return DB_ERROR;
    }

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

    /**
     * Returns information about a table or a result set
     *
     * NOTE: only supports 'table' if <var>$result</var> is a table name.
     *
     * If analyzing a query result and the result has duplicate field names,
     * an error will be raised saying
     * <samp>can't distinguish duplicate field names</samp>.
     *
     * @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.
             */
            $id = @ifx_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.
             */
            $id = $result;
            $got_string = false;
        }

        if (!is_resource($id)) {
            return $this->ifxRaiseError(DB_ERROR_NEED_MORE_DATA);
        }

        $flds = @ifx_fieldproperties($id);
        $count = @ifx_num_fields($id);

        if (count($flds) != $count) {
            return $this->raiseError("can't distinguish duplicate field names");
        }

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

        $i   = 0;
        $res = array();

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

        foreach ($flds as $key => $value) {
            $props = explode(';', $value);
            $res[$i] = array(
                'table' => $got_string ? $case_func($result) : '',
                'name'  => $case_func($key),
                'type'  => $props[0],
                'len'   => $props[1],
                'flags' => $props[4] == 'N' ? 'not_null' : '',
            );
            if ($mode & DB_TABLEINFO_ORDER) {
                $res['order'][$res[$i]['name']] = $i;
            }
            if ($mode & DB_TABLEINFO_ORDERTABLE) {
                $res['ordertable'][$res[$i]['table']][$res[$i]['name']] = $i;
            }
            $i++;
        }

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

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

    /**
     * Obtains the query string needed for listing a given type of objects
     *
     * @param string $type  the kind of objects you want to retrieve
     *
     * @return string  the SQL query string or null if the driver doesn't
     *                  support the object type requested
     *
     * @access protected
     * @see DB_common::getListOf()
     */
    function getSpecialQuery($type)
    {
        switch ($type) {
            case 'tables':
                return 'SELECT tabname FROM systables WHERE tabid >= 100';
            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 ifx extension	6	* The PEAR DB driver for PHP's ifx extension
7	* for interacting with Informix databases	7	* for interacting with Informix 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 Tomas V.V.Cox <cox@idecnet.com>	19	* @author Tomas V.V.Cox <cox@idecnet.com>
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: ifx.php,v 1.75 2007/07/06 05:19:21 aharvey Exp $	23	* @version CVS: $Id: ifx.php,v 1.75 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 ifx extension	33	* The methods PEAR DB uses to interact with PHP's ifx extension
34	* for interacting with Informix databases	34	* for interacting with Informix databases
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 Informix errors can be found at:	38	* More info on Informix errors can be found at:
39	* http://www.informix.com/answers/english/ierrors.htm	39	* http://www.informix.com/answers/english/ierrors.htm
40	*	40	*
41	* TODO:	41	* TODO:
42	* - set needed env Informix vars on connect	42	* - set needed env Informix vars on connect
43	* - implement native prepare/execute	43	* - implement native prepare/execute
44	*	44	*
45	* @category Database	45	* @category Database
46	* @package DB	46	* @package DB
47	* @author Tomas V.V.Cox <cox@idecnet.com>	47	* @author Tomas V.V.Cox <cox@idecnet.com>
48	* @author Daniel Convissor <danielc@php.net>	48	* @author Daniel Convissor <danielc@php.net>
49	* @copyright 1997-2007 The PHP Group	49	* @copyright 1997-2007 The PHP Group
50	* @license http://www.php.net/license/3_0.txt PHP License 3.0	50	* @license http://www.php.net/license/3_0.txt PHP License 3.0
51	* @version Release: 1.7.13	51	* @version Release: 1.7.13
52	* @link http://pear.php.net/package/DB	52	* @link http://pear.php.net/package/DB
53	*/	53	*/
54	class DB_ifx extends DB_common	54	class DB_ifx extends DB_common
55	{	55	{
56	// {{{ properties	56	// {{{ properties
57		57
58	/**	58	/**
59	* The DB driver type (mysql, oci8, odbc, etc.)	59	* The DB driver type (mysql, oci8, odbc, etc.)
60	* @var string	60	* @var string
61	*/	61	*/
62	var $phptype = 'ifx';	62	var $phptype = 'ifx';
63		63
64	/**	64	/**
65	* The database syntax variant to be used (db2, access, etc.), if any	65	* The database syntax variant to be used (db2, access, etc.), if any
66	* @var string	66	* @var string
67	*/	67	*/
68	var $dbsyntax = 'ifx';	68	var $dbsyntax = 'ifx';
69		69
70	/**	70	/**
71	* The capabilities of this DB implementation	71	* The capabilities of this DB implementation
72	*	72	*
73	* The 'new_link' element contains the PHP version that first provided	73	* The 'new_link' element contains the PHP version that first provided
74	* new_link support for this DBMS. Contains false if it's unsupported.	74	* new_link support for this DBMS. Contains false if it's unsupported.
75	*	75	*
76	* Meaning of the 'limit' element:	76	* Meaning of the 'limit' element:
77	* + 'emulate' = emulate with fetch row by number	77	* + 'emulate' = emulate with fetch row by number
78	* + 'alter' = alter the query	78	* + 'alter' = alter the query
79	* + false = skip rows	79	* + false = skip rows
80	*	80	*
81	* @var array	81	* @var array
82	*/	82	*/
83	var $features = array(	83	var $features = array(
84	'limit' => 'emulate',	84	'limit' => 'emulate',
85	'new_link' => false,	85	'new_link' => false,
86	'numrows' => 'emulate',	86	'numrows' => 'emulate',
87	'pconnect' => true,	87	'pconnect' => true,
88	'prepare' => false,	88	'prepare' => false,
89	'ssl' => false,	89	'ssl' => false,
90	'transactions' => true,	90	'transactions' => true,
91	);	91	);
92		92
93	/**	93	/**
94	* A mapping of native error codes to DB error codes	94	* A mapping of native error codes to DB error codes
95	* @var array	95	* @var array
96	*/	96	*/
97	var $errorcode_map = array(	97	var $errorcode_map = array(
98	'-201' => DB_ERROR_SYNTAX,	98	'-201' => DB_ERROR_SYNTAX,
99	'-206' => DB_ERROR_NOSUCHTABLE,	99	'-206' => DB_ERROR_NOSUCHTABLE,
100	'-217' => DB_ERROR_NOSUCHFIELD,	100	'-217' => DB_ERROR_NOSUCHFIELD,
101	'-236' => DB_ERROR_VALUE_COUNT_ON_ROW,	101	'-236' => DB_ERROR_VALUE_COUNT_ON_ROW,
102	'-239' => DB_ERROR_CONSTRAINT,	102	'-239' => DB_ERROR_CONSTRAINT,
103	'-253' => DB_ERROR_SYNTAX,	103	'-253' => DB_ERROR_SYNTAX,
104	'-268' => DB_ERROR_CONSTRAINT,	104	'-268' => DB_ERROR_CONSTRAINT,
105	'-292' => DB_ERROR_CONSTRAINT_NOT_NULL,	105	'-292' => DB_ERROR_CONSTRAINT_NOT_NULL,
106	'-310' => DB_ERROR_ALREADY_EXISTS,	106	'-310' => DB_ERROR_ALREADY_EXISTS,
107	'-316' => DB_ERROR_ALREADY_EXISTS,	107	'-316' => DB_ERROR_ALREADY_EXISTS,
108	'-319' => DB_ERROR_NOT_FOUND,	108	'-319' => DB_ERROR_NOT_FOUND,
109	'-329' => DB_ERROR_NODBSELECTED,	109	'-329' => DB_ERROR_NODBSELECTED,
110	'-346' => DB_ERROR_CONSTRAINT,	110	'-346' => DB_ERROR_CONSTRAINT,
111	'-386' => DB_ERROR_CONSTRAINT_NOT_NULL,	111	'-386' => DB_ERROR_CONSTRAINT_NOT_NULL,
112	'-391' => DB_ERROR_CONSTRAINT_NOT_NULL,	112	'-391' => DB_ERROR_CONSTRAINT_NOT_NULL,
113	'-554' => DB_ERROR_SYNTAX,	113	'-554' => DB_ERROR_SYNTAX,
114	'-691' => DB_ERROR_CONSTRAINT,	114	'-691' => DB_ERROR_CONSTRAINT,
115	'-692' => DB_ERROR_CONSTRAINT,	115	'-692' => DB_ERROR_CONSTRAINT,
116	'-703' => DB_ERROR_CONSTRAINT_NOT_NULL,	116	'-703' => DB_ERROR_CONSTRAINT_NOT_NULL,
117	'-1202' => DB_ERROR_DIVZERO,	117	'-1202' => DB_ERROR_DIVZERO,
118	'-1204' => DB_ERROR_INVALID_DATE,	118	'-1204' => DB_ERROR_INVALID_DATE,
119	'-1205' => DB_ERROR_INVALID_DATE,	119	'-1205' => DB_ERROR_INVALID_DATE,
120	'-1206' => DB_ERROR_INVALID_DATE,	120	'-1206' => DB_ERROR_INVALID_DATE,
121	'-1209' => DB_ERROR_INVALID_DATE,	121	'-1209' => DB_ERROR_INVALID_DATE,
122	'-1210' => DB_ERROR_INVALID_DATE,	122	'-1210' => DB_ERROR_INVALID_DATE,
123	'-1212' => DB_ERROR_INVALID_DATE,	123	'-1212' => DB_ERROR_INVALID_DATE,
124	'-1213' => DB_ERROR_INVALID_NUMBER,	124	'-1213' => DB_ERROR_INVALID_NUMBER,
125	);	125	);
126		126
127	/**	127	/**
128	* The raw database connection created by PHP	128	* The raw database connection created by PHP
129	* @var resource	129	* @var resource
130	*/	130	*/
131	var $connection;	131	var $connection;
132		132
133	/**	133	/**
134	* The DSN information for connecting to a database	134	* The DSN information for connecting to a database
135	* @var array	135	* @var array
136	*/	136	*/
137	var $dsn = array();	137	var $dsn = array();
138		138
139		139
140	/**	140	/**
141	* Should data manipulation queries be committed automatically?	141	* Should data manipulation queries be committed automatically?
142	* @var bool	142	* @var bool
143	* @access private	143	* @access private
144	*/	144	*/
145	var $autocommit = true;	145	var $autocommit = true;
146		146
147	/**	147	/**
148	* The quantity of transactions begun	148	* The quantity of transactions begun
149	*	149	*
150	* {@internal While this is private, it can't actually be designated	150	* {@internal While this is private, it can't actually be designated
151	* private in PHP 5 because it is directly accessed in the test suite.}}	151	* private in PHP 5 because it is directly accessed in the test suite.}}
152	*	152	*
153	* @var integer	153	* @var integer
154	* @access private	154	* @access private
155	*/	155	*/
156	var $transaction_opcount = 0;	156	var $transaction_opcount = 0;
157		157
158	/**	158	/**
159	* The number of rows affected by a data manipulation query	159	* The number of rows affected by a data manipulation query
160	* @var integer	160	* @var integer
161	* @access private	161	* @access private
162	*/	162	*/
163	var $affected = 0;	163	var $affected = 0;
164		164
165		165
166	// }}}	166	// }}}
167	// {{{ constructor	167	// {{{ constructor
168		168
169	/**	169	/**
170	* This constructor calls <kbd>$this->DB_common()</kbd>	170	* This constructor calls <kbd>$this->DB_common()</kbd>
171	*	171	*
172	* @return void	172	* @return void
173	*/	173	*/
174	function DB_ifx()	174	function DB_ifx()
175	{	175	{
176	$this->DB_common();	176	$this->DB_common();
177	}	177	}
178		178
179	// }}}	179	// }}}
180	// {{{ connect()	180	// {{{ connect()
181		181
182	/**	182	/**
183	* Connect to the database server, log in and open the database	183	* Connect to the database server, log in and open the database
184	*	184	*
185	* Don't call this method directly. Use DB::connect() instead.	185	* Don't call this method directly. Use DB::connect() instead.
186	*	186	*
187	* @param array $dsn the data source name	187	* @param array $dsn the data source name
188	* @param bool $persistent should the connection be persistent?	188	* @param bool $persistent should the connection be persistent?
189	*	189	*
190	* @return int DB_OK on success. A DB_Error object on failure.	190	* @return int DB_OK on success. A DB_Error object on failure.
191	*/	191	*/
192	function connect($dsn, $persistent = false)	192	function connect($dsn, $persistent = false)
193	{	193	{
194	if (!PEAR::loadExtension('informix') &&	194	if (!PEAR::loadExtension('informix') &&
195	!PEAR::loadExtension('Informix'))	195	!PEAR::loadExtension('Informix'))
196	{	196	{
197	return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);	197	return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
198	}	198	}
199		199
200	$this->dsn = $dsn;	200	$this->dsn = $dsn;
201	if ($dsn['dbsyntax']) {	201	if ($dsn['dbsyntax']) {
202	$this->dbsyntax = $dsn['dbsyntax'];	202	$this->dbsyntax = $dsn['dbsyntax'];
203	}	203	}
204		204
205	$dbhost = $dsn['hostspec'] ? '@' . $dsn['hostspec'] : '';	205	$dbhost = $dsn['hostspec'] ? '@' . $dsn['hostspec'] : '';
206	$dbname = $dsn['database'] ? $dsn['database'] . $dbhost : '';	206	$dbname = $dsn['database'] ? $dsn['database'] . $dbhost : '';
207	$user = $dsn['username'] ? $dsn['username'] : '';	207	$user = $dsn['username'] ? $dsn['username'] : '';
208	$pw = $dsn['password'] ? $dsn['password'] : '';	208	$pw = $dsn['password'] ? $dsn['password'] : '';
209		209
210	$connect_function = $persistent ? 'ifx_pconnect' : 'ifx_connect';	210	$connect_function = $persistent ? 'ifx_pconnect' : 'ifx_connect';
211		211
212	$this->connection = @$connect_function($dbname, $user, $pw);	212	$this->connection = @$connect_function($dbname, $user, $pw);
213	if (!is_resource($this->connection)) {	213	if (!is_resource($this->connection)) {
214	return $this->ifxRaiseError(DB_ERROR_CONNECT_FAILED);	214	return $this->ifxRaiseError(DB_ERROR_CONNECT_FAILED);
215	}	215	}
216	return DB_OK;	216	return DB_OK;
217	}	217	}
218		218
219	// }}}	219	// }}}
220	// {{{ disconnect()	220	// {{{ disconnect()
221		221
222	/**	222	/**
223	* Disconnects from the database server	223	* Disconnects from the database server
224	*	224	*
225	* @return bool TRUE on success, FALSE on failure	225	* @return bool TRUE on success, FALSE on failure
226	*/	226	*/
227	function disconnect()	227	function disconnect()
228	{	228	{
229	$ret = @ifx_close($this->connection);	229	$ret = @ifx_close($this->connection);
230	$this->connection = null;	230	$this->connection = null;
231	return $ret;	231	return $ret;
232	}	232	}
233		233
234	// }}}	234	// }}}
235	// {{{ simpleQuery()	235	// {{{ simpleQuery()
236		236
237	/**	237	/**
238	* Sends a query to the database server	238	* Sends a query to the database server
239	*	239	*
240	* @param string the SQL query string	240	* @param string the SQL query string
241	*	241	*
242	* @return mixed + a PHP result resrouce for successful SELECT queries	242	* @return mixed + a PHP result resrouce for successful SELECT queries
243	* + the DB_OK constant for other successful queries	243	* + the DB_OK constant for other successful queries
244	* + a DB_Error object on failure	244	* + a DB_Error object on failure
245	*/	245	*/
246	function simpleQuery($query)	246	function simpleQuery($query)
247	{	247	{
248	$ismanip = $this->_checkManip($query);	248	$ismanip = $this->_checkManip($query);
249	$this->last_query = $query;	249	$this->last_query = $query;
250	$this->affected = null;	250	$this->affected = null;
251	if (preg_match('/(SELECT\|EXECUTE)/i', $query)) { //TESTME: Use !DB::isManip()?	251	if (preg_match('/(SELECT\|EXECUTE)/i', $query)) { //TESTME: Use !DB::isManip()?
252	// the scroll is needed for fetching absolute row numbers	252	// the scroll is needed for fetching absolute row numbers
253	// in a select query result	253	// in a select query result
254	$result = @ifx_query($query, $this->connection, IFX_SCROLL);	254	$result = @ifx_query($query, $this->connection, IFX_SCROLL);
255	} else {	255	} else {
256	if (!$this->autocommit && $ismanip) {	256	if (!$this->autocommit && $ismanip) {
257	if ($this->transaction_opcount == 0) {	257	if ($this->transaction_opcount == 0) {
258	$result = @ifx_query('BEGIN WORK', $this->connection);	258	$result = @ifx_query('BEGIN WORK', $this->connection);
259	if (!$result) {	259	if (!$result) {
260	return $this->ifxRaiseError();	260	return $this->ifxRaiseError();
261	}	261	}
262	}	262	}
263	$this->transaction_opcount++;	263	$this->transaction_opcount++;
264	}	264	}
265	$result = @ifx_query($query, $this->connection);	265	$result = @ifx_query($query, $this->connection);
266	}	266	}
267	if (!$result) {	267	if (!$result) {
268	return $this->ifxRaiseError();	268	return $this->ifxRaiseError();
269	}	269	}
270	$this->affected = @ifx_affected_rows($result);	270	$this->affected = @ifx_affected_rows($result);
271	// Determine which queries should return data, and which	271	// Determine which queries should return data, and which
272	// should return an error code only.	272	// should return an error code only.
273	if (preg_match('/(SELECT\|EXECUTE)/i', $query)) {	273	if (preg_match('/(SELECT\|EXECUTE)/i', $query)) {
274	return $result;	274	return $result;
275	}	275	}
276	// XXX Testme: free results inside a transaction	276	// XXX Testme: free results inside a transaction
277	// may cause to stop it and commit the work?	277	// may cause to stop it and commit the work?
278		278
279	// Result has to be freed even with a insert or update	279	// Result has to be freed even with a insert or update
280	@ifx_free_result($result);	280	@ifx_free_result($result);
281		281
282	return DB_OK;	282	return DB_OK;
283	}	283	}
284		284
285	// }}}	285	// }}}
286	// {{{ nextResult()	286	// {{{ nextResult()
287		287
288	/**	288	/**
289	* Move the internal ifx result pointer to the next available result	289	* Move the internal ifx result pointer to the next available result
290	*	290	*
291	* @param a valid fbsql result resource	291	* @param a valid fbsql result resource
292	*	292	*
293	* @access public	293	* @access public
294	*	294	*
295	* @return true if a result is available otherwise return false	295	* @return true if a result is available otherwise return false
296	*/	296	*/
297	function nextResult($result)	297	function nextResult($result)
298	{	298	{
299	return false;	299	return false;
300	}	300	}
301		301
302	// }}}	302	// }}}
303	// {{{ affectedRows()	303	// {{{ affectedRows()
304		304
305	/**	305	/**
306	* Determines the number of rows affected by a data maniuplation query	306	* Determines the number of rows affected by a data maniuplation query
307	*	307	*
308	* 0 is returned for queries that don't manipulate data.	308	* 0 is returned for queries that don't manipulate data.
309	*	309	*
310	* @return int the number of rows. A DB_Error object on failure.	310	* @return int the number of rows. A DB_Error object on failure.
311	*/	311	*/
312	function affectedRows()	312	function affectedRows()
313	{	313	{
314	if ($this->_last_query_manip) {	314	if ($this->_last_query_manip) {
315	return $this->affected;	315	return $this->affected;
316	} else {	316	} else {
317	return 0;	317	return 0;
318	}	318	}
319	}	319	}
320		320
321	// }}}	321	// }}}
322	// {{{ fetchInto()	322	// {{{ fetchInto()
323		323
324	/**	324	/**
325	* Places a row from the result set into the given array	325	* Places a row from the result set into the given array
326	*	326	*
327	* Formating of the array and the data therein are configurable.	327	* Formating of the array and the data therein are configurable.
328	* See DB_result::fetchInto() for more information.	328	* See DB_result::fetchInto() for more information.
329	*	329	*
330	* This method is not meant to be called directly. Use	330	* This method is not meant to be called directly. Use
331	* DB_result::fetchInto() instead. It can't be declared "protected"	331	* DB_result::fetchInto() instead. It can't be declared "protected"
332	* because DB_result is a separate object.	332	* because DB_result is a separate object.
333	*	333	*
334	* @param resource $result the query result resource	334	* @param resource $result the query result resource
335	* @param array $arr the referenced array to put the data in	335	* @param array $arr the referenced array to put the data in
336	* @param int $fetchmode how the resulting array should be indexed	336	* @param int $fetchmode how the resulting array should be indexed
337	* @param int $rownum the row number to fetch (0 = first row)	337	* @param int $rownum the row number to fetch (0 = first row)
338	*	338	*
339	* @return mixed DB_OK on success, NULL when the end of a result set is	339	* @return mixed DB_OK on success, NULL when the end of a result set is
340	* reached or on failure	340	* reached or on failure
341	*	341	*
342	* @see DB_result::fetchInto()	342	* @see DB_result::fetchInto()
343	*/	343	*/
344	function fetchInto($result, &$arr, $fetchmode, $rownum = null)	344	function fetchInto($result, &$arr, $fetchmode, $rownum = null)
345	{	345	{
346	if (($rownum !== null) && ($rownum < 0)) {	346	if (($rownum !== null) && ($rownum < 0)) {
347	return null;	347	return null;
348	}	348	}
349	if ($rownum === null) {	349	if ($rownum === null) {
350	/*	350	/*
351	* Even though fetch_row() should return the next row if	351	* Even though fetch_row() should return the next row if
352	* $rownum is null, it doesn't in all cases. Bug 598.	352	* $rownum is null, it doesn't in all cases. Bug 598.
353	*/	353	*/
354	$rownum = 'NEXT';	354	$rownum = 'NEXT';
355	} else {	355	} else {
356	// Index starts at row 1, unlike most DBMS's starting at 0.	356	// Index starts at row 1, unlike most DBMS's starting at 0.
357	$rownum++;	357	$rownum++;
358	}	358	}
359	if (!$arr = @ifx_fetch_row($result, $rownum)) {	359	if (!$arr = @ifx_fetch_row($result, $rownum)) {
360	return null;	360	return null;
361	}	361	}
362	if ($fetchmode !== DB_FETCHMODE_ASSOC) {	362	if ($fetchmode !== DB_FETCHMODE_ASSOC) {
363	$i=0;	363	$i=0;
364	$order = array();	364	$order = array();
365	foreach ($arr as $val) {	365	foreach ($arr as $val) {
366	$order[$i++] = $val;	366	$order[$i++] = $val;
367	}	367	}
368	$arr = $order;	368	$arr = $order;
369	} elseif ($fetchmode == DB_FETCHMODE_ASSOC &&	369	} elseif ($fetchmode == DB_FETCHMODE_ASSOC &&
370	$this->options['portability'] & DB_PORTABILITY_LOWERCASE)	370	$this->options['portability'] & DB_PORTABILITY_LOWERCASE)
371	{	371	{
372	$arr = array_change_key_case($arr, CASE_LOWER);	372	$arr = array_change_key_case($arr, CASE_LOWER);
373	}	373	}
374	if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {	374	if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {
375	$this->_rtrimArrayValues($arr);	375	$this->_rtrimArrayValues($arr);
376	}	376	}
377	if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {	377	if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {
378	$this->_convertNullArrayValuesToEmpty($arr);	378	$this->_convertNullArrayValuesToEmpty($arr);
379	}	379	}
380	return DB_OK;	380	return DB_OK;
381	}	381	}
382		382
383	// }}}	383	// }}}
384	// {{{ numCols()	384	// {{{ numCols()
385		385
386	/**	386	/**
387	* Gets the number of columns in a result set	387	* Gets the number of columns in a result set
388	*	388	*
389	* This method is not meant to be called directly. Use	389	* This method is not meant to be called directly. Use
390	* DB_result::numCols() instead. It can't be declared "protected"	390	* DB_result::numCols() instead. It can't be declared "protected"
391	* because DB_result is a separate object.	391	* because DB_result is a separate object.
392	*	392	*
393	* @param resource $result PHP's query result resource	393	* @param resource $result PHP's query result resource
394	*	394	*
395	* @return int the number of columns. A DB_Error object on failure.	395	* @return int the number of columns. A DB_Error object on failure.
396	*	396	*
397	* @see DB_result::numCols()	397	* @see DB_result::numCols()
398	*/	398	*/
399	function numCols($result)	399	function numCols($result)
400	{	400	{
401	if (!$cols = @ifx_num_fields($result)) {	401	if (!$cols = @ifx_num_fields($result)) {
402	return $this->ifxRaiseError();	402	return $this->ifxRaiseError();
403	}	403	}
404	return $cols;	404	return $cols;
405	}	405	}
406		406
407	// }}}	407	// }}}
408	// {{{ freeResult()	408	// {{{ freeResult()
409		409
410	/**	410	/**
411	* Deletes the result set and frees the memory occupied by the result set	411	* Deletes the result set and frees the memory occupied by the result set
412	*	412	*
413	* This method is not meant to be called directly. Use	413	* This method is not meant to be called directly. Use
414	* DB_result::free() instead. It can't be declared "protected"	414	* DB_result::free() instead. It can't be declared "protected"
415	* because DB_result is a separate object.	415	* because DB_result is a separate object.
416	*	416	*
417	* @param resource $result PHP's query result resource	417	* @param resource $result PHP's query result resource
418	*	418	*
419	* @return bool TRUE on success, FALSE if $result is invalid	419	* @return bool TRUE on success, FALSE if $result is invalid
420	*	420	*
421	* @see DB_result::free()	421	* @see DB_result::free()
422	*/	422	*/
423	function freeResult($result)	423	function freeResult($result)
424	{	424	{
425	return is_resource($result) ? ifx_free_result($result) : false;	425	return is_resource($result) ? ifx_free_result($result) : false;
426	}	426	}
427		427
428	// }}}	428	// }}}
429	// {{{ autoCommit()	429	// {{{ autoCommit()
430		430
431	/**	431	/**
432	* Enables or disables automatic commits	432	* Enables or disables automatic commits
433	*	433	*
434	* @param bool $onoff true turns it on, false turns it off	434	* @param bool $onoff true turns it on, false turns it off
435	*	435	*
436	* @return int DB_OK on success. A DB_Error object if the driver	436	* @return int DB_OK on success. A DB_Error object if the driver
437	* doesn't support auto-committing transactions.	437	* doesn't support auto-committing transactions.
438	*/	438	*/
439	function autoCommit($onoff = true)	439	function autoCommit($onoff = true)
440	{	440	{
441	// XXX if $this->transaction_opcount > 0, we should probably	441	// XXX if $this->transaction_opcount > 0, we should probably
442	// issue a warning here.	442	// issue a warning here.
443	$this->autocommit = $onoff ? true : false;	443	$this->autocommit = $onoff ? true : false;
444	return DB_OK;	444	return DB_OK;
445	}	445	}
446		446
447	// }}}	447	// }}}
448	// {{{ commit()	448	// {{{ commit()
449		449
450	/**	450	/**
451	* Commits the current transaction	451	* Commits the current transaction
452	*	452	*
453	* @return int DB_OK on success. A DB_Error object on failure.	453	* @return int DB_OK on success. A DB_Error object on failure.
454	*/	454	*/
455	function commit()	455	function commit()
456	{	456	{
457	if ($this->transaction_opcount > 0) {	457	if ($this->transaction_opcount > 0) {
458	$result = @ifx_query('COMMIT WORK', $this->connection);	458	$result = @ifx_query('COMMIT WORK', $this->connection);
459	$this->transaction_opcount = 0;	459	$this->transaction_opcount = 0;
460	if (!$result) {	460	if (!$result) {
461	return $this->ifxRaiseError();	461	return $this->ifxRaiseError();
462	}	462	}
463	}	463	}
464	return DB_OK;	464	return DB_OK;
465	}	465	}
466		466
467	// }}}	467	// }}}
468	// {{{ rollback()	468	// {{{ rollback()
469		469
470	/**	470	/**
471	* Reverts the current transaction	471	* Reverts the current transaction
472	*	472	*
473	* @return int DB_OK on success. A DB_Error object on failure.	473	* @return int DB_OK on success. A DB_Error object on failure.
474	*/	474	*/
475	function rollback()	475	function rollback()
476	{	476	{
477	if ($this->transaction_opcount > 0) {	477	if ($this->transaction_opcount > 0) {
478	$result = @ifx_query('ROLLBACK WORK', $this->connection);	478	$result = @ifx_query('ROLLBACK WORK', $this->connection);
479	$this->transaction_opcount = 0;	479	$this->transaction_opcount = 0;
480	if (!$result) {	480	if (!$result) {
481	return $this->ifxRaiseError();	481	return $this->ifxRaiseError();
482	}	482	}
483	}	483	}
484	return DB_OK;	484	return DB_OK;
485	}	485	}
486		486
487	// }}}	487	// }}}
488	// {{{ ifxRaiseError()	488	// {{{ ifxRaiseError()
489		489
490	/**	490	/**
491	* Produces a DB_Error object regarding the current problem	491	* Produces a DB_Error object regarding the current problem
492	*	492	*
493	* @param int $errno if the error is being manually raised pass a	493	* @param int $errno if the error is being manually raised pass a
494	* DB_ERROR* constant here. If this isn't passed	494	* DB_ERROR* constant here. If this isn't passed
495	* the error information gathered from the DBMS.	495	* the error information gathered from the DBMS.
496	*	496	*
497	* @return object the DB_Error object	497	* @return object the DB_Error object
498	*	498	*
499	* @see DB_common::raiseError(),	499	* @see DB_common::raiseError(),
500	* DB_ifx::errorNative(), DB_ifx::errorCode()	500	* DB_ifx::errorNative(), DB_ifx::errorCode()

Хранилища Subversion ant

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