support database connect

wpjscc · wpjscc · commit a207fbec55e0 · 2025-02-28T08:57:10.000+08:00
diff --git a/composer.json b/composer.json
@@ -13,7 +13,7 @@
         "php": "^8.1",
         "react/async": "^4 || ^3 || ^2",
         "illuminate/database": "^11.19",
-        "reactphp-x/mysql-pool": "^2.0@dev"
+        "reactphp-x/mysql-pool": "^2.0"
     },
     "autoload": {
         "psr-4": {
diff --git a/src/AsyncMysqlConnector.php b/src/AsyncMysqlConnector.php
@@ -8,13 +8,13 @@
 class AsyncMysqlConnector implements ConnectorInterface
 {
 
-    protected static $pool;
+    protected static $connectToPoll;
 
     public function connect($config)
     {
 
-        if (static::$pool) {
-            return static::$pool;
+        if (isset(static::$connectToPoll[$config['name']])) {
+            return static::$connectToPoll[$config['name']];
         }
 
         $username = $config['username'];
@@ -27,7 +27,7 @@ public function connect($config)
         }
         $database = $config['database'];
 
-        return static::$pool = new Pool(
+        return static::$connectToPoll[$config['name']] = new Pool(
             $username . ':' . $password . '@' . $host . '/' . $database . '?charset=' . $charset.'&idle='.($config['idle'] ?? 30),
             $config['pool']['min_connections'] ?? 1,
             $config['pool']['max_connections'] ?? 10,

Original file line number	Diff line number	Diff line change
`@@ -8,13 +8,13 @@`
`8`	`8`	`class AsyncMysqlConnector implements ConnectorInterface`
`9`	`9`	`{`
`10`	`10`
`11`		`- protected static $pool;`
	`11`	`+ protected static $connectToPoll;`
`12`	`12`
`13`	`13`	`public function connect($config)`
`14`	`14`	`{`
`15`	`15`
`16`		`- if (static::$pool) {`
`17`		`- return static::$pool;`
	`16`	`+ if (isset(static::$connectToPoll[$config['name']])) {`
	`17`	`+ return static::$connectToPoll[$config['name']];`
`18`	`18`	`}`
`19`	`19`
`20`	`20`	`$username = $config['username'];`
`@@ -27,7 +27,7 @@ public function connect($config)`
`27`	`27`	`}`
`28`	`28`	`$database = $config['database'];`
`29`	`29`
`30`		`- return static::$pool = new Pool(`
	`30`	`+ return static::$connectToPoll[$config['name']] = new Pool(`
`31`	`31`	`$username . ':' . $password . '@' . $host . '/' . $database . '?charset=' . $charset.'&idle='.($config['idle'] ?? 30),`
`32`	`32`	`$config['pool']['min_connections'] ?? 1,`
`33`	`33`	`$config['pool']['max_connections'] ?? 10,`