Kir\MySQL\Builder\RunnableInsert

Complexity

Total Complexity

7

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	insertRows()	0	14	4
A	prepare()	0	5	1
A	run()	0	3	1

<?php
namespace Kir\MySQL\Builder;

use BadMethodCallException;
use Kir\MySQL\Builder\Internal\DDLPreparable;
use Kir\MySQL\Builder\Internal\DDLRunnable;
use Kir\MySQL\Builder\Traits\CreateDDLRunnable;
use Kir\MySQL\Databases\MySQL;
use Traversable;

class RunnableInsert extends Insert implements DDLPreparable {
	use CreateDDLRunnable;
	
	/**
	 * @param MySQL $db
	 * @param array $options
	 */
	public function __construct(MySQL $db, array $options = []) {

The parameter $options is not used and could be removed.

		parent::__construct($db);
	}

	/**
	 * @param array|Traversable $rows
	 * @return int[] Insert IDs
	 */
	public function insertRows($rows) {
		if (!(is_array($rows) || $rows instanceof Traversable)) {
			throw new BadMethodCallException('Expected $rows to by an array or an instance of \\Traversable');
		}
		$result = [];
		$query = $this->__toString();
		$stmt = $this->db()->prepare($query);
		foreach ($rows as $row) {
			$stmt->execute($row);
			$result[] = (int) $this->db()->getLastInsertId();
		}
		$stmt->closeCursor();
		return $result;
	}

	/**
	 * @return DDLRunnable
	 */
	public function prepare() {
		return $this->createPreparable($this->db()->prepare($this), function() {
			return (int) $this->db()->getLastInsertId();
		});
	}

	/**
	 * @param array $params
	 * @return int
	 * @throws Exception
	 */
	public function run(array $params = array()) {
		return $this->prepare()->run($params);
	}
}