]> git.vanrenterghem.biz Git - www.vanrenterghem.biz.git/blob - phpBB2/db/oracle.php
update brief bio
[www.vanrenterghem.biz.git] / phpBB2 / db / oracle.php
1 <?php
2 /***************************************************************************
3  *                                oracle.php
4  *                            -------------------
5  *   begin                : Thrusday Feb 15, 2001
6  *   copyright            : (C) 2001 The phpBB Group
7  *   email                : support@phpbb.com
8  *
9  *   $Id: oracle.php,v 1.18.2.1 2002/11/26 11:42:12 psotfx Exp $
10  *
11  ***************************************************************************/
13 /***************************************************************************
14  *
15  *   This program is free software; you can redistribute it and/or modify
16  *   it under the terms of the GNU General Public License as published by
17  *   the Free Software Foundation; either version 2 of the License, or
18  *   (at your option) any later version.
19  *
20  ***************************************************************************/
22 if(!defined("SQL_LAYER"))
23 {
25 define("SQL_LAYER","oracle");
27 class sql_db
28 {
30         var $db_connect_id;
31         var $query_result;
32         var $in_transaction = 0;
33         var $row = array();
34         var $rowset = array();
35         var $num_queries = 0;
36         var $last_query_text = "";
38         //
39         // Constructor
40         //
41         function sql_db($sqlserver, $sqluser, $sqlpassword, $database="", $persistency = true)
42         {
43                 $this->persistency = $persistency;
44                 $this->user = $sqluser;
45                 $this->password = $sqlpassword;
46                 $this->server = $sqlserver;
47                 $this->dbname = $database;
49                 if($this->persistency)
50                 {
51                         $this->db_connect_id = @OCIPLogon($this->user, $this->password, $this->server);
52                 }
53                 else
54                 {
55                         $this->db_connect_id = @OCINLogon($this->user, $this->password, $this->server);
56                 }
57                 if($this->db_connect_id)
58                 {
59                         return $this->db_connect_id;
60                 }
61                 else
62                 {
63                         return false;
64                 }
65         }
67         //
68         // Other base methods
69         //
70         function sql_close()
71         {
72                 if($this->db_connect_id)
73                 {
74                         // Commit outstanding transactions
75                         if($this->in_transaction)
76                         {
77                                 OCICommit($this->db_connect_id);
78                         }
80                         if($this->query_result)
81                         {
82                                 @OCIFreeStatement($this->query_result);
83                         }
84                         $result = @OCILogoff($this->db_connect_id);
85                         return $result;
86                 }
87                 else
88                 {
89                         return false;
90                 }
91         }
93         //
94         // Base query method
95         //
96         function sql_query($query = "", $transaction = FALSE)
97         {
98                 // Remove any pre-existing queries
99                 unset($this->query_result);
101                 // Put us in transaction mode because with Oracle as soon as you make a query you're in a transaction
102                 $this->in_transaction = TRUE;
104                 if($query != "")
105                 {
106                         $this->last_query = $query;
107                         $this->num_queries++;
109                         if(eregi("LIMIT", $query))
110                         {
111                                 preg_match("/^(.*)LIMIT ([0-9]+)[, ]*([0-9]+)*/s", $query, $limits);
113                                 $query = $limits[1];
114                                 if($limits[3])
115                                 {
116                                         $row_offset = $limits[2];
117                                         $num_rows = $limits[3];
118                                 }
119                                 else
120                                 {
121                                         $row_offset = 0;
122                                         $num_rows = $limits[2];
123                                 }
124                         }
126                         if(eregi("^(INSERT|UPDATE) ", $query))
127                         {
128                                 $query = preg_replace("/\\\'/s", "''", $query);
129                         }
131                         $this->query_result = @OCIParse($this->db_connect_id, $query);
132                         $success = @OCIExecute($this->query_result, OCI_DEFAULT);
133                 }
134                 if($success)
135                 {
136                         if($transaction == END_TRANSACTION)
137                         {
138                                 OCICommit($this->db_connect_id);
139                                 $this->in_transaction = FALSE;
140                         }
142                         unset($this->row[$this->query_result]);
143                         unset($this->rowset[$this->query_result]);
144                         $this->last_query_text[$this->query_result] = $query;
146                         return $this->query_result;
147                 }
148                 else
149                 {
150                         if($this->in_transaction)
151                         {
152                                 OCIRollback($this->db_connect_id);
153                         }
154                         return false;
155                 }
156         }
158         //
159         // Other query methods
160         //
161         function sql_numrows($query_id = 0)
162         {
163                 if(!$query_id)
164                 {
165                         $query_id = $this->query_result;
166                 }
167                 if($query_id)
168                 {
169                         $result = @OCIFetchStatement($query_id, $this->rowset);
170                         // OCIFetchStatment kills our query result so we have to execute the statment again
171                         // if we ever want to use the query_id again.
172                         @OCIExecute($query_id, OCI_DEFAULT);
173                         return $result;
174                 }
175                 else
176                 {
177                         return false;
178                 }
179         }
180         function sql_affectedrows($query_id = 0)
181         {
182                 if(!$query_id)
183                 {
184                         $query_id = $this->query_result;
185                 }
186                 if($query_id)
187                 {
188                         $result = @OCIRowCount($query_id);
189                         return $result;
190                 }
191                 else
192                 {
193                         return false;
194                 }
195         }
196         function sql_numfields($query_id = 0)
197         {
198                 if(!$query_id)
199                 {
200                         $query_id = $this->query_result;
201                 }
202                 if($query_id)
203                 {
204                         $result = @OCINumCols($query_id);
205                         return $result;
206                 }
207                 else
208                 {
209                         return false;
210                 }
211         }
212         function sql_fieldname($offset, $query_id = 0)
213         {
214                 // OCIColumnName uses a 1 based array so we have to up the offset by 1 in here to maintain
215                 // full abstraction compatibitly
216                 $offset += 1;
217                 if(!$query_id)
218                 {
219                         $query_id = $this->query_result;
220                 }
221                 if($query_id)
222                 {
223                         $result = strtolower(@OCIColumnName($query_id, $offset));
224                         return $result;
225                 }
226                 else
227                 {
228                         return false;
229                 }
230         }
231         function sql_fieldtype($offset, $query_id = 0)
232         {
233                 // This situation is the same as fieldname
234                 $offset += 1;
235                 if(!$query_id)
236                 {
237                         $query_id = $this->query_result;
238                 }
239                 if($query_id)
240                 {
241                         $result = @OCIColumnType($query_id, $offset);
242                         return $result;
243                 }
244                 else
245                 {
246                         return false;
247                 }
248         }
249         function sql_fetchrow($query_id = 0, $debug = FALSE)
250         {
251                 if(!$query_id)
252                 {
253                         $query_id = $this->query_result;
254                 }
255                 if($query_id)
256                 {
257                         $result_row = "";
258                         $result = @OCIFetchInto($query_id, $result_row, OCI_ASSOC+OCI_RETURN_NULLS);
259                         if($debug)
260                         {
261                                 echo "Query was: ".$this->last_query . "<br>";
262                                 echo "Result: $result<br>";
263                                 echo "Query ID: $query_id<br>";
264                                 echo "<pre>";
265                                 var_dump($result_row);
266                                 echo "</pre>";
267                         }
268                         if($result_row == "")
269                         {
270                                 return false;
271                         }
273                         for($i = 0; $i < count($result_row); $i++)
274                         {
275                                 list($key, $val) = each($result_row);
276                                 $return_arr[strtolower($key)] = $val;
277                         }
278                         $this->row[$query_id] = $return_arr;
280                         return $this->row[$query_id];
281                 }
282                 else
283                 {
284                         return false;
285                 }
286         }
287         // This function probably isn't as efficant is it could be but any other way I do it
288         // I end up losing 1 row...
289         function sql_fetchrowset($query_id = 0)
290         {
291                 if(!$query_id)
292                 {
293                         $query_id = $this->query_result;
294                 }
295                 if($query_id)
296                 {
297                         $rows = @OCIFetchStatement($query_id, $results);
298                         @OCIExecute($query_id, OCI_DEFAULT);
299                         for($i = 0; $i < $rows; $i++)
300                         {
301                                 @OCIFetchInto($query_id, $tmp_result, OCI_ASSOC+OCI_RETURN_NULLS);
303                                 for($j = 0; $j < count($tmp_result); $j++)
304                                 {
305                                         list($key, $val) = each($tmp_result);
306                                         $return_arr[strtolower($key)] = $val;
307                                 }
308                                 $result[] = $return_arr;
309                         }
310                         return $result;
311                 }
312                 else
313                 {
314                         return false;
315                 }
316         }
317         function sql_fetchfield($field, $rownum = -1, $query_id = 0)
318         {
319                 if(!$query_id)
320                 {
321                         $query_id = $this->query_result;
322                 }
323                 if($query_id)
324                 {
325                         if($rownum > -1)
326                         {
327                                 // Reset the internal rownum pointer.
328                                 @OCIExecute($query_id, OCI_DEFAULT);
329                                 for($i = 0; $i < $rownum; $i++)
330                                   {
331                                                 // Move the interal pointer to the row we want
332                                                 @OCIFetch($query_id);
333                                   }
334                                 // Get the field data.
335                                 $result = @OCIResult($query_id, strtoupper($field));
336                         }
337                         else
338                         {
339                                 // The internal pointer should be where we want it
340                                 // so we just grab the field out of the current row.
341                                 $result = @OCIResult($query_id, strtoupper($field));
342                         }
343                         return $result;
344                 }
345                 else
346                 {
347                         return false;
348                 }
349         }
350         function sql_rowseek($rownum, $query_id = 0)
351         {
352                 if(!$query_id)
353                 {
354                                 $query_id = $this->query_result;
355                 }
356                 if($query_id)
357                 {
358                                 @OCIExecute($query_id, OCI_DEFAULT);
359                         for($i = 0; $i < $rownum; $i++)
360                                 {
361                                         @OCIFetch($query_id);
362                                 }
363                         $result = @OCIFetch($query_id);
364                         return $result;
365                 }
366                 else
367                 {
368                                 return false;
369                 }
370         }
371         function sql_nextid($query_id = 0)
372         {
373                 if(!$query_id)
374                 {
375                         $query_id = $this->query_result;
376                 }
377                 if($query_id && $this->last_query_text[$query_id] != "")
378                 {
379                         if( eregi("^(INSERT{1}|^INSERT INTO{1})[[:space:]][\"]?([a-zA-Z0-9\_\-]+)[\"]?", $this->last_query_text[$query_id], $tablename))
380                         {
381                                 $query = "SELECT ".$tablename[2]."_id_seq.currval FROM DUAL";
382                                 $stmt = @OCIParse($this->db_connect_id, $query);
383                                 @OCIExecute($stmt,OCI_DEFAULT );
384                                 $temp_result = @OCIFetchInto($stmt, $temp_result, OCI_ASSOC+OCI_RETURN_NULLS);
385                                 if($temp_result)
386                                 {
387                                         return $temp_result['CURRVAL'];
388                                 }
389                                 else
390                                 {
391                                         return false;
392                                 }
393                         }
394                         else
395                         {
396                                 return false;
397                         }
398                 }
399                 else
400                 {
401                         return false;
402                 }
403         }
405         function sql_nextid($query_id = 0)
406         {
407                 if(!$query_id)
408                 {
409                         $query_id = $this->query_result;
410                 }
411                 if($query_id && $this->last_query_text[$query_id] != "")
412                 {
413                         if( eregi("^(INSERT{1}|^INSERT INTO{1})[[:space:]][\"]?([a-zA-Z0-9\_\-]+)[\"]?", $this->last_query_text[$query_id], $tablename))
414                         {
415                                 $query = "SELECT ".$tablename[2]."_id_seq.CURRVAL FROM DUAL";
416                                 $temp_q_id =  @OCIParse($this->db_connect_id, $query);
417                                 @OCIExecute($temp_q_id, OCI_DEFAULT);
418                                 @OCIFetchInto($temp_q_id, $temp_result, OCI_ASSOC+OCI_RETURN_NULLS);
420                                 if($temp_result)
421                                 {
422                                         return $temp_result['CURRVAL'];
423                                 }
424                                 else
425                                 {
426                                         return false;
427                                 }
428                         }
429                         else
430                         {
431                                 return false;
432                         }
433                 }
434                 else
435                 {
436                         return false;
437                 }
438         }
442         function sql_freeresult($query_id = 0)
443         {
444                 if(!$query_id)
445                 {
446                                 $query_id = $this->query_result;
447                 }
448                 if($query_id)
449                 {
450                                 $result = @OCIFreeStatement($query_id);
451                                 return $result;
452                 }
453                 else
454                 {
455                                 return false;
456                 }
457         }
458         function sql_error($query_id  = 0)
459         {
460                 if(!$query_id)
461                 {
462                         $query_id = $this->query_result;
463                 }
464                 $result  = @OCIError($query_id);
465                 return $result;
466         }
468 } // class sql_db
470 } // if ... define
472 ?>