Bump Diesel and bb8 to match v-api (#92)

* bumped diesel version
* update bb8 to be inline with v-api
* fix CustomizeConnection example for bb8 0.9
* Use explicit lifetimes with Pin<Box<dyn Future>> instead of
async_trait macro to match bb8 0.9's trait signature.

Author: nickryand

Cargo.toml

@@ -14,17 +14,17 @@ cockroach = []
 default = [ "cockroach" ]
 
 [dependencies]
-bb8 = "0.8"
+bb8 = "0.9"
 async-trait = "0.1.89"
-diesel = { version = "2.3.4", default-features = false, features = [ "r2d2" ] }
+diesel = { version = "2.3.5", default-features = false, features = [ "r2d2" ] }
 futures = "0.3"
 thiserror = "2.0"
 tokio = { version = "1.32", default-features = false, features = [ "rt-multi-thread" ] }
 
 [dev-dependencies]
 anyhow = "1.0"
 crdb-harness = "0.0.2"
-diesel = { version = "2.3.4", features = [ "postgres", "r2d2" ] }
+diesel = { version = "2.3.5", features = [ "postgres", "r2d2" ] }
 libc = "0.2.178"
 tempfile = "3.8"
 tokio = { version = "1.32", features = [ "macros", "fs", "process" ] }

examples/customize_connection.rs

@@ -1,21 +1,26 @@
 //! An example showing how to cutomize connections while using pooling.
 
 use async_bb8_diesel::{AsyncSimpleConnection, Connection, ConnectionError};
-use async_trait::async_trait;
 use diesel::pg::PgConnection;
+use std::future::Future;
+use std::pin::Pin;
 
 #[derive(Debug)]
 struct ConnectionCustomizer {}
 
 type DieselPgConn = Connection<PgConnection>;
 
-#[async_trait]
 impl bb8::CustomizeConnection<DieselPgConn, ConnectionError> for ConnectionCustomizer {
-    async fn on_acquire(&self, connection: &mut DieselPgConn) -> Result<(), ConnectionError> {
-        connection
-            .batch_execute_async("please execute some raw sql for me")
-            .await
-            .map_err(ConnectionError::from)
+    fn on_acquire<'a>(
+        &'a self,
+        connection: &'a mut DieselPgConn,
+    ) -> Pin<Box<dyn Future<Output = Result<(), ConnectionError>> + Send + 'a>> {
+        Box::pin(async move {
+            connection
+                .batch_execute_async("please execute some raw sql for me")
+                .await
+                .map_err(ConnectionError::from)
+        })
     }
 }
 

src/connection_manager.rs

@@ -1,7 +1,6 @@
 //! An async-safe connection pool for Diesel.
 
 use crate::{Connection, ConnectionError};
-use async_trait::async_trait;
 use diesel::r2d2::{self, ManageConnection, R2D2Connection};
 use std::sync::{Arc, Mutex};
 
@@ -59,7 +58,6 @@ impl<T: Send + 'static> ConnectionManager<T> {
     }
 }
 
-#[async_trait]
 impl<T> bb8::ManageConnection for ConnectionManager<T>
 where
     T: R2D2Connection + Send + 'static,