| @@ 81-90 (lines=10) @@ | ||
| 78 | * @return bool |
|
| 79 | * @throws Exception |
|
| 80 | */ |
|
| 81 | public function rollback() |
|
| 82 | { |
|
| 83 | try { |
|
| 84 | $this->log(Logger::DEBUG, 'Transaction rollback'); |
|
| 85 | return $this->getDriver()->rollBack(); |
|
| 86 | } catch (\PDOException $e) { |
|
| 87 | $this->log(Logger::ERROR, $e->getMessage(), array('error' => $e)); |
|
| 88 | throw new Exception($e->getMessage(), (int)$e->getCode(), $e); |
|
| 89 | } |
|
| 90 | } |
|
| 91 | ||
| 92 | /** |
|
| 93 | * @return mixed |
|
| @@ 124-133 (lines=10) @@ | ||
| 121 | * @return bool |
|
| 122 | * @throws Exception |
|
| 123 | */ |
|
| 124 | public function commit() |
|
| 125 | { |
|
| 126 | try { |
|
| 127 | $this->log(Logger::DEBUG, 'Transaction commit'); |
|
| 128 | return $this->getDriver()->commit(); |
|
| 129 | } catch (\PDOException $e) { |
|
| 130 | $this->log(Logger::ERROR, $e->getMessage(), array('error' => $e)); |
|
| 131 | throw new Exception($e->getMessage(), (int)$e->getCode(), $e); |
|
| 132 | } |
|
| 133 | } |
|
| 134 | ||
| 135 | /** |
|
| 136 | * Execute a statement for given values |
|
| @@ 182-190 (lines=9) @@ | ||
| 179 | * @return string |
|
| 180 | * @throws Exception |
|
| 181 | */ |
|
| 182 | public function lastInsertId($name = null) |
|
| 183 | { |
|
| 184 | try { |
|
| 185 | return $this->getDriver()->lastInsertId($name); |
|
| 186 | } catch (\PDOException $e) { |
|
| 187 | $this->log(Logger::ERROR, $e->getMessage(), array('error' => $e)); |
|
| 188 | throw new Exception($e->getMessage(), (int)$e->getCode(), $e); |
|
| 189 | } |
|
| 190 | } |
|
| 191 | ||
| 192 | /** |
|
| 193 | * Retrieve number of affected rows of a statement |
|