?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
#7424
[phpbb.git] / phpBB / includes / db / oracle.php
blob860c7a3614466c25cec9b08146955a0fc8278e16
1 <?php
2 /**
3 *
4 * @package dbal
5 * @version $Id$
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 * Oracle Database Abstraction Layer
23 * @package dbal
24 */
25 class dbal_oracle extends dbal
26 {
27 var $last_query_text = '';
28
29 /**
30 * Connect to server
31 */
32 function sql_connect($sqlserver, $sqluser, $sqlpassword, $database, $port = false, $persistency = false)
33 {
34 $this->persistency = $persistency;
35 $this->user = $sqluser;
36 $this->server = $sqlserver . (($port) ? ':' . $port : '');
37 $this->dbname = $database;
38
39 $this->db_connect_id = ($this->persistency) ? @ociplogon($this->user, $sqlpassword, $this->server, 'UTF8') : @ocinlogon($this->user, $sqlpassword, $this->server, 'UTF8');
40
41 return ($this->db_connect_id) ? $this->db_connect_id : $this->sql_error('');
42 }
43
44 /**
45 * Version information about used database
46 */
47 function sql_server_info()
48 {
49 return @ociserverversion($this->db_connect_id);
50 }
51
52 /**
53 * SQL Transaction
54 * @access private
55 */
56 function _sql_transaction($status = 'begin')
57 {
58 switch ($status)
59 {
60 case 'begin':
61 return true;
62 break;
63
64 case 'commit':
65 return @ocicommit($this->db_connect_id);
66 break;
67
68 case 'rollback':
69 return @ocirollback($this->db_connect_id);
70 break;
71 }
72
73 return true;
74 }
75
76 /**
77 * Base query method
78 *
79 * @param string $query Contains the SQL query which shall be executed
80 * @param int $cache_ttl Either 0 to avoid caching or the time in seconds which the result shall be kept in cache
81 * @return mixed When casted to bool the returned value returns true on success and false on failure
82 *
83 * @access public
84 */
85 function sql_query($query = '', $cache_ttl = 0)
86 {
87 if ($query != '')
88 {
89 global $cache;
90
91 // EXPLAIN only in extra debug mode
92 if (defined('DEBUG_EXTRA'))
93 {
94 $this->sql_report('start', $query);
95 }
96
97 $this->last_query_text = $query;
98 $this->query_result = ($cache_ttl && method_exists($cache, 'sql_load')) ? $cache->sql_load($query) : false;
99 $this->sql_add_num_queries($this->query_result);
100
101 if ($this->query_result === false)
102 {
103 $in_transaction = false;
104 if (!$this->transaction)
105 {
106 $this->sql_transaction('begin');
107 }
108 else
109 {
110 $in_transaction = true;
111 }
112
113 $array = array();
114
115 // We overcome Oracle's 4000 char limit by binding vars
116 if (preg_match('/^(INSERT INTO[^(]+)\\(([^()]+)\\) VALUES[^(]+\\(([^()]+)\\)$/', $query, $regs))
117 {
118 if (strlen($regs[3]) > 4000)
119 {
120 $cols = explode(', ', $regs[2]);
121 $vals = explode(', ', $regs[3]);
122 foreach ($vals as $key => $value)
123 {
124 if (strlen($value) > 4002) // check to see if this thing is greater than the max + 'x2
125 {
126 $vals[$key] = ':' . strtoupper($cols[$key]);
127 $array[$vals[$key]] = substr($value, 1, -1);
128 }
129 }
130 $query = $regs[1] . '(' . implode(', ', $cols) . ') VALUES (' . implode(', ', $vals) . ')';
131 }
132 }
133 else if (preg_match('/^(UPDATE.*?)SET (.*)(\\sWHERE.*)$/s', $query, $regs))
134 {
135 if (strlen($regs[2]) > 4000)
136 {
137 $args = explode(', ', $regs[2]);
138 $cols = array();
139 foreach ($args as $value)
140 {
141 $temp_array = explode('=', $value);
142 $cols[$temp_array[0]] = $temp_array[1];
143 }
144
145 foreach ($cols as $col => $val)
146 {
147 if (strlen($val) > 4003) // check to see if this thing is greater than the max + 'x2 + a space
148 {
149 $cols[$col] = ' :' . strtoupper(rtrim($col));
150 $array[ltrim($cols[$col])] = substr(trim($val), 2, -1);
151 }
152 }
153
154 $art = array();
155 foreach ($cols as $col => $val)
156 {
157 $art[] = $col . '=' . $val;
158 }
159 $query = $regs[1] . 'SET ' . implode(', ', $art) . $regs[3];
160 }
161 }
162
163 $this->query_result = @ociparse($this->db_connect_id, $query);
164
165 foreach ($array as $key => $value)
166 {
167 @ocibindbyname($this->query_result, $key, $array[$key], -1);
168 }
169
170 $success = @ociexecute($this->query_result, OCI_DEFAULT);
171
172 if (!$success)
173 {
174 $this->sql_error($query);
175 $this->query_result = false;
176 }
177 else
178 {
179 if (!$in_transaction)
180 {
181 $this->sql_transaction('commit');
182 }
183 }
184
185 if (defined('DEBUG_EXTRA'))
186 {
187 $this->sql_report('stop', $query);
188 }
189
190 if ($cache_ttl && method_exists($cache, 'sql_save'))
191 {
192 $this->open_queries[(int) $this->query_result] = $this->query_result;
193 $cache->sql_save($query, $this->query_result, $cache_ttl);
194 }
195 else if (strpos($query, 'SELECT') === 0 && $this->query_result)
196 {
197 $this->open_queries[(int) $this->query_result] = $this->query_result;
198 }
199 }
200 else if (defined('DEBUG_EXTRA'))
201 {
202 $this->sql_report('fromcache', $query);
203 }
204 }
205 else
206 {
207 return false;
208 }
209
210 return ($this->query_result) ? $this->query_result : false;
211 }
212
213 /**
214 * Build LIMIT query
215 */
216 function _sql_query_limit($query, $total, $offset = 0, $cache_ttl = 0)
217 {
218 $this->query_result = false;
219
220 $query = 'SELECT * FROM (SELECT /*+ FIRST_ROWS */ rownum AS xrownum, a.* FROM (' . $query . ') a WHERE rownum <= ' . ($offset + $total) . ') WHERE xrownum >= ' . $offset;
221
222 return $this->sql_query($query, $cache_ttl);
223 }
224
225 /**
226 * Return number of affected rows
227 */
228 function sql_affectedrows()
229 {
230 return ($this->query_result) ? @ocirowcount($this->query_result) : false;
231 }
232
233 /**
234 * Fetch current row
235 */
236 function sql_fetchrow($query_id = false)
237 {
238 global $cache;
239
240 if ($query_id === false)
241 {
242 $query_id = $this->query_result;
243 }
244
245 if (isset($cache->sql_rowset[$query_id]))
246 {
247 return $cache->sql_fetchrow($query_id);
248 }
249
250 if ($query_id !== false)
251 {
252 $row = array();
253 $result = @ocifetchinto($query_id, $row, OCI_ASSOC + OCI_RETURN_NULLS);
254
255 if (!$result || !$row)
256 {
257 return false;
258 }
259
260 $result_row = array();
261 foreach ($row as $key => $value)
262 {
263 // OCI->CLOB?
264 if (is_object($value))
265 {
266 $value = $value->load();
267 }
268
269 $result_row[strtolower($key)] = $value;
270 }
271
272 return $result_row;
273 }
274
275 return false;
276 }
277
278 /**
279 * Seek to given row number
280 * rownum is zero-based
281 */
282 function sql_rowseek($rownum, $query_id = false)
283 {
284 global $cache;
285
286 if ($query_id === false)
287 {
288 $query_id = $this->query_result;
289 }
290
291 if (isset($cache->sql_rowset[$query_id]))
292 {
293 return $cache->sql_rowseek($rownum, $query_id);
294 }
295
296 if ($query_id === false)
297 {
298 return false;
299 }
300
301 // Reset internal pointer
302 @ociexecute($query_id, OCI_DEFAULT);
303
304 // We do not fetch the row for rownum == 0 because then the next resultset would be the second row
305 for ($i = 0; $i < $rownum; $i++)
306 {
307 if (!$this->sql_fetchrow($query_id))
308 {
309 return false;
310 }
311 }
312
313 return true;
314 }
315
316 /**
317 * Get last inserted id after insert statement
318 */
319 function sql_nextid()
320 {
321 $query_id = $this->query_result;
322
323 if ($query_id !== false && $this->last_query_text != '')
324 {
325 if (preg_match('#^INSERT[\t\n ]+INTO[\t\n ]+([a-z0-9\_\-]+)#is', $this->last_query_text, $tablename))
326 {
327 $query = 'SELECT ' . $tablename[1] . '_seq.currval FROM DUAL';
328 $stmt = @ociparse($this->db_connect_id, $query);
329 @ociexecute($stmt, OCI_DEFAULT);
330
331 $temp_result = @ocifetchinto($stmt, $temp_array, OCI_ASSOC + OCI_RETURN_NULLS);
332 @ocifreestatement($stmt);
333
334 if ($temp_result)
335 {
336 return $temp_array['CURRVAL'];
337 }
338 else
339 {
340 return false;
341 }
342 }
343 }
344
345 return false;
346 }
347
348 /**
349 * Free sql result
350 */
351 function sql_freeresult($query_id = false)
352 {
353 global $cache;
354
355 if ($query_id === false)
356 {
357 $query_id = $this->query_result;
358 }
359
360 if (isset($cache->sql_rowset[$query_id]))
361 {
362 return $cache->sql_freeresult($query_id);
363 }
364
365 if (isset($this->open_queries[(int) $query_id]))
366 {
367 unset($this->open_queries[(int) $query_id]);
368 return @ocifreestatement($query_id);
369 }
370
371 return false;
372 }
373
374 /**
375 * Escape string used in sql query
376 */
377 function sql_escape($msg)
378 {
379 return str_replace("'", "''", $msg);
380 }
381
382 function _sql_custom_build($stage, $data)
383 {
384 return $data;
385 }
386
387 /**
388 * return sql error array
389 * @access private
390 */
391 function _sql_error()
392 {
393 $error = @ocierror();
394 $error = (!$error) ? @ocierror($this->query_result) : $error;
395 $error = (!$error) ? @ocierror($this->db_connect_id) : $error;
396
397 if ($error)
398 {
399 $this->last_error_result = $error;
400 }
401 else
402 {
403 $error = (isset($this->last_error_result) && $this->last_error_result) ? $this->last_error_result : array();
404 }
405
406 return $error;
407 }
408
409 /**
410 * Close sql connection
411 * @access private
412 */
413 function _sql_close()
414 {
415 return @ocilogoff($this->db_connect_id);
416 }
417
418 /**
419 * Build db-specific report
420 * @access private
421 */
422 function _sql_report($mode, $query = '')
423 {
424 switch ($mode)
425 {
426 case 'start':
427 break;
428
429 case 'fromcache':
430 $endtime = explode(' ', microtime());
431 $endtime = $endtime[0] + $endtime[1];
432
433 $result = @ociparse($this->db_connect_id, $query);
434 $success = @ociexecute($result, OCI_DEFAULT);
435 $row = array();
436
437 while (@ocifetchinto($result, $row, OCI_ASSOC + OCI_RETURN_NULLS))
438 {
439 // Take the time spent on parsing rows into account
440 }
441 @ocifreestatement($result);
442
443 $splittime = explode(' ', microtime());
444 $splittime = $splittime[0] + $splittime[1];
445
446 $this->sql_report('record_fromcache', $query, $endtime, $splittime);
447
448 break;
449 }
450 }
451 }
452
453 ?>
phpbb is a php-based BBS (buletin board system)