#![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 o = Command::new(bin).arg(":memory:").arg(sql).output().unwrap();
let mut s = String::from_utf8_lossy(&o.stdout).into_owned();
s.push_str(&String::from_utf8_lossy(&o.stderr));
let mut lines = Vec::new();
for line in s.lines() {
let mut t = line.trim_end();
if t.trim_start().starts_with('^') {
continue;
}
for prefix in [
"Error: ",
"in prepare, ",
"stepping, ",
"SQL error: ",
"error: ",
] {
t = t.strip_prefix(prefix).unwrap_or(t);
}
lines.push(t.to_string());
}
lines.join("\n")
}
#[test]
fn view_rename_column_subquery_matches_sqlite() {
if !sqlite3_available() {
eprintln!("sqlite3 CLI not found; skipping");
return;
}
let g = env!("CARGO_BIN_EXE_graphitesql");
let matching = [
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT a, (SELECT b FROM t t2 WHERE t2.a=t.a) AS m \
FROM t; ALTER TABLE t RENAME COLUMN a TO aa; SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT a FROM t WHERE \
EXISTS(SELECT 1 FROM t t2 WHERE t2.a=t.a); ALTER TABLE t RENAME COLUMN a TO aa; \
SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT a FROM t WHERE \
NOT EXISTS(SELECT 1 FROM t t2 WHERE t2.a<t.a); ALTER TABLE t RENAME COLUMN a TO aa; \
SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT a FROM t WHERE a IN (SELECT a FROM t t2); \
ALTER TABLE t RENAME COLUMN a TO aa; SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE TABLE t(a,b); INSERT INTO t VALUES(1,10),(2,20); \
CREATE VIEW v AS SELECT a FROM t WHERE a IN (SELECT a FROM t t2 WHERE a IN \
(SELECT a FROM t t3)); ALTER TABLE t RENAME COLUMN a TO aa; \
SELECT sql FROM sqlite_schema WHERE name='v'; SELECT * FROM v ORDER BY aa",
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT a FROM t GROUP BY a HAVING a > \
(SELECT min(a) FROM t t2); ALTER TABLE t RENAME COLUMN a TO aa; \
SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE TABLE t(a,b); INSERT INTO t VALUES(1,10),(2,20); \
CREATE VIEW v AS SELECT a, (SELECT max(b) FROM t t2 WHERE t2.a<=t.a) AS m FROM t; \
ALTER TABLE t RENAME COLUMN a TO aa; SELECT sql FROM sqlite_schema WHERE name='v'; \
SELECT * FROM v ORDER BY aa",
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT a, (SELECT b FROM t t2 WHERE t2.a=t.a) AS m \
FROM t; ALTER TABLE t RENAME COLUMN b TO bb; SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT a, (SELECT 1) AS one FROM t; \
ALTER TABLE t RENAME COLUMN a TO aa; SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE TABLE t(a,b); CREATE TABLE other(id); \
CREATE VIEW v AS SELECT a FROM t WHERE a IN (SELECT id FROM other); \
ALTER TABLE t RENAME COLUMN a TO aa; SELECT sql FROM sqlite_schema WHERE name='v'",
];
for sql in matching {
assert_eq!(run("sqlite3", sql), run(g, sql), "for {sql}");
}
let bail = [
(
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT b AS a, a FROM t; \
ALTER TABLE t RENAME COLUMN a TO aa; SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE VIEW v AS SELECT b AS a, a FROM t",
),
(
"CREATE TABLE t(a,b); CREATE VIEW v AS SELECT a FROM (SELECT a FROM t); \
ALTER TABLE t RENAME COLUMN a TO aa; SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE VIEW v AS SELECT a FROM (SELECT a FROM t)",
),
(
"CREATE TABLE t(a,b); CREATE TABLE u(a,c); \
CREATE VIEW v AS SELECT a, (SELECT c FROM u WHERE u.a=t.a) FROM t; \
ALTER TABLE t RENAME COLUMN a TO aa; SELECT sql FROM sqlite_schema WHERE name='v'",
"CREATE VIEW v AS SELECT a, (SELECT c FROM u WHERE u.a=t.a) FROM t",
),
];
for (sql, unchanged) in bail {
assert_eq!(run(g, sql), unchanged, "bail invariant for {sql}");
}
}