db/mysql.php

   1 <?php
   2 /***************************************************************************
   3  *                                 mysql.php
   4  *                            -------------------
   5  *   begin                : Saturday, Feb 13, 2001
   6  *   copyright            : (C) 2001 The phpBB Group
   7  *   email                : support@phpbb.com
   8  *
   9  *   $Id: mysql.php,v 1.16.2.1 2005/09/18 16:17:20 acydburn 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","mysql");
  26
  27 class sql_db
  28 {
  29
  30         var $db_connect_id;
  31         var $query_result;
  32         var $row = array();
  33         var $rowset = array();
  34         var $num_queries = 0;
  35
  36         //
  37         // Constructor
  38         //
  39         function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency = true)
  40         {
  41
  42                 $this->persistency = $persistency;
  43                 $this->user = $sqluser;
  44                 $this->password = $sqlpassword;
  45                 $this->server = $sqlserver;
  46                 $this->dbname = $database;
  47
  48                 if($this->persistency)
  49                 {
  50                         $this->db_connect_id = @mysql_pconnect($this->server, $this->user, $this->password);
  51                 }
  52                 else
  53                 {
  54                         $this->db_connect_id = @mysql_connect($this->server, $this->user, $this->password);
  55                 }
  56                 if($this->db_connect_id)
  57                 {
  58                         if($database != "")
  59                         {
  60                                 $this->dbname = $database;
  61                                 $dbselect = @mysql_select_db($this->dbname);
  62                                 if(!$dbselect)
  63                                 {
  64                                         @mysql_close($this->db_connect_id);
  65                                         $this->db_connect_id = $dbselect;
  66                                 }
  67                         }
  68                         return $this->db_connect_id;
  69                 }
  70                 else
  71                 {
  72                         return false;
  73                 }
  74         }
  75
  76         //
  77         // Other base methods
  78         //
  79         function sql_close()
  80         {
  81                 if($this->db_connect_id)
  82                 {
  83                         if($this->query_result)
  84                         {
  85                                 @mysql_free_result($this->query_result);
  86                         }
  87                         $result = @mysql_close($this->db_connect_id);
  88                         return $result;
  89                 }
  90                 else
  91                 {
  92                         return false;
  93                 }
  94         }
  95
  96         //
  97         // Base query method
  98         //
  99         function sql_query($query = "", $transaction = FALSE)
 100         {
 101                 // Remove any pre-existing queries
 102                 unset($this->query_result);
 103                 if($query != "")
 104                 {
 105                         $this->num_queries++;
 106
 107                         $this->query_result = @mysql_query($query, $this->db_connect_id);
 108                 }
 109                 if($this->query_result)
 110                 {
 111                         unset($this->row[$this->query_result]);
 112                         unset($this->rowset[$this->query_result]);
 113                         return $this->query_result;
 114                 }
 115                 else
 116                 {
 117                         return ( $transaction == END_TRANSACTION ) ? true : false;
 118                 }
 119         }
 120
 121         //
 122         // Other query methods
 123         //
 124         function sql_numrows($query_id = 0)
 125         {
 126                 if(!$query_id)
 127                 {
 128                         $query_id = $this->query_result;
 129                 }
 130                 if($query_id)
 131                 {
 132                         $result = @mysql_num_rows($query_id);
 133                         return $result;
 134                 }
 135                 else
 136                 {
 137                         return false;
 138                 }
 139         }
 140         function sql_affectedrows()
 141         {
 142                 if($this->db_connect_id)
 143                 {
 144                         $result = @mysql_affected_rows($this->db_connect_id);
 145                         return $result;
 146                 }
 147                 else
 148                 {
 149                         return false;
 150                 }
 151         }
 152         function sql_numfields($query_id = 0)
 153         {
 154                 if(!$query_id)
 155                 {
 156                         $query_id = $this->query_result;
 157                 }
 158                 if($query_id)
 159                 {
 160                         $result = @mysql_num_fields($query_id);
 161                         return $result;
 162                 }
 163                 else
 164                 {
 165                         return false;
 166                 }
 167         }
 168         function sql_fieldname($offset, $query_id = 0)
 169         {
 170                 if(!$query_id)
 171                 {
 172                         $query_id = $this->query_result;
 173                 }
 174                 if($query_id)
 175                 {
 176                         $result = @mysql_field_name($query_id, $offset);
 177                         return $result;
 178                 }
 179                 else
 180                 {
 181                         return false;
 182                 }
 183         }
 184         function sql_fieldtype($offset, $query_id = 0)
 185         {
 186                 if(!$query_id)
 187                 {
 188                         $query_id = $this->query_result;
 189                 }
 190                 if($query_id)
 191                 {
 192                         $result = @mysql_field_type($query_id, $offset);
 193                         return $result;
 194                 }
 195                 else
 196                 {
 197                         return false;
 198                 }
 199         }
 200         function sql_fetchrow($query_id = 0)
 201         {
 202                 if(!$query_id)
 203                 {
 204                         $query_id = $this->query_result;
 205                 }
 206                 if($query_id)
 207                 {
 208                         $this->row[$query_id] = @mysql_fetch_array($query_id);
 209                         return $this->row[$query_id];
 210                 }
 211                 else
 212                 {
 213                         return false;
 214                 }
 215         }
 216         function sql_fetchrowset($query_id = 0)
 217         {
 218                 if(!$query_id)
 219                 {
 220                         $query_id = $this->query_result;
 221                 }
 222                 if($query_id)
 223                 {
 224                         unset($this->rowset[$query_id]);
 225                         unset($this->row[$query_id]);
 226                         while($this->rowset[$query_id] = @mysql_fetch_array($query_id))
 227                         {
 228                                 $result[] = $this->rowset[$query_id];
 229                         }
 230                         return $result;
 231                 }
 232                 else
 233                 {
 234                         return false;
 235                 }
 236         }
 237         function sql_fetchfield($field, $rownum = -1, $query_id = 0)
 238         {
 239                 if(!$query_id)
 240                 {
 241                         $query_id = $this->query_result;
 242                 }
 243                 if($query_id)
 244                 {
 245                         if($rownum > -1)
 246                         {
 247                                 $result = @mysql_result($query_id, $rownum, $field);
 248                         }
 249                         else
 250                         {
 251                                 if(empty($this->row[$query_id]) && empty($this->rowset[$query_id]))
 252                                 {
 253                                         if($this->sql_fetchrow())
 254                                         {
 255                                                 $result = $this->row[$query_id][$field];
 256                                         }
 257                                 }
 258                                 else
 259                                 {
 260                                         if($this->rowset[$query_id])
 261                                         {
 262                                                 $result = $this->rowset[$query_id][0][$field];
 263                                         }
 264                                         else if($this->row[$query_id])
 265                                         {
 266                                                 $result = $this->row[$query_id][$field];
 267                                         }
 268                                 }
 269                         }
 270                         return $result;
 271                 }
 272                 else
 273                 {
 274                         return false;
 275                 }
 276         }
 277         function sql_rowseek($rownum, $query_id = 0){
 278                 if(!$query_id)
 279                 {
 280                         $query_id = $this->query_result;
 281                 }
 282                 if($query_id)
 283                 {
 284                         $result = @mysql_data_seek($query_id, $rownum);
 285                         return $result;
 286                 }
 287                 else
 288                 {
 289                         return false;
 290                 }
 291         }
 292         function sql_nextid(){
 293                 if($this->db_connect_id)
 294                 {
 295                         $result = @mysql_insert_id($this->db_connect_id);
 296                         return $result;
 297                 }
 298                 else
 299                 {
 300                         return false;
 301                 }
 302         }
 303         function sql_freeresult($query_id = 0){
 304                 if(!$query_id)
 305                 {
 306                         $query_id = $this->query_result;
 307                 }
 308
 309                 if ( $query_id )
 310                 {
 311                         unset($this->row[$query_id]);
 312                         unset($this->rowset[$query_id]);
 313
 314                         @mysql_free_result($query_id);
 315
 316                         return true;
 317                 }
 318                 else
 319                 {
 320                         return false;
 321                 }
 322         }
 323         function sql_error($query_id = 0)
 324         {
 325                 $result["message"] = @mysql_error($this->db_connect_id);
 326                 $result["code"] = @mysql_errno($this->db_connect_id);
 327
 328                 return $result;
 329         }
 330
 331 } // class sql_db
 332
 333 } // if ... define
 334
 335 ?>