Index: cls/db/db.mysqli.php
===================================================================
--- cls/db/db.mysqli.php	(Revision 0)
+++ cls/db/db.mysqli.php	(Revision 0)
@@ -0,0 +1,136 @@
+<?php
+###############################################################################
+# Gregarius - A PHP based RSS aggregator.
+# Copyright (C) 2003 - 2005 Marco Bonetti
+#
+###############################################################################
+# This program is free software and open source 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.
+#
+# This program is distributed in the hope that it will be useful, but WITHOUT
+# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+# FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
+# more details.
+#
+# You should have received a copy of the GNU General Public License along
+# with this program; if not, write to the Free Software Foundation, Inc.,
+# 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA  or visit
+# http://www.gnu.org/licenses/gpl.html
+#
+###############################################################################
+# E-mail:      mbonetti at gmail dot com
+# Web page:    http://gregarius.net/
+#
+###############################################################################
+# mysqli adapter 2006 by Niels Ganser, ng at depoll dot de
+# just a quick hack before returning to ruby country :-)
+###############################################################################
+
+
+require_once(dirname(__FILE__) . '/db.php');
+
+class MysqliDB extends DB {
+
+	var $connection;
+
+	function  MysqliDB() {
+		parent::DB();
+	}
+
+	
+	//// The following are just wrappers of their mysql counterpart for now
+	//// maybe one day I shall support other rdbms and add some differentiation
+	//// in here.
+	
+	function DBConnect($dbserver, $dbuname, $dbpass) {
+		 if (!($this->connection = new mysqli($dbserver, $dbuname, $dbpass))) {
+			  die( "<h1>Error connecting to the database!</h1>\n"
+					 ."<p>Have you edited dbinit.php and correctly defined "
+					 ."the database username and password?</p>\n" );		  
+		}
+	}
+	
+	function DBSelectDB($dbname) {
+		if (!$this->connection->select_db($dbname)) {
+			  die( "<h1>Error selecting the database!</h1>\n"
+					 ."<p>Does your database exist?"
+					 . "Have you edited dbinit.php and correctly defined "
+					 ."the database username and password?</p>\n"
+					 ."<p>Refer to the <a href=\"INSTALL\">INSTALL</a> document "
+					 ."if in doubt</p>\n" );
+		}
+	}
+	
+	function rss_query ($query, $dieOnError=true, $preventRecursion=false) {
+		 $ret =  $this->connection->query($query);
+	
+		 if ($error = $this -> rss_sql_error()) {
+			  $errorString = $this -> rss_sql_error_message();
+		 }
+	
+		 // if we got a missing table error, look for missing tables in the schema
+		 // and try to create them
+		 if ($error == 1146 && !$preventRecursion && $dieOnError) {
+		 		require_once(dirname(__FILE__) . '/../../init.php');
+		 		rss_require('schema.php');
+			  checkSchema();
+			  return $this -> rss_query ($query, $dieOnError, true);
+		 } elseif ($error == 1054 && !$preventRecursion && $dieOnError) {
+			  if (preg_match("/^[^']+'([^']+)'.*$/",$errorString,$matches)) {
+			  	require_once(dirname(__FILE__) . '/../../init.php');
+			  	rss_require('schema.php');
+					checkSchemaColumns($matches[1]);
+					return $this -> rss_query ($query, $dieOnError, true);
+			  }
+		 }
+	
+		if ($error && $dieOnError) {
+			  die ("<p>Failed to execute the SQL query <pre>$query</pre> </p>"
+					 ."<p>Error $error: $errorString</p>");
+		 }
+		 return $ret;
+	}
+	
+	function rss_fetch_row($rs) {
+		return  mysqli_fetch_row($rs);
+	}
+	
+	function rss_fetch_assoc($rs) {
+		return mysqli_fetch_assoc($rs);
+	}
+	function rss_num_rows($rs) {
+		return mysqli_num_rows($rs);
+	}
+	
+	function rss_sql_error() {
+		 return $this->connection->errno;
+	}
+	
+	function rss_sql_error_message () {
+		 return $this->connection->error;
+	}
+	
+	function rss_insert_id() {
+		return $this->connection->insert_id;
+	}
+	
+	function rss_real_escape_string($string) {
+		 return $this->connection->real_escape_string($string);
+	}
+	
+	function rss_is_sql_error($kind) {
+		switch ($kind) {
+			case RSS_SQL_ERROR_NO_ERROR:
+				return ($this->connection->errno == 0);
+				break;
+			case RSS_SQL_ERROR_DUPLICATE_ROW:
+				return ($this->connection->errno == 1062);
+				break;
+			default:
+				return false;
+		}
+	}
+}
+?>