hawdb-sql 0.13.0

An embedded Rust graph database for local data-plane workloads
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
141
142
143
144
145
146
147
148
149

// Copyright 2026 Nowledge
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

use crate::{
    prepare_postgres_sql, Expr, ExprKind, RelationalPlanTemplateCache, SelectProjection,
    SelectStatement, SqlSourceLocation, SqlSourceSpan, SqlStatement, SqlValue,
};
use hawdb_core::Value;

fn parse_select(sql: &str) -> SelectStatement {
    let SqlStatement::Select(select) = prepare_postgres_sql(sql).unwrap().statement else {
        panic!("expected SELECT");
    };
    select
}

fn span(line: u64, start: u64, end: u64) -> SqlSourceSpan {
    SqlSourceSpan {
        start: SqlSourceLocation {
            line,
            column: start,
        },
        end: SqlSourceLocation { line, column: end },
    }
}

#[test]
fn projections_predicates_and_order_retain_token_locations() {
    let select = parse_select("SELECT id, $1\nFROM items\nWHERE id = $2\nORDER BY id DESC");
    let expressions = select
        .projection
        .iter()
        .map(|projection| match projection {
            SelectProjection::Expression { expression, .. } => expression,
            _ => panic!("expected expression"),
        })
        .collect::<Vec<_>>();
    assert_eq!(expressions[0].span, span(1, 8, 10));
    assert_eq!(expressions[1].span, span(1, 12, 14));
    assert_eq!(select.order_by[0].expression.span, span(4, 10, 12));
    let predicate = select.selection.unwrap();
    assert_eq!(predicate.span, span(3, 7, 14));
    let ExprKind::Compare { left, right, .. } = predicate.kind else {
        panic!("expected comparison");
    };
    assert_eq!(left.span, span(3, 7, 9));
    assert_eq!(right.span, span(3, 12, 14));
    assert_eq!(right.as_value(), Some(&SqlValue::Parameter(2)));

    // Columns are character positions, not UTF-8 byte offsets.
    let unicode = parse_select("SELECT 'é', id FROM items");
    let SelectProjection::Expression { expression, .. } = &unicode.projection[1] else {
        panic!("expected column expression");
    };
    assert_eq!(expression.span, span(1, 13, 15));
}

#[test]
fn shared_traversal_keeps_filter_parameters_and_cached_source_metadata() {
    let sql = "SELECT COALESCE($1, id), COUNT(*) FILTER (WHERE active = $2) \
               FROM items JOIN owners ON items.owner = $3 \
               WHERE id IN ($4, $1) AND NOT name LIKE $5 ORDER BY id LIMIT $6 OFFSET $7";
    let prepared = prepare_postgres_sql(sql).unwrap();
    assert_eq!(
        prepared
            .parameters
            .iter()
            .map(|p| p.position)
            .collect::<Vec<_>>(),
        (1..=7).collect::<Vec<_>>()
    );
    assert!(prepare_postgres_sql(&sql.replace("$2", "$8"))
        .unwrap_err()
        .to_string()
        .contains("must be dense"));

    let cache = RelationalPlanTemplateCache::new(Some(2));
    let first = cache.prepare(sql).unwrap();
    let mut statement = first.statement().clone();
    let SqlStatement::Select(select) = &mut statement else {
        panic!("expected SELECT");
    };
    let SelectProjection::Expression { expression, .. } = &mut select.projection[1] else {
        panic!("expected filtered aggregate");
    };
    let mut before = Vec::new();
    expression.visit(&mut |node| before.push(node.span));
    let mut rewritten = Vec::new();
    expression
        .try_visit_mut(&mut |node: &mut Expr| {
            if let ExprKind::Value(SqlValue::Parameter(position)) = &node.kind {
                rewritten.push(*position);
                node.kind = ExprKind::Value(SqlValue::Literal(Value::Bool(true)));
            }
            Ok::<_, ()>(())
        })
        .unwrap();
    let mut after = Vec::new();
    expression.visit(&mut |node| after.push(node.span));
    assert_eq!(rewritten, vec![2]);
    assert_eq!(after, before);
    assert!(before.iter().all(|span| *span != SqlSourceSpan::default()));
    let second = cache.prepare(sql).unwrap();
    assert!(std::sync::Arc::ptr_eq(&first.template, &second.template));
    assert_eq!(*second.template, prepared);
    assert_ne!(statement, prepared.statement);
}

#[test]
fn uniform_representation_preserves_frontend_expression_boundaries() {
    for sql in [
        "SELECT id = 1 FROM items",
        "SELECT id + 1 FROM items",
        "SELECT id FROM items WHERE 1 = id",
        "SELECT id FROM items WHERE COALESCE(id, 1) = 2",
        "SELECT id FROM items WHERE id IN (other)",
        "SELECT id FROM items WHERE TRUE",
        "SELECT id FROM items ORDER BY $1",
        "SELECT id FROM items ORDER BY COALESCE(id, 1)",
    ] {
        assert!(
            prepare_postgres_sql(sql).is_err(),
            "unexpected acceptance: {sql}"
        );
    }
    for sql in [
        "SELECT id FROM items WHERE id = other",
        "SELECT COALESCE(id, $1) FROM items WHERE NOT (id IS NULL)",
        "SELECT COUNT(*) FILTER (WHERE active = $1) FROM items",
        "SELECT id FROM items HAVING id = 1",
        "SELECT id FROM items, owners",
    ] {
        assert!(
            prepare_postgres_sql(sql).is_ok(),
            "unexpected rejection: {sql}"
        );
    }
}