feat(core): expose acquired pool connections

Author: angelnereira

sqlx-core/src/pool/inner.rs

@@ -84,6 +84,11 @@ impl<DB: Database> PoolInner<DB> {
         self.num_idle.load(Ordering::Acquire)
     }
 
+    pub(super) fn num_acquired(&self) -> u32 {
+        self.size()
+            .saturating_sub(u32::try_from(self.num_idle()).unwrap_or(u32::MAX))
+    }
+
     pub(super) fn is_closed(&self) -> bool {
         self.is_closed.load(Ordering::Acquire)
     }

sqlx-core/src/pool/mod.rs

@@ -541,6 +541,14 @@ impl<DB: Database> Pool<DB> {
         self.0.num_idle()
     }
 
+    /// Returns the number of connections currently checked out from the pool.
+    ///
+    /// This is an instantaneous snapshot. The value may change immediately as
+    /// tasks acquire or release connections.
+    pub fn num_acquired(&self) -> u32 {
+        self.0.num_acquired()
+    }
+
     /// Gets a clone of the connection options for this pool
     pub fn connect_options(&self) -> Arc<<DB::Connection as Connection>::Options> {
         self.0
@@ -581,6 +589,7 @@ impl<DB: Database> fmt::Debug for Pool<DB> {
         fmt.debug_struct("Pool")
             .field("size", &self.0.size())
             .field("num_idle", &self.0.num_idle())
+            .field("num_acquired", &self.0.num_acquired())
             .field("is_closed", &self.0.is_closed())
             .field("options", &self.0.options)
             .finish()

tests/any/pool.rs

@@ -71,6 +71,39 @@ async fn pool_should_be_returned_failed_transactions() -> anyhow::Result<()> {
     Ok(())
 }
 
+#[sqlx_macros::test]
+async fn pool_should_report_acquired_connections() -> anyhow::Result<()> {
+    sqlx::any::install_default_drivers();
+
+    let pool = AnyPoolOptions::new()
+        .max_connections(2)
+        .connect(&dotenvy::var("DATABASE_URL")?)
+        .await?;
+
+    assert_eq!(pool.size(), 1);
+    assert_eq!(pool.num_idle(), 1);
+    assert_eq!(pool.num_acquired(), 0);
+
+    let conn1 = pool.acquire().await?;
+
+    assert_eq!(pool.size(), 1);
+    assert_eq!(pool.num_idle(), 0);
+    assert_eq!(pool.num_acquired(), 1);
+
+    let conn2 = pool.acquire().await?;
+
+    assert_eq!(pool.size(), 2);
+    assert_eq!(pool.num_idle(), 0);
+    assert_eq!(pool.num_acquired(), 2);
+
+    drop(conn2);
+    drop(conn1);
+
+    pool.close().await;
+
+    Ok(())
+}
+
 #[sqlx_macros::test]
 async fn test_pool_callbacks() -> anyhow::Result<()> {
     sqlx::any::install_default_drivers();