as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-08-09 11:06:47 +08:00
parent b486686474
commit 27297e29fd
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Pool/Connection.php
+2 -5
View File
@@ -46,9 +46,6 @@ class Connection extends Component
if (!Context::hasContext('begin_' . $coroutineName)) { if (!Context::hasContext('begin_' . $coroutineName)) {
Context::setContext('begin_' . $coroutineName, 0); Context::setContext('begin_' . $coroutineName, 0);
} }
if (Context::increment('begin_' . $coroutineName) != 0) {
return;
}
$connection = Context::getContext($coroutineName); $connection = Context::getContext($coroutineName);
if ($connection instanceof PDO && !$connection->inTransaction()) { if ($connection instanceof PDO && !$connection->inTransaction()) {
$connection->beginTransaction(); $connection->beginTransaction();
@@ -104,8 +101,8 @@ class Connection extends Component
} }
/** @var PDO $connections */ /** @var PDO $connections */
$connections = $this->getPool()->get($coroutineName, $this->create($coroutineName, $config)); $connections = $this->getPool()->get($coroutineName, $this->create($coroutineName, $config));
if ($number = Context::getContext('begin_' . $coroutineName)) { if (Context::hasContext('begin_' . $coroutineName)) {
$number > 0 && $connections->beginTransaction(); $connections->beginTransaction();
} }
return Context::setContext($coroutineName, $connections); return Context::setContext($coroutineName, $connections);
} }