Veles\DataBase\Connections\PdoConnection

Complexity

Total Complexity

10

Size/Duplication

Total Lines	115
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	setDsn()	0	4	1
A	getOptions()	0	3	1
A	getCallbacks()	0	3	1
A	setOptions()	0	4	1
A	getDsn()	0	6	2
A	create()	0	18	3
A	setCallback()	0	7	1

<?php
/**
 * PDO connection class
 *
 * @file      PdoConnection.php
 *
 * PHP version 8.0+
 *
 * @author    Alexander Yancharuk <alex at itvault dot info>
 * @copyright © 2012-2021 Alexander Yancharuk
 * @date      2013-12-31 15:44
 * @license   The BSD 3-Clause License
 *            <https://tldrlegal.com/license/bsd-3-clause-license-(revised)>
 */

namespace Veles\DataBase\Connections;

use Exception;

/**
 * Class PdoConnection
 *
 * Class-container for PDO connection and it's options
 *
 * @author  Alexander Yancharuk <alex at itvault dot info>
 */
class PdoConnection extends DbConnection
{
	/** @var string */
	protected $dsn;
	/** @var array */
	protected $options;
	/** @var array */
	protected $callbacks = [];
	/** @var string */
	protected $driver = '\PDO';

	/**
	 * Create connection
	 *
	 * @return \PDO
	 * @throws Exception
	 */
	public function create()
	{
		$this->resource = new $this->driver(
			$this->getDsn(), $this->getUserName(),
			$this->getPassword(), $this->getOptions()
		);

		if ([] === $this->callbacks) {
			return $this->resource;
		}

		foreach ($this->callbacks as $call) {
			call_user_func_array(
				[$this->resource, $call['method']], $call['arguments']
			);
		}

		return $this->resource;
	}

	/**
	 * Set connection DSN (Data Source Name)
	 *
	 * @param string $dsn
	 *
	 * @return $this
	 */
	public function setDsn($dsn)
	{
		$this->dsn = $dsn;
		return $this;
	}

	/**
	 * Get connection DSN (Data Source Name)
	 *
	 * @throws Exception
	 *
	 * @return string
	 */
	public function getDsn()
	{
		if (null === $this->dsn) {
			throw new Exception('Connection DSN not set.');
		}
		return $this->dsn;
	}

	/**
	 * Set connection options
	 *
	 * @param array $options
	 *
	 * @return $this
	 */
	public function setOptions(array $options)
	{
		$this->options = $options;
		return $this;
	}

	/**
	 * Get connection options
	 *
	 * @throws Exception
	 *
	 * @return array
	 */
	public function getOptions()
	{
		return $this->options;
	}

	/**
	 * Get connection callbacks
	 *
	 * @return array
	 */
	public function getCallbacks()
	{
		return $this->callbacks;
	}

	/**
	 * Save calls for future invocation
	 *
	 * @param string $method Method name that should be called
	 * @param array $arguments Method arguments
	 *
	 * @return $this
	 */
	public function setCallback($method, array $arguments)
	{
		$this->callbacks[] = [
			'method'    => $method,
			'arguments' => $arguments
		];
		return $this;
	}
}