uqa-sql 0.1.6

PostgreSQL-compatible SQL compiler built on libpg_query
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

//! Qualified-name rendering and durable relation-envelope validation.

use super::{extract_string, Node, RangeVar, Result, SQLError};

pub(crate) fn range_var_name(r: &RangeVar) -> String {
    if r.schemaname.is_empty() {
        render_relation_component(&r.relname)
    } else {
        format!(
            "{}.{}",
            render_relation_component(&r.schemaname),
            render_relation_component(&r.relname)
        )
    }
}

/// Reject relation qualifiers that the durable catalog cannot faithfully
/// represent.  `PostgreSQL` records temporary/unlogged persistence separately;
/// silently storing either as a permanent relation would change restart
/// semantics.
pub(crate) fn validate_durable_create_relation(relation: &RangeVar, statement: &str) -> Result<()> {
    if !relation.catalogname.is_empty() {
        return Err(SQLError::Unsupported(format!(
            "{statement}: cross-database relation names are not supported"
        )));
    }
    match relation.relpersistence.as_str() {
        "" | "p" => Ok(()),
        "t" => Err(SQLError::Unsupported(format!(
            "{statement}: TEMPORARY relations are not supported"
        ))),
        "u" => Err(SQLError::Unsupported(format!(
            "{statement}: UNLOGGED relations are not supported"
        ))),
        other => Err(SQLError::Unsupported(format!(
            "{statement}: relation persistence `{other}` is not supported"
        ))),
    }
}

pub(crate) fn validate_create_table_envelope(
    stmt: &pg_query::protobuf::CreateStmt,
    statement: &str,
) -> Result<()> {
    use pg_query::protobuf::OnCommitAction;

    let relation = stmt
        .relation
        .as_ref()
        .ok_or_else(|| SQLError::Internal(format!("{statement} without relation")))?;
    validate_durable_create_relation(relation, statement)?;
    if !stmt.inh_relations.is_empty() {
        return Err(SQLError::Unsupported(format!(
            "{statement}: INHERITS is not supported"
        )));
    }
    if stmt.partbound.is_some() || stmt.partspec.is_some() {
        return Err(SQLError::Unsupported(format!(
            "{statement}: partitioning is not supported"
        )));
    }
    if stmt.of_typename.is_some() {
        return Err(SQLError::Unsupported(format!(
            "{statement}: typed tables are not supported"
        )));
    }
    if !stmt.constraints.is_empty() {
        return Err(SQLError::Unsupported(format!(
            "{statement}: out-of-line constraint payloads are not supported"
        )));
    }
    if !stmt.options.is_empty() {
        return Err(SQLError::Unsupported(format!(
            "{statement}: table storage options are not supported"
        )));
    }
    if !matches!(
        stmt.oncommit(),
        OnCommitAction::Undefined | OnCommitAction::OncommitNoop
    ) {
        return Err(SQLError::Unsupported(format!(
            "{statement}: ON COMMIT is not supported"
        )));
    }
    if !stmt.tablespacename.is_empty() {
        return Err(SQLError::Unsupported(format!(
            "{statement}: TABLESPACE is not supported"
        )));
    }
    if !stmt.access_method.is_empty() {
        return Err(SQLError::Unsupported(format!(
            "{statement}: USING access methods are not supported"
        )));
    }
    Ok(())
}

pub(super) fn render_relation_component(component: &str) -> String {
    let can_render_bare = component
        .bytes()
        .enumerate()
        .all(|(index, byte)| match byte {
            b'a'..=b'z' | b'_' => true,
            b'0'..=b'9' | b'$' => index != 0,
            _ => false,
        });
    if can_render_bare && !component.is_empty() {
        component.to_string()
    } else {
        format!("\"{}\"", component.replace('"', "\"\""))
    }
}

pub(crate) fn compile_qualified_name(parts: &[Node], statement: &str) -> Result<String> {
    let parts = parts
        .iter()
        .map(extract_string)
        .collect::<Result<Vec<_>>>()?;
    if parts.is_empty() {
        return Err(SQLError::Internal(format!(
            "{statement} without a routine name"
        )));
    }
    if parts.len() > 2 {
        return Err(SQLError::Unsupported(format!(
            "{statement}: cross-database routine names are not supported"
        )));
    }
    Ok(parts
        .iter()
        .map(|part| render_relation_component(part))
        .collect::<Vec<_>>()
        .join("."))
}