More test fixes

Author: weiznich

src/doctest_setup.rs

@@ -27,7 +27,6 @@ cfg_if::cfg_if! {
         }
 
         async fn create_tables(connection: &mut AsyncPgConnection) {
-
             diesel::sql_query("CREATE TABLE users (
                 id SERIAL PRIMARY KEY,
                 name VARCHAR NOT NULL
@@ -138,7 +137,7 @@ cfg_if::cfg_if! {
             )").execute(connection).await.unwrap();
 
             connection.begin_test_transaction().await.unwrap();
-            diesel::sql_query("INSERT INTO users (name) VALUES ('Sean'), ('Tess')").execute(&mut connection).await.unwrap();
+            diesel::sql_query("INSERT INTO users (name) VALUES ('Sean'), ('Tess')").execute(connection).await.unwrap();
             diesel::sql_query("INSERT INTO posts (user_id, title) VALUES
                 (1, 'My first post'),
                 (1, 'About Rust'),

src/pooled_connection/bb8.rs

@@ -22,7 +22,7 @@
 //! # #[cfg(feature = "mysql")]
 //! # fn get_config() -> AsyncDieselConnectionManager<diesel_async::AsyncMysqlConnection> {
 //! #     let db_url = database_url_from_env("MYSQL_DATABASE_URL");
-//! #    let config = AsyncDieselConnectionManager::<diesel_async::AsyncMysqlConnection>::new(db_url);
+//! #     let config = AsyncDieselConnectionManager::<diesel_async::AsyncMysqlConnection>::new(db_url);
 //! #     config
 //! #  }
 //! #
@@ -32,8 +32,9 @@
 //!   let pool = Pool::builder().build(config).await?;
 //!   let mut conn = pool.get().await?;
 //! # conn.begin_test_transaction();
-//! # clear_tables(&mut conn);
-//! # create_tables(&mut conn);
+//! # clear_tables(&mut conn).await;
+//! # create_tables(&mut conn).await;
+//! #[cfg(feature = "mysql")]
 //! # conn.begin_test_transaction();
 //!   let res = users.load::<(i32, String)>(&mut conn).await?;
 //! #     Ok(())

src/pooled_connection/deadpool.rs

@@ -32,8 +32,8 @@
 //!   let pool = Pool::builder(config).build()?;
 //!   let mut conn = pool.get().await?;
 //! # conn.begin_test_transaction();
-//! # clear_tables(&mut conn);
-//! # create_tables(&mut conn);
+//! # clear_tables(&mut conn).await;
+//! # create_tables(&mut conn).await;
 //! # conn.begin_test_transaction();
 //!   let res = users.load::<(i32, String)>(&mut conn).await?;
 //! #     Ok(())

src/pooled_connection/mobc.rs

@@ -32,8 +32,8 @@
 //!   let pool = Pool::new(config);
 //!   let mut conn = pool.get().await?;
 //! # conn.begin_test_transaction();
-//! # clear_tables(&mut conn);
-//! # create_tables(&mut conn);
+//! # clear_tables(&mut conn).await;
+//! # create_tables(&mut conn).await;
 //! # conn.begin_test_transaction();
 //!   let res = users.load::<(i32, String)>(&mut conn).await?;
 //! #     Ok(())