fix: Fixed REDIS_DB is not effected when redis reconnected. (#242)

* Fixed REDIS_DB is not effected when redis reconnected.

* 修改切换DB操作统一在createConnection中进行

* 增加重连后，REDIS_DB会失效的BUG

src/AbstractRedisConnection.php

@@ -88,10 +88,6 @@ protected function initRedis()
             $error = sprintf('Redis connection authentication failed host=%s port=%d auth=%s', $host, (int)$port, (string)$config['auth']);
             throw new RedisException($error);
         }
-        if (isset($config['database']) && $config['database'] < 16 && false === $redis->select($config['database'])) {
-            $error = sprintf('Redis selection database failure host=%s port=%d database=%d', $host, (int)$port, (int)$config['database']);
-            throw new RedisException($error);
-        }
 
         return $redis;
     }

src/Pool/RedisPool.php

@@ -39,9 +39,6 @@ public function createConnection(): ConnectionInterface
             $redis = new SyncRedisConnection($this);
         }
 
-        $dbIndex = $this->poolConfig->getDb();
-        $redis->select($dbIndex);
-
         return $redis;
     }
 }

src/RedisConnection.php

@@ -33,6 +33,10 @@ public function createConnection()
     {
         $redis            = $this->initRedis();
         $this->connection = $redis;
+
+        /** @var RedisPoolConfig $config */
+        $config = $this->getPool()->getPoolConfig();
+        $redis->select($config->getDb());
     }
 
     /**

src/SyncRedisConnection.php

@@ -39,6 +39,10 @@ public function createConnection()
             $redis->setOption(\Redis::OPT_PREFIX, $prefix);
         }
         $this->connection = $redis;
+
+        /** @var RedisPoolConfig $config */
+        $config = $this->getPool()->getPoolConfig();
+        $redis->select($config->getDb());
     }
 
     /**

test/Cases/PoolTest.php

@@ -4,6 +4,7 @@
 
 use Swoft\App;
 use Swoft\Redis\Exception\RedisException;
+use Swoft\Redis\Redis;
 use SwoftTest\Redis\Pool\RedisEnvPoolConfig;
 use SwoftTest\Redis\Pool\RedisPptPoolConfig;
 use SwoftTest\Redis\Testing\Clients\TimeoutRedis;
@@ -73,4 +74,16 @@ public function testRedisTimeout()
         });
 
     }
+
+    public function testRedisReconnectSelectDb()
+    {
+        $redis = bean(Redis::class);
+        $redis->set('test_select_db', 1);
+
+        $redis->reconnect();
+
+        $res = $redis->get('test_select_db');
+
+        $this->assertEquals(1, $res);
+    }
 }