diff --git a/src/driver/sqlx_mysql.rs b/src/driver/sqlx_mysql.rs
index 872bc1f5..505a0bed 100644
--- a/src/driver/sqlx_mysql.rs
+++ b/src/driver/sqlx_mysql.rs
@@ -60,6 +60,17 @@ impl SqlxMySqlConnector {
     /// Add configuration options for the MySQL database
     #[instrument(level = "trace")]
     pub async fn connect(options: ConnectOptions) -> Result<DatabaseConnection, DbErr> {
+        Self::connect_and_then(options, |o| o).await
+    }
+
+    #[instrument(level = "trace")]
+    pub async fn connect_and_then<F>(
+        options: ConnectOptions,
+        and_then: F,
+    ) -> Result<DatabaseConnection, DbErr>
+    where
+        F: FnOnce(MySqlConnectOptions) -> MySqlConnectOptions + std::fmt::Debug,
+    {
         let mut opt = options
             .url
             .parse::<MySqlConnectOptions>()