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