db-http-core 0.1.0

Core types and traits for HTTP-based database backends
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use crate::backend::DatabaseBackend;
use crate::error::Error;
use crate::types::{Query, QueryResult, Transaction};

pub struct TransactionBuilder<B: DatabaseBackend> {
    backend: B,
    queries: Vec<Query>,
}

impl<B: DatabaseBackend> TransactionBuilder<B> {
    pub fn new(backend: B) -> Self {
        Self {
            backend,
            queries: Vec::new(),
        }
    }

    pub fn add(mut self, query: Query) -> Self {
        self.queries.push(query);
        self
    }

    pub fn merge(mut self, transaction: Transaction) -> Self {
        self.queries.extend(transaction.queries);
        self
    }

    pub fn build(self) -> Transaction {
        Transaction {
            queries: self.queries,
        }
    }

    pub async fn execute(self) -> Result<Vec<QueryResult>, Error> {
        let transaction = Transaction {
            queries: self.queries,
        };
        self.backend.execute_transaction(&transaction).await
    }
}