support database connect

reactphp-x · Feb 28, 2025 · a207fbe · a207fbe
1 parent 1d3ee76
commit a207fbe
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
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,