rbdc_oracle/
query_result.rs

1use rbdc::db::ExecResult;
2use rbs::Value;
3
4#[derive(Debug, Default, Clone, Eq, PartialEq)]
5pub struct OracleQueryResult {
6    pub(crate) rows_affected: u64,
7    pub(crate) out_values: Vec<Value>,
8}
9
10impl OracleQueryResult {
11    pub fn rows_affected(&self) -> u64 {
12        self.rows_affected
13    }
14
15    pub fn out_values(&self) -> &[Value] {
16        &self.out_values
17    }
18
19    pub fn into_exec_result(self) -> ExecResult {
20        ExecResult {
21            rows_affected: self.rows_affected,
22            last_insert_id: Value::Array(self.out_values),
23        }
24    }
25}
26
27impl Extend<OracleQueryResult> for OracleQueryResult {
28    fn extend<T: IntoIterator<Item = OracleQueryResult>>(&mut self, iter: T) {
29        for elem in iter {
30            self.rows_affected += elem.rows_affected;
31            self.out_values = elem.out_values;
32        }
33    }
34}
rbdc_oracle/query_result.rs

rbdc_oracle/
query_result.rs
