sqlx_postgres/
query_result.rs

1use std::iter::{Extend, IntoIterator};
2
3#[derive(Debug, Default)]
4pub struct PgQueryResult {
5    pub(super) rows_affected: u64,
6}
7
8impl PgQueryResult {
9    pub fn rows_affected(&self) -> u64 {
10        self.rows_affected
11    }
12}
13
14impl Extend<PgQueryResult> for PgQueryResult {
15    fn extend<T: IntoIterator<Item = PgQueryResult>>(&mut self, iter: T) {
16        for elem in iter {
17            self.rows_affected += elem.rows_affected;
18        }
19    }
20}
21
22#[cfg(feature = "any")]
23impl From<PgQueryResult> for sqlx_core::any::AnyQueryResult {
24    fn from(done: PgQueryResult) -> Self {
25        sqlx_core::any::AnyQueryResult {
26            rows_affected: done.rows_affected,
27            last_insert_id: None,
28        }
29    }
30}

sqlx_postgres/query_result.rs

sqlx_postgres/
query_result.rs