toasty 0.4.0

An async ORM for Rust supporting SQL and NoSQL databases
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use std::ops;

use crate::engine::mir::{Node, NodeId, Store};

/// The complete operation graph for a query.
///
/// [`LogicalPlan`] is a directed acyclic graph of operations produced by the
/// planning phase. It contains all nodes, their topologically sorted execution
/// order, and the final completion node whose output is returned to the user.
#[derive(Debug)]
pub(crate) struct LogicalPlan {
    /// All nodes in the operation graph.
    store: Store,

    /// Topologically sorted order in which to execute operations.
    execution_order: Vec<NodeId>,

    /// The final node whose output is the query result.
    completion: NodeId,
}

impl LogicalPlan {
    pub(crate) fn new(store: Store, completion: NodeId) -> LogicalPlan {
        let mut execution_order = vec![];
        compute_operation_execution_order(completion, &store, &mut execution_order);

        LogicalPlan {
            store,
            execution_order,
            completion,
        }
    }

    pub(crate) fn operations(&self) -> impl Iterator<Item = &Node> {
        self.execution_order
            .iter()
            .map(|node_id| &self.store[node_id])
    }

    pub(crate) fn completion(&self) -> &Node {
        &self.store[self.completion]
    }
}

impl ops::Index<NodeId> for LogicalPlan {
    type Output = Node;

    fn index(&self, index: NodeId) -> &Self::Output {
        self.store.index(index)
    }
}

impl ops::Index<&NodeId> for LogicalPlan {
    type Output = Node;

    fn index(&self, index: &NodeId) -> &Self::Output {
        self.store.index(index)
    }
}

fn compute_operation_execution_order(
    node_id: NodeId,
    mir: &Store,
    execution_order: &mut Vec<NodeId>,
) {
    let node = &mir[node_id];

    if node.visited.get() {
        return;
    }

    node.visited.set(true);

    for &dep_id in &node.deps {
        let dep = &mir[dep_id];
        dep.num_uses.set(dep.num_uses.get() + 1);

        compute_operation_execution_order(dep_id, mir, execution_order);
    }

    execution_order.push(node_id);
}