[Summary view] [Print] [Text view]

   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 2906 2002-09-28 12:50:59Z 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","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  
  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          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          }
  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              $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                          {
 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                          $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                              $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                      $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          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      //
 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  	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      {
 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          }
 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              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              $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          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          $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  ?>