reconnect the correct connection when using read or write connections

Author: themsaid

src/Illuminate/Database/Connection.php

@@ -161,6 +161,13 @@ class Connection implements ConnectionInterface
      */
     protected static $resolvers = [];
 
+    /**
+     * The type of the connection.
+     *
+     * @var string|null
+     */
+    protected $type;
+
     /**
      * Create a new database connection instance.
      *
@@ -1045,6 +1052,16 @@ public function getName()
         return $this->getConfig('name');
     }
 
+    /**
+     * Get the database connection full name.
+     *
+     * @return string|null
+     */
+    public function getFullName()
+    {
+        return $this->getName().($this->type ? '::'.$this->type : '');
+    }
+
     /**
      * Get an option from the configuration options.
      *
@@ -1274,6 +1291,19 @@ public function setDatabaseName($database)
         return $this;
     }
 
+    /**
+     * Set the type of the connection.
+     *
+     * @param  string  $type
+     * @return $this
+     */
+    public function setType($type)
+    {
+        $this->type = $type;
+
+        return $this;
+    }
+
     /**
      * Get the table prefix for the connection.
      *

src/Illuminate/Database/DatabaseManager.php

@@ -62,7 +62,7 @@ public function __construct($app, ConnectionFactory $factory)
         $this->factory = $factory;
 
         $this->reconnector = function ($connection) {
-            $this->reconnect($connection->getName());
+            $this->reconnect($connection->getFullName());
         };
     }
 
@@ -165,7 +165,7 @@ protected function configuration($name)
      */
     protected function configure(Connection $connection, $type)
     {
-        $connection = $this->setPdoForType($connection, $type);
+        $connection = $this->setPdoForType($connection, $type)->setType($type);
 
         // First we'll set the fetch mode and a few other dependencies of the database
         // connection. This method basically just configures and prepares it to get
@@ -275,7 +275,11 @@ public function usingConnection($name, callable $callback)
      */
     protected function refreshPdoConnections($name)
     {
-        $fresh = $this->makeConnection($name);
+        [$database, $type] = $this->parseConnectionName($name);
+
+        $fresh = $this->configure(
+            $this->makeConnection($database), $type
+        );
 
         return $this->connections[$name]
                                 ->setPdo($fresh->getRawPdo())