yolk\database\GenericConnectionManager

Complexity

Total Complexity

22

Size/Duplication

Total Lines	139
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	2
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	add()	0	16	3
A	remove()	0	4	1
A	get()	0	3	2
A	has()	0	3	1
A	getDefault()	0	3	1
A	setDefault()	0	10	2
A	create()	0	18	2
A	validateDSN()	0	10	4
A	createMySQL()	0	3	1
A	createPgSQL()	0	3	1
A	createSQLite()	0	3	1
A	checkName()	0	6	3

<?php
/*
 * This file is part of Yolk - Gamer Network's PHP Framework.
 *
 * Copyright (c) 2014 Gamer Network Ltd.
 * 
 * Distributed under the MIT License, a copy of which is available in the
 * LICENSE file that was bundled with this package, or online at:
 * https://github.com/gamernetwork/yolk-database
 */

namespace yolk\database;

use yolk\contracts\database\DatabaseConnection;
use yolk\contracts\database\ConnectionManager;

use yolk\database\exceptions\DatabaseException;
use yolk\database\exceptions\ConfigurationException;

class GenericConnectionManager implements ConnectionManager {

	/**
	 * Array of database connections
	 * @var []
	 */
	protected $connections = [];

	/**
	 * Name of the default connection.
	 * @var string
	 */
	protected $default = '';

	public function add( $name, $connection ) {

		$this->checkName($name);

		if( $connection instanceof DatabaseConnection )
			$this->connections[$name] = $connection;
		else
			$this->connections[$name] = $this->create($connection);

		// no default connection so use the first one
		if( !$this->default )
			$this->default = $name;

		return $this->connections[$name];

	}

	public function remove( $name ) {
		unset($this->connections[$name]);
		return $this;
	}

	public function get( $name ) {
		return isset($this->connections[$name]) ? $this->connections[$name] : null;
	}

	public function has( $name ) {
		return isset($this->connections[$name]);
	}

	public function getDefault() {
		return $this->connections[$this->default];
	}

	public function setDefault( $name ) {

		if( !isset($this->connections[$name]) )
			throw new \InvalidArgumentException("Unknown Connection: {$name}");

		$this->default = $name;

		return $this;

	}

	/**
	 * Create a suitable implementation of DatabaseConnection based on the specified DSN.
	 * @param  mixed $dsn
	 * @return DatabaseConnection
	 */
	protected function create( $dsn ) {

		$dsn = $this->validateDSN($dsn);

		$factories = [
			DSN::TYPE_MYSQL  => 'createMySQL',
			DSN::TYPE_PGSQL  => 'createPgSQL',
			DSN::TYPE_SQLITE => 'createSQLite',
		];

		if( !isset($factories[$dsn->type]) )
			throw new ConfigurationException('Invalid database type: '. $dsn->type);

		$factory = $factories[$dsn->type];

		return $this->$factory($dsn);

	}

	/**
	 * Ensure we have a valid DSN instance.
	 * @param  mixed $dsn a string, array or DSN instance
	 * @return DSN
	 */
	protected function validateDSN( $dsn ) {
		if( $dsn instanceof DSN )
			return $dsn;
		elseif( is_string($dsn) )
			return DSN::fromString($dsn);
		elseif( is_array($dsn) )
			return new DSN($dsn);
		else
			throw new ConfigurationException('Invalid DSN: '. $dsn);
	}

	/**
	 * Create a MySQL connection.
	 * @param  DSN    $dsn
	 * @return adapters\MySQLConnection
	 */
	protected function createMySQL( DSN $dsn ) {
		return new adapters\MySQLConnection($dsn);
	}

	/**
	 * Create a PgSQL connection.
	 * @param  DSN    $dsn
	 * @return adapters\PgSQLConnection
	 */
	protected function createPgSQL( DSN $dsn ) {
		return new adapters\PgSQLConnection($dsn);
	}

	/**
	 * Create a SQLite connection.
	 * @param  DSN    $dsn
	 * @return adapters\SQLiteConnection
	 */
	protected function createSQLite( DSN $dsn ) {
		return new adapters\SQLiteConnection($dsn);
	}

	/**
	 * Ensure we have a valid connection name, i.e. it's not empty and doesn't already exist.
	 * @param  string $name
	 * @return void
	 */
	protected function checkName( $name ) {
		if( !$name )
			throw new DatabaseException('Managed database connections must have a name');
		if( $this->has($name) )
			throw new DatabaseException('Connection already exists with name: '. $name);
	}

}

// EOF