MCPcopy Create free account
hub / github.com/SeaQL/sea-orm / fetch

Method fetch

src/driver/mock.rs:169–177  ·  view source on GitHub ↗
(
        &self,
        statement: &Statement,
    )

Source from the content-addressed store, hash-verified

167 /// Return [QueryResult]s from a multi-query operation
168 #[instrument(level = "trace")]
169 pub fn fetch(
170 &self,
171 statement: &Statement,
172 ) -> Pin<Box<dyn Stream<Item = Result<QueryResult, DbErr>> + Send>> {
173 match self.query_all(statement.clone()) {
174 Ok(v) => Box::pin(futures_util::stream::iter(v.into_iter().map(Ok))),
175 Err(e) => Box::pin(futures_util::stream::iter(Some(Err(e)).into_iter())),
176 }
177 }
178
179 /// Create a statement block of SQL statements that execute together.
180 ///

Callers 2

buildMethod · 0.45
buildMethod · 0.45

Calls 2

into_iterMethod · 0.80
query_allMethod · 0.45

Tested by

no test coverage detected