Move Schema::getConnectionsCount to Connection::getThreadsCount

Author: GromNaN

src/Illuminate/Database/Connection.php

@@ -1084,6 +1084,18 @@ public function raw($value)
         return new Expression($value);
     }
 
+    /**
+     * Get the number of open connections for a database.
+     *
+     * @return int|null
+     */
+    public function getThreadsCount()
+    {
+        $query = $this->getQueryGrammar()->compileThreadsCount();
+
+        return $query ? $this->scalar($query) : null;
+    }
+
     /**
      * Escape a value for safe SQL embedding.
      *

src/Illuminate/Database/Console/DatabaseInspectionCommand.php

@@ -3,6 +3,7 @@
 namespace Illuminate\Database\Console;
 
 use Illuminate\Console\Command;
+use Illuminate\Database\Connection;
 use Illuminate\Database\ConnectionInterface;
 use Illuminate\Support\Arr;
 
@@ -15,7 +16,7 @@ abstract class DatabaseInspectionCommand extends Command
      * @param  string  $database
      * @return string
      *
-     * @deprecated Use $connection->getDriverTitle() instead.
+     * @deprecated
      */
     protected function getConnectionName(ConnectionInterface $connection, $database)
     {
@@ -28,11 +29,11 @@ protected function getConnectionName(ConnectionInterface $connection, $database)
      * @param  \Illuminate\Database\ConnectionInterface  $connection
      * @return int|null
      *
-     * @deprecated Use Schema\Builder::getConnectionsCount() instead.
+     * @deprecated
      */
     protected function getConnectionCount(ConnectionInterface $connection)
     {
-        return $connection->getSchemaBuilder()->getConnectionsCount();
+        return $connection->getThreadsCount();
     }
 
     /**

src/Illuminate/Database/Console/MonitorCommand.php

@@ -84,7 +84,8 @@ protected function parseDatabases($databases)
             }
 
             $maxConnections = $this->option('max');
-            $connections = $this->connection->connection($database)->getSchemaBuilder()->getConnectionsCount();
+
+            $connections = $this->connection->connection($database)->getThreadsCount();
 
             return [
                 'database' => $database,

src/Illuminate/Database/Console/ShowCommand.php

@@ -48,7 +48,7 @@ public function handle(ConnectionResolverInterface $connections)
                 'name' => $connection->getDriverTitle(),
                 'connection' => $connection->getName(),
                 'version' => $connection->getServerVersion(),
-                'open_connections' => $schema->getConnectionsCount(),
+                'open_connections' => $connection->getThreadsCount(),
             ],
             'tables' => $this->tables($connection, $schema),
         ];

src/Illuminate/Database/Query/Grammars/Grammar.php

@@ -1564,4 +1564,14 @@ public function getBitwiseOperators()
     {
         return $this->bitwiseOperators;
     }
+
+    /**
+     * Get the number of open connections for a database.
+     *
+     * @return string|null
+     */
+    public function compileThreadsCount()
+    {
+        return null;
+    }
 }

src/Illuminate/Database/Query/Grammars/MariaDbGrammar.php

@@ -43,4 +43,9 @@ public function useLegacyGroupLimit(Builder $query)
     {
         return false;
     }
+
+    public function compileThreadsCount()
+    {
+        return 'select variable_value as `Value` from information_schema.global_status where variable_name = \'THREADS_CONNECTED\'';
+    }
 }

src/Illuminate/Database/Query/Grammars/MySqlGrammar.php

@@ -514,4 +514,9 @@ protected function wrapJsonBooleanSelector($value)
 
         return 'json_extract('.$field.$path.')';
     }
+
+    public function compileThreadsCount()
+    {
+        return 'select variable_value as `Value` from performance_schema.session_status where variable_name = \'threads_connected\'';
+    }
 }

src/Illuminate/Database/Query/Grammars/PostgresGrammar.php

@@ -762,4 +762,9 @@ public function substituteBindingsIntoRawSql($sql, $bindings)
 
         return $query;
     }
+
+    public function compileThreadsCount()
+    {
+        return 'select count(*) as "Value" from pg_stat_activity';
+    }
 }

src/Illuminate/Database/Query/Grammars/SqlServerGrammar.php

@@ -497,6 +497,11 @@ public function compileSavepointRollBack($name)
         return 'ROLLBACK TRANSACTION '.$name;
     }
 
+    public function compileThreadsCount()
+    {
+        return 'select count(*) Value from sys.dm_exec_sessions where status = N\'running\'';
+    }
+
     /**
      * Get the format for database stored dates.
      *

src/Illuminate/Database/Schema/Builder.php

@@ -606,19 +606,6 @@ public function setConnection(Connection $connection)
 
         return $this;
     }
-
-    /**
-     * Get the number of open connections for a database.
-     *
-     * @return int|null
-     */
-    public function getConnectionsCount()
-    {
-        $query = $this->grammar->compileConnectionsCount();
-
-        return $query ? $this->connection->scalar($query) : null;
-    }
-
     /**
      * Set the Schema Blueprint resolver callback.
      *