- Add ::prepare to RunnableDelete/RunnableInsert/RunnableUpdate

Author: rkrx

src/Builder/Internal/DDLPreparable.php

@@ -0,0 +1,8 @@
+<?php
+namespace Kir\MySQL\Builder\Internal;
+
+interface DDLPreparable {
+	/**
+	 */
+	public function prepare();
+}

src/Builder/Internal/DDLRunnable.php

@@ -0,0 +1,32 @@
+<?php
+namespace Kir\MySQL\Builder\Internal;
+
+use Kir\MySQL\Database\DatabaseStatement;
+
+class DDLRunnable {
+	/** @var DatabaseStatement */
+	private $query;
+	/** @var callable */
+	private $callbackFn;
+
+	/**
+	 * @param DatabaseStatement $query
+	 * @param callable $callbackFn
+	 */
+	public function __construct(DatabaseStatement $query, callable $callbackFn = null) {
+		$this->query = $query;
+		$this->callbackFn = $callbackFn;
+	}
+
+	/**
+	 * @param array $params
+	 * @return mixed
+	 */
+	public function run(array $params = array()) {
+		$response = $this->query->execute($params);
+		if($this->callbackFn !== null) {
+			$response = call_user_func($this->callbackFn, $response);
+		}
+		return $response;
+	}
+}

src/Builder/RunnableDelete.php

@@ -1,13 +1,25 @@
 <?php
 namespace Kir\MySQL\Builder;
 
-class RunnableDelete extends Delete {
+use Kir\MySQL\Builder\Internal\DDLPreparable;
+use Kir\MySQL\Builder\Internal\DDLRunnable;
+use Kir\MySQL\Builder\Traits\CreateDDLRunnable;
+
+class RunnableDelete extends Delete implements DDLPreparable {
+	use CreateDDLRunnable;
+
 	/**
 	 * @param array $params
 	 * @return int
 	 */
 	public function run(array $params = array()) {
-		$query = (string)$this;
-		return $this->db()->exec($query, $params);
+		return $this->prepare()->run($params);
+	}
+
+	/**
+	 * @return DDLRunnable
+	 */
+	public function prepare() {
+		return $this->createPreparable($this->db()->prepare($this));
 	}
 }

src/Builder/RunnableInsert.php

@@ -2,9 +2,14 @@
 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 Traversable;
 
-class RunnableInsert extends Insert {
+class RunnableInsert extends Insert implements DDLPreparable {
+	use CreateDDLRunnable;
+
 	/**
 	 * @param array|Traversable $rows
 	 * @return int[] Insert IDs
@@ -24,14 +29,21 @@ public function insertRows($rows) {
 		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()) {
-		$query = $this->__toString();
-		$this->db()->exec($query, $params);
-		return (int) $this->db()->getLastInsertId();
+		return $this->prepare()->run($params);
 	}
 }

src/Builder/RunnableUpdate.php

@@ -1,7 +1,12 @@
 <?php
 namespace Kir\MySQL\Builder;
 
-class RunnableUpdate extends Update {
+use Kir\MySQL\Builder\Internal\DDLPreparable;
+use Kir\MySQL\Builder\Traits\CreateDDLRunnable;
+
+class RunnableUpdate extends Update implements DDLPreparable {
+	use CreateDDLRunnable;
+
 	/**
 	 * @param array $params
 	 * @return int
@@ -10,4 +15,10 @@ public function run(array $params = array()) {
 		$query = $this->__toString();
 		return $this->db()->exec($query, $params);
 	}
+
+	/**
+	 */
+	public function prepare() {
+		return $this->createPreparable($this->db()->prepare($this));
+	}
 }

src/Builder/Traits/CreateDDLRunnable.php

@@ -0,0 +1,17 @@
+<?php
+namespace Kir\MySQL\Builder\Traits;
+
+use Kir\MySQL\Builder\Internal\DDLRunnable;
+use Kir\MySQL\Database\DatabaseStatement;
+
+trait CreateDDLRunnable {
+	/**
+	 * @param DatabaseStatement $query
+	 * @param callback $callbackFn
+	 * @return DDLRunnable
+	 */
+	public function createPreparable(DatabaseStatement $query, callable $callbackFn = null) {
+		$runnable = new DDLRunnable($query, $callbackFn);
+		return $runnable;
+	}
+}

src/Databases/MySQL.php

@@ -73,7 +73,7 @@ public function query($query) {
 	 * @return QueryStatement
 	 */
 	public function prepare($query) {
-		return $this->buildQueryStatement($query, function ($query) {
+		return $this->buildQueryStatement((string) $query, function ($query) {
 			$stmt = $this->pdo->prepare($query);
 			return $stmt;
 		});