sql_middleware/executor/
connection.rs

1use crate::error::SqlMiddlewareDbError;
2use crate::pool::MiddlewarePoolConnection;
3use crate::query_builder::QueryBuilder;
4
5#[cfg(feature = "mssql")]
6use crate::mssql;
7#[cfg(feature = "postgres")]
8use crate::postgres;
9#[cfg(feature = "sqlite")]
10use crate::sqlite;
11#[cfg(feature = "turso")]
12use crate::turso;
13
14impl MiddlewarePoolConnection {
15    /// Executes a batch of SQL queries within a transaction by delegating to the specific database module.
16    ///
17    /// # Errors
18    /// Returns an error if the selected backend cannot execute the batch or the database responds with an error.
19    pub async fn execute_batch(&mut self, query: &str) -> Result<(), SqlMiddlewareDbError> {
20        match self {
21            #[cfg(feature = "postgres")]
22            MiddlewarePoolConnection::Postgres {
23                client: pg_client, ..
24            } => postgres::execute_batch(pg_client, query).await,
25            #[cfg(feature = "sqlite")]
26            MiddlewarePoolConnection::Sqlite { .. } => {
27                let sqlite_client = self.sqlite_conn_mut()?;
28                sqlite::execute_batch(sqlite_client, query).await
29            }
30            #[cfg(feature = "mssql")]
31            MiddlewarePoolConnection::Mssql {
32                conn: mssql_client, ..
33            } => mssql::execute_batch(mssql_client, query).await,
34            #[cfg(feature = "turso")]
35            MiddlewarePoolConnection::Turso {
36                conn: turso_conn, ..
37            } => turso::execute_batch(turso_conn, query).await,
38            #[allow(unreachable_patterns)]
39            _ => Err(SqlMiddlewareDbError::Unimplemented(
40                "This database type is not enabled in the current build".to_string(),
41            )),
42        }
43    }
44
45    /// Start a fluent query builder that can translate placeholders before executing.
46    ///
47    /// # Examples
48    /// ```rust,no_run
49    /// use sql_middleware::prelude::*;
50    ///
51    /// # async fn demo() -> Result<(), SqlMiddlewareDbError> {
52    /// let cap = ConfigAndPool::sqlite_builder("file::memory:?cache=shared".to_string())
53    ///     .build()
54    ///     .await?;
55    /// let mut conn = cap.get_connection().await?;
56    /// conn.execute_batch("CREATE TABLE t (id INTEGER)").await?;
57    ///
58    /// let rows = conn
59    ///     .query("SELECT id FROM t WHERE id = ?1")
60    ///     .params(&[RowValues::Int(1)])
61    ///     .select()
62    ///     .await?;
63    /// assert!(rows.results.is_empty());
64    /// # Ok(()) }
65    /// ```
66    pub fn query<'a>(&'a mut self, query: &'a str) -> QueryBuilder<'a, 'a> {
67        QueryBuilder::new(self, query)
68    }
69}
sql_middleware/executor/connection.rs

sql_middleware/executor/
connection.rs
