1 rizwank 1.1 <?php
2 /***************************************************************************
3 * db2.php
4 * -------------------
5 * begin : Saturday, Feb 13, 2001
6 * copyright : (C) 2001 The phpBB Group
7 * email : support@phpbb.com
8 *
9 * $Id: db2.php,v 1.2 2002/01/28 17:24:45 psotfx Exp $
10 *
11 ***************************************************************************/
12
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 ***************************************************************************/
21
22 rizwank 1.1 if(!defined("SQL_LAYER"))
23 {
24
25 define("SQL_LAYER","db2");
26
27 class sql_db
28 {
29
30 var $db_connect_id;
31 var $query_result;
32 var $query_resultset;
33 var $query_numrows;
34 var $next_id;
35 var $row = array();
36 var $rowset = array();
37 var $row_index;
38 var $num_queries = 0;
39
40 //
41 // Constructor
42 //
43 rizwank 1.1 function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency = true)
44 {
45 $this->persistency = $persistency;
46 $this->user = $sqluser;
47 $this->password = $sqlpassword;
48 $this->dbname = $database;
49
50 $this->server = $sqlserver;
51
52 if($this->persistency)
53 {
54 $this->db_connect_id = odbc_pconnect($this->server, "", "");
55 }
56 else
57 {
58 $this->db_connect_id = odbc_connect($this->server, "", "");
59 }
60
61 if($this->db_connect_id)
62 {
63 @odbc_autocommit($this->db_connect_id, off);
64 rizwank 1.1
65 return $this->db_connect_id;
66 }
67 else
68 {
69 return false;
70 }
71 }
72 //
73 // Other base methods
74 //
75 function sql_close()
76 {
77 if($this->db_connect_id)
78 {
79 if($this->query_result)
80 {
81 @odbc_free_result($this->query_result);
82 }
83 $result = @odbc_close($this->db_connect_id);
84 return $result;
85 rizwank 1.1 }
86 else
87 {
88 return false;
89 }
90 }
91
92
93 //
94 // Query method
95 //
96 function sql_query($query = "", $transaction = FALSE)
97 {
98 //
99 // Remove any pre-existing queries
100 //
101 unset($this->query_result);
102 unset($this->row);
103 if($query != "")
104 {
105 $this->num_queries++;
106 rizwank 1.1
107 if(!eregi("^INSERT ",$query))
108 {
109 if(eregi("LIMIT", $query))
110 {
111 preg_match("/^(.*)LIMIT ([0-9]+)[, ]*([0-9]+)*/s", $query, $limits);
112
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
125 $query .= " FETCH FIRST ".($row_offset+$num_rows)." ROWS ONLY OPTIMIZE FOR ".($row_offset+$num_rows)." ROWS";
126
127 rizwank 1.1 $this->query_result = odbc_exec($this->db_connect_id, $query);
128
129 $query_limit_offset = $row_offset;
130 $this->result_numrows[$this->query_result] = $num_rows;
131 }
132 else
133 {
134 $this->query_result = odbc_exec($this->db_connect_id, $query);
135
136 $row_offset = 0;
137 $this->result_numrows[$this->query_result] = 5E6;
138 }
139
140 $result_id = $this->query_result;
141 if($this->query_result && eregi("^SELECT", $query))
142 {
143
144 for($i = 1; $i < odbc_num_fields($result_id)+1; $i++)
145 {
146 $this->result_field_names[$result_id][] = odbc_field_name($result_id, $i);
147 }
148 rizwank 1.1
149 $i = $row_offset + 1;
150 $k = 0;
151 while(odbc_fetch_row($result_id, $i) && $k < $this->result_numrows[$result_id])
152 {
153
154 for($j = 1; $j < count($this->result_field_names[$result_id])+1; $j++)
155 {
156 $this->result_rowset[$result_id][$k][$this->result_field_names[$result_id][$j-1]] = odbc_result($result_id, $j);
157 }
158 $i++;
159 $k++;
160 }
161
162 $this->result_numrows[$result_id] = $k;
163 $this->row_index[$result_id] = 0;
164 }
165 else
166 {
167 $this->result_numrows[$result_id] = @odbc_num_rows($result_id);
168 $this->row_index[$result_id] = 0;
169 rizwank 1.1 }
170 }
171 else
172 {
173 if(eregi("^(INSERT|UPDATE) ", $query))
174 {
175 $query = preg_replace("/\\\'/s", "''", $query);
176 }
177
178 $this->query_result = odbc_exec($this->db_connect_id, $query);
179
180 if($this->query_result)
181 {
182 $sql_id = "VALUES(IDENTITY_VAL_LOCAL())";
183
184 $id_result = odbc_exec($this->db_connect_id, $sql_id);
185 if($id_result)
186 {
187 $row_result = odbc_fetch_row($id_result);
188 if($row_result)
189 {
190 rizwank 1.1 $this->next_id[$this->query_result] = odbc_result($id_result, 1);
191 }
192 }
193 }
194
195 odbc_commit($this->db_connect_id);
196
197 $this->query_limit_offset[$this->query_result] = 0;
198 $this->result_numrows[$this->query_result] = 0;
199 }
200
201 return $this->query_result;
202 }
203 else
204 {
205 return false;
206 }
207 }
208
209 //
210 // Other query methods
211 rizwank 1.1 //
212 function sql_numrows($query_id = 0)
213 {
214 if(!$query_id)
215 {
216 $query_id = $this->query_result;
217 }
218 if($query_id)
219 {
220 return $this->result_numrows[$query_id];
221 }
222 else
223 {
224 return false;
225 }
226 }
227 function sql_affectedrows($query_id = 0)
228 {
229 if(!$query_id)
230 {
231 $query_id = $this->query_result;
232 rizwank 1.1 }
233 if($query_id)
234 {
235 return $this->result_numrows[$query_id];
236 }
237 else
238 {
239 return false;
240 }
241 }
242 function sql_numfields($query_id = 0)
243 {
244 if(!$query_id)
245 {
246 $query_id = $this->query_result;
247 }
248 if($query_id)
249 {
250 $result = count($this->result_field_names[$query_id]);
251 return $result;
252 }
253 rizwank 1.1 else
254 {
255 return false;
256 }
257 }
258 function sql_fieldname($offset, $query_id = 0)
259 {
260 if(!$query_id)
261 {
262 $query_id = $this->query_result;
263 }
264 if($query_id)
265 {
266 $result = $this->result_field_names[$query_id][$offset];
267 return $result;
268 }
269 else
270 {
271 return false;
272 }
273 }
274 rizwank 1.1 function sql_fieldtype($offset, $query_id = 0)
275 {
276 if(!$query_id)
277 {
278 $query_id = $this->query_result;
279 }
280 if($query_id)
281 {
282 $result = @odbc_field_type($query_id, $offset);
283 return $result;
284 }
285 else
286 {
287 return false;
288 }
289 }
290 function sql_fetchrow($query_id = 0)
291 {
292 if(!$query_id)
293 {
294 $query_id = $this->query_result;
295 rizwank 1.1 }
296 if($query_id)
297 {
298 if($this->row_index[$query_id] < $this->result_numrows[$query_id])
299 {
300 $result = $this->result_rowset[$query_id][$this->row_index[$query_id]];
301 $this->row_index[$query_id]++;
302 return $result;
303 }
304 else
305 {
306 return false;
307 }
308 }
309 else
310 {
311 return false;
312 }
313 }
314 function sql_fetchrowset($query_id = 0)
315 {
316 rizwank 1.1 if(!$query_id)
317 {
318 $query_id = $this->query_result;
319 }
320 if($query_id)
321 {
322 $this->row_index[$query_id] = $this->result_numrows[$query_id];
323 return $this->result_rowset[$query_id];
324 }
325 else
326 {
327 return false;
328 }
329 }
330 function sql_fetchfield($field, $row = -1, $query_id = 0)
331 {
332 if(!$query_id)
333 {
334 $query_id = $this->query_result;
335 }
336 if($query_id)
337 rizwank 1.1 {
338 if($row < $this->result_numrows[$query_id])
339 {
340 if($row == -1)
341 {
342 $getrow = $this->row_index[$query_id]-1;
343 }
344 else
345 {
346 $getrow = $row;
347 }
348
349 return $this->result_rowset[$query_id][$getrow][$this->result_field_names[$query_id][$field]];
350
351 }
352 else
353 {
354 return false;
355 }
356 }
357 else
358 rizwank 1.1 {
359 return false;
360 }
361 }
362 function sql_rowseek($offset, $query_id = 0)
363 {
364 if(!$query_id)
365 {
366 $query_id = $this->query_result;
367 }
368 if($query_id)
369 {
370 $this->row_index[$query_id] = 0;
371 return true;
372 }
373 else
374 {
375 return false;
376 }
377 }
378 function sql_nextid($query_id = 0)
379 rizwank 1.1 {
380 if(!$query_id)
381 {
382 $query_id = $this->query_result;
383 }
384 if($query_id)
385 {
386 return $this->next_id[$query_id];
387 }
388 else
389 {
390 return false;
391 }
392 }
393 function sql_freeresult($query_id = 0)
394 {
395 if(!$query_id)
396 {
397 $query_id = $this->query_result;
398 }
399 if($query_id)
400 rizwank 1.1 {
401 $result = @odbc_free_result($query_id);
402 return $result;
403 }
404 else
405 {
406 return false;
407 }
408 }
409 function sql_error($query_id = 0)
410 {
411 // $result['code'] = @odbc_error($this->db_connect_id);
412 // $result['message'] = @odbc_errormsg($this->db_connect_id);
413
414 return "";
415 }
416
417 } // class sql_db
418
419 } // if ... define
420
421 rizwank 1.1 ?>
|
Return to
db2.php
CVS log
Up to [RizwankCVS] / geekymedia_web / phpBB2 / db