current state as framework

drivers/DatabaseDriver.inc

@@ -0,0 +1,81 @@
+<?php
+
+	/**
+	 * NRE
+	 *
+	 * @author	coderkun <olli@coderkun.de>
+	 * @copyright	2013 coderkun (http://www.coderkun.de)
+	 * @license	http://www.gnu.org/licenses/gpl.html
+	 * @link	http://www.coderkun.de/projects/nre
+	 */
+	
+	namespace nre\drivers;
+	
+	
+	/**
+	 * Abstract class for implementing a database driver.
+	 * 
+	 * @author	coderkun <olli@coderkun.de>
+	 */
+	abstract class DatabaseDriver extends \nre\core\Driver
+	{
+		/**
+		 * Connection and login settings
+		 * 
+		 * @var array
+		 */
+		protected $config;
+		/**
+		 * Connection resource
+		 * 
+		 * @var resource
+		 */
+		protected $connection = null;
+		
+		
+		
+		
+		/**
+		 * Execute a SQL-query.
+		 * 
+		 * @param	string	$query	Query to run
+		 * @return	array		Result
+		 */
+		public abstract function query($query);
+		
+				
+		/**
+		 * Return the last insert id (of the last insert-query).
+		 * 
+		 * @return	int	Last insert id
+		 */
+		public abstract function getInsertId();
+		
+		
+		/**
+		 * Mask an input for using it in a SQL-query.
+		 * 
+		 * @param	mixed	$input	Input to mask
+		 * @return	mixed		Masked input
+		 */
+		public abstract function mask($input);
+		
+		
+		
+		
+		/**
+		 * Construct a new database driver.
+		 * 
+		 * @param	array	$config	Connection and login settings
+		 */
+		protected function __construct($config)
+		{
+			parent::__construct();
+			
+			// Save values
+			$this->config = $config;
+		}
+		
+	}
+
+?>

drivers/MysqlDriver.inc

@@ -0,0 +1,153 @@
+<?php
+
+	/**
+	 * NRE
+	 *
+	 * @author	coderkun <olli@coderkun.de>
+	 * @copyright	2013 coderkun (http://www.coderkun.de)
+	 * @license	http://www.gnu.org/licenses/gpl.html
+	 * @link	http://www.coderkun.de/projects/nre
+	 */
+	
+	namespace nre\drivers;
+	
+	
+	/**
+	 * Implementation of a database driver for MySQL-databases.
+	 * 
+	 * @author	coderkun <olli@coderkun.de>
+	 */
+	class MysqlDriver extends \nre\drivers\DatabaseDriver
+	{
+		
+		
+		
+		
+		/**
+		 * Construct a MySQL-driver.
+		 * 
+		 * @throws	DatamodelException
+		 * @param	array	$config	Connection and login settings
+		 */
+		function __construct($config)
+		{
+			parent::__construct($config);
+			
+			// Connect
+			$this->connect();
+		}
+		
+		
+		
+		
+		/**
+		 * Execute a SQL-query.
+		 * 
+		 * @param	string	$query	Query to run
+		 * @return	array		Result
+		 */
+		public function	query($query)
+		{
+			// Return-array
+			$data = array();
+			
+			
+			// Execute query
+			$result = mysql_query($query, $this->connection);
+			
+			// Check result
+			if(($errno = mysql_errno($this->connection)) > 0) {
+				throw new DatamodelException(mysql_error($this->connection), $errno);
+			}
+			
+			// Process result
+			if(is_resource($result))
+			{
+				while($row = mysql_fetch_array($result, MYSQL_ASSOC)) {
+					$data[] = $row;
+				}
+			}
+			
+			
+			// Return data
+			return $data;
+		}
+		
+		
+		/**
+		 * Return the last insert id (of the last insert-query).
+		 * 
+		 * @return	int	Last insert id
+		 */
+		public function getInsertId()
+		{
+			return mysql_insert_id($this->connection);
+		}
+		
+		
+		/**
+		 * Mask an input for using it in a SQL-query.
+		 * 
+		 * @param	mixed	$input	Input to mask
+		 * @return	mixed		Masked input
+		 */
+		public function mask($input)
+		{
+			return mysql_real_escape_string($input, $this->connection);
+		}
+		
+		
+		
+		
+		/**
+		 * Establish a connect to a MqSQL-database.
+		 * 
+		 * @throws	DatamodelException
+		 */
+		private function connect()
+		{
+			// Connect
+			$con = @mysql_connect(
+				$this->config['host'],
+				$this->config['user'],
+				$this->config['password']
+			);
+			
+			// Check connection
+			if($con === false) {
+				throw new \nre\exceptions\DatamodelException(mysql_error(), mysql_errno());
+			}
+			
+			// Save connection
+			$this->connection = $con;
+			
+			
+			// Select database
+			$db = mysql_select_db(
+				$this->config['db'],
+				$this->connection
+			);
+			
+			// Check database selection
+			if(!$db) {
+				throw new DatamodelException(mysql_error(), mysql_errno());
+			}
+			
+			
+			// Configure connection
+			$this->configConnection();
+		}
+		
+		
+		/**
+		 * Configure the current connection
+		 */
+		private function configConnection()
+		{
+			// Set character encoding
+			$this->query("SET NAMES 'utf8'", $this->connection);
+		}
+		
+	}
+
+?>