Send SELECT command when changing DB if connection exists

Author: mythz

src/ServiceStack.Redis/RedisClient.cs

@@ -237,12 +237,6 @@ public bool SetValueIfNotExists(string key, string value, TimeSpan expireIn)
                 return base.Set(key, bytesValue, exists: false, expirySeconds: (int)expireIn.TotalSeconds);
         }
 
-        public void ChangeDb(long db)
-        {
-            Db = db;
-            SendExpectSuccess(Commands.Select, db.ToUtf8Bytes());
-        }
-
         [Obsolete("Use GetClientsInfo")]
         public List<Dictionary<string, string>> GetClientList()
         {

src/ServiceStack.Redis/RedisNativeClient.cs

@@ -211,9 +211,20 @@ public long Db
             set
             {
                 db = value;
+
+                if (HasConnected)
+                {
+                    ChangeDb(db);
+                }
             }
         }
 
+        public void ChangeDb(long db)
+        {
+            this.db = db;
+            SendExpectSuccess(Commands.Select, db.ToUtf8Bytes());
+        }
+
         public long DbSize
         {
             get

src/ServiceStack.Redis/RedisNativeClient_Utils.cs

@@ -217,6 +217,11 @@ protected string ReadLine()
             return sb.ToString();
         }
 
+        public bool HasConnected
+        {
+            get { return socket != null; }
+        }
+
         public bool IsSocketConnected()
         {
             var part1 = socket.Poll(1000, SelectMode.SelectRead);

tests/ServiceStack.Redis.Tests/BasicRediscClientManagerTests.cs

@@ -0,0 +1,40 @@
+using NUnit.Framework;
+
+namespace ServiceStack.Redis.Tests
+{
+    public class BasicRediscClientManagerTests
+        : RedisClientTestsBase
+    {
+        [Test]
+        public void Can_select_db()
+        {
+            var redisManager = new BasicRedisClientManager("127.0.0.1");
+
+            using (var client = redisManager.GetClient())
+            {
+                client.Db = 2;
+                client.Set("db", 2);
+            }
+
+            using (var client = redisManager.GetClient())
+            {
+                client.Db = 3;
+                client.Set("db", 3);
+            }
+
+            using (var client = redisManager.GetClient())
+            {
+                client.Db = 2;
+                var db = client.Get<int>("db");
+                Assert.That(db, Is.EqualTo(2));
+            }
+
+            redisManager = new BasicRedisClientManager("127.0.0.1?db=3");
+            using (var client = redisManager.GetClient())
+            {
+                var db = client.Get<int>("db");
+                Assert.That(db, Is.EqualTo(3));
+            }
+        }
+    }
+}

tests/ServiceStack.Redis.Tests/ServiceStack.Redis.Tests.csproj

@@ -181,6 +181,7 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="AdhocClientTests.cs" />
+    <Compile Include="BasicRediscClientManagerTests.cs" />
     <Compile Include="ConfigTests.cs" />
     <Compile Include="CustomCommandTests.cs" />
     <Compile Include="LuaCachedScripts.cs" />