#![cfg(feature = "std")]
use std::process::Command;
fn sqlite3_available() -> bool {
Command::new("sqlite3").arg("--version").output().is_ok()
}
fn run(bin: &str, sql: &str) -> String {
let out = Command::new(bin).arg(":memory:").arg(sql).output().unwrap();
let stdout = String::from_utf8_lossy(&out.stdout);
if !stdout.trim().is_empty() {
return stdout.trim_end().to_string();
}
String::from_utf8_lossy(&out.stderr)
.lines()
.find(|l| !l.trim_start().starts_with('^'))
.unwrap_or("")
.trim_start_matches("Error: in prepare, ")
.trim_start_matches("Error: stepping, ")
.trim_start_matches("Error: ")
.trim_start_matches("SQL error: ")
.trim_start_matches("error: ")
.trim_end()
.to_string()
}
const BASE: &str = "CREATE TABLE t(a,b); CREATE INDEX it ON t(a);";
const DATA: &str = "CREATE TABLE t(a,b); INSERT INTO t VALUES(1,2),(3,4),(5,6);";
#[test]
fn materialized_cte_renders_materialize_node() {
if !sqlite3_available() {
eprintln!("sqlite3 CLI not found; skipping");
return;
}
let g = env!("CARGO_BIN_EXE_graphitesql");
for q in [
"WITH c AS MATERIALIZED (SELECT * FROM t) SELECT * FROM c",
"WITH c AS MATERIALIZED (SELECT * FROM t) SELECT * FROM c WHERE a=1",
"WITH c AS MATERIALIZED (SELECT a FROM t WHERE b>1) SELECT * FROM c",
"WITH c AS MATERIALIZED (SELECT a FROM t WHERE a=5) SELECT * FROM c",
"WITH c AS MATERIALIZED (SELECT * FROM t) SELECT count(*) FROM c",
"WITH c AS MATERIALIZED (SELECT * FROM t) SELECT * FROM c ORDER BY a",
"WITH c AS MATERIALIZED (SELECT * FROM t) SELECT * FROM c GROUP BY a",
"WITH c AS MATERIALIZED (SELECT * FROM t) SELECT DISTINCT a FROM c",
"WITH c AS MATERIALIZED (SELECT * FROM t) SELECT max(a) FROM c",
"WITH c AS MATERIALIZED (VALUES(1,2),(3,4)) SELECT * FROM c",
"WITH c AS MATERIALIZED (VALUES(1)) SELECT * FROM c",
"WITH c AS NOT MATERIALIZED (SELECT * FROM t) SELECT * FROM c",
"WITH c AS (SELECT * FROM t) SELECT * FROM c",
] {
let sql = format!("{BASE} EXPLAIN QUERY PLAN {q}");
assert_eq!(run("sqlite3", &sql), run(g, &sql), "for {q}");
}
}
#[test]
fn materialized_hint_does_not_change_rows() {
if !sqlite3_available() {
eprintln!("sqlite3 CLI not found; skipping");
return;
}
let g = env!("CARGO_BIN_EXE_graphitesql");
for q in [
"WITH c AS MATERIALIZED (SELECT * FROM t) SELECT * FROM c",
"WITH c AS MATERIALIZED (SELECT a FROM t WHERE b>2) SELECT sum(a) FROM c",
"WITH c AS MATERIALIZED (VALUES(1,2),(3,4)) SELECT * FROM c",
"WITH c AS NOT MATERIALIZED (SELECT * FROM t) SELECT max(a) FROM c",
] {
let sql = format!("{DATA} {q}");
assert_eq!(run("sqlite3", &sql), run(g, &sql), "rows for {q}");
}
}
#[test]
fn materialized_values_subquery_body_declines() {
let g = env!("CARGO_BIN_EXE_graphitesql");
for q in [
"WITH c AS MATERIALIZED (VALUES((SELECT 1))) SELECT * FROM c",
"WITH c AS MATERIALIZED (VALUES((SELECT 1),2),(3,4)) SELECT * FROM c",
] {
let sql = format!("EXPLAIN QUERY PLAN {q}");
let got = run(g, &sql);
assert!(
got.contains("EXPLAIN QUERY PLAN for this query shape"),
"{q} should decline as unsupported, got {got:?}"
);
}
}