thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 07:31:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Check if the mutation query is valid.

Browse Source
This commit is contained in:
Christoph Wurm 2024-10-31 12:04:24 +00:00
parent e29c488b05
commit b229fb1664
3 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Interpreters/MutationsInterpreter.cpp
View File

@ -1386,6 +1386,9 @@ void MutationsInterpreter::validate()
} }
} }
// Make sure the mutations query is valid
prepareQueryAffectedQueryTree(commands, source.getStorage(), context);
QueryPlan plan; QueryPlan plan;
initQueryPlan(stages.front(), plan); initQueryPlan(stages.front(), plan);

0
tests/queries/0_stateless/03256_invalid_mutation_query.reference Normal file
View File

19
tests/queries/0_stateless/03256_invalid_mutation_query.sql Normal file
View File

@ -0,0 +1,19 @@
DROP TABLE IF EXISTS t;
DROP TABLE IF EXISTS t2;
CREATE TABLE t (x int) ENGINE = MergeTree() ORDER BY ();
DELETE FROM t WHERE y in (SELECT y FROM t); -- { serverError 47 }
DELETE FROM t WHERE x in (SELECT y FROM t); -- { serverError 47 }
DELETE FROM t WHERE x IN (SELECT * FROM t2); -- { serverError 60 }
ALTER TABLE t DELETE WHERE x in (SELECT y FROM t); -- { serverError 47 }
ALTER TABLE t UPDATE x = 1 WHERE x IN (SELECT y FROM t); -- { serverError 47 }
ALTER TABLE t ADD COLUMN y int;
DELETE FROM t WHERE y in (SELECT y FROM t);
CREATE TABLE t2 (x int) ENGINE = MergeTree() ORDER BY ();
DELETE FROM t WHERE x IN (SELECT * FROM t2);
DROP TABLE t;
DROP TABLE t2;