DSNManager.inc

<?php
require_once dirname(__FILE__).'/DSN.inc';
require_once dirname(__FILE__).'/DSNPool.inc';

class DSNManager
{
    
    
    private static $_dsnpool_supported_conns = Array('db', 'dbsearch');
    
    private static $_dsns = Array();
    
    
    public static function addDSN($conn_id = 'db', Array $dsn)
    {
        // If the DSN of the provided connection is already in the list, return FALSE immediately.
        if (isset(self::$_dsns[$conn_id])) {
            return FALSE;
        }
        
        // Parse the DSN to convert the one entry DSN array to a DSN
        self::_parseDSN($dsn);
        
        // If the DSN is a DSN array, create a DSNPool for it
        if (self::_isDSNArray($dsn)) {
            // Throw an exception if this connection does not support DSN Pool
            if (!self::isDSNPoolSupportedConnection($conn_id)) {
                throw new DALException("The connection '$conn_id' does not support DSN Pool.");
            }
            
            $new_dsn = new DSNPool($dsn);
        } else {
            $new_dsn = new DSN($dsn);
        }
        
        // Add the DSN or DSNPool object to the DSN list
        self::$_dsns[$conn_id] = $new_dsn;
        
        return TRUE;
        
    }//end addDSN()
    
    
    public static function getDSN($conn_id = 'db')
    {
        if (!isset(self::$_dsns[$conn_id])) {
            return NULL;
        }
        
        return self::$_dsns[$conn_id]->getDSN();
        
    }//end getDSN()
    
    
    public static function registerDSNFailure($conn_id = 'db')
    {
        if (self::isDSNPool($conn_id)) {
            self::$_dsns[$conn_id]->registerFailureDSN();
        }
        
    }//end registerDSNFailure()
    
    
    public static function isDSNPool($conn_id = 'db')
    {
        if (!isset(self::$_dsns[$conn_id])) {
            return FALSE;
        }
        
        return (self::$_dsns[$conn_id] instanceof DSNPool);
        
    }//end isDSNPool()
    
    
    public static function isDSNPoolSupportedConnection($conn_id = 'db')
    {
        return in_array($conn_id, self::$_dsnpool_supported_conns);
        
    }//end isDSNPoolSupportedConnection()
    
    
    private static function _parseDSN(&$dsn)
    {
        if (self::_isDSNArray($dsn) && (count($dsn) == 1)) {
            $dsn = $dsn[0];
        }
        
    }//end _parseDSN()
    
    
    private static function _isDSNArray($dsn)
    {
        return !isset($dsn['DSN']);
        
    }//end _isDSNArray()
    
    
}//end class


?>