Initial revision

git-svn-id: file:///svn/phpbb/trunk@2 89ea8834-ac86-4346-8a33-228a782c2dd0
author: James Atkinson <thefinn@users.sourceforge.net> 2001-02-17 08:37:32 +0000
committer: James Atkinson <thefinn@users.sourceforge.net> 2001-02-17 08:37:32 +0000
commit: 86282fce6fae0a471a851fc33ae34aa455ddc2ab (patch)
tree: 50e8f85e856ac34ee12555c4caced7d059b91e52 /phpBB/db
parent: 4b77cbd2cbf9d367c55d9e2db500bf3f536c17ec (diff)
download: forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.tar
forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.tar.gz
forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.tar.bz2
forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.tar.xz
forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.zip
3 files changed, 721 insertions, 0 deletions
diff --git a/phpBB/db/mssql.php b/phpBB/db/mssql.php
new file mode 100644
index 0000000000..0b0ce5cf8a
--- /dev/null
+++ b/phpBB/db/mssql.php
@@ -0,0 +1,208 @@
+<?php
+/***************************************************************************
+ *                                 mssql.php
+ *                            -------------------
+ *   begin                : Saturday, Feb 13, 2001
+ *   copyright            : (C) 2001 The phpBB Group
+ *   email                : support@phpbb.com
+ *
+ *   $Id$
+ *
+ ***************************************************************************/
+
+/***************************************************************************
+ *
+ *   This program is free software; you can redistribute it and/or modify
+ *   it under the terms of the GNU General Public License as published by
+ *   the Free Software Foundation; either version 2 of the License, or
+ *   (at your option) any later version.
+ *
+ ***************************************************************************/
+if(!defined("SQL_LAYER")){
+
+define("SQL_LAYER","mssql");
+
+class sql_db {
+
+   var $db_connect_id;
+   var $query_result;
+   var $row;
+
+   //
+   // Constructor
+   //
+   function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency=false){
+
+      $this->persistency = $persistency;
+      $this->user = $sqluser;
+      $this->password = $sqlpassword;
+      $this->host = $sqlserver;
+      $this->dbname = $database;
+
+      if($this->persistency){
+         $this->db_connect_id = @mssql_pconnect($this->server,$this->user,$this->password);
+      } else {
+         $this->db_connect_id = @mssql_connect($this->server,$this->user,$this->password);
+      }
+      if($this->db_connect_id){
+         if($this->dbname != ""){
+            $dbselect = @mssql_select_db($this->dbname);
+            if(!$dbselect){
+               @mssql_close($this->db_connect_id);
+               $this->db_connect_id = $dbselect;
+            }
+         }
+      }
+      return $this->db_connect_id;
+   }
+   //
+   // Other base methods
+   //
+   function sql_setdb($database){
+      $this->dbname = $database;
+      $dbselect = @mssql_select_db($this->dbname);
+      if(!$dbselect){
+         sql_close();
+         $this->db_connect_id = $dbselect;
+      }
+      return $this->db_connect_id;
+   }
+   function sql_close(){
+      if($this->db_connect_id){
+         if($this->query_result){
+            @mssql_free_result($this->query_result);
+         }
+         $result = @mssql_close($this->db_connect_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+
+
+   //
+   // Query method
+   //
+   function sql_query($query=""){
+      // Remove any pre-existing queries
+      unset($this->query_result);
+      unset($this->row);
+      if($query != ""){
+         // Does query contain any LIMIT code?
+         // If so pull out relevant start and num_results
+         // This isn't terribly easy with MSSQL, the best way is
+         // to use a temporary table.
+         if(eregi("LIMIT ",$query){
+            eregi("LIMIT ([0-9]+)[, ]+([0-9]+)", $query, $limits);
+            $row_offset = $limits[1];
+            if($limits[2])
+               $num_rows = $limits[2];
+         } else {
+            $this->query_result = @mssql_query($query, $this->db_connect_id);
+         }
+         return $this->query_result;
+      } else {
+         return 0;
+      }
+   }
+   //
+   // Other query methods
+   //
+   function sql_numrows(){
+      if($this->query_result){
+         $result = @mssql_num_rows($this->query_result);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_numfields(){
+      if($this->query_result){
+         $result = @mssql_num_fields($this->query_result);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fieldname($offset){
+      if($this->query_result){
+         $result = @mssql_field_name($this->query_result, $offset);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fieldtype($offset){
+      if($this->query_result){
+         $result = @mssql_field_type($this->query_result, $offset);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchrow(){
+      if($this->query_result){
+         $this->row = @mssql_fetch_array($this->query_result);
+         return $this->row;
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchrowset(){
+      if($this->query_result){
+         empty($this->rowset);
+         while($this->rowset = @mssql_fetch_array($this->query_result)){
+            $result[] = $this->rowset;
+         }
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchfield($field, $row=-1) {
+      if($this->query_result){
+         if($row != -1){
+            $result=@mssql_result($this->query_result, $row, $field);
+         } else {
+            if(empty($this->row))
+               $this->row = @mssql_fetch_array($this->query_result);
+            $result = $this->row[$field];
+         }
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_rowseek($offset){
+      if($this->query_result){
+         $result = @mssql_data_seek($this->query_result, $rownum);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_nextid(){
+      if($this->query_result){
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_freeresult(){
+      if($this->query_result){
+         @mssql_free_result($this->query_result);
+         return;
+      } else {
+         return false;
+      }
+   }
+   function sql_error(){
+      $result[message] = @mssql_get_last_message();
+      return $result;
+   }
+
+} // class sql_db
+
+} // if ... define
+
+?>
diff --git a/phpBB/db/mysql.php b/phpBB/db/mysql.php
new file mode 100644
index 0000000000..3b592f048c
--- /dev/null
+++ b/phpBB/db/mysql.php
@@ -0,0 +1,235 @@
+<?php
+/***************************************************************************
+ *                                 mysql.php 
+ *                            -------------------
+ *   begin                : Saturday, Feb 13, 2001
+ *   copyright            : (C) 2001 The phpBB Group
+ *   email                : support@phpbb.com
+ *
+ *   $Id$
+ *
+ ***************************************************************************/
+
+/***************************************************************************
+ *
+ *   This program is free software; you can redistribute it and/or modify
+ *   it under the terms of the GNU General Public License as published by
+ *   the Free Software Foundation; either version 2 of the License, or
+ *   (at your option) any later version.
+ *
+ ***************************************************************************/
+
+if(!defined("SQL_LAYER")){
+
+define("SQL_LAYER","mysql");
+
+class sql_db {
+
+   var $db_connect_id;
+   var $query_result;
+   var $row;
+
+   //
+   // Constructor
+   //
+   function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency=true){
+
+      $this->persistency = $persistency;
+      $this->user = $sqluser;
+      $this->password = $sqlpassword;
+      $this->host = $sqlserver;
+
+      if($this->persistency){
+         $this->db_connect_id = @mysql_pconnect($this->server, $this->user, $this->password);
+      } else {
+         $this->db_connect_id = @mysql_connect($this->server, $this->user, $this->password);
+      }
+      if($this->db_connect_id){
+         if($database != ""){
+            $this->dbname = $database;
+            $dbselect = @mysql_select_db($this->dbname);
+            if(!$dbselect){
+               mysql_close($this->db_connect_id);
+               $this->db_connect_id = $dbselect;
+            }
+         }
+      }
+      return $this->db_connect_id;
+   }
+   //
+   // Other base methods
+   //
+   function sql_setdb($database){
+      if($database != ""){
+         $this->dbname = $database;
+         $dbselect = @mysql_select_db($this->dbname);
+         if(!$dbselect){
+            sql_close();
+            $this->db_connect_id = $dbselect;
+         }
+         return $this->db_connect_id;
+      } else {
+         return false;
+      }
+   }
+   function sql_close(){
+      if($this->db_connect_id){
+         if($this->query_result){
+            @mysql_free_result($this->query_result);
+         }
+         $result = @mysql_close($this->db_connect_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+
+   //
+   // Base query method
+   //
+   function sql_query($query=""){
+      // Remove any pre-existing queries
+      unset($this->query_result);
+      if($query != ""){
+         $this->query_result = @mysql_query($query, $this->db_connect_id);
+      }
+      if($this->query_result){
+         unset($this->row[$this->query_result]);
+         unset($this->rowset[$this->query_result]);
+         return $this->query_result;
+      } else {
+         return false;
+      }
+   }
+   //
+   // Other query methods
+   //
+   function sql_numrows($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @mysql_num_rows($query_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_numfields($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @mysql_num_fields($query_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fieldname($offset, $query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @mysql_field_name($query_id, $offset);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fieldtype($offset, $query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @mysql_field_type($query_id, $offset);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchrow($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $this->row[$query_id] = @mysql_fetch_array($query_id);
+         return $this->row[$query_id];
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchrowset($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         unset($this->rowset[$query_id]);
+         unset($this->row[$query_id]);
+         while($this->rowset[$query_id] = @mysql_fetch_array($query_id)){
+            $result[] = $this->rowset[$query_id];
+         }
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchfield($field, $rownum=-1, $query_id = 0) {
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         if($rownum > -1){
+            $result = @mysql_result($query_id, $rownum, $field);
+         } else {
+            if(empty($this->row[$query_id]) && empty($this->rowset[$query_id])){
+               if($this->sql_fetchrow())
+                  $result = $this->row[$query_id][$field];
+            } else {
+               if($this->rowset[$query_id]){
+                  $result = $this->rowset[$query_id][$field];
+               } else if($this->row[$query_id]){
+                  $result = $this->row[$query_id][$field];
+               }
+            }
+         }
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_rowseek($rownum, $query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @mysql_data_seek($query_id, $rownum);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_nextid(){
+      if($this->db_connection_id){
+         $result = @mysql_insert_id();
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_freeresult($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @mysql_free_result($query_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_error($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      $result[message] = @mysql_error($query_id);
+      $result[code] = @mysql_errno($query_id);
+
+      return $result;
+   }
+
+} // class sql_db
+
+} // if ... define
+
+?>
diff --git a/phpBB/db/postgres7.php b/phpBB/db/postgres7.php
new file mode 100644
index 0000000000..a2a848204a
--- /dev/null
+++ b/phpBB/db/postgres7.php
@@ -0,0 +1,278 @@
+<?php
+  /***************************************************************************
+   *                                 postgres7.php
+   *                            -------------------
+   *   begin                : Saturday, Feb 13, 2001
+   *   copyright            : (C) 2001 The phpBB Group
+   *   email                : support@phpbb.com
+   *
+   *   $Id$
+   *
+   ***************************************************************************/
+
+  /***************************************************************************
+   *
+   *   This program is free software; you can redistribute it and/or modify
+   *   it under the terms of the GNU General Public License as published by
+   *   the Free Software Foundation; either version 2 of the License, or
+   *   (at your option) any later version.
+   *
+   ***************************************************************************/
+
+if(!defined("SQL_LAYER")){
+
+define("SQL_LAYER","postgresql");
+
+class sql_db {
+
+   var $db_connect_id;
+   var $query_result;
+   var $row;
+   var $rownum = array();
+   //
+   // Constructor
+   //
+   function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency=true){
+
+      $this->connect_string = "";
+      if($sqluser){
+         $this->connect_string .= "user=$sqluser ";
+      }
+      if($sqlpassword){
+         $this->connect_string .= "password=$sqlpassword ";
+      }
+      if($sqlserver){
+         if(ereg(":",$sqlserver)){
+            list($sqlserver,$sqlport) = split(":",$sqlserver);
+            $this->connect_string .= "host=$sqlserver port=$sqlport ";
+         } else {
+            $this->connect_string .= "host=$sqlserver ";
+         }
+      }
+      if($database){
+         $this->dbname = $database;
+         $make_connect = $this->connect_string . "dbname=$database";
+      } else {
+         $make_connect = $this->connect_string;
+      }
+      $this->persistency = $persistency;
+
+      if($this->persistency){
+         $this->db_connect_id = @pg_pconnect($make_connect);
+      } else {
+         $this->db_connect_id = @pg_connect($make_connect);
+      }
+      return $this->db_connect_id;
+   }
+   //
+   // Other base methods
+   //
+   function sql_setdb($database){
+      if($this->db_connect_id){
+         if($this->query_result){
+            @pg_freeresult($this->query_result);
+            unset($this->query_result);
+            unset($this->row);
+         }
+         $result = @pg_close($this->db_connect_id);
+         if($result){
+            $this->dbname = $database;
+            $make_connect = $this->connect_string . "dbname=$database";
+            if($this->persistency){
+               $this->db_connect_id = @pg_pconnect($make_connect);
+            } else {
+               $this->db_connect_id = @pg_connect($make_connect);
+            }
+         }
+      }
+      return $this->db_connect_id;
+   }
+   function sql_close(){
+      if($this->db_connect_id){
+         if($this->query_result){
+            @pg_freeresult($this->query_result);
+         }
+         $result = @pg_close($this->db_connect_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+
+
+   //
+   // Query method
+   //
+   function sql_query($query=""){
+      // Remove any pre-existing queries
+      unset($this->query_result);
+      if($query != ""){
+         $this->query_result = @pg_exec($this->db_connect_id, $query);
+         if($this->query_result){
+
+            $this->last_query_text[$this->query_result] = $query;
+            $this->rownum[$this->query_result] = 0;
+            unset($this->row[$this->query_result]);
+            unset($this->rowset[$this->query_result]);
+
+            return $this->query_result;
+         } else {
+            return false;
+         }
+      } else {
+         return 0;
+      }
+   }
+   //
+   // Other query methods
+   //
+   function sql_numrows($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @pg_numrows($query_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_numfields($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @pg_numfields($query_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fieldname($offset, $query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @pg_fieldname($query_id, $offset);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fieldtype($offset, $query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @pg_fieldtype($query_id, $offset);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchrow($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]);
+         if($this->row)
+            $this->rownum[$query_id]++;
+         return $this->row;
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchrowset($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         unset($this->rowset[$query_id]);
+         unset($this->row[$query_id]);
+         $this->rownum[$query_id] = 0;
+         while($this->rowset = @pg_fetch_array($query_id, $this->rownum[$query_id])){
+            $result[] = $this->rowset;
+            $this->rownum[$query_id]++;
+         }
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_fetchfield($field, $row_offset=-1, $query_id = 0) {
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         if($row_offset != -1){
+            $this->row = @pg_fetch_array($query_id, $row_offset);
+         } else {
+            if($this->rownum[$query_id]){
+               $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]-1);
+            } else {
+               $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]);
+               if($this->row)
+                  $this->rownum[$query_id]++;
+            }
+         }
+         $result = $this->row[$field];
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_rowseek($offset, $query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         if($offset>-1){
+            $this->rownum[$query_id] = $offset;
+            return true;
+         } else {
+            return false;
+         }
+      } else {
+         return false;
+      }
+   }
+   function sql_nextid($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id && $this->last_query_text[$query_id] != ""){
+         if(eregi("^(INSERT{1}|^INSERT INTO{1})[[:space:]][\"]?([[:alnum:]]+)[\"]?", $this->last_query_text[$query_id], $tablename);
+            $query = "SELECT last_value FROM ".$tablename[2]."_id_seq";
+            $temp_q_id =  @pg_exec($this->db_connect_id, $query);
+            if($query_id){
+               $temp_result = @pg_fetch_array($temp_q_id, 0);
+               if($temp_result){
+                  return $temp_result["last_value"]+1;
+               } else {
+                  return false;
+               }
+            } else {
+               return false;
+            }
+         } else {
+            return false;
+         }
+      } else {
+         return false;
+      }
+   }
+   function sql_freeresult($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      if($query_id){
+         $result = @pg_freeresult($query_id);
+         return $result;
+      } else {
+         return false;
+      }
+   }
+   function sql_error($query_id = 0){
+      if(!$query_id)
+         $query_id = $this->query_result;
+      $result[message] = @pg_errormessage($query_id);
+      $result[code] = -1;
+      return $result;
+   }
+
+} // class ... db_sql
+
+} // if ... defined
+
+?>
author	James Atkinson <thefinn@users.sourceforge.net>	2001-02-17 08:37:32 +0000
committer	James Atkinson <thefinn@users.sourceforge.net>	2001-02-17 08:37:32 +0000
commit	86282fce6fae0a471a851fc33ae34aa455ddc2ab (patch)
tree	50e8f85e856ac34ee12555c4caced7d059b91e52 /phpBB/db
parent	4b77cbd2cbf9d367c55d9e2db500bf3f536c17ec (diff)
download	forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.tar forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.tar.gz forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.tar.bz2 forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.tar.xz forums-86282fce6fae0a471a851fc33ae34aa455ddc2ab.zip