This commit is contained in:
2021-08-13 16:41:15 +08:00
parent c54e600d6f
commit 531d7c8a78
-7
View File
@@ -117,11 +117,6 @@ class Connection extends Component
public function create($coroutineName, $config): Closure public function create($coroutineName, $config): Closure
{ {
return static function () use ($coroutineName, $config) { return static function () use ($coroutineName, $config) {
if (Coroutine::getCid() === -1) {
Runtime::enableCoroutine(false);
}
debug('mysql connect startTime ' . microtime(true));
$cds = 'mysql:dbname=' . $config['database'] . ';host=' . $config['cds']; $cds = 'mysql:dbname=' . $config['database'] . ';host=' . $config['cds'];
$link = new PDO($cds, $config['username'], $config['password'], [ $link = new PDO($cds, $config['username'], $config['password'], [
PDO::ATTR_EMULATE_PREPARES => false, PDO::ATTR_EMULATE_PREPARES => false,
@@ -133,8 +128,6 @@ class Connection extends Component
$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);
debug('mysql connect endTime ' . microtime(true));
return $link; return $link;
}; };
} }