--- a/busui/owa/plugins/db/owa_db_mysql.php
+++ b/busui/owa/plugins/db/owa_db_mysql.php
@@ -1,1 +1,242 @@
+<?php
+
+//
+// Open Web Analytics - An Open Source Web Analytics Framework
+//
+// Copyright 2006 Peter Adams. All rights reserved.
+//
+// Licensed under GPL v2.0 http://www.gnu.org/copyleft/gpl.html
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// $Id$
+//
+
+
+define('OWA_DTD_BIGINT', 'BIGINT'); 
+define('OWA_DTD_INT', 'INT');
+define('OWA_DTD_TINYINT', 'TINYINT(1)');
+define('OWA_DTD_TINYINT2', 'TINYINT(2)');
+define('OWA_DTD_TINYINT4', 'TINYINT(4)');
+define('OWA_DTD_SERIAL', 'SERIAL');
+define('OWA_DTD_PRIMARY_KEY', 'PRIMARY KEY');
+define('OWA_DTD_VARCHAR10', 'VARCHAR(10)');
+define('OWA_DTD_VARCHAR255', 'VARCHAR(255)');
+define('OWA_DTD_VARCHAR', 'VARCHAR(%s)');
+define('OWA_DTD_TEXT', 'MEDIUMTEXT');
+define('OWA_DTD_BOOLEAN', 'TINYINT(1)');
+define('OWA_DTD_TIMESTAMP', 'TIMESTAMP');
+define('OWA_DTD_BLOB', 'BLOB');
+define('OWA_DTD_INDEX', 'KEY');
+define('OWA_DTD_AUTO_INCREMENT', 'AUTO_INCREMENT');
+define('OWA_DTD_NOT_NULL', 'NOT NULL');
+define('OWA_DTD_UNIQUE', 'PRIMARY KEY(%s)');
+define('OWA_SQL_ADD_COLUMN', 'ALTER TABLE %s ADD %s %s');   
+define('OWA_SQL_DROP_COLUMN', 'ALTER TABLE %s DROP %s');
+define('OWA_SQL_RENAME_COLUMN', 'ALTER TABLE %s CHANGE %s %s %s'); 
+define('OWA_SQL_MODIFY_COLUMN', 'ALTER TABLE %s MODIFY %s %s'); 
+define('OWA_SQL_RENAME_TABLE', 'ALTER TABLE %s RENAME %s'); 
+define('OWA_SQL_CREATE_TABLE', 'CREATE TABLE IF NOT EXISTS %s (%s) %s'); 
+define('OWA_SQL_DROP_TABLE', 'DROP TABLE IF EXISTS %s');  
+define('OWA_SQL_INSERT_ROW', 'INSERT into %s (%s) VALUES (%s)');
+define('OWA_SQL_UPDATE_ROW', 'UPDATE %s SET %s %s');
+define('OWA_SQL_DELETE_ROW', "DELETE from %s %s");
+define('OWA_SQL_CREATE_INDEX', 'CREATE INDEX %s ON %s (%s)');
+define('OWA_SQL_DROP_INDEX', 'DROP INDEX %s ON %s');
+define('OWA_SQL_INDEX', 'INDEX (%s)');
+define('OWA_SQL_BEGIN_TRANSACTION', 'BEGIN');
+define('OWA_SQL_END_TRANSACTION', 'COMMIT');
+define('OWA_DTD_TABLE_TYPE', 'ENGINE = %s');
+define('OWA_DTD_TABLE_TYPE_DEFAULT', 'INNODB');
+define('OWA_DTD_TABLE_TYPE_DISK', 'INNODB');
+define('OWA_DTD_TABLE_TYPE_MEMORY', 'MEMORY');
+define('OWA_SQL_ALTER_TABLE_TYPE', 'ALTER TABLE %s ENGINE = %s');
+define('OWA_SQL_JOIN_LEFT_OUTER', 'LEFT OUTER JOIN');
+define('OWA_SQL_JOIN_LEFT_INNER', 'LEFT INNER JOIN');
+define('OWA_SQL_JOIN_RIGHT_OUTER', 'RIGHT OUTER JOIN');
+define('OWA_SQL_JOIN_RIGHT_INNER', 'RIGHT INNER JOIN');
+define('OWA_SQL_JOIN', 'JOIN');
+define('OWA_SQL_DESCENDING', 'DESC');
+define('OWA_SQL_ASCENDING', 'ASC');
+define('OWA_SQL_REGEXP', 'REGEXP');
+define('OWA_SQL_NOTREGEXP', 'NOT REGEXP');
+define('OWA_SQL_LIKE', 'LIKE');
+define('OWA_SQL_ADD_INDEX', 'ALTER TABLE %s ADD INDEX (%s) %s');
+define('OWA_DTD_CHARACTER_ENCODING_UTF8', 'utf8');
+define('OWA_DTD_TABLE_CHARACTER_ENCODING', 'CHARACTER SET = %s');
+
+
+/**
+ * MySQL Data Access Class
+ * 
+ * @author      Peter Adams <peter@openwebanalytics.com>
+ * @copyright   Copyright &copy; 2006 Peter Adams <peter@openwebanalytics.com>
+ * @license     http://www.gnu.org/copyleft/gpl.html GPL v2.0
+ * @category    owa
+ * @package     owa
+ * @version		$Revision$	      
+ * @since		owa 1.0.0
+ */
+class owa_db_mysql extends owa_db {
+
+	function connect() {
+	
+		if (!$this->connection) {
+		
+			if ($this->getConnectionParam('persistant')) {
+				
+				$this->connection = mysql_pconnect(
+					$this->getConnectionParam('host'),
+					$this->getConnectionParam('user'),
+					$this->getConnectionParam('password'),
+					$this->getConnectionParam('open_new_connection')
+	    		);
+	    		
+			} else {
+				
+				$this->connection = mysql_connect(
+					$this->getConnectionParam('host'),
+					$this->getConnectionParam('user'),
+					$this->getConnectionParam('password'),
+					$this->getConnectionParam('open_new_connection')
+	    		);
+			}
+			
+			$this->database_selection = mysql_select_db($this->getConnectionParam('name'), $this->connection);
+			
+			if (function_exists('mysql_set_charset')) {
+				mysql_set_charset('utf8',$this->connection);
+			} else {
+				$this->query("SET NAMES 'utf8'");
+			}
+			
+		}
+			
+			
+		if (!$this->connection || !$this->database_selection) {
+			$this->e->alert('Could not connect to database.');
+			$this->connection_status = false;
+			return false;
+		} else {
+			$this->connection_status = true;
+			return true;
+		}
+	}
+	
+	
+	/**
+	 * Database Query
+	 *
+	 * @param 	string $sql
+	 * @access 	public
+	 * 
+	 */
+	function query($sql) {
+  
+  		if ($this->connection_status == false):
+  		owa_coreAPI::profile($this, __FUNCTION__, __LINE__);
+  			$this->connect();
+  		owa_coreAPI::profile($this, __FUNCTION__, __LINE__);
+  		endif;
+  
+  		owa_coreAPI::profile($this, __FUNCTION__, __LINE__);
+		$this->e->debug(sprintf('Query: %s', $sql));
+		
+		$this->result = '';
+		$this->new_result = '';	
+		
+		if (!empty($this->new_result)):
+			mysql_free_result($this->new_result);
+		endif;
+		owa_coreAPI::profile($this, __FUNCTION__, __LINE__, $sql);
+		$result = @mysql_unbuffered_query($sql, $this->connection);
+		owa_coreAPI::profile($this, __FUNCTION__, __LINE__);			
+		// Log Errors
+		if (mysql_errno($this->connection)):
+			$this->e->debug(sprintf('A MySQL error occured. Error: (%s) %s. Query: %s',
+			mysql_errno($this->connection),
+			htmlspecialchars(mysql_error($this->connection)),
+			$sql));
+		endif;			
+		owa_coreAPI::profile($this, __FUNCTION__, __LINE__);
+		$this->new_result = $result;
+		
+		return $this->new_result;
+		
+	}
+	
+	function close() {
+		
+		@mysql_close($this->connection);
+		return;
+		
+	}
+	
+	/**
+	 * Fetch result set array
+	 *
+	 * @param 	string $sql
+	 * @return 	array
+	 * @access  public
+	 */
+	function get_results($sql) {
+	
+		if ($sql):
+			$this->query($sql);
+		endif;
+	
+		$num_rows = 0;
+		
+		while ( $row = @mysql_fetch_assoc($this->new_result) ) {
+			$this->result[$num_rows] = $row;
+			$num_rows++;
+		}
+		
+		if ($this->result):
+					
+			return $this->result;
+			
+		else:
+			return null;
+		endif;
+	}
+	
+	/**
+	 * Fetch Single Row
+	 *
+	 * @param string $sql
+	 * @return array
+	 */
+	function get_row($sql) {
+		
+		$this->query($sql);
+		
+		//print_r($this->result);
+		$row = @mysql_fetch_assoc($this->new_result);
+		
+		return $row;
+	}
+	
+	/**
+	 * Prepares and escapes string
+	 *
+	 * @param string $string
+	 * @return string
+	 */
+	function prepare($string) {
+		
+		if ($this->connection_status == false):
+  			$this->connect();
+  		endif;
+		
+		return mysql_real_escape_string($string, $this->connection); 
+		
+	}
+}
+
+?>