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
2020-09-05 01:35:52 +08:00
parent d4e5cc009b
commit b841dbd622
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Pool/Connection.php
+5 -5
View File
@@ -177,7 +177,6 @@ class Connection extends Pool
} }
for ($i = 0; $i < 10 - $this->size($name); $i++) { for ($i = 0; $i < 10 - $this->size($name); $i++) {
$this->push($name, $this->createConnect($config['cds'], $config['username'], $config['password'])); $this->push($name, $this->createConnect($config['cds'], $config['username'], $config['password']));
$this->incr($name);
} }
return $this; return $this;
} }
@@ -218,12 +217,11 @@ class Connection extends Pool
private function nowClient($coroutineName, $config) private function nowClient($coroutineName, $config)
{ {
$this->success('create db client -> ' . $config['cds'] . ':' . $this->hasCreate[$coroutineName] . ':' . $this->size($coroutineName)); $this->success('create db client -> ' . $config['cds'] . ':' . $this->hasCreate[$coroutineName] . ':' . $this->size($coroutineName));
$client = $this->createConnect($config['cds'], $config['username'], $config['password']); $client = $this->createConnect($coroutineName, $config['cds'], $config['username'], $config['password']);
if (isset(Context::getContext('begin_' . $coroutineName)[Coroutine::getCid()])) { if (isset(Context::getContext('begin_' . $coroutineName)[Coroutine::getCid()])) {
$number = Context::getContext('begin_' . $coroutineName)[Coroutine::getCid()]; $number = Context::getContext('begin_' . $coroutineName)[Coroutine::getCid()];
$number > 0 && $client->beginTransaction(); $number > 0 && $client->beginTransaction();
} }
$this->incr($coroutineName);
return $client; return $client;
} }
@@ -319,13 +317,14 @@ class Connection extends Pool
/** /**
* @param $coroutineName
* @param $cds * @param $cds
* @param $username * @param $username
* @param $password * @param $password
* @return PDO * @return PDO
* @throws Exception * @throws Exception
*/ */
public function createConnect($cds, $username, $password) public function createConnect($coroutineName, $cds, $username, $password)
{ {
try { try {
$link = new PDO($cds, $username, $password, [ $link = new PDO($cds, $username, $password, [
@@ -337,6 +336,7 @@ class Connection extends Pool
$link->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $link->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$link->setAttribute(PDO::ATTR_STRINGIFY_FETCHES, false); $link->setAttribute(PDO::ATTR_STRINGIFY_FETCHES, false);
$link->setAttribute(PDO::ATTR_ORACLE_NULLS, PDO::NULL_EMPTY_STRING); $link->setAttribute(PDO::ATTR_ORACLE_NULLS, PDO::NULL_EMPTY_STRING);
$this->incr($coroutineName);
return $link; return $link;
} catch (\Throwable $exception) { } catch (\Throwable $exception) {
if ($exception->getCode() !== 2006) { if ($exception->getCode() !== 2006) {
@@ -344,7 +344,7 @@ class Connection extends Pool
throw new Exception($exception->getMessage()); throw new Exception($exception->getMessage());
} }
$this->addError($cds . ' -> ' . $exception->getMessage()); $this->addError($cds . ' -> ' . $exception->getMessage());
return $this->createConnect($cds, $username, $password); return $this->createConnect($coroutineName, $cds, $username, $password);
} }
} }