db.php

Ir a la documentación de este archivo.

<?php
require_once dirname(__FILE__) . '/db_base_interface.php';
require_once dirname(__FILE__) . '/db_base.php';

class Db
{

    protected static $_connections = array();

    public static function factory($database = null)
    {

        //Cargo el mode para mi aplicacion
        if (!$database) {
            $database = Config::get('config.application.database');
        }
        //Si no es una conexion nueva y existe la conexion singleton
        if (isset(self::$_connections[$database])) {
            return self::$_connections[$database];
        }

        return self::$_connections[$database] = self::connect($database);
    }

    private static function connect($database)
    {
        $databases = Config::read('databases');
        $config = $databases[$database];

        // carga los valores por defecto para la conexión, si no existen
        $default = array('port' => 0, 'dsn' => NULL, 'dbname' => NULL, 'host' => 'localhost', 'username' => NULL, 'password' => NULL);
        $config = $config + $default;
        $path = dirname(__FILE__); 

        //Si usa PDO
        if (isset($config['pdo'])) {
            $dbclass = "DbPdo{$config['type']}";
            $db_file = "$path/adapters/pdo/{$config['type']}.php";
        } else {
            if($config['type'] == 'mysql') $config['type'] = 'mysqli';
            $dbclass = "Db{$config['type']}";
            $db_file = "$path/adapters/{$config['type']}.php";
        }

        //Carga la clase adaptadora necesaria
        if (!include_once $db_file) {
            throw new KumbiaException("No existe la clase $dbclass, necesaria para iniciar el adaptador");
        }

        return new $dbclass($config);
    }

}