qail-core 1.3.0

AST-native query builder - type-safe expressions, zero SQL strings
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

use std::collections::BTreeSet;

use crate::ast::{Action, ConflictAction, MergeAction, Qail};

use super::model::AccessOperation;

/// Required operations for a full command.
pub fn required_operations_for_command(cmd: &Qail) -> Option<BTreeSet<AccessOperation>> {
    let mut operations = BTreeSet::new();
    match cmd.action {
        Action::Add => {
            operations.insert(AccessOperation::Create);
            if matches!(
                cmd.on_conflict.as_ref().map(|conflict| &conflict.action),
                Some(ConflictAction::DoUpdate { .. })
            ) {
                operations.insert(AccessOperation::Update);
            }
        }
        Action::Merge => {
            if let Some(merge) = &cmd.merge {
                for clause in &merge.clauses {
                    match &clause.action {
                        MergeAction::Update { .. } => {
                            operations.insert(AccessOperation::Update);
                        }
                        MergeAction::Insert { .. } => {
                            operations.insert(AccessOperation::Create);
                        }
                        MergeAction::Delete => {
                            operations.insert(AccessOperation::Delete);
                        }
                        MergeAction::DoNothing => {}
                    }
                }
                if operations.is_empty() {
                    operations.extend([
                        AccessOperation::Create,
                        AccessOperation::Update,
                        AccessOperation::Delete,
                    ]);
                }
            } else {
                operations.extend([
                    AccessOperation::Create,
                    AccessOperation::Update,
                    AccessOperation::Delete,
                ]);
            }
        }
        action => {
            operations.extend(AccessOperation::required_for_action(action)?);
        }
    }
    Some(operations)
}