Subversion Repositories Applications.gtt

Rev

Rev 94 | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 94 Rev 187
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 version 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-2005 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.70 2005/02/20 00:44:48 danielc Exp $
 23 
 * @version    CVS: $Id$
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-2005 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.6
 51 
 * @version    Release: 1.9.2
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 
        '-292'    => DB_ERROR_CONSTRAINT_NOT_NULL,
 105 
        '-292'    => DB_ERROR_CONSTRAINT_NOT_NULL,
105 
        '-310'    => DB_ERROR_ALREADY_EXISTS,
 106 
        '-310'    => DB_ERROR_ALREADY_EXISTS,
106 
        '-316'    => DB_ERROR_ALREADY_EXISTS,
 107 
        '-316'    => DB_ERROR_ALREADY_EXISTS,
107 
        '-319'    => DB_ERROR_NOT_FOUND,
 108 
        '-319'    => DB_ERROR_NOT_FOUND,
108 
        '-329'    => DB_ERROR_NODBSELECTED,
 109 
        '-329'    => DB_ERROR_NODBSELECTED,
109 
        '-346'    => DB_ERROR_CONSTRAINT,
 110 
        '-346'    => DB_ERROR_CONSTRAINT,
110 
        '-386'    => DB_ERROR_CONSTRAINT_NOT_NULL,
 111 
        '-386'    => DB_ERROR_CONSTRAINT_NOT_NULL,
111 
        '-391'    => DB_ERROR_CONSTRAINT_NOT_NULL,
 112 
        '-391'    => DB_ERROR_CONSTRAINT_NOT_NULL,
112 
        '-554'    => DB_ERROR_SYNTAX,
 113 
        '-554'    => DB_ERROR_SYNTAX,
113 
        '-691'    => DB_ERROR_CONSTRAINT,
 114 
        '-691'    => DB_ERROR_CONSTRAINT,
114 
        '-692'    => DB_ERROR_CONSTRAINT,
 115 
        '-692'    => DB_ERROR_CONSTRAINT,
115 
        '-703'    => DB_ERROR_CONSTRAINT_NOT_NULL,
 116 
        '-703'    => DB_ERROR_CONSTRAINT_NOT_NULL,
- 
 
 117 
        '-1202'   => DB_ERROR_DIVZERO,
116 
        '-1204'   => DB_ERROR_INVALID_DATE,
 118 
        '-1204'   => DB_ERROR_INVALID_DATE,
117 
        '-1205'   => DB_ERROR_INVALID_DATE,
 119 
        '-1205'   => DB_ERROR_INVALID_DATE,
118 
        '-1206'   => DB_ERROR_INVALID_DATE,
 120 
        '-1206'   => DB_ERROR_INVALID_DATE,
119 
        '-1209'   => DB_ERROR_INVALID_DATE,
 121 
        '-1209'   => DB_ERROR_INVALID_DATE,
120 
        '-1210'   => DB_ERROR_INVALID_DATE,
 122 
        '-1210'   => DB_ERROR_INVALID_DATE,
121 
        '-1212'   => DB_ERROR_INVALID_DATE,
 123 
        '-1212'   => DB_ERROR_INVALID_DATE,
122 
        '-1213'   => DB_ERROR_INVALID_NUMBER,
 124 
        '-1213'   => DB_ERROR_INVALID_NUMBER,
123 
    );
 125 
    );
124 
 
 126 
 
125 
    /**
 127 
    /**
126 
     * The raw database connection created by PHP
 128 
     * The raw database connection created by PHP
127 
     * @var resource
 129 
     * @var resource
128 
     */
 130 
     */
129 
    var $connection;
 131 
    var $connection;
130 
 
 132 
 
131 
    /**
 133 
    /**
132 
     * The DSN information for connecting to a database
 134 
     * The DSN information for connecting to a database
133 
     * @var array
 135 
     * @var array
134 
     */
 136 
     */
135 
    var $dsn = array();
 137 
    var $dsn = array();
136 
 
 138 
 
137 
 
 139 
 
138 
    /**
 140 
    /**
139 
     * Should data manipulation queries be committed automatically?
 141 
     * Should data manipulation queries be committed automatically?
140 
     * @var bool
 142 
     * @var bool
141 
     * @access private
 143 
     * @access private
142 
     */
 144 
     */
143 
    var $autocommit = true;
 145 
    var $autocommit = true;
144 
 
 146 
 
145 
    /**
 147 
    /**
146 
     * The quantity of transactions begun
 148 
     * The quantity of transactions begun
147 
     *
 149 
     *
148 
     * {@internal  While this is private, it can't actually be designated
 150 
     * {@internal  While this is private, it can't actually be designated
149 
     * 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.}}
150 
     *
 152 
     *
151 
     * @var integer
 153 
     * @var integer
152 
     * @access private
 154 
     * @access private
153 
     */
 155 
     */
154 
    var $transaction_opcount = 0;
 156 
    var $transaction_opcount = 0;
155 
 
 157 
 
156 
    /**
 158 
    /**
157 
     * The number of rows affected by a data manipulation query
 159 
     * The number of rows affected by a data manipulation query
158 
     * @var integer
 160 
     * @var integer
159 
     * @access private
 161 
     * @access private
160 
     */
 162 
     */
161 
    var $affected = 0;
 163 
    var $affected = 0;
162 
 
 164 
 
163 
 
 165 
 
164 
    // }}}
 166 
    // }}}
165 
    // {{{ constructor
 167 
    // {{{ constructor
166 
 
 168 
 
167 
    /**
 169 
    /**
168 
     * This constructor calls <kbd>$this->DB_common()</kbd>
 170 
     * This constructor calls <kbd>parent::__construct()</kbd>
169 
     *
 171 
     *
170 
     * @return void
 172 
     * @return void
171 
     */
 173 
     */
172 
    function DB_ifx()
 174 
    function __construct()
173 
    {
 175 
    {
174 
        $this->DB_common();
 176 
        parent::__construct();
175 
    }
 177 
    }
176 
 
 178 
 
177 
    // }}}
 179 
    // }}}
178 
    // {{{ connect()
 180 
    // {{{ connect()
179 
 
 181 
 
180 
    /**
 182 
    /**
181 
     * Connect to the database server, log in and open the database
 183 
     * Connect to the database server, log in and open the database
182 
     *
 184 
     *
183 
     * Don't call this method directly.  Use DB::connect() instead.
 185 
     * Don't call this method directly.  Use DB::connect() instead.
184 
     *
 186 
     *
185 
     * @param array $dsn         the data source name
 187 
     * @param array $dsn         the data source name
186 
     * @param bool  $persistent  should the connection be persistent?
 188 
     * @param bool  $persistent  should the connection be persistent?
187 
     *
 189 
     *
188 
     * @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.
189 
     */
 191 
     */
190 
    function connect($dsn, $persistent = false)
 192 
    function connect($dsn, $persistent = false)
191 
    {
 193 
    {
192 
        if (!PEAR::loadExtension('informix') &&
 194 
        if (!PEAR::loadExtension('informix') &&
193 
            !PEAR::loadExtension('Informix'))
 195 
            !PEAR::loadExtension('Informix'))
194 
        {
 196 
        {
195 
            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
 197 
            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);
196 
        }
 198 
        }
197 
 
 199 
 
198 
        $this->dsn = $dsn;
 200 
        $this->dsn = $dsn;
199 
        if ($dsn['dbsyntax']) {
 201 
        if ($dsn['dbsyntax']) {
200 
            $this->dbsyntax = $dsn['dbsyntax'];
 202 
            $this->dbsyntax = $dsn['dbsyntax'];
201 
        }
 203 
        }
202 
 
 204 
 
203 
        $dbhost = $dsn['hostspec'] ? '@' . $dsn['hostspec'] : '';
 205 
        $dbhost = $dsn['hostspec'] ? '@' . $dsn['hostspec'] : '';
204 
        $dbname = $dsn['database'] ? $dsn['database'] . $dbhost : '';
 206 
        $dbname = $dsn['database'] ? $dsn['database'] . $dbhost : '';
205 
        $user = $dsn['username'] ? $dsn['username'] : '';
 207 
        $user = $dsn['username'] ? $dsn['username'] : '';
206 
        $pw = $dsn['password'] ? $dsn['password'] : '';
 208 
        $pw = $dsn['password'] ? $dsn['password'] : '';
207 
 
 209 
 
208 
        $connect_function = $persistent ? 'ifx_pconnect' : 'ifx_connect';
 210 
        $connect_function = $persistent ? 'ifx_pconnect' : 'ifx_connect';
209 
 
 211 
 
210 
        $this->connection = @$connect_function($dbname, $user, $pw);
 212 
        $this->connection = @$connect_function($dbname, $user, $pw);
211 
        if (!is_resource($this->connection)) {
 213 
        if (!is_resource($this->connection)) {
212 
            return $this->ifxRaiseError(DB_ERROR_CONNECT_FAILED);
 214 
            return $this->ifxRaiseError(DB_ERROR_CONNECT_FAILED);
213 
        }
 215 
        }
214 
        return DB_OK;
 216 
        return DB_OK;
215 
    }
 217 
    }
216 
 
 218 
 
217 
    // }}}
 219 
    // }}}
218 
    // {{{ disconnect()
 220 
    // {{{ disconnect()
219 
 
 221 
 
220 
    /**
 222 
    /**
221 
     * Disconnects from the database server
 223 
     * Disconnects from the database server
222 
     *
 224 
     *
223 
     * @return bool  TRUE on success, FALSE on failure
 225 
     * @return bool  TRUE on success, FALSE on failure
224 
     */
 226 
     */
225 
    function disconnect()
 227 
    function disconnect()
226 
    {
 228 
    {
227 
        $ret = @ifx_close($this->connection);
 229 
        $ret = @ifx_close($this->connection);
228 
        $this->connection = null;
 230 
        $this->connection = null;
229 
        return $ret;
 231 
        return $ret;
230 
    }
 232 
    }
231 
 
 233 
 
232 
    // }}}
 234 
    // }}}
233 
    // {{{ simpleQuery()
 235 
    // {{{ simpleQuery()
234 
 
 236 
 
235 
    /**
 237 
    /**
236 
     * Sends a query to the database server
 238 
     * Sends a query to the database server
237 
     *
 239 
     *
238 
     * @param string  the SQL query string
 240 
     * @param string  the SQL query string
239 
     *
 241 
     *
240 
     * @return mixed  + a PHP result resrouce for successful SELECT queries
 242 
     * @return mixed  + a PHP result resrouce for successful SELECT queries
241 
     *                + the DB_OK constant for other successful queries
 243 
     *                + the DB_OK constant for other successful queries
242 
     *                + a DB_Error object on failure
 244 
     *                + a DB_Error object on failure
243 
     */
 245 
     */
244 
    function simpleQuery($query)
 246 
    function simpleQuery($query)
245 
    {
 247 
    {
246 
        $ismanip = DB::isManip($query);
 248 
        $ismanip = $this->_checkManip($query);
247 
        $this->last_query = $query;
 249 
        $this->last_query = $query;
248 
        $this->affected   = null;
 250 
        $this->affected   = null;
249 
        if (preg_match('/(SELECT)/i', $query)) {    //TESTME: Use !DB::isManip()?
 251 
        if (preg_match('/(SELECT|EXECUTE)/i', $query)) {    //TESTME: Use !DB::isManip()?
250 
            // the scroll is needed for fetching absolute row numbers
 252 
            // the scroll is needed for fetching absolute row numbers
251 
            // in a select query result
 253 
            // in a select query result
252 
            $result = @ifx_query($query, $this->connection, IFX_SCROLL);
 254 
            $result = @ifx_query($query, $this->connection, IFX_SCROLL);
253 
        } else {
 255 
        } else {
254 
            if (!$this->autocommit && $ismanip) {
 256 
            if (!$this->autocommit && $ismanip) {
255 
                if ($this->transaction_opcount == 0) {
 257 
                if ($this->transaction_opcount == 0) {
256 
                    $result = @ifx_query('BEGIN WORK', $this->connection);
 258 
                    $result = @ifx_query('BEGIN WORK', $this->connection);
257 
                    if (!$result) {
 259 
                    if (!$result) {
258 
                        return $this->ifxRaiseError();
 260 
                        return $this->ifxRaiseError();
259 
                    }
 261 
                    }
260 
                }
 262 
                }
261 
                $this->transaction_opcount++;
 263 
                $this->transaction_opcount++;
262 
            }
 264 
            }
263 
            $result = @ifx_query($query, $this->connection);
 265 
            $result = @ifx_query($query, $this->connection);
264 
        }
 266 
        }
265 
        if (!$result) {
 267 
        if (!$result) {
266 
            return $this->ifxRaiseError();
 268 
            return $this->ifxRaiseError();
267 
        }
 269 
        }
268 
        $this->affected = @ifx_affected_rows($result);
 270 
        $this->affected = @ifx_affected_rows($result);
269 
        // Determine which queries should return data, and which
 271 
        // Determine which queries should return data, and which
270 
        // should return an error code only.
 272 
        // should return an error code only.
271 
        if (preg_match('/(SELECT)/i', $query)) {
 273 
        if (preg_match('/(SELECT|EXECUTE)/i', $query)) {
272 
            return $result;
 274 
            return $result;
273 
        }
 275 
        }
274 
        // XXX Testme: free results inside a transaction
 276 
        // XXX Testme: free results inside a transaction
275 
        // may cause to stop it and commit the work?
 277 
        // may cause to stop it and commit the work?
276 
 
 278 
 
277 
        // Result has to be freed even with a insert or update
 279 
        // Result has to be freed even with a insert or update
278 
        @ifx_free_result($result);
 280 
        @ifx_free_result($result);
279 
 
 281 
 
280 
        return DB_OK;
 282 
        return DB_OK;
281 
    }
 283 
    }
282 
 
 284 
 
283 
    // }}}
 285 
    // }}}
284 
    // {{{ nextResult()
 286 
    // {{{ nextResult()
285 
 
 287 
 
286 
    /**
 288 
    /**
287 
     * Move the internal ifx result pointer to the next available result
 289 
     * Move the internal ifx result pointer to the next available result
288 
     *
 290 
     *
289 
     * @param a valid fbsql result resource
 291 
     * @param a valid fbsql result resource
290 
     *
 292 
     *
291 
     * @access public
 293 
     * @access public
292 
     *
 294 
     *
293 
     * @return true if a result is available otherwise return false
 295 
     * @return true if a result is available otherwise return false
294 
     */
 296 
     */
295 
    function nextResult($result)
 297 
    function nextResult($result)
296 
    {
 298 
    {
297 
        return false;
 299 
        return false;
298 
    }
 300 
    }
299 
 
 301 
 
300 
    // }}}
 302 
    // }}}
301 
    // {{{ affectedRows()
 303 
    // {{{ affectedRows()
302 
 
 304 
 
303 
    /**
 305 
    /**
304 
     * Determines the number of rows affected by a data maniuplation query
 306 
     * Determines the number of rows affected by a data maniuplation query
305 
     *
 307 
     *
306 
     * 0 is returned for queries that don't manipulate data.
 308 
     * 0 is returned for queries that don't manipulate data.
307 
     *
 309 
     *
308 
     * @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.
309 
     */
 311 
     */
310 
    function affectedRows()
 312 
    function affectedRows()
311 
    {
 313 
    {
312 
        if (DB::isManip($this->last_query)) {
 314 
        if ($this->_last_query_manip) {
313 
            return $this->affected;
 315 
            return $this->affected;
314 
        } else {
 316 
        } else {
315 
            return 0;
 317 
            return 0;
316 
        }
 318 
        }
317 
    }
 319 
    }
318 
 
 320 
 
319 
    // }}}
 321 
    // }}}
320 
    // {{{ fetchInto()
 322 
    // {{{ fetchInto()
321 
 
 323 
 
322 
    /**
 324 
    /**
323 
     * Places a row from the result set into the given array
 325 
     * Places a row from the result set into the given array
324 
     *
 326 
     *
325 
     * Formating of the array and the data therein are configurable.
 327 
     * Formating of the array and the data therein are configurable.
326 
     * See DB_result::fetchInto() for more information.
 328 
     * See DB_result::fetchInto() for more information.
327 
     *
 329 
     *
328 
     * This method is not meant to be called directly.  Use
 330 
     * This method is not meant to be called directly.  Use
329 
     * DB_result::fetchInto() instead.  It can't be declared "protected"
 331 
     * DB_result::fetchInto() instead.  It can't be declared "protected"
330 
     * because DB_result is a separate object.
 332 
     * because DB_result is a separate object.
331 
     *
 333 
     *
332 
     * @param resource $result    the query result resource
 334 
     * @param resource $result    the query result resource
333 
     * @param array    $arr       the referenced array to put the data in
 335 
     * @param array    $arr       the referenced array to put the data in
334 
     * @param int      $fetchmode how the resulting array should be indexed
 336 
     * @param int      $fetchmode how the resulting array should be indexed
335 
     * @param int      $rownum    the row number to fetch (0 = first row)
 337 
     * @param int      $rownum    the row number to fetch (0 = first row)
336 
     *
 338 
     *
337 
     * @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
338 
     *                 reached or on failure
 340 
     *                 reached or on failure
339 
     *
 341 
     *
340 
     * @see DB_result::fetchInto()
 342 
     * @see DB_result::fetchInto()
341 
     */
 343 
     */
342 
    function fetchInto($result, &$arr, $fetchmode, $rownum = null)
 344 
    function fetchInto($result, &$arr, $fetchmode, $rownum = null)
343 
    {
 345 
    {
344 
        if (($rownum !== null) && ($rownum < 0)) {
 346 
        if (($rownum !== null) && ($rownum < 0)) {
345 
            return null;
 347 
            return null;
346 
        }
 348 
        }
347 
        if ($rownum === null) {
 349 
        if ($rownum === null) {
348 
            /*
 350 
            /*
349 
             * Even though fetch_row() should return the next row  if
 351 
             * Even though fetch_row() should return the next row  if
350 
             * $rownum is null, it doesn't in all cases.  Bug 598.
 352 
             * $rownum is null, it doesn't in all cases.  Bug 598.
351 
             */
 353 
             */
352 
            $rownum = 'NEXT';
 354 
            $rownum = 'NEXT';
353 
        } else {
 355 
        } else {
354 
            // 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.
355 
            $rownum++;
 357 
            $rownum++;
356 
        }
 358 
        }
357 
        if (!$arr = @ifx_fetch_row($result, $rownum)) {
 359 
        if (!$arr = @ifx_fetch_row($result, $rownum)) {
358 
            return null;
 360 
            return null;
359 
        }
 361 
        }
360 
        if ($fetchmode !== DB_FETCHMODE_ASSOC) {
 362 
        if ($fetchmode !== DB_FETCHMODE_ASSOC) {
361 
            $i=0;
 363 
            $i=0;
362 
            $order = array();
 364 
            $order = array();
363 
            foreach ($arr as $val) {
 365 
            foreach ($arr as $val) {
364 
                $order[$i++] = $val;
 366 
                $order[$i++] = $val;
365 
            }
 367 
            }
366 
            $arr = $order;
 368 
            $arr = $order;
367 
        } elseif ($fetchmode == DB_FETCHMODE_ASSOC &&
 369 
        } elseif ($fetchmode == DB_FETCHMODE_ASSOC &&
368 
                  $this->options['portability'] & DB_PORTABILITY_LOWERCASE)
 370 
                  $this->options['portability'] & DB_PORTABILITY_LOWERCASE)
369 
        {
 371 
        {
370 
            $arr = array_change_key_case($arr, CASE_LOWER);
 372 
            $arr = array_change_key_case($arr, CASE_LOWER);
371 
        }
 373 
        }
372 
        if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {
 374 
        if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {
373 
            $this->_rtrimArrayValues($arr);
 375 
            $this->_rtrimArrayValues($arr);
374 
        }
 376 
        }
375 
        if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {
 377 
        if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {
376 
            $this->_convertNullArrayValuesToEmpty($arr);
 378 
            $this->_convertNullArrayValuesToEmpty($arr);
377 
        }
 379 
        }
378 
        return DB_OK;
 380 
        return DB_OK;
379 
    }
 381 
    }
380 
 
 382 
 
381 
    // }}}
 383 
    // }}}
382 
    // {{{ numCols()
 384 
    // {{{ numCols()
383 
 
 385 
 
384 
    /**
 386 
    /**
385 
     * Gets the number of columns in a result set
 387 
     * Gets the number of columns in a result set
386 
     *
 388 
     *
387 
     * This method is not meant to be called directly.  Use
 389 
     * This method is not meant to be called directly.  Use
388 
     * DB_result::numCols() instead.  It can't be declared "protected"
 390 
     * DB_result::numCols() instead.  It can't be declared "protected"
389 
     * because DB_result is a separate object.
 391 
     * because DB_result is a separate object.
390 
     *
 392 
     *
391 
     * @param resource $result  PHP's query result resource
 393 
     * @param resource $result  PHP's query result resource
392 
     *
 394 
     *
393 
     * @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.
394 
     *
 396 
     *
395 
     * @see DB_result::numCols()
 397 
     * @see DB_result::numCols()
396 
     */
 398 
     */
397 
    function numCols($result)
 399 
    function numCols($result)
398 
    {
 400 
    {
399 
        if (!$cols = @ifx_num_fields($result)) {
 401 
        if (!$cols = @ifx_num_fields($result)) {
400 
            return $this->ifxRaiseError();
 402 
            return $this->ifxRaiseError();
401 
        }
 403 
        }
402 
        return $cols;
 404 
        return $cols;
403 
    }
 405 
    }
404 
 
 406 
 
405 
    // }}}
 407 
    // }}}
406 
    // {{{ freeResult()
 408 
    // {{{ freeResult()
407 
 
 409 
 
408 
    /**
 410 
    /**
409 
     * 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
410 
     *
 412 
     *
411 
     * This method is not meant to be called directly.  Use
 413 
     * This method is not meant to be called directly.  Use
412 
     * DB_result::free() instead.  It can't be declared "protected"
 414 
     * DB_result::free() instead.  It can't be declared "protected"
413 
     * because DB_result is a separate object.
 415 
     * because DB_result is a separate object.
414 
     *
 416 
     *
415 
     * @param resource $result  PHP's query result resource
 417 
     * @param resource $result  PHP's query result resource
416 
     *
 418 
     *
417 
     * @return bool  TRUE on success, FALSE if $result is invalid
 419 
     * @return bool  TRUE on success, FALSE if $result is invalid
418 
     *
 420 
     *
419 
     * @see DB_result::free()
 421 
     * @see DB_result::free()
420 
     */
 422 
     */
421 
    function freeResult($result)
 423 
    function freeResult($result)
422 
    {
 424 
    {
423 
        return @ifx_free_result($result);
 425 
        return is_resource($result) ? ifx_free_result($result) : false;
424 
    }
 426 
    }
425 
 
 427 
 
426 
    // }}}
 428 
    // }}}
427 
    // {{{ autoCommit()
 429 
    // {{{ autoCommit()
428 
 
 430 
 
429 
    /**
 431 
    /**
430 
     * Enables or disables automatic commits
 432 
     * Enables or disables automatic commits
431 
     *
 433 
     *
432 
     * @param bool $onoff  true turns it on, false turns it off
 434 
     * @param bool $onoff  true turns it on, false turns it off
433 
     *
 435 
     *
434 
     * @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
435 
     *               doesn't support auto-committing transactions.
 437 
     *               doesn't support auto-committing transactions.
436 
     */
 438 
     */
437 
    function autoCommit($onoff = true)
 439 
    function autoCommit($onoff = true)
438 
    {
 440 
    {
439 
        // XXX if $this->transaction_opcount > 0, we should probably
 441 
        // XXX if $this->transaction_opcount > 0, we should probably
440 
        // issue a warning here.
 442 
        // issue a warning here.
441 
        $this->autocommit = $onoff ? true : false;
 443 
        $this->autocommit = $onoff ? true : false;
442 
        return DB_OK;
 444 
        return DB_OK;
443 
    }
 445 
    }
444 
 
 446 
 
445 
    // }}}
 447 
    // }}}
446 
    // {{{ commit()
 448 
    // {{{ commit()
447 
 
 449 
 
448 
    /**
 450 
    /**
449 
     * Commits the current transaction
 451 
     * Commits the current transaction
450 
     *
 452 
     *
451 
     * @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.
452 
     */
 454 
     */
453 
    function commit()
 455 
    function commit()
454 
    {
 456 
    {
455 
        if ($this->transaction_opcount > 0) {
 457 
        if ($this->transaction_opcount > 0) {
456 
            $result = @ifx_query('COMMIT WORK', $this->connection);
 458 
            $result = @ifx_query('COMMIT WORK', $this->connection);
457 
            $this->transaction_opcount = 0;
 459 
            $this->transaction_opcount = 0;
458 
            if (!$result) {
 460 
            if (!$result) {
459 
                return $this->ifxRaiseError();
 461 
                return $this->ifxRaiseError();
460 
            }
 462 
            }
461 
        }
 463 
        }
462 
        return DB_OK;
 464 
        return DB_OK;
463 
    }
 465 
    }
464 
 
 466 
 
465 
    // }}}
 467 
    // }}}
466 
    // {{{ rollback()
 468 
    // {{{ rollback()
467 
 
 469 
 
468 
    /**
 470 
    /**
469 
     * Reverts the current transaction
 471 
     * Reverts the current transaction
470 
     *
 472 
     *
471 
     * @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.
472 
     */
 474 
     */
473 
    function rollback()
 475 
    function rollback()
474 
    {
 476 
    {
475 
        if ($this->transaction_opcount > 0) {
 477 
        if ($this->transaction_opcount > 0) {
476 
            $result = @ifx_query('ROLLBACK WORK', $this->connection);
 478 
            $result = @ifx_query('ROLLBACK WORK', $this->connection);
477 
            $this->transaction_opcount = 0;
 479 
            $this->transaction_opcount = 0;
478 
            if (!$result) {
 480 
            if (!$result) {
479 
                return $this->ifxRaiseError();
 481 
                return $this->ifxRaiseError();
480 
            }
 482 
            }
481 
        }
 483 
        }
482 
        return DB_OK;
 484 
        return DB_OK;
483 
    }
 485 
    }
484 
 
 486 
 
485 
    // }}}
 487 
    // }}}
486 
    // {{{ ifxRaiseError()
 488 
    // {{{ ifxRaiseError()
487 
 
 489 
 
488 
    /**
 490 
    /**
489 
     * Produces a DB_Error object regarding the current problem
 491 
     * Produces a DB_Error object regarding the current problem
490 
     *
 492 
     *
491 
     * @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
492 
     *                     DB_ERROR* constant here.  If this isn't passed
 494 
     *                     DB_ERROR* constant here.  If this isn't passed
493 
     *                     the error information gathered from the DBMS.
 495 
     *                     the error information gathered from the DBMS.
494 
     *
 496 
     *
495 
     * @return object  the DB_Error object
 497 
     * @return object  the DB_Error object
496 
     *
 498 
     *
497 
     * @see DB_common::raiseError(),
 499 
     * @see DB_common::raiseError(),
498 
     *      DB_ifx::errorNative(), DB_ifx::errorCode()
 500 
     *      DB_ifx::errorNative(), DB_ifx::errorCode()
499 
     */
 501 
     */
500 
    function ifxRaiseError($errno = null)
 502 
    function ifxRaiseError($errno = null)
501 
    {
 503 
    {
502 
        if ($errno === null) {
 504 
        if ($errno === null) {
503 
            $errno = $this->errorCode(ifx_error());
 505 
            $errno = $this->errorCode(ifx_error());
504 
        }
 506 
        }
505 
        return $this->raiseError($errno, null, null, null,
 507 
        return $this->raiseError($errno, null, null, null,
506 
                                 $this->errorNative());
 508 
                                 $this->errorNative());
507 
    }
 509 
    }
508 
 
 510 
 
509 
    // }}}
 511 
    // }}}
510 
    // {{{ errorNative()
 512 
    // {{{ errorNative()
511 
 
 513 
 
512 
    /**
 514 
    /**
513 
     * Gets the DBMS' native error code and message produced by the last query
 515 
     * Gets the DBMS' native error code and message produced by the last query
514 
     *
 516 
     *
515 
     * @return string  the DBMS' error code and message
 517 
     * @return string  the DBMS' error code and message
516 
     */
 518 
     */
517 
    function errorNative()
 519 
    function errorNative()
518 
    {
 520 
    {
519 
        return @ifx_error() . ' ' . @ifx_errormsg();
 521 
        return @ifx_error() . ' ' . @ifx_errormsg();
520 
    }
 522 
    }
521 
 
 523 
 
522 
    // }}}
 524 
    // }}}
523 
    // {{{ errorCode()
 525 
    // {{{ errorCode()
524 
 
 526 
 
525 
    /**
 527 
    /**
526 
     * Maps native error codes to DB's portable ones.
 528 
     * Maps native error codes to DB's portable ones.
527 
     *
 529 
     *
528 
     * Requires that the DB implementation's constructor fills
 530 
     * Requires that the DB implementation's constructor fills
529 
     * in the <var>$errorcode_map</var> property.
 531 
     * in the <var>$errorcode_map</var> property.
530 
     *
 532 
     *
531 
     * @param  string  $nativecode  error code returned by the database
 533 
     * @param  string  $nativecode  error code returned by the database
532 
     * @return int a portable DB error code, or DB_ERROR if this DB
 534 
     * @return int a portable DB error code, or DB_ERROR if this DB
533 
     * implementation has no mapping for the given error code.
 535 
     * implementation has no mapping for the given error code.
534 
     */
 536 
     */
535 
    function errorCode($nativecode)
 537 
    function errorCode($nativecode)
536 
    {
 538 
    {
537 
        if (ereg('SQLCODE=(.*)]', $nativecode, $match)) {
 539 
        if (preg_match('/SQLCODE=(.*)]/', $nativecode, $match)) {
538 
            $code = $match[1];
 540 
            $code = $match[1];
539 
            if (isset($this->errorcode_map[$code])) {
 541 
            if (isset($this->errorcode_map[$code])) {
540 
                return $this->errorcode_map[$code];
 542 
                return $this->errorcode_map[$code];
541 
            }
 543 
            }
542 
        }
 544 
        }
543 
        return DB_ERROR;
 545 
        return DB_ERROR;
544 
    }
 546 
    }
545 
 
 547 
 
546 
    // }}}
 548 
    // }}}
547 
    // {{{ tableInfo()
 549 
    // {{{ tableInfo()
548 
 
 550 
 
549 
    /**
 551 
    /**
550 
     * Returns information about a table or a result set
 552 
     * Returns information about a table or a result set
551 
     *
 553 
     *
552 
     * NOTE: only supports 'table' if <var>$result</var> is a table name.
 554 
     * NOTE: only supports 'table' if <var>$result</var> is a table name.
553 
     *
 555 
     *
554 
     * If analyzing a query result and the result has duplicate field names,
 556 
     * If analyzing a query result and the result has duplicate field names,
555 
     * an error will be raised saying
 557 
     * an error will be raised saying
556 
     * <samp>can't distinguish duplicate field names</samp>.
 558 
     * <samp>can't distinguish duplicate field names</samp>.
557 
     *
 559 
     *
558 
     * @param object|string  $result  DB_result object from a query or a
 560 
     * @param object|string  $result  DB_result object from a query or a
559 
     *                                 string containing the name of a table.
 561 
     *                                 string containing the name of a table.
560 
     *                                 While this also accepts a query result
 562 
     *                                 While this also accepts a query result
561 
     *                                 resource identifier, this behavior is
 563 
     *                                 resource identifier, this behavior is
562 
     *                                 deprecated.
 564 
     *                                 deprecated.
563 
     * @param int            $mode    a valid tableInfo mode
 565 
     * @param int            $mode    a valid tableInfo mode
564 
     *
 566 
     *
565 
     * @return array  an associative array with the information requested.
 567 
     * @return array  an associative array with the information requested.
566 
     *                 A DB_Error object on failure.
 568 
     *                 A DB_Error object on failure.
567 
     *
 569 
     *
568 
     * @see DB_common::tableInfo()
 570 
     * @see DB_common::tableInfo()
569 
     * @since Method available since Release 1.6.0
 571 
     * @since Method available since Release 1.6.0
570 
     */
 572 
     */
571 
    function tableInfo($result, $mode = null)
 573 
    function tableInfo($result, $mode = null)
572 
    {
 574 
    {
573 
        if (is_string($result)) {
 575 
        if (is_string($result)) {
574 
            /*
 576 
            /*
575 
             * Probably received a table name.
 577 
             * Probably received a table name.
576 
             * Create a result resource identifier.
 578 
             * Create a result resource identifier.
577 
             */
 579 
             */
578 
            $id = @ifx_query("SELECT * FROM $result WHERE 1=0",
 580 
            $id = @ifx_query("SELECT * FROM $result WHERE 1=0",
579 
                             $this->connection);
 581 
                             $this->connection);
580 
            $got_string = true;
 582 
            $got_string = true;
581 
        } elseif (isset($result->result)) {
 583 
        } elseif (isset($result->result)) {
582 
            /*
 584 
            /*
583 
             * Probably received a result object.
 585 
             * Probably received a result object.
584 
             * Extract the result resource identifier.
 586 
             * Extract the result resource identifier.
585 
             */
 587 
             */
586 
            $id = $result->result;
 588 
            $id = $result->result;
587 
            $got_string = false;
 589 
            $got_string = false;
588 
        } else {
 590 
        } else {
589 
            /*
 591 
            /*
590 
             * Probably received a result resource identifier.
 592 
             * Probably received a result resource identifier.
591 
             * Copy it.
 593 
             * Copy it.
592 
             */
 594 
             */
593 
            $id = $result;
 595 
            $id = $result;
594 
            $got_string = false;
 596 
            $got_string = false;
595 
        }
 597 
        }
596 
 
 598 
 
597 
        if (!is_resource($id)) {
 599 
        if (!is_resource($id)) {
598 
            return $this->ifxRaiseError(DB_ERROR_NEED_MORE_DATA);
 600 
            return $this->ifxRaiseError(DB_ERROR_NEED_MORE_DATA);
599 
        }
 601 
        }
600 
 
 602 
 
601 
        $flds = @ifx_fieldproperties($id);
 603 
        $flds = @ifx_fieldproperties($id);
602 
        $count = @ifx_num_fields($id);
 604 
        $count = @ifx_num_fields($id);
603 
 
 605 
 
604 
        if (count($flds) != $count) {
 606 
        if (count($flds) != $count) {
605 
            return $this->raiseError("can't distinguish duplicate field names");
 607 
            return $this->raiseError("can't distinguish duplicate field names");
606 
        }
 608 
        }
607 
 
 609 
 
608 
        if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) {
 610 
        if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE) {
609 
            $case_func = 'strtolower';
 611 
            $case_func = 'strtolower';
610 
        } else {
 612 
        } else {
611 
            $case_func = 'strval';
 613 
            $case_func = 'strval';
612 
        }
 614 
        }
613 
 
 615 
 
614 
        $i   = 0;
 616 
        $i   = 0;
615 
        $res = array();
 617 
        $res = array();
616 
 
 618 
 
617 
        if ($mode) {
 619 
        if ($mode) {
618 
            $res['num_fields'] = $count;
 620 
            $res['num_fields'] = $count;
619 
        }
 621 
        }
620 
 
 622 
 
621 
        foreach ($flds as $key => $value) {
 623 
        foreach ($flds as $key => $value) {
622 
            $props = explode(';', $value);
 624 
            $props = explode(';', $value);
623 
            $res[$i] = array(
 625 
            $res[$i] = array(
624 
                'table' => $got_string ? $case_func($result) : '',
 626 
                'table' => $got_string ? $case_func($result) : '',
625 
                'name'  => $case_func($key),
 627 
                'name'  => $case_func($key),
626 
                'type'  => $props[0],
 628 
                'type'  => $props[0],
627 
                'len'   => $props[1],
 629 
                'len'   => $props[1],
628 
                'flags' => $props[4] == 'N' ? 'not_null' : '',
 630 
                'flags' => $props[4] == 'N' ? 'not_null' : '',
629 
            );
 631 
            );
630 
            if ($mode & DB_TABLEINFO_ORDER) {
 632 
            if ($mode & DB_TABLEINFO_ORDER) {
631 
                $res['order'][$res[$i]['name']] = $i;
 633 
                $res['order'][$res[$i]['name']] = $i;
632 
            }
 634 
            }
633 
            if ($mode & DB_TABLEINFO_ORDERTABLE) {
 635 
            if ($mode & DB_TABLEINFO_ORDERTABLE) {
634 
                $res['ordertable'][$res[$i]['table']][$res[$i]['name']] = $i;
 636 
                $res['ordertable'][$res[$i]['table']][$res[$i]['name']] = $i;
635 
            }
 637 
            }
636 
            $i++;
 638 
            $i++;
637 
        }
 639 
        }
638 
 
 640 
 
639 
        // free the result only if we were called on a table
 641 
        // free the result only if we were called on a table
640 
        if ($got_string) {
 642 
        if ($got_string) {
641 
            @ifx_free_result($id);
 643 
            @ifx_free_result($id);
642 
        }
 644 
        }
643 
        return $res;
 645 
        return $res;
644 
    }
 646 
    }
645 
 
 647 
 
646 
    // }}}
 648 
    // }}}
647 
    // {{{ getSpecialQuery()
 649 
    // {{{ getSpecialQuery()
648 
 
 650 
 
649 
    /**
 651 
    /**
650 
     * Obtains the query string needed for listing a given type of objects
 652 
     * Obtains the query string needed for listing a given type of objects
651 
     *
 653 
     *
652 
     * @param string $type  the kind of objects you want to retrieve
 654 
     * @param string $type  the kind of objects you want to retrieve
653 
     *
 655 
     *
654 
     * @return string  the SQL query string or null if the driver doesn't
 656 
     * @return string  the SQL query string or null if the driver doesn't
655 
     *                  support the object type requested
 657 
     *                  support the object type requested
656 
     *
 658 
     *
657 
     * @access protected
 659 
     * @access protected
658 
     * @see DB_common::getListOf()
 660 
     * @see DB_common::getListOf()
659 
     */
 661 
     */
660 
    function getSpecialQuery($type)
 662 
    function getSpecialQuery($type)
661 
    {
 663 
    {
662 
        switch ($type) {
 664 
        switch ($type) {
663 
            case 'tables':
 665 
            case 'tables':
664 
                return 'SELECT tabname FROM systables WHERE tabid >= 100';
 666 
                return 'SELECT tabname FROM systables WHERE tabid >= 100';
665 
            default:
 667 
            default:
666 
                return null;
 668 
                return null;
667 
        }
 669 
        }
668 
    }
 670 
    }
669 
 
 671 
 
670 
    // }}}
 672 
    // }}}
671 
 
 673 
 
672 
}
 674 
}
673 
 
 675 
 
674 
/*
 676 
/*
675 
 * Local variables:
 677 
 * Local variables:
676 
 * tab-width: 4
 678 
 * tab-width: 4
677 
 * c-basic-offset: 4
 679 
 * c-basic-offset: 4
678 
 * End:
 680 
 * End:
679 
 */
 681 
 */
680 
 
 682 
 
681 
?>
 683 
?>