diff --git a/sqlx-core/src/any/connection/mod.rs b/sqlx-core/src/any/connection/mod.rs index d4b28bd46..cabe78198 100644 --- a/sqlx-core/src/any/connection/mod.rs +++ b/sqlx-core/src/any/connection/mod.rs @@ -183,3 +183,31 @@ impl Connection for AnyConnection { delegate_to!(self.should_flush()) } } + +#[cfg(feature = "postgres")] +impl From for AnyConnection { + fn from(conn: postgres::PgConnection) -> Self { + AnyConnection(AnyConnectionKind::Postgres(conn)) + } +} + +#[cfg(feature = "mssql")] +impl From for AnyConnection { + fn from(conn: mssql::MssqlConnection) -> Self { + AnyConnection(AnyConnectionKind::Mssql(conn)) + } +} + +#[cfg(feature = "mysql")] +impl From for AnyConnection { + fn from(conn: mysql::MySqlConnection) -> Self { + AnyConnection(AnyConnectionKind::MySql(conn)) + } +} + +#[cfg(feature = "sqlite")] +impl From for AnyConnection { + fn from(conn: sqlite::SqliteConnection) -> Self { + AnyConnection(AnyConnectionKind::Sqlite(conn)) + } +}