Connect.php

<?php

namespace dc\yukon;

require_once(dirname(__FILE__).'\config.php');

// Database connection object.
interface iConnect 
{	
	function get_config();
	function get_connection();					// Return database connection resource.
	function set_config(ConnectConfig $value);	// Set config object.
	function close_connection();				// Close current connection.
	function open_connection();					// Attempt database connection.
}

// Database host connection manager.
class Connect implements iConnect 
{			
	private
		$connect	= NULL,	// Database connection resource.
		$config		= NULL;	// Connection parameters object.
			
	public function __construct(ConnectConfig $connect = NULL)
	{			
		// Set connection parameters member. If no argument
		// is provided, then create a blank connection
		// parameter instance.
		if($connect)
		{
			$this->set_config($connect);
		}
		else
		{
			$this->set_config(new ConnectConfig);
		}
	
		// Connect to database server.
		$this->open_connection();
	}
	
	public function __destruct() 
	{		
		// Close DB connection.
		// $this->close_connection();
   	}
	
	// Accessors.
	public function get_config()
	{
		return $this->config;
	}
	
	public function get_connection()
	{	
		return $this->connect;
	}
	
	// Mutators
	public function set_config(ConnectConfig $value)
	{
		$this->config = $value;
	}
	
	// Connect to database host. Returns connection.
	public function open_connection()
	{			
		$connect = NULL; // Database connection reference.
		$db_cred = NULL; // Credentials array.
		
		$config	= $this->config;
		$error	= $config->get_error();
				
		// Set up credential array.
		$db_cred = array('Database'	=> $config->get_name(), 
				'UID' 		=> $config->get_user(), 
				'PWD' 		=> $config->get_password(),
				'CharacterSet' 	=> $config->get_charset());	
		
		try 
		{
			// Can't connect if there's no host.
			if(!$config->get_host())
			{
				$msg = EXCEPTION_MSG::CONNECT_OPEN_HOST;
				$msg .= ', Host: '.$config->get_host();
				$msg .= ', DB: '.$config->get_name();
				
				$error->exception_throw(new Exception($msg, EXCEPTION_CODE::CONNECT_OPEN_HOST));				
			}
			
			// Establish database connection.
			//$connect = sqlsrv_connect($config->get_host(), $db_cred);
			
			// PDO requires a single concatenated string 
			// containing the type (MYSQL, MSSQL, etc.), 
			// hostname, and database name.
			$dsn = 'sqlsrv:Server='.$config->get_host().';Database='.$config->get_name();
						
			$connect = new \PDO($dsn, $config->get_user(), $config->get_password());
			
			// False returned. Database connection has failed.
			if(!$connect)
			{
				$error->exception_throw(new Exception(EXCEPTION_MSG::CONNECT_OPEN_FAIL, EXCEPTION_CODE::CONNECT_OPEN_FAIL));
			}			
		}		
		catch (\PDOException $pdo_exception)
		{
			// PDO always throws an exception on connect fail.
			// Let's just catch it here since sending it
			// on to our custom exception handler isn't really
			// tennable at the moment. Hopefully fix that soon. :)
			
			echo('<br />');
			echo('<b>'.LIBRARY::NAME.' error code '.EXCEPTION_CODE::CONNECT_OPEN_FAIL.": </b>");
			echo(EXCEPTION_MSG::CONNECT_OPEN_FAIL);
			echo('<br />');
			
			error_log($pdo_exception->getMessage());
		}
		catch (Exception $exception) 
		{		
			// Send to catch.
			$error->exception_catch();
		}
		
		// Set connect data
		$this->connect = $connect;
		
		return $connect;
	}
	
	// Close database connection and returns TRUE, or 
	// return FALSE if connection does not exist.
	public function close_connection()
	{
		/*
		$result 	= FALSE;					// Connection present and closed?
		$connect 	= $this->connect;			// Database connection.
		$config		= $this->config;
		$error		= $config->get_error();
		
		try 
		{
			// Can't close if there is no connection.
			if(!$connect)
			{
				$error->exception_throw(new Exception(EXCEPTION_MSG::CONNECT_CLOSE_CONNECTION, EXCEPTION_CODE::CONNECT_CLOSE_CONNECTION));				
			}
			
			// Close database connection.
			$result = sqlsrv_close($connect);

			// Verify we were able to disconnect, else throw exception.
			if($result)
			{	
				// Clean connection member.
				$this->connect = NULL;
			}
			else
			{
				$error->exception_throw(new Exception(EXCEPTION_MSG::CONNECT_CLOSE_FAIL, EXCEPTION_CODE::CONNECT_CLOSE_FAIL));
			}
			
		}
		catch (Exception $exception) 
		{			
			// Send to application catch.
			$error->exception_catch();
			
		}
		return $result;
		*/	
		
		return TRUE;
	}
}

?>