diff --git a/src/driver/sqlx_mysql.rs b/src/driver/sqlx_mysql.rs
index 3de086bc..4b2f690c 100644
--- a/src/driver/sqlx_mysql.rs
+++ b/src/driver/sqlx_mysql.rs
@@ -22,9 +22,9 @@ impl Connector for SqlxMySqlConnector {
     }
 
     async fn connect(string: &str) -> Result<DatabaseConnection, ConnectionErr> {
-        if let Ok(conn) = MySqlPool::connect(string).await {
+        if let Ok(pool) = MySqlPool::connect(string).await {
             Ok(DatabaseConnection::SqlxMySqlPoolConnection(
-                SqlxMySqlPoolConnection { pool: conn },
+                SqlxMySqlPoolConnection { pool },
             ))
         } else {
             Err(ConnectionErr)
@@ -32,6 +32,14 @@ impl Connector for SqlxMySqlConnector {
     }
 }
 
+impl SqlxMySqlConnector {
+    pub fn from_sqlx_mysql_pool(pool: MySqlPool) -> DatabaseConnection {
+        DatabaseConnection::SqlxMySqlPoolConnection(
+            SqlxMySqlPoolConnection { pool },
+        )
+    }
+}
+
 #[async_trait]
 impl Connection for &SqlxMySqlPoolConnection {
     async fn execute(&self, stmt: Statement) -> Result<ExecResult, ExecErr> {