- Added $params to Runnable{Delete|Insert|Update}::run() for Prepared Statements

Author: rkrx

src/Builder/RunnableDelete.php

@@ -3,10 +3,11 @@
 
 class RunnableDelete extends Delete {
 	/**
+	 * @param array $params
 	 * @return int
 	 */
-	public function run() {
+	public function run(array $params = array()) {
 		$query = (string)$this;
-		return $this->db()->exec($query);
+		return $this->db()->exec($query, $params);
 	}
 }

src/Builder/RunnableInsert.php

@@ -18,10 +18,13 @@ public function insertRows(array $rows) {
 	}
 
 	/**
+	 * @param array $params
+	 * @return int
+	 * @throws Exception
 	 */
-	public function run() {
+	public function run(array $params = array()) {
 		$query = $this->__toString();
-		$this->db()->exec($query);
+		$this->db()->exec($query, $params);
 		return (int) $this->db()->getLastInsertId();
 	}
 }

src/Builder/RunnableUpdate.php

@@ -3,10 +3,11 @@
 
 class RunnableUpdate extends Update {
 	/**
+	 * @param array $params
 	 * @return int
 	 */
-	public function run() {
+	public function run(array $params = array()) {
 		$query = $this->__toString();
-		return $this->db()->exec($query);
+		return $this->db()->exec($query, $params);
 	}
 }

src/Databases/MySQL.php

@@ -87,17 +87,18 @@ public function prepare($query) {
 	 * @return int
 	 */
 	public function exec($query, array $params = array()) {
-		$stmt = $this->pdo->prepare($query);
-		$timer = microtime(true);
 		try {
+			$stmt = $this->pdo->prepare($query);
+			$timer = microtime(true);
 			$stmt->execute($params);
+			$this->queryLoggers->log($query, microtime(true) - $timer);
+			$result = $stmt->rowCount();
+			$stmt->closeCursor();
+			return $result;
 		} catch (PDOException $e) {
 			$this->exceptionInterpreter->throwMoreConcreteException($e);
+			throw $e;
 		}
-		$this->queryLoggers->log($query, microtime(true) - $timer);
-		$result = $stmt->rowCount();
-		$stmt->closeCursor();
-		return $result;
 	}
 
 	/**