1 files changed, 92 insertions, 0 deletions
diff --git a/library/ajaxchat/chat/lib/class/AJAXChatMySQLDataBase.php b/library/ajaxchat/chat/lib/class/AJAXChatMySQLDataBase.php
new file mode 100644
index 000000000..6dca348d1
--- /dev/null
+++ b/library/ajaxchat/chat/lib/class/AJAXChatMySQLDataBase.php
@@ -0,0 +1,92 @@
+<?php
+/*
+ * @package AJAX_Chat
+ * @author Sebastian Tschan
+ * @copyright (c) Sebastian Tschan
+ * @license Modified MIT License
+ * @link https://blueimp.net/ajax/
+ */
+
+// Class to initialize the MySQL DataBase connection:
+class AJAXChatDataBaseMySQL {
+
+	var $_connectionID;
+	var $_errno = 0;
+	var $_error = '';
+	var $_dbName;
+
+	function __construct(&$dbConnectionConfig) {
+		$this->_connectionID = $dbConnectionConfig['link'];
+		$this->_dbName = $dbConnectionConfig['name'];
+	}
+	
+	// Method to connect to the DataBase server:
+	function connect(&$dbConnectionConfig) {
+		$this->_connectionID = @mysql_connect(
+			$dbConnectionConfig['host'],
+			$dbConnectionConfig['user'],
+			$dbConnectionConfig['pass'],
+			true
+		);
+		if(!$this->_connectionID) {
+			$this->_errno = null;
+			$this->_error = 'Database connection failed.';
+			return false;
+		}
+		return true;
+	}
+	
+	// Method to select the DataBase:
+	function select($dbName) {
+		if(!@mysql_select_db($dbName, $this->_connectionID)) {
+			$this->_errno = mysql_errno($this->_connectionID);
+			$this->_error = mysql_error($this->_connectionID);
+			return false;
+		}
+		$this->_dbName = $dbName;
+		return true;	
+	}
+	
+	// Method to determine if an error has occured:
+	function error() {
+		return (bool)$this->_error;
+	}
+	
+	// Method to return the error report:
+	function getError() {
+		if($this->error()) {
+			$str = 'Error-Report: '	.$this->_error."\n";
+			$str .= 'Error-Code: '.$this->_errno."\n";
+		} else {
+			$str = 'No errors.'."\n";
+		}
+		return $str;		
+	}
+	
+	// Method to return the connection identifier:
+	function &getConnectionID() {
+		return $this->_connectionID;
+	}
+	
+	// Method to prevent SQL injections:
+	function makeSafe($value) {
+		return "'".mysql_real_escape_string($value, $this->_connectionID)."'";
+	}
+	
+	// Method to perform SQL queries:
+	function sqlQuery($sql) {
+		return new AJAXChatMySQLQuery($sql, $this->_connectionID);
+	}
+
+	// Method to retrieve the current DataBase name:
+	function getName() {
+		return $this->_dbName;
+	}
+
+	// Method to retrieve the last inserted ID:
+	function getLastInsertedID() {
+		return mysql_insert_id($this->_connectionID);
+	}
+
+}
+?>
+\ No newline at end of file