db/db2.php

   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 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 ?>