← Back to branch summary

~azzar1/unity/add-show-desktop-key

« back to all changes in this revision

Viewing changes to www/php/phpBB3/includes/db/firebird.php

  • Committer: dcoles
  • Date: 2008-02-13 04:10:55 UTC
  • Revision ID: svn-v3-trunk0:2b9c9e99-6f39-0410-b283-7f802c844ae2:trunk:443
Added Forum application along with unmodifed version of phpBB3 "Olympus" 3.0.0

Show diffs side-by-side

added added

removed removed

Lines of Context:
www/php/phpBB3/includes/db/firebird.php
 
1
<?php
 
2
/**
 
3
*
 
4
* @package dbal
 
5
* @version $Id: firebird.php,v 1.57 2007/10/05 14:36:32 acydburn Exp $
 
6
* @copyright (c) 2005 phpBB Group
 
7
* @license http://opensource.org/licenses/gpl-license.php GNU Public License
 
8
*
 
9
*/
 
10
 
 
11
/**
 
12
* @ignore
 
13
*/
 
14
if (!defined('IN_PHPBB'))
 
15
{
 
16
        exit;
 
17
}
 
18
 
 
19
include_once($phpbb_root_path . 'includes/db/dbal.' . $phpEx);
 
20
 
 
21
/**
 
22
* Firebird/Interbase Database Abstraction Layer
 
23
* Minimum Requirement is Firebird 2.0
 
24
* @package dbal
 
25
*/
 
26
class dbal_firebird extends dbal
 
27
{
 
28
        var $last_query_text = '';
 
29
        var $service_handle = false;
 
30
        var $affected_rows = 0;
 
31
 
 
32
        /**
 
33
        * Connect to server
 
34
        */
 
35
        function sql_connect($sqlserver, $sqluser, $sqlpassword, $database, $port = false, $persistency = false, $new_link = false)
 
36
        {
 
37
                $this->persistency = $persistency;
 
38
                $this->user = $sqluser;
 
39
                $this->server = $sqlserver . (($port) ? ':' . $port : '');
 
40
                $this->dbname = $database;
 
41
 
 
42
                $this->db_connect_id = ($this->persistency) ? @ibase_pconnect($this->server . ':' . $this->dbname, $this->user, $sqlpassword, false, false, 3) : @ibase_connect($this->server . ':' . $this->dbname, $this->user, $sqlpassword, false, false, 3);
 
43
 
 
44
                $this->service_handle = (function_exists('ibase_service_attach')) ? @ibase_service_attach($this->server, $this->user, $sqlpassword) : false;
 
45
 
 
46
                return ($this->db_connect_id) ? $this->db_connect_id : $this->sql_error('');
 
47
        }
 
48
 
 
49
        /**
 
50
        * Version information about used database
 
51
        */
 
52
        function sql_server_info()
 
53
        {
 
54
                if ($this->service_handle !== false && function_exists('ibase_server_info'))
 
55
                {
 
56
                        return @ibase_server_info($this->service_handle, IBASE_SVC_SERVER_VERSION);
 
57
                }
 
58
 
 
59
                return 'Firebird/Interbase';
 
60
        }
 
61
 
 
62
        /**
 
63
        * SQL Transaction
 
64
        * @access private
 
65
        */
 
66
        function _sql_transaction($status = 'begin')
 
67
        {
 
68
                switch ($status)
 
69
                {
 
70
                        case 'begin':
 
71
                                return true;
 
72
                        break;
 
73
 
 
74
                        case 'commit':
 
75
                                return @ibase_commit();
 
76
                        break;
 
77
 
 
78
                        case 'rollback':
 
79
                                return @ibase_rollback();
 
80
                        break;
 
81
                }
 
82
 
 
83
                return true;
 
84
        }
 
85
 
 
86
        /**
 
87
        * Base query method
 
88
        *
 
89
        * @param        string  $query          Contains the SQL query which shall be executed
 
90
        * @param        int             $cache_ttl      Either 0 to avoid caching or the time in seconds which the result shall be kept in cache
 
91
        * @return       mixed                           When casted to bool the returned value returns true on success and false on failure
 
92
        *
 
93
        * @access       public
 
94
        */
 
95
        function sql_query($query = '', $cache_ttl = 0)
 
96
        {
 
97
                if ($query != '')
 
98
                {
 
99
                        global $cache;
 
100
 
 
101
                        // EXPLAIN only in extra debug mode
 
102
                        if (defined('DEBUG_EXTRA'))
 
103
                        {
 
104
                                $this->sql_report('start', $query);
 
105
                        }
 
106
 
 
107
                        $this->last_query_text = $query;
 
108
                        $this->query_result = ($cache_ttl && method_exists($cache, 'sql_load')) ? $cache->sql_load($query) : false;
 
109
                        $this->sql_add_num_queries($this->query_result);
 
110
 
 
111
                        if ($this->query_result === false)
 
112
                        {
 
113
                                $array = array();
 
114
                                // We overcome Firebird's 32767 char limit by binding vars
 
115
                                if (strlen($query) > 32767)
 
116
                                {
 
117
                                        if (preg_match('/^(INSERT INTO[^(]++)\\(([^()]+)\\) VALUES[^(]++\\((.*?)\\)$/s', $query, $regs))
 
118
                                        {
 
119
                                                if (strlen($regs[3]) > 32767)
 
120
                                                {
 
121
                                                        preg_match_all('/\'(?:[^\']++|\'\')*+\'|[\d-.]+/', $regs[3], $vals, PREG_PATTERN_ORDER);
 
122
 
 
123
                                                        $inserts = $vals[0];
 
124
                                                        unset($vals);
 
125
 
 
126
                                                        foreach ($inserts as $key => $value)
 
127
                                                        {
 
128
                                                                if (!empty($value) && $value[0] === "'" && strlen($value) > 32769) // check to see if this thing is greater than the max + 'x2
 
129
                                                                {
 
130
                                                                        $inserts[$key] = '?';
 
131
                                                                        $array[] = str_replace("''", "'", substr($value, 1, -1));
 
132
                                                                }
 
133
                                                        }
 
134
 
 
135
                                                        $query = $regs[1] . '(' . $regs[2] . ') VALUES (' . implode(', ', $inserts) . ')';
 
136
                                                }
 
137
                                        }
 
138
                                        else if (preg_match('/^(UPDATE ([\\w_]++)\\s+SET )([\\w_]++\\s*=\\s*(?:\'(?:[^\']++|\'\')*+\'|\\d+)(?:,\\s*[\\w_]++\\s*=\\s*(?:\'(?:[^\']++|\'\')*+\'|[\d-.]+))*+)\\s+(WHERE.*)$/s', $query, $data))
 
139
                                        {
 
140
                                                if (strlen($data[3]) > 32767)
 
141
                                                {
 
142
                                                        $update = $data[1];
 
143
                                                        $where = $data[4];
 
144
                                                        preg_match_all('/(\\w++)\\s*=\\s*(\'(?:[^\']++|\'\')*+\'|[\d-.]++)/', $data[3], $temp, PREG_SET_ORDER);
 
145
                                                        unset($data);
 
146
 
 
147
                                                        $cols = array();
 
148
                                                        foreach ($temp as $value)
 
149
                                                        {
 
150
                                                                if (!empty($value[2]) && $value[2][0] === "'" && strlen($value[2]) > 32769) // check to see if this thing is greater than the max + 'x2
 
151
                                                                {
 
152
                                                                        $array[] = str_replace("''", "'", substr($value[2], 1, -1));
 
153
                                                                        $cols[] = $value[1] . '=?';
 
154
                                                                }
 
155
                                                                else
 
156
                                                                {
 
157
                                                                        $cols[] = $value[1] . '=' . $value[2];
 
158
                                                                }
 
159
                                                        }
 
160
 
 
161
                                                        $query = $update . implode(', ', $cols) . ' ' . $where;
 
162
                                                        unset($cols);
 
163
                                                }
 
164
                                        }
 
165
                                }
 
166
 
 
167
                                if (!function_exists('ibase_affected_rows') && (preg_match('/^UPDATE ([\w_]++)\s+SET [\w_]++\s*=\s*(?:\'(?:[^\']++|\'\')*+\'|[\d-.]+)(?:,\s*[\w_]++\s*=\s*(?:\'(?:[^\']++|\'\')*+\'|[\d-.]+))*+\s+(WHERE.*)?$/s', $query, $regs) || preg_match('/^DELETE FROM ([\w_]++)\s*(WHERE\s*.*)?$/s', $query, $regs)))
 
168
                                {
 
169
                                        $affected_sql = 'SELECT COUNT(*) as num_rows_affected FROM ' . $regs[1];
 
170
                                        if (!empty($regs[2]))
 
171
                                        {
 
172
                                                $affected_sql .= ' ' . $regs[2];
 
173
                                        }
 
174
 
 
175
                                        if (!($temp_q_id = @ibase_query($this->db_connect_id, $affected_sql)))
 
176
                                        {
 
177
                                                return false;
 
178
                                        }
 
179
 
 
180
                                        $temp_result = @ibase_fetch_assoc($temp_q_id);
 
181
                                        @ibase_free_result($temp_q_id);
 
182
 
 
183
                                        $this->affected_rows = ($temp_result) ? $temp_result['NUM_ROWS_AFFECTED'] : false;
 
184
                                }
 
185
 
 
186
                                if (sizeof($array))
 
187
                                {
 
188
                                        $p_query = @ibase_prepare($this->db_connect_id, $query);
 
189
                                        array_unshift($array, $p_query);
 
190
                                        $this->query_result = call_user_func_array('ibase_execute', $array);
 
191
                                        unset($array);
 
192
 
 
193
                                        if ($this->query_result === false)
 
194
                                        {
 
195
                                                $this->sql_error($query);
 
196
                                        }
 
197
                                }
 
198
                                else if (($this->query_result = @ibase_query($this->db_connect_id, $query)) === false)
 
199
                                {
 
200
                                        $this->sql_error($query);
 
201
                                }
 
202
 
 
203
                                if (defined('DEBUG_EXTRA'))
 
204
                                {
 
205
                                        $this->sql_report('stop', $query);
 
206
                                }
 
207
 
 
208
                                if (!$this->transaction)
 
209
                                {
 
210
                                        if (function_exists('ibase_commit_ret'))
 
211
                                        {
 
212
                                                @ibase_commit_ret();
 
213
                                        }
 
214
                                        else
 
215
                                        {
 
216
                                                // way cooler than ibase_commit_ret :D
 
217
                                                @ibase_query('COMMIT RETAIN;');
 
218
                                        }
 
219
                                }
 
220
 
 
221
                                if ($cache_ttl && method_exists($cache, 'sql_save'))
 
222
                                {
 
223
                                        $this->open_queries[(int) $this->query_result] = $this->query_result;
 
224
                                        $cache->sql_save($query, $this->query_result, $cache_ttl);
 
225
                                }
 
226
                                else if (strpos($query, 'SELECT') === 0 && $this->query_result)
 
227
                                {
 
228
                                        $this->open_queries[(int) $this->query_result] = $this->query_result;
 
229
                                }
 
230
                        }
 
231
                        else if (defined('DEBUG_EXTRA'))
 
232
                        {
 
233
                                $this->sql_report('fromcache', $query);
 
234
                        }
 
235
                }
 
236
                else
 
237
                {
 
238
                        return false;
 
239
                }
 
240
 
 
241
                return ($this->query_result) ? $this->query_result : false;
 
242
        }
 
243
 
 
244
        /**
 
245
        * Build LIMIT query
 
246
        */
 
247
        function _sql_query_limit($query, $total, $offset = 0, $cache_ttl = 0)
 
248
        {
 
249
                $this->query_result = false;
 
250
 
 
251
                $query = 'SELECT FIRST ' . $total . ((!empty($offset)) ? ' SKIP ' . $offset : '') . substr($query, 6);
 
252
 
 
253
                return $this->sql_query($query, $cache_ttl);
 
254
        }
 
255
 
 
256
        /**
 
257
        * Return number of affected rows
 
258
        */
 
259
        function sql_affectedrows()
 
260
        {
 
261
                // PHP 5+ function
 
262
                if (function_exists('ibase_affected_rows'))
 
263
                {
 
264
                        return ($this->db_connect_id) ? @ibase_affected_rows($this->db_connect_id) : false;
 
265
                }
 
266
                else
 
267
                {
 
268
                        return $this->affected_rows;
 
269
                }
 
270
        }
 
271
 
 
272
        /**
 
273
        * Fetch current row
 
274
        */
 
275
        function sql_fetchrow($query_id = false)
 
276
        {
 
277
                global $cache;
 
278
 
 
279
                if ($query_id === false)
 
280
                {
 
281
                        $query_id = $this->query_result;
 
282
                }
 
283
 
 
284
                if (isset($cache->sql_rowset[$query_id]))
 
285
                {
 
286
                        return $cache->sql_fetchrow($query_id);
 
287
                }
 
288
 
 
289
                if ($query_id === false)
 
290
                {
 
291
                        return false;
 
292
                }
 
293
 
 
294
                $row = array();
 
295
                $cur_row = @ibase_fetch_object($query_id, IBASE_TEXT);
 
296
 
 
297
                if (!$cur_row)
 
298
                {
 
299
                        return false;
 
300
                }
 
301
 
 
302
                foreach (get_object_vars($cur_row) as $key => $value)
 
303
                {
 
304
                        $row[strtolower($key)] = (is_string($value)) ? trim(str_replace(array("\\0", "\\n"), array("\0", "\n"), $value)) : $value;
 
305
                }
 
306
 
 
307
                return (sizeof($row)) ? $row : false;
 
308
        }
 
309
 
 
310
        /**
 
311
        * Seek to given row number
 
312
        * rownum is zero-based
 
313
        */
 
314
        function sql_rowseek($rownum, &$query_id)
 
315
        {
 
316
                global $cache;
 
317
 
 
318
                if ($query_id === false)
 
319
                {
 
320
                        $query_id = $this->query_result;
 
321
                }
 
322
 
 
323
                if (isset($cache->sql_rowset[$query_id]))
 
324
                {
 
325
                        return $cache->sql_rowseek($rownum, $query_id);
 
326
                }
 
327
 
 
328
                if ($query_id === false)
 
329
                {
 
330
                        return;
 
331
                }
 
332
 
 
333
                $this->sql_freeresult($query_id);
 
334
                $query_id = $this->sql_query($this->last_query_text);
 
335
 
 
336
                if ($query_id === false)
 
337
                {
 
338
                        return false;
 
339
                }
 
340
 
 
341
                // We do not fetch the row for rownum == 0 because then the next resultset would be the second row
 
342
                for ($i = 0; $i < $rownum; $i++)
 
343
                {
 
344
                        if (!$this->sql_fetchrow($query_id))
 
345
                        {
 
346
                                return false;
 
347
                        }
 
348
                }
 
349
 
 
350
                return true;
 
351
        }
 
352
 
 
353
        /**
 
354
        * Get last inserted id after insert statement
 
355
        */
 
356
        function sql_nextid()
 
357
        {
 
358
                $query_id = $this->query_result;
 
359
 
 
360
                if ($query_id !== false && $this->last_query_text != '')
 
361
                {
 
362
                        if ($this->query_result && preg_match('#^INSERT[\t\n ]+INTO[\t\n ]+([a-z0-9\_\-]+)#i', $this->last_query_text, $tablename))
 
363
                        {
 
364
                                $sql = 'SELECT GEN_ID(' . $tablename[1] . '_gen, 0) AS new_id FROM RDB$DATABASE';
 
365
 
 
366
                                if (!($temp_q_id = @ibase_query($this->db_connect_id, $sql)))
 
367
                                {
 
368
                                        return false;
 
369
                                }
 
370
 
 
371
                                $temp_result = @ibase_fetch_assoc($temp_q_id);
 
372
                                @ibase_free_result($temp_q_id);
 
373
 
 
374
                                return ($temp_result) ? $temp_result['NEW_ID'] : false;
 
375
                        }
 
376
                }
 
377
 
 
378
                return false;
 
379
        }
 
380
 
 
381
        /**
 
382
        * Free sql result
 
383
        */
 
384
        function sql_freeresult($query_id = false)
 
385
        {
 
386
                global $cache;
 
387
 
 
388
                if ($query_id === false)
 
389
                {
 
390
                        $query_id = $this->query_result;
 
391
                }
 
392
 
 
393
                if (isset($cache->sql_rowset[$query_id]))
 
394
                {
 
395
                        return $cache->sql_freeresult($query_id);
 
396
                }
 
397
 
 
398
                if (isset($this->open_queries[(int) $query_id]))
 
399
                {
 
400
                        unset($this->open_queries[(int) $query_id]);
 
401
                        return @ibase_free_result($query_id);
 
402
                }
 
403
 
 
404
                return false;
 
405
        }
 
406
 
 
407
        /**
 
408
        * Escape string used in sql query
 
409
        */
 
410
        function sql_escape($msg)
 
411
        {
 
412
                return str_replace("'", "''", $msg);
 
413
        }
 
414
 
 
415
        /**
 
416
        * Build LIKE expression
 
417
        * @access private
 
418
        */
 
419
        function _sql_like_expression($expression)
 
420
        {
 
421
                return $expression . " ESCAPE '\\'";
 
422
        }
 
423
 
 
424
        /**
 
425
        * Build db-specific query data
 
426
        * @access private
 
427
        */
 
428
        function _sql_custom_build($stage, $data)
 
429
        {
 
430
                return $data;
 
431
        }
 
432
 
 
433
        /**
 
434
        * return sql error array
 
435
        * @access private
 
436
        */
 
437
        function _sql_error()
 
438
        {
 
439
                return array(
 
440
                        'message'       => @ibase_errmsg(),
 
441
                        'code'          => (@function_exists('ibase_errcode') ? @ibase_errcode() : '')
 
442
                );
 
443
        }
 
444
 
 
445
        /**
 
446
        * Close sql connection
 
447
        * @access private
 
448
        */
 
449
        function _sql_close()
 
450
        {
 
451
                if ($this->service_handle !== false)
 
452
                {
 
453
                        @ibase_service_detach($this->service_handle);
 
454
                }
 
455
 
 
456
                return @ibase_close($this->db_connect_id);
 
457
        }
 
458
 
 
459
        /**
 
460
        * Build db-specific report
 
461
        * @access private
 
462
        */
 
463
        function _sql_report($mode, $query = '')
 
464
        {
 
465
                switch ($mode)
 
466
                {
 
467
                        case 'start':
 
468
                        break;
 
469
 
 
470
                        case 'fromcache':
 
471
                                $endtime = explode(' ', microtime());
 
472
                                $endtime = $endtime[0] + $endtime[1];
 
473
 
 
474
                                $result = @ibase_query($this->db_connect_id, $query);
 
475
                                while ($void = @ibase_fetch_object($result, IBASE_TEXT))
 
476
                                {
 
477
                                        // Take the time spent on parsing rows into account
 
478
                                }
 
479
                                @ibase_free_result($result);
 
480
 
 
481
                                $splittime = explode(' ', microtime());
 
482
                                $splittime = $splittime[0] + $splittime[1];
 
483
 
 
484
                                $this->sql_report('record_fromcache', $query, $endtime, $splittime);
 
485
 
 
486
                        break;
 
487
                }
 
488
        }
 
489
}
 
490
 
 
491
?>
 
 
b'\\ No newline at end of file'