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