Add ConnectionCount and DriverTitle for monitoring commands

mongodb · Aug 12, 2024 · 03b907f · 03b907f
1 parent 61aa6f1
commit 03b907f
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 0 deletions.
diff --git a/src/Connection.php b/src/Connection.php
@@ -294,6 +294,12 @@ public function getDriverName()
  return 'mongodb';
  }
 
+ /** @inheritdoc */
+ public function getDriverTitle()
+ {
+ return 'MongoDB';
+ }
+
  /** @inheritdoc */
  protected function getDefaultPostProcessor()
  {
@@ -320,6 +326,14 @@ public function setDatabase(Database $db)
  $this->db = $db;
  }
 
+ /** @inheritdoc */
+ public function threadCount()
+ {
+ $status = $this->db->command(['serverStatus' => 1])->toArray();
+
+ return $status[0]['connections']['current'];
+ }
+
  /**
  * Dynamically pass methods to the connection.
  *

diff --git a/tests/ConnectionTest.php b/tests/ConnectionTest.php
@@ -25,6 +25,9 @@ public function testConnection()
  {
  $connection = DB::connection('mongodb');
  $this->assertInstanceOf(Connection::class, $connection);
+
+ $this->assertSame('mongodb', $connection->getDriverName());
+ $this->assertSame('MongoDB', $connection->getDriverTitle());
  }
 
  public function testReconnect()
@@ -305,4 +308,12 @@ public function testServerVersion()
  $version = DB::connection('mongodb')->getServerVersion();
  $this->assertIsString($version);
  }
+
+ public function testThreadsCount()
+ {
+ $threads = DB::connection('mongodb')->threadCount();
+
+ $this->assertIsInt($threads);
+ $this->assertGreaterThanOrEqual(1, $threads);
+ }
 }