| [ Index ] |
PHP Cross Reference of Unnamed Project |
[Summary view] [Print] [Text view]
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 1997 2002-01-28 17:25:58Z psotfx $ 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 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 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 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 } 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 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 $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 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 } 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 $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 // 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 } 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 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 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 } 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 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 { 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 { 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 { 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 { 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 ?>
title
Description
Body
title
Description
Body
title
Description
Body
title
Body
| Generated: Mon Jan 14 19:21:40 2013 | Cross-referenced by PHPXref 0.7.1 |