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