| @@ 1263-1279 (lines=17) @@ | ||
| 1260 | ||
| 1261 | $logger = $this->_config->getSQLLogger(); |
|
| 1262 | ||
| 1263 | if ($this->_transactionNestingLevel == 1) { |
|
| 1264 | if ($logger) { |
|
| 1265 | $logger->startQuery('"START TRANSACTION"'); |
|
| 1266 | } |
|
| 1267 | $this->_conn->beginTransaction(); |
|
| 1268 | if ($logger) { |
|
| 1269 | $logger->stopQuery(); |
|
| 1270 | } |
|
| 1271 | } elseif ($this->_nestTransactionsWithSavepoints) { |
|
| 1272 | if ($logger) { |
|
| 1273 | $logger->startQuery('"SAVEPOINT"'); |
|
| 1274 | } |
|
| 1275 | $this->createSavepoint($this->_getNestedTransactionSavePointName()); |
|
| 1276 | if ($logger) { |
|
| 1277 | $logger->stopQuery(); |
|
| 1278 | } |
|
| 1279 | } |
|
| 1280 | } |
|
| 1281 | ||
| 1282 | /** |
|
| @@ 1303-1319 (lines=17) @@ | ||
| 1300 | ||
| 1301 | $logger = $this->_config->getSQLLogger(); |
|
| 1302 | ||
| 1303 | if ($this->_transactionNestingLevel == 1) { |
|
| 1304 | if ($logger) { |
|
| 1305 | $logger->startQuery('"COMMIT"'); |
|
| 1306 | } |
|
| 1307 | $this->_conn->commit(); |
|
| 1308 | if ($logger) { |
|
| 1309 | $logger->stopQuery(); |
|
| 1310 | } |
|
| 1311 | } elseif ($this->_nestTransactionsWithSavepoints) { |
|
| 1312 | if ($logger) { |
|
| 1313 | $logger->startQuery('"RELEASE SAVEPOINT"'); |
|
| 1314 | } |
|
| 1315 | $this->releaseSavepoint($this->_getNestedTransactionSavePointName()); |
|
| 1316 | if ($logger) { |
|
| 1317 | $logger->stopQuery(); |
|
| 1318 | } |
|
| 1319 | } |
|
| 1320 | ||
| 1321 | --$this->_transactionNestingLevel; |
|
| 1322 | ||