(&self, stmt: Statement)
| 381 | #[instrument(level = "trace")] |
| 382 | #[allow(unused_variables)] |
| 383 | async fn query_all(&self, stmt: Statement) -> Result<Vec<QueryResult>, DbErr> { |
| 384 | debug_print!("{}", stmt); |
| 385 | |
| 386 | match &mut *self.conn.lock().await { |
| 387 | #[cfg(feature = "sqlx-mysql")] |
| 388 | InnerConnection::MySql(conn) => { |
| 389 | let query = crate::driver::sqlx_mysql::sqlx_query(&stmt); |
| 390 | let conn: &mut sqlx::MySqlConnection = &mut *conn; |
| 391 | crate::metric::metric!(self.metric_callback, &stmt, { |
| 392 | query |
| 393 | .fetch_all(conn) |
| 394 | .await |
| 395 | .map(|rows| rows.into_iter().map(|r| r.into()).collect()) |
| 396 | .map_err(sqlx_error_to_query_err) |
| 397 | }) |
| 398 | } |
| 399 | #[cfg(feature = "sqlx-postgres")] |
| 400 | InnerConnection::Postgres(conn) => { |
| 401 | let query = crate::driver::sqlx_postgres::sqlx_query(&stmt); |
| 402 | let conn: &mut sqlx::PgConnection = &mut *conn; |
| 403 | crate::metric::metric!(self.metric_callback, &stmt, { |
| 404 | query |
| 405 | .fetch_all(conn) |
| 406 | .await |
| 407 | .map(|rows| rows.into_iter().map(|r| r.into()).collect()) |
| 408 | .map_err(sqlx_error_to_query_err) |
| 409 | }) |
| 410 | } |
| 411 | #[cfg(feature = "sqlx-sqlite")] |
| 412 | InnerConnection::Sqlite(conn) => { |
| 413 | let query = crate::driver::sqlx_sqlite::sqlx_query(&stmt); |
| 414 | let conn: &mut sqlx::SqliteConnection = &mut *conn; |
| 415 | crate::metric::metric!(self.metric_callback, &stmt, { |
| 416 | query |
| 417 | .fetch_all(conn) |
| 418 | .await |
| 419 | .map(|rows| rows.into_iter().map(|r| r.into()).collect()) |
| 420 | .map_err(sqlx_error_to_query_err) |
| 421 | }) |
| 422 | } |
| 423 | #[cfg(feature = "mock")] |
| 424 | InnerConnection::Mock(conn) => return conn.query_all(stmt), |
| 425 | #[cfg(feature = "proxy")] |
| 426 | InnerConnection::Proxy(conn) => return conn.query_all(stmt).await, |
| 427 | #[allow(unreachable_patterns)] |
| 428 | _ => Err(conn_err("Disconnected")), |
| 429 | } |
| 430 | } |
| 431 | } |
| 432 | |
| 433 | impl StreamTrait for DatabaseTransaction { |
nothing calls this directly
no test coverage detected