← 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/mysqli.php

  • Committer: William Grant
  • Date: 2009-02-23 23:47:02 UTC
  • mfrom: (1099.1.211 new-dispatch)
  • Revision ID: grantw@unimelb.edu.au-20090223234702-db4b1llly46ignwo
Merge from lp:~ivle-dev/ivle/new-dispatch.

Pretty much everything changes. Reread the setup docs. Backup your databases.
Every file is now in a different installed location, the configuration system
is rewritten, the dispatch system is rewritten, URLs are different, the
database is different, worksheets and exercises are no longer on the
filesystem, we use a templating engine, jail service protocols are rewritten,
we don't repeat ourselves, we have authorization rewritten, phpBB is gone,
and probably lots of other things that I cannot remember.

This is certainly the biggest commit I have ever made, and hopefully
the largest I ever will.

Show diffs side-by-side

added added

removed removed

Lines of Context:
www/php/phpBB3/includes/db/mysqli.php
1
 
<?php
2
 
/**
3
 
*
4
 
* @package dbal
5
 
* @version $Id: mysqli.php,v 1.36 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
 
* MySQLi Database Abstraction Layer
23
 
* mysqli-extension has to be compiled with:
24
 
* MySQL 4.1+ or MySQL 5.0+
25
 
* @package dbal
26
 
*/
27
 
class dbal_mysqli extends dbal
28
 
{
29
 
        var $multi_insert = true;
30
 
 
31
 
        /**
32
 
        * Connect to server
33
 
        */
34
 
        function sql_connect($sqlserver, $sqluser, $sqlpassword, $database, $port = false, $persistency = false , $new_link = false)
35
 
        {
36
 
                $this->persistency = $persistency;
37
 
                $this->user = $sqluser;
38
 
                $this->server = $sqlserver;
39
 
                $this->dbname = $database;
40
 
                $port = (!$port) ? NULL : $port;
41
 
 
42
 
                // Persistant connections not supported by the mysqli extension?
43
 
                $this->db_connect_id = @mysqli_connect($this->server, $this->user, $sqlpassword, $this->dbname, $port);
44
 
 
45
 
                if ($this->db_connect_id && $this->dbname != '')
46
 
                {
47
 
                        @mysqli_query($this->db_connect_id, "SET NAMES 'utf8'");
48
 
                        // enforce strict mode on databases that support it
49
 
                        if (mysqli_get_server_version($this->db_connect_id) >= 50002)
50
 
                        {
51
 
                                $result = @mysqli_query($this->db_connect_id, 'SELECT @@session.sql_mode AS sql_mode');
52
 
                                $row = @mysqli_fetch_assoc($result);
53
 
                                @mysqli_free_result($result);
54
 
                                $modes = array_map('trim', explode(',', $row['sql_mode']));
55
 
 
56
 
                                // TRADITIONAL includes STRICT_ALL_TABLES and STRICT_TRANS_TABLES
57
 
                                if (!in_array('TRADITIONAL', $modes))
58
 
                                {
59
 
                                        if (!in_array('STRICT_ALL_TABLES', $modes))
60
 
                                        {
61
 
                                                $modes[] = 'STRICT_ALL_TABLES';
62
 
                                        }
63
 
 
64
 
                                        if (!in_array('STRICT_TRANS_TABLES', $modes))
65
 
                                        {
66
 
                                                $modes[] = 'STRICT_TRANS_TABLES';
67
 
                                        }
68
 
                                }
69
 
 
70
 
                                $mode = implode(',', $modes);
71
 
                                @mysqli_query($this->db_connect_id, "SET SESSION sql_mode='{$mode}'");
72
 
                        }
73
 
                        return $this->db_connect_id;
74
 
                }
75
 
 
76
 
                return $this->sql_error('');
77
 
        }
78
 
 
79
 
        /**
80
 
        * Version information about used database
81
 
        */
82
 
        function sql_server_info()
83
 
        {
84
 
                return 'MySQL(i) ' . @mysqli_get_server_info($this->db_connect_id);
85
 
        }
86
 
 
87
 
        /**
88
 
        * SQL Transaction
89
 
        * @access private
90
 
        */
91
 
        function _sql_transaction($status = 'begin')
92
 
        {
93
 
                switch ($status)
94
 
                {
95
 
                        case 'begin':
96
 
                                return @mysqli_autocommit($this->db_connect_id, false);
97
 
                        break;
98
 
 
99
 
                        case 'commit':
100
 
                                $result = @mysqli_commit($this->db_connect_id);
101
 
                                @mysqli_autocommit($this->db_connect_id, true);
102
 
                                return $result;
103
 
                        break;
104
 
 
105
 
                        case 'rollback':
106
 
                                $result = @mysqli_rollback($this->db_connect_id);
107
 
                                @mysqli_autocommit($this->db_connect_id, true);
108
 
                                return $result;
109
 
                        break;
110
 
                }
111
 
 
112
 
                return true;
113
 
        }
114
 
 
115
 
        /**
116
 
        * Base query method
117
 
        *
118
 
        * @param        string  $query          Contains the SQL query which shall be executed
119
 
        * @param        int             $cache_ttl      Either 0 to avoid caching or the time in seconds which the result shall be kept in cache
120
 
        * @return       mixed                           When casted to bool the returned value returns true on success and false on failure
121
 
        *
122
 
        * @access       public
123
 
        */
124
 
        function sql_query($query = '', $cache_ttl = 0)
125
 
        {
126
 
                if ($query != '')
127
 
                {
128
 
                        global $cache;
129
 
 
130
 
                        // EXPLAIN only in extra debug mode
131
 
                        if (defined('DEBUG_EXTRA'))
132
 
                        {
133
 
                                $this->sql_report('start', $query);
134
 
                        }
135
 
 
136
 
                        $this->query_result = ($cache_ttl && method_exists($cache, 'sql_load')) ? $cache->sql_load($query) : false;
137
 
                        $this->sql_add_num_queries($this->query_result);
138
 
 
139
 
                        if ($this->query_result === false)
140
 
                        {
141
 
                                if (($this->query_result = @mysqli_query($this->db_connect_id, $query)) === false)
142
 
                                {
143
 
                                        $this->sql_error($query);
144
 
                                }
145
 
 
146
 
                                if (defined('DEBUG_EXTRA'))
147
 
                                {
148
 
                                        $this->sql_report('stop', $query);
149
 
                                }
150
 
 
151
 
                                if ($cache_ttl && method_exists($cache, 'sql_save'))
152
 
                                {
153
 
                                        $cache->sql_save($query, $this->query_result, $cache_ttl);
154
 
                                }
155
 
                        }
156
 
                        else if (defined('DEBUG_EXTRA'))
157
 
                        {
158
 
                                $this->sql_report('fromcache', $query);
159
 
                        }
160
 
                }
161
 
                else
162
 
                {
163
 
                        return false;
164
 
                }
165
 
 
166
 
                return ($this->query_result) ? $this->query_result : false;
167
 
        }
168
 
 
169
 
        /**
170
 
        * Build LIMIT query
171
 
        */
172
 
        function _sql_query_limit($query, $total, $offset = 0, $cache_ttl = 0)
173
 
        {
174
 
                $this->query_result = false;
175
 
 
176
 
                // if $total is set to 0 we do not want to limit the number of rows
177
 
                if ($total == 0)
178
 
                {
179
 
                        // MySQL 4.1+ no longer supports -1 in limit queries
180
 
                        $total = '18446744073709551615';
181
 
                }
182
 
 
183
 
                $query .= "\n LIMIT " . ((!empty($offset)) ? $offset . ', ' . $total : $total);
184
 
 
185
 
                return $this->sql_query($query, $cache_ttl);
186
 
        }
187
 
 
188
 
        /**
189
 
        * Return number of affected rows
190
 
        */
191
 
        function sql_affectedrows()
192
 
        {
193
 
                return ($this->db_connect_id) ? @mysqli_affected_rows($this->db_connect_id) : false;
194
 
        }
195
 
 
196
 
        /**
197
 
        * Fetch current row
198
 
        */
199
 
        function sql_fetchrow($query_id = false)
200
 
        {
201
 
                global $cache;
202
 
 
203
 
                if ($query_id === false)
204
 
                {
205
 
                        $query_id = $this->query_result;
206
 
                }
207
 
 
208
 
                if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
209
 
                {
210
 
                        return $cache->sql_fetchrow($query_id);
211
 
                }
212
 
 
213
 
                return ($query_id !== false) ? @mysqli_fetch_assoc($query_id) : false;
214
 
        }
215
 
 
216
 
        /**
217
 
        * Seek to given row number
218
 
        * rownum is zero-based
219
 
        */
220
 
        function sql_rowseek($rownum, &$query_id)
221
 
        {
222
 
                global $cache;
223
 
 
224
 
                if ($query_id === false)
225
 
                {
226
 
                        $query_id = $this->query_result;
227
 
                }
228
 
 
229
 
                if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
230
 
                {
231
 
                        return $cache->sql_rowseek($rownum, $query_id);
232
 
                }
233
 
 
234
 
                return ($query_id !== false) ? @mysqli_data_seek($query_id, $rownum) : false;
235
 
        }
236
 
 
237
 
        /**
238
 
        * Get last inserted id after insert statement
239
 
        */
240
 
        function sql_nextid()
241
 
        {
242
 
                return ($this->db_connect_id) ? @mysqli_insert_id($this->db_connect_id) : false;
243
 
        }
244
 
 
245
 
        /**
246
 
        * Free sql result
247
 
        */
248
 
        function sql_freeresult($query_id = false)
249
 
        {
250
 
                global $cache;
251
 
 
252
 
                if ($query_id === false)
253
 
                {
254
 
                        $query_id = $this->query_result;
255
 
                }
256
 
 
257
 
                if (!is_object($query_id) && isset($cache->sql_rowset[$query_id]))
258
 
                {
259
 
                        return $cache->sql_freeresult($query_id);
260
 
                }
261
 
 
262
 
                return @mysqli_free_result($query_id);
263
 
        }
264
 
 
265
 
        /**
266
 
        * Escape string used in sql query
267
 
        */
268
 
        function sql_escape($msg)
269
 
        {
270
 
                return @mysqli_real_escape_string($this->db_connect_id, $msg);
271
 
        }
272
 
 
273
 
        /**
274
 
        * Build LIKE expression
275
 
        * @access private
276
 
        */
277
 
        function _sql_like_expression($expression)
278
 
        {
279
 
                return $expression;
280
 
        }
281
 
 
282
 
        /**
283
 
        * Build db-specific query data
284
 
        * @access private
285
 
        */
286
 
        function _sql_custom_build($stage, $data)
287
 
        {
288
 
                switch ($stage)
289
 
                {
290
 
                        case 'FROM':
291
 
                                $data = '(' . $data . ')';
292
 
                        break;
293
 
                }
294
 
 
295
 
                return $data;
296
 
        }
297
 
 
298
 
        /**
299
 
        * return sql error array
300
 
        * @access private
301
 
        */
302
 
        function _sql_error()
303
 
        {
304
 
                if (!$this->db_connect_id)
305
 
                {
306
 
                        return array(
307
 
                                'message'       => @mysqli_connect_error(),
308
 
                                'code'          => @mysqli_connect_errno()
309
 
                        );
310
 
                }
311
 
 
312
 
                return array(
313
 
                        'message'       => @mysqli_error($this->db_connect_id),
314
 
                        'code'          => @mysqli_errno($this->db_connect_id)
315
 
                );
316
 
        }
317
 
 
318
 
        /**
319
 
        * Close sql connection
320
 
        * @access private
321
 
        */
322
 
        function _sql_close()
323
 
        {
324
 
                return @mysqli_close($this->db_connect_id);
325
 
        }
326
 
 
327
 
        /**
328
 
        * Build db-specific report
329
 
        * @access private
330
 
        */
331
 
        function _sql_report($mode, $query = '')
332
 
        {
333
 
                static $test_prof;
334
 
 
335
 
                // current detection method, might just switch to see the existance of INFORMATION_SCHEMA.PROFILING
336
 
                if ($test_prof === null)
337
 
                {
338
 
                        $test_prof = false;
339
 
                        if (strpos(mysqli_get_server_info($this->db_connect_id), 'community') !== false)
340
 
                        {
341
 
                                $ver = mysqli_get_server_version($this->db_connect_id);
342
 
                                if ($ver >= 50037 && $ver < 50100)
343
 
                                {
344
 
                                        $test_prof = true;
345
 
                                }
346
 
                        }
347
 
                }
348
 
 
349
 
                switch ($mode)
350
 
                {
351
 
                        case 'start':
352
 
 
353
 
                                $explain_query = $query;
354
 
                                if (preg_match('/UPDATE ([a-z0-9_]+).*?WHERE(.*)/s', $query, $m))
355
 
                                {
356
 
                                        $explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];
357
 
                                }
358
 
                                else if (preg_match('/DELETE FROM ([a-z0-9_]+).*?WHERE(.*)/s', $query, $m))
359
 
                                {
360
 
                                        $explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];
361
 
                                }
362
 
 
363
 
                                if (preg_match('/^SELECT/', $explain_query))
364
 
                                {
365
 
                                        $html_table = false;
366
 
 
367
 
                                        // begin profiling
368
 
                                        if ($test_prof)
369
 
                                        {
370
 
                                                @mysqli_query($this->db_connect_id, 'SET profiling = 1;');
371
 
                                        }
372
 
 
373
 
                                        if ($result = @mysqli_query($this->db_connect_id, "EXPLAIN $explain_query"))
374
 
                                        {
375
 
                                                while ($row = @mysqli_fetch_assoc($result))
376
 
                                                {
377
 
                                                        $html_table = $this->sql_report('add_select_row', $query, $html_table, $row);
378
 
                                                }
379
 
                                        }
380
 
                                        @mysqli_free_result($result);
381
 
 
382
 
                                        if ($html_table)
383
 
                                        {
384
 
                                                $this->html_hold .= '</table>';
385
 
                                        }
386
 
 
387
 
                                        if ($test_prof)
388
 
                                        {
389
 
                                                $html_table = false;
390
 
 
391
 
                                                // get the last profile
392
 
                                                if ($result = @mysqli_query($this->db_connect_id, 'SHOW PROFILE ALL;'))
393
 
                                                {
394
 
                                                        $this->html_hold .= '<br />';
395
 
                                                        while ($row = @mysqli_fetch_assoc($result))
396
 
                                                        {
397
 
                                                                // make <unknown> HTML safe
398
 
                                                                if (!empty($row['Source_function']))
399
 
                                                                {
400
 
                                                                        $row['Source_function'] = str_replace(array('<', '>'), array('&lt;', '&gt;'), $row['Source_function']);
401
 
                                                                }
402
 
 
403
 
                                                                // remove unsupported features
404
 
                                                                foreach ($row as $key => $val)
405
 
                                                                {
406
 
                                                                        if ($val === null)
407
 
                                                                        {
408
 
                                                                                unset($row[$key]);
409
 
                                                                        }
410
 
                                                                }
411
 
                                                                $html_table = $this->sql_report('add_select_row', $query, $html_table, $row);
412
 
                                                        }
413
 
                                                }
414
 
                                                @mysqli_free_result($result);
415
 
 
416
 
                                                if ($html_table)
417
 
                                                {
418
 
                                                        $this->html_hold .= '</table>';
419
 
                                                }
420
 
 
421
 
                                                @mysqli_query($this->db_connect_id, 'SET profiling = 0;');
422
 
                                        }
423
 
                                }
424
 
 
425
 
                        break;
426
 
 
427
 
                        case 'fromcache':
428
 
                                $endtime = explode(' ', microtime());
429
 
                                $endtime = $endtime[0] + $endtime[1];
430
 
 
431
 
                                $result = @mysqli_query($this->db_connect_id, $query);
432
 
                                while ($void = @mysqli_fetch_assoc($result))
433
 
                                {
434
 
                                        // Take the time spent on parsing rows into account
435
 
                                }
436
 
                                @mysqli_free_result($result);
437
 
 
438
 
                                $splittime = explode(' ', microtime());
439
 
                                $splittime = $splittime[0] + $splittime[1];
440
 
 
441
 
                                $this->sql_report('record_fromcache', $query, $endtime, $splittime);
442
 
 
443
 
                        break;
444
 
                }
445
 
        }
446
 
}
447
 
 
448
 
?>
 
 
b'\\ No newline at end of file'