miBadger\ActiveRecord\AbstractActiveRecordSearch

Complexity

Total Complexity

11

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes	3
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
B	search()	0	26	3
C	getSearchQuery()	0	23	8

<?php

/**
 * This file is part of the miBadger package.
 *
 * @author Michael Webbers <michael@webbers.io>
 * @license http://opensource.org/licenses/Apache-2.0 Apache v2 License
 * @version 1.0.0
 */

namespace miBadger\ActiveRecord;

/**
 * The abstract active record search class.
 *
 * @since 1.0.0
 */
abstract class AbstractActiveRecordSearch extends AbstractActiveRecord
{
	/**
	 * {@inheritdoc}
	 */
	public function search($options = [])
	{
		$pdoStatement = $this->getPdo()->prepare($this->getSearchQuery($options));
		array_walk_recursive($options, function (&$value) use ($pdoStatement) {
			static $index = 1;

			$pdoStatement->bindParam($index++, $value);
		});

		$pdoStatement->execute();
		$result = [];

		while ($row = $pdoStatement->fetch()) {
			$new = new static($this->getPdo());
			$new->setId(intval($row['id']));
			$data = $new->getActiveRecordData();

			foreach ($data as $key => &$value) {
				$value = $row[$key];
			}

			$result[] = $new;
		}

		return $result;
	}

	/**
	 * Returns the search query with the given options.
	 *
	 * @param array $options = []
	 * @return string the search query with the given options.
	 */
	private function getSearchQuery($options = [])
	{
		$columns = array_keys($this->getActiveRecordData());
		$values = [];

		foreach ($options as $key => $value) {
			if (!in_array($key, $columns)) {
				throw new ActiveRecordException('Invalid option key.');
			}

			if (is_int($value)) {
				$values[] = $key . ' = ?';
			} elseif (is_string($value)) {
				$values[] = $key . ' LIKE ?';
			} elseif(is_array($value) && !empty($value)) {
				$values[] = $key . ' IN(' . implode(',', array_fill(0, count($value), '?')) . ')';
			} else {
				throw new ActiveRecordException('Invalid option value.');
			}
		}

		return sprintf('SELECT * FROM %s %s %s', $this->getActiveRecordName(), empty($values) ? '' : 'WHERE', implode(' AND ', $values));
	}
}