nodedb_sql/parser/preprocess/
literal.rs

1// SPDX-License-Identifier: Apache-2.0
2
3//! SQL literal canonicalization for `nodedb_types::Value`.
4
5/// Convert a `nodedb_types::Value` to a SQL literal string.
6///
7/// Used by pre-processing and by Origin's pgwire handlers to build SQL
8/// from parsed field maps. Handles all Value variants.
9pub fn value_to_sql_literal(value: &nodedb_types::Value) -> String {
10    match value {
11        nodedb_types::Value::String(s) => format!("'{}'", s.replace('\'', "''")),
12        nodedb_types::Value::Integer(n) => n.to_string(),
13        nodedb_types::Value::Float(f) => {
14            if f.is_finite() {
15                format!("{f}")
16            } else {
17                // NaN / ±inf have no canonical SQL literal form. Emitting
18                // `NaN` or `inf` would be parsed as an identifier
19                // reference by the planner and either bind to an unrelated
20                // column or fail with an opaque error. Canonicalize to
21                // NULL instead; the column value becomes unknown, which
22                // matches the semantic of a non-finite numeric.
23                "NULL".to_string()
24            }
25        }
26        nodedb_types::Value::Bool(b) => if *b { "TRUE" } else { "FALSE" }.to_string(),
27        nodedb_types::Value::Null => "NULL".to_string(),
28        nodedb_types::Value::Array(items) => {
29            let inner: Vec<String> = items.iter().map(value_to_sql_literal).collect();
30            format!("ARRAY[{}]", inner.join(", "))
31        }
32        nodedb_types::Value::Bytes(b) => {
33            let hex: String = b.iter().map(|byte| format!("{byte:02x}")).collect();
34            format!("'\\x{hex}'")
35        }
36        nodedb_types::Value::Object(map) => {
37            let json = super::function_args::value_map_to_json(map);
38            format!("'{}'", json.replace('\'', "''"))
39        }
40        nodedb_types::Value::Uuid(u) => format!("'{u}'"),
41        nodedb_types::Value::Ulid(u) => format!("'{u}'"),
42        nodedb_types::Value::DateTime(dt) | nodedb_types::Value::NaiveDateTime(dt) => {
43            format!("'{dt}'")
44        }
45        nodedb_types::Value::Duration(d) => format!("'{d}'"),
46        nodedb_types::Value::Decimal(d) => d.to_string(),
47        other => format!("'{}'", format!("{other:?}").replace('\'', "''")),
48    }
49}
nodedb_sql/parser/preprocess/literal.rs

nodedb_sql/parser/preprocess/
literal.rs
