(&self, statement: Statement)
| 76 | /// Return all [QueryResult]s if the query was successful |
| 77 | #[instrument(level = "trace")] |
| 78 | pub async fn query_all(&self, statement: Statement) -> Result<Vec<QueryResult>, DbErr> { |
| 79 | debug_print!("{}", statement); |
| 80 | let result = self.proxy.query(statement).await?; |
| 81 | |
| 82 | Ok(result |
| 83 | .into_iter() |
| 84 | .map(|row| QueryResult { |
| 85 | row: crate::QueryResultRow::Proxy(row), |
| 86 | }) |
| 87 | .collect()) |
| 88 | } |
| 89 | |
| 90 | /// Create a statement block of SQL statements that execute together. |
| 91 | #[instrument(level = "trace")] |