@@ -7,7 +7,7 @@ discard block |
||
7 | 7 | |
8 | 8 | public function __construct(\PDO $pdo) { |
9 | 9 | $this->pdo = $pdo; |
10 | - $this->stmtCache = new StmtCache($pdo); |
|
10 | + $this->stmtCache = new StmtCache($pdo); |
|
11 | 11 | } |
12 | 12 | |
13 | 13 | public function quote($str) { |
@@ -15,19 +15,19 @@ discard block |
||
15 | 15 | } |
16 | 16 | |
17 | 17 | public function query(\Maphper\Lib\Query $query) { |
18 | - $stmt = $this->stmtCache->getCachedStmt($query->getSql()); |
|
18 | + $stmt = $this->stmtCache->getCachedStmt($query->getSql()); |
|
19 | 19 | $args = $query->getArgs(); |
20 | 20 | |
21 | - //Handle SQLite when PDO_ERRMODE is set to SILENT |
|
22 | - if ($stmt === false) throw new \Exception('Invalid query'); |
|
21 | + //Handle SQLite when PDO_ERRMODE is set to SILENT |
|
22 | + if ($stmt === false) throw new \Exception('Invalid query'); |
|
23 | 23 | |
24 | - $stmt->execute($args); |
|
25 | - if ($stmt->errorCode() !== '00000' && $stmt->errorInfo()[2] == 'database schema has changed') { |
|
24 | + $stmt->execute($args); |
|
25 | + if ($stmt->errorCode() !== '00000' && $stmt->errorInfo()[2] == 'database schema has changed') { |
|
26 | 26 | $this->stmtCache->deleteQueryFromCache($query->getSql()); |
27 | 27 | return $this->query($query); |
28 | - } |
|
28 | + } |
|
29 | 29 | |
30 | - return $stmt; |
|
30 | + return $stmt; |
|
31 | 31 | } |
32 | 32 | |
33 | 33 | public function lastInsertId() { |