Subversion-Projekte lars-tiefland.laravel_shop

<?php namespace Clockwork\Storage;

use Clockwork\Request\Request;

use PDO;

// Rules for searching requests using SQL storage, builds the SQL query conditions

class SqlSearch extends Search

{

	// Generated SQL query and bindings

	public $query;

	public $bindings;

	// Internal representation of the SQL where conditions

	protected $conditions;

	// PDO instance

	protected $pdo;

	// Create a new instance, takes search parameters

	public function __construct($search = [], PDO $pdo = null)

	{

		parent::__construct($search);

		$this->pdo = $pdo;

		list($this->conditions, $this->bindings) = $this->resolveConditions();

		$this->buildQuery();

	}

	// Creates a new instance from a base Search class instance

	public static function fromBase(Search $search = null, PDO $pdo = null)

	{

		return new static((array) $search, $pdo);

	}

	// Add an additional where condition, takes the SQL condition and array of bindings

	public function addCondition($condition, $bindings = [])

	{

		$this->conditions = array_merge([ $condition ], $this->conditions);

		$this->bindings = array_merge($bindings, $this->bindings);

		$this->buildQuery();

		return $this;

	}

	// Resolve SQL conditions and bindings based on the search parameters

	protected function resolveConditions()

	{

		if ($this->isEmpty()) return [ [], [] ];

		$conditions = array_filter([

			$this->resolveStringCondition([ 'type' ], $this->type),

			$this->resolveStringCondition([ 'uri', 'commandName', 'jobName', 'testName' ], array_merge($this->uri, $this->name)),

			$this->resolveStringCondition([ 'controller' ], $this->controller),

			$this->resolveExactCondition([ 'method' ], $this->method),

			$this->resolveNumberCondition([ 'responseStatus', 'commandExitCode', 'jobStatus', 'testStatus' ], $this->status),

			$this->resolveNumberCondition([ 'responseDuration' ], $this->time),

			$this->resolveDateCondition([ 'time' ], $this->received)

		]);

		$sql = array_map(function ($condition) { return $condition[0]; }, $conditions);

		$bindings = array_reduce($conditions, function ($bindings, $condition) {

			return array_merge($bindings, $condition[1]);

		}, []);

		return [ $sql, $bindings ];

	}

	// Resolve a date type condition and bindings

	protected function resolveDateCondition($fields, $inputs)

	{

		if (! count($inputs)) return null;

		$bindings = [];

		$conditions = implode(' OR ', array_map(function ($field) use ($inputs, &$bindings) {

			return implode(' OR ', array_map(function ($input, $index) use ($field, &$bindings) {

				if (preg_match('/^<(.+)$/', $input, $match)) {

					$bindings["{$field}{$index}"] = $match[1];

					return $this->quote($field) . " < :{$field}{$index}";

				} elseif (preg_match('/^>(.+)$/', $input, $match)) {

					$bindings["{$field}{$index}"] = $match[1];

					return $this->quote($field). " > :{$field}{$index}";

				}

			}, $inputs, array_keys($inputs)));

		}, $fields));

		return [ "({$conditions})", $bindings ];

	}

	// Resolve an exact type condition and bindings

	protected function resolveExactCondition($fields, $inputs)

	{

		if (! count($inputs)) return null;

		$bindings = [];

		$values = implode(' OR ', array_map(function ($field) use ($inputs, &$bindings) {

			return implode(', ', array_map(function ($input, $index) use ($field, &$bindings) {

				$bindings["{$field}{$index}"] = $input;

				return ":{$field}{$index}";

			}, $inputs, array_keys($inputs)));

		}, $fields));

		return [ $this->quote($field) . " IN ({$values})", $bindings ];

	}

	// Resolve a number type condition and bindings

	protected function resolveNumberCondition($fields, $inputs)

	{

		if (! count($inputs)) return null;

		$bindings = [];

		$conditions = implode(' OR ', array_map(function ($field) use ($inputs, &$bindings) {

			return implode(' OR ', array_map(function ($input, $index) use ($field, &$bindings) {

				if (preg_match('/^<(\d+(?:\.\d+)?)$/', $input, $match)) {

					$bindings["{$field}{$index}"] = $match[1];

					return $this->quote($field) . " < :{$field}{$index}";

				} elseif (preg_match('/^>(\d+(?:\.\d+)?)$/', $input, $match)) {

					$bindings["{$field}{$index}"] = $match[1];

					return $this->quote($field) . " > :{$field}{$index}";

				} elseif (preg_match('/^(\d+(?:\.\d+)?)-(\d+(?:\.\d+)?)$/', $input, $match)) {

					$bindings["{$field}{$index}from"] = $match[1];

					$bindings["{$field}{$index}to"] = $match[2];

					$quotedField = $this->quote($field);

					return "({$quotedField} > :{$field}{$index}from AND {$quotedField} < :{$field}{$index}to)";

				} else {

					$bindings["{$field}{$index}"] = $input;

					return $this->quote($field) . " = :{$field}{$index}";

				}

			}, $inputs, array_keys($inputs)));

		}, $fields));

		return [ "({$conditions})", $bindings ];

	}

	// Resolve a string type condition and bindings

	protected function resolveStringCondition($fields, $inputs)

	{

		if (! count($inputs)) return null;

		$bindings = [];

		$conditions = implode(' OR ', array_map(function ($field) use ($inputs, &$bindings) {

			return implode(' OR ', array_map(function ($input, $index) use ($field, &$bindings) {

				$bindings["{$field}{$index}"] = $input;

				return $this->quote($field) . " LIKE :{$field}{$index}";

			}, $inputs, array_keys($inputs)));

		}, $fields));

		return [ "({$conditions})", $bindings ];

	}

	// Build the where part of the SQL query

	protected function buildQuery()

	{

		$this->query = count($this->conditions) ? 'WHERE ' . implode(' AND ', $this->conditions) : '';

	}

	// Quotes SQL identifier name properly for the current database

	protected function quote($identifier)

	{

		return $this->pdo && $this->pdo->getAttribute(PDO::ATTR_DRIVER_NAME) == 'mysql' ? "`{$identifier}`" : "\"{$identifier}\"";

	}

}