Aimeos\MW\DB\Statement\DBAL\Simple

Complexity

Total Complexity

16

Size/Duplication

Total Lines	114
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
C	bind()	0	24	7
B	execute()	0	23	4
A	__toString()	0	8	2
A	exec()	0	8	2

<?php

/**
 * @license LGPLv3, http://opensource.org/licenses/LGPL-3.0
 * @copyright Aimeos (aimeos.org), 2016
 * @package MW
 * @subpackage DB
 */


namespace Aimeos\MW\DB\Statement\DBAL;


/**
 * Database statement class for simple DBAL statements
 *
 * @package MW
 * @subpackage DB
 */
class Simple extends \Aimeos\MW\DB\Statement\Base implements \Aimeos\MW\DB\Statement\Iface
{
	private $binds = [];
	private $parts;
	private $sql;


	/**
	 * Initializes the statement object
	 *
	 * @param \Aimeos\MW\DB\Connection\DBAL $conn Database connection object
	 * @param string $sql SQL statement
	 */
	public function __construct( \Aimeos\MW\DB\Connection\DBAL $conn, $sql )
	{
		parent::__construct( $conn );

		$this->parts = $this->getSqlParts( $sql );
	}


	/**
	 * Binds a value to a parameter in the statement.
	 *
	 * @param integer $position Position index of the placeholder
	 * @param mixed $value Value which should be bound to the placeholder
	 * @param integer $type Type of given value defined in \Aimeos\MW\DB\Statement\Base as constant
	 */
	public function bind( $position, $value, $type = \Aimeos\MW\DB\Statement\Base::PARAM_STR )
	{
		if( is_null( $value ) ) {
			$this->binds[$position] = 'NULL'; return;
		}

		switch( $type )
		{
			case \Aimeos\MW\DB\Statement\Base::PARAM_NULL:
				$this->binds[$position] = 'NULL'; break;
			case \Aimeos\MW\DB\Statement\Base::PARAM_BOOL:
				$this->binds[$position] = (int) (bool) $value; break;
			case \Aimeos\MW\DB\Statement\Base::PARAM_INT:
				$this->binds[$position] = (int) $value; break;
			case \Aimeos\MW\DB\Statement\Base::PARAM_FLOAT:
				$this->binds[$position] = (float) $value; break;
			case \Aimeos\MW\DB\Statement\Base::PARAM_STR:
				$this->binds[$position] = $this->getConnection()->getRawObject()->quote( $value ); break;
			default:
				throw new \Aimeos\MW\DB\Exception( sprintf( 'Invalid parameter type "%1$s"', $type ) );
		}

		$this->sql = null;
	}


	/**
	 * Executes the statement.
	 *
	 * @return \Aimeos\MW\DB\Result\Iface Result object
	 * @throws \Aimeos\MW\DB\Exception If an error occured in the unterlying driver or if the number of binds doesn't match
	 */
	public function execute()
	{
		if( count( $this->binds ) !== count( $this->parts ) - 1 )
		{
			$msg = 'Number of binds (%1$d) doesn\'t match the number of markers in "%2$s"';
			throw new \Aimeos\MW\DB\Exception( sprintf( $msg, count( $this->binds ), implode( '?', $this->parts ) ) );
		}

		try
		{
			$result = $this->exec();
		}
		catch( \Doctrine\DBAL\DBALException $e )
		{
			try {
				$result = $this->reconnect( $e )->exec();
			} catch( \Doctrine\DBAL\DBALException $e ) {
				throw new \Aimeos\MW\DB\Exception( $e->getMessage(), $e->getCode() );
			}
		}

		return new \Aimeos\MW\DB\Result\DBAL( $result );
	}


	/**
	 * Returns the SQL string as sent to the database (magic PHP method)
	 *
	 * @return string SQL statement

Should the return type not be string|null?

	 */
	public function __toString()
	{
		if( $this->sql === null ) {
			$this->sql = $this->buildSQL( $this->parts, $this->binds );
		}

		return $this->sql;
	}


	/**
	 * Binds the parameters and executes the SQL statment
	 *
	 * @return \Doctrine\DBAL\Driver\Statement Executed DBAL statement
	 */
	protected function exec()
	{
		if( $this->sql === null ) {
			$this->sql = $this->buildSQL( $this->parts, $this->binds );
		}

		return $this->getConnection()->getRawObject()->query( $this->sql );
	}
}