TestSqlStatementParser.cpp 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785
  1. /*
  2. * Copyright (c) 2021, Tim Flynn <trflynn89@serenityos.org>
  3. * Copyright (c) 2021, Jan de Visser <jan@de-visser.net>
  4. * Copyright (c) 2021, Mahmoud Mandour <ma.mandourr@gmail.com>
  5. *
  6. * SPDX-License-Identifier: BSD-2-Clause
  7. */
  8. #include <LibTest/TestCase.h>
  9. #include <AK/ByteString.h>
  10. #include <AK/Optional.h>
  11. #include <AK/Result.h>
  12. #include <AK/StringView.h>
  13. #include <AK/TypeCasts.h>
  14. #include <AK/Vector.h>
  15. #include <LibSQL/AST/Lexer.h>
  16. #include <LibSQL/AST/Parser.h>
  17. namespace {
  18. using ParseResult = AK::Result<NonnullRefPtr<SQL::AST::Statement>, ByteString>;
  19. ParseResult parse(StringView sql)
  20. {
  21. auto parser = SQL::AST::Parser(SQL::AST::Lexer(sql));
  22. auto statement = parser.next_statement();
  23. if (parser.has_errors()) {
  24. return parser.errors()[0].to_byte_string();
  25. }
  26. return statement;
  27. }
  28. }
  29. TEST_CASE(create_table)
  30. {
  31. EXPECT(parse("CREATE TABLE"sv).is_error());
  32. EXPECT(parse("CREATE TABLE test"sv).is_error());
  33. EXPECT(parse("CREATE TABLE test ()"sv).is_error());
  34. EXPECT(parse("CREATE TABLE test ();"sv).is_error());
  35. EXPECT(parse("CREATE TABLE test ( column1 "sv).is_error());
  36. EXPECT(parse("CREATE TABLE test ( column1 )"sv).is_error());
  37. EXPECT(parse("CREATE TABLE IF test ( column1 );"sv).is_error());
  38. EXPECT(parse("CREATE TABLE IF NOT test ( column1 );"sv).is_error());
  39. EXPECT(parse("CREATE TABLE AS;"sv).is_error());
  40. EXPECT(parse("CREATE TABLE AS SELECT;"sv).is_error());
  41. EXPECT(parse("CREATE TABLE test ( column1 varchar()"sv).is_error());
  42. EXPECT(parse("CREATE TABLE test ( column1 varchar(abc)"sv).is_error());
  43. EXPECT(parse("CREATE TABLE test ( column1 varchar(123 )"sv).is_error());
  44. EXPECT(parse("CREATE TABLE test ( column1 varchar(123, )"sv).is_error());
  45. EXPECT(parse("CREATE TABLE test ( column1 varchar(123, ) )"sv).is_error());
  46. EXPECT(parse("CREATE TABLE test ( column1 varchar(.) )"sv).is_error());
  47. EXPECT(parse("CREATE TABLE test ( column1 varchar(.abc) )"sv).is_error());
  48. EXPECT(parse("CREATE TABLE test ( column1 varchar(0x) )"sv).is_error());
  49. EXPECT(parse("CREATE TABLE test ( column1 varchar(0xzzz) )"sv).is_error());
  50. EXPECT(parse("CREATE TABLE test ( column1 int ) AS SELECT * FROM table_name;"sv).is_error());
  51. EXPECT(parse("CREATE TABLE test AS SELECT * FROM table_name ( column1 int ) ;"sv).is_error());
  52. struct Column {
  53. StringView name;
  54. StringView type;
  55. Vector<double> signed_numbers {};
  56. };
  57. auto validate = [](StringView sql, StringView expected_schema, StringView expected_table, Vector<Column> expected_columns, bool expected_is_temporary = false, bool expected_is_error_if_table_exists = true) {
  58. auto statement = TRY_OR_FAIL(parse(sql));
  59. EXPECT(is<SQL::AST::CreateTable>(*statement));
  60. auto const& table = static_cast<const SQL::AST::CreateTable&>(*statement);
  61. EXPECT_EQ(table.schema_name(), expected_schema);
  62. EXPECT_EQ(table.table_name(), expected_table);
  63. EXPECT_EQ(table.is_temporary(), expected_is_temporary);
  64. EXPECT_EQ(table.is_error_if_table_exists(), expected_is_error_if_table_exists);
  65. bool expect_select_statement = expected_columns.is_empty();
  66. EXPECT_EQ(table.has_selection(), expect_select_statement);
  67. EXPECT_EQ(table.has_columns(), !expect_select_statement);
  68. auto const& select_statement = table.select_statement();
  69. EXPECT_EQ(select_statement.is_null(), !expect_select_statement);
  70. auto const& columns = table.columns();
  71. EXPECT_EQ(columns.size(), expected_columns.size());
  72. for (size_t i = 0; i < columns.size(); ++i) {
  73. auto const& column = columns[i];
  74. auto const& expected_column = expected_columns[i];
  75. EXPECT_EQ(column->name(), expected_column.name);
  76. auto const& type_name = column->type_name();
  77. EXPECT_EQ(type_name->name(), expected_column.type);
  78. auto const& signed_numbers = type_name->signed_numbers();
  79. EXPECT_EQ(signed_numbers.size(), expected_column.signed_numbers.size());
  80. for (size_t j = 0; j < signed_numbers.size(); ++j) {
  81. double signed_number = signed_numbers[j]->value();
  82. double expected_signed_number = expected_column.signed_numbers[j];
  83. EXPECT_EQ(signed_number, expected_signed_number);
  84. }
  85. }
  86. };
  87. validate("CREATE TABLE test ( column1 );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "BLOB"sv } });
  88. validate("Create Table test ( column1 );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "BLOB"sv } });
  89. validate(R"(CREATE TABLE "test" ( "column1" );)"sv, {}, "test"sv, { { "column1"sv, "BLOB"sv } });
  90. validate(R"(CREATE TABLE "te""st" ( "co""lumn1" );)"sv, {}, "te\"st"sv, { { "co\"lumn1"sv, "BLOB"sv } });
  91. validate("CREATE TABLE schema_name.test ( column1 );"sv, "SCHEMA_NAME"sv, "TEST"sv, { { "COLUMN1"sv, "BLOB"sv } });
  92. validate("CREATE TABLE \"schema\".test ( column1 );"sv, "schema"sv, "TEST"sv, { { "COLUMN1"sv, "BLOB"sv } });
  93. validate("CREATE TEMP TABLE test ( column1 );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "BLOB"sv } }, true, true);
  94. validate("CREATE TEMPORARY TABLE test ( column1 );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "BLOB"sv } }, true, true);
  95. validate("CREATE TABLE IF NOT EXISTS test ( column1 );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "BLOB"sv } }, false, false);
  96. validate("CREATE TABLE test AS SELECT * FROM table_name;"sv, {}, "TEST"sv, {});
  97. validate("CREATE TABLE test ( column1 int );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "INT"sv } });
  98. validate("CREATE TABLE test ( column1 varchar );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "VARCHAR"sv } });
  99. validate("CREATE TABLE test ( column1 varchar(255) );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "VARCHAR"sv, { 255 } } });
  100. validate("CREATE TABLE test ( column1 varchar(255, 123) );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "VARCHAR"sv, { 255, 123 } } });
  101. validate("CREATE TABLE test ( column1 varchar(255, -123) );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "VARCHAR"sv, { 255, -123 } } });
  102. validate("CREATE TABLE test ( column1 varchar(0xff) );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "VARCHAR"sv, { 255 } } });
  103. validate("CREATE TABLE test ( column1 varchar(3.14) );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "VARCHAR"sv, { 3.14 } } });
  104. validate("CREATE TABLE test ( column1 varchar(1e3) );"sv, {}, "TEST"sv, { { "COLUMN1"sv, "VARCHAR"sv, { 1000 } } });
  105. }
  106. TEST_CASE(alter_table)
  107. {
  108. // This test case only contains common error cases of the AlterTable subclasses.
  109. EXPECT(parse("ALTER"sv).is_error());
  110. EXPECT(parse("ALTER TABLE"sv).is_error());
  111. EXPECT(parse("ALTER TABLE table_name"sv).is_error());
  112. EXPECT(parse("ALTER TABLE table_name;"sv).is_error());
  113. }
  114. TEST_CASE(alter_table_rename_table)
  115. {
  116. EXPECT(parse("ALTER TABLE table_name RENAME"sv).is_error());
  117. EXPECT(parse("ALTER TABLE table_name RENAME TO"sv).is_error());
  118. EXPECT(parse("ALTER TABLE table_name RENAME TO new_table"sv).is_error());
  119. auto validate = [](StringView sql, StringView expected_schema, StringView expected_table, StringView expected_new_table) {
  120. auto statement = TRY_OR_FAIL(parse(sql));
  121. EXPECT(is<SQL::AST::RenameTable>(*statement));
  122. auto const& alter = static_cast<const SQL::AST::RenameTable&>(*statement);
  123. EXPECT_EQ(alter.schema_name(), expected_schema);
  124. EXPECT_EQ(alter.table_name(), expected_table);
  125. EXPECT_EQ(alter.new_table_name(), expected_new_table);
  126. };
  127. validate("ALTER TABLE table_name RENAME TO new_table;"sv, {}, "TABLE_NAME"sv, "NEW_TABLE"sv);
  128. validate("ALTER TABLE schema_name.table_name RENAME TO new_table;"sv, "SCHEMA_NAME"sv, "TABLE_NAME"sv, "NEW_TABLE"sv);
  129. }
  130. TEST_CASE(alter_table_rename_column)
  131. {
  132. EXPECT(parse("ALTER TABLE table_name RENAME"sv).is_error());
  133. EXPECT(parse("ALTER TABLE table_name RENAME COLUMN"sv).is_error());
  134. EXPECT(parse("ALTER TABLE table_name RENAME COLUMN column_name"sv).is_error());
  135. EXPECT(parse("ALTER TABLE table_name RENAME COLUMN column_name TO"sv).is_error());
  136. EXPECT(parse("ALTER TABLE table_name RENAME COLUMN column_name TO new_column"sv).is_error());
  137. EXPECT(parse("ALTER TABLE table_name RENAME column_name"sv).is_error());
  138. EXPECT(parse("ALTER TABLE table_name RENAME column_name TO"sv).is_error());
  139. EXPECT(parse("ALTER TABLE table_name RENAME column_name TO new_column"sv).is_error());
  140. auto validate = [](StringView sql, StringView expected_schema, StringView expected_table, StringView expected_column, StringView expected_new_column) {
  141. auto statement = TRY_OR_FAIL(parse(sql));
  142. EXPECT(is<SQL::AST::RenameColumn>(*statement));
  143. auto const& alter = static_cast<const SQL::AST::RenameColumn&>(*statement);
  144. EXPECT_EQ(alter.schema_name(), expected_schema);
  145. EXPECT_EQ(alter.table_name(), expected_table);
  146. EXPECT_EQ(alter.column_name(), expected_column);
  147. EXPECT_EQ(alter.new_column_name(), expected_new_column);
  148. };
  149. validate("ALTER TABLE table_name RENAME column_name TO new_column;"sv, {}, "TABLE_NAME"sv, "COLUMN_NAME"sv, "NEW_COLUMN"sv);
  150. validate("ALTER TABLE table_name RENAME COLUMN column_name TO new_column;"sv, {}, "TABLE_NAME"sv, "COLUMN_NAME"sv, "NEW_COLUMN"sv);
  151. validate("ALTER TABLE schema_name.table_name RENAME column_name TO new_column;"sv, "SCHEMA_NAME"sv, "TABLE_NAME"sv, "COLUMN_NAME"sv, "NEW_COLUMN"sv);
  152. validate("ALTER TABLE schema_name.table_name RENAME COLUMN column_name TO new_column;"sv, "SCHEMA_NAME"sv, "TABLE_NAME"sv, "COLUMN_NAME"sv, "NEW_COLUMN"sv);
  153. }
  154. TEST_CASE(alter_table_add_column)
  155. {
  156. EXPECT(parse("ALTER TABLE table_name ADD"sv).is_error());
  157. EXPECT(parse("ALTER TABLE table_name ADD COLUMN"sv).is_error());
  158. EXPECT(parse("ALTER TABLE table_name ADD COLUMN column_name"sv).is_error());
  159. struct Column {
  160. StringView name;
  161. StringView type;
  162. Vector<double> signed_numbers {};
  163. };
  164. auto validate = [](StringView sql, StringView expected_schema, StringView expected_table, Column expected_column) {
  165. auto statement = TRY_OR_FAIL(parse(sql));
  166. EXPECT(is<SQL::AST::AddColumn>(*statement));
  167. auto const& alter = static_cast<const SQL::AST::AddColumn&>(*statement);
  168. EXPECT_EQ(alter.schema_name(), expected_schema);
  169. EXPECT_EQ(alter.table_name(), expected_table);
  170. auto const& column = alter.column();
  171. EXPECT_EQ(column->name(), expected_column.name);
  172. auto const& type_name = column->type_name();
  173. EXPECT_EQ(type_name->name(), expected_column.type);
  174. auto const& signed_numbers = type_name->signed_numbers();
  175. EXPECT_EQ(signed_numbers.size(), expected_column.signed_numbers.size());
  176. for (size_t j = 0; j < signed_numbers.size(); ++j) {
  177. double signed_number = signed_numbers[j]->value();
  178. double expected_signed_number = expected_column.signed_numbers[j];
  179. EXPECT_EQ(signed_number, expected_signed_number);
  180. }
  181. };
  182. validate("ALTER TABLE test ADD column1;"sv, {}, "TEST"sv, { "COLUMN1"sv, "BLOB"sv });
  183. validate("ALTER TABLE test ADD column1 int;"sv, {}, "TEST"sv, { "COLUMN1"sv, "INT"sv });
  184. validate("ALTER TABLE test ADD column1 varchar;"sv, {}, "TEST"sv, { "COLUMN1"sv, "VARCHAR"sv });
  185. validate("ALTER TABLE test ADD column1 varchar(255);"sv, {}, "TEST"sv, { "COLUMN1"sv, "VARCHAR"sv, { 255 } });
  186. validate("ALTER TABLE test ADD column1 varchar(255, 123);"sv, {}, "TEST"sv, { "COLUMN1"sv, "VARCHAR"sv, { 255, 123 } });
  187. validate("ALTER TABLE schema_name.test ADD COLUMN column1;"sv, "SCHEMA_NAME"sv, "TEST"sv, { "COLUMN1"sv, "BLOB"sv });
  188. validate("ALTER TABLE schema_name.test ADD COLUMN column1 int;"sv, "SCHEMA_NAME"sv, "TEST"sv, { "COLUMN1"sv, "INT"sv });
  189. validate("ALTER TABLE schema_name.test ADD COLUMN column1 varchar;"sv, "SCHEMA_NAME"sv, "TEST"sv, { "COLUMN1"sv, "VARCHAR"sv });
  190. validate("ALTER TABLE schema_name.test ADD COLUMN column1 varchar(255);"sv, "SCHEMA_NAME"sv, "TEST"sv, { "COLUMN1"sv, "VARCHAR"sv, { 255 } });
  191. validate("ALTER TABLE schema_name.test ADD COLUMN column1 varchar(255, 123);"sv, "SCHEMA_NAME"sv, "TEST"sv, { "COLUMN1"sv, "VARCHAR"sv, { 255, 123 } });
  192. }
  193. TEST_CASE(alter_table_drop_column)
  194. {
  195. EXPECT(parse("ALTER TABLE table_name DROP"sv).is_error());
  196. EXPECT(parse("ALTER TABLE table_name DROP COLUMN"sv).is_error());
  197. EXPECT(parse("ALTER TABLE table_name DROP column_name"sv).is_error());
  198. EXPECT(parse("ALTER TABLE table_name DROP COLUMN column_name"sv).is_error());
  199. auto validate = [](StringView sql, StringView expected_schema, StringView expected_table, StringView expected_column) {
  200. auto statement = TRY_OR_FAIL(parse(sql));
  201. EXPECT(is<SQL::AST::DropColumn>(*statement));
  202. auto const& alter = static_cast<const SQL::AST::DropColumn&>(*statement);
  203. EXPECT_EQ(alter.schema_name(), expected_schema);
  204. EXPECT_EQ(alter.table_name(), expected_table);
  205. EXPECT_EQ(alter.column_name(), expected_column);
  206. };
  207. validate("ALTER TABLE table_name DROP column_name;"sv, {}, "TABLE_NAME"sv, "COLUMN_NAME"sv);
  208. validate("ALTER TABLE table_name DROP COLUMN column_name;"sv, {}, "TABLE_NAME"sv, "COLUMN_NAME"sv);
  209. validate("ALTER TABLE schema_name.table_name DROP column_name;"sv, "SCHEMA_NAME"sv, "TABLE_NAME"sv, "COLUMN_NAME"sv);
  210. validate("ALTER TABLE schema_name.table_name DROP COLUMN column_name;"sv, "SCHEMA_NAME"sv, "TABLE_NAME"sv, "COLUMN_NAME"sv);
  211. }
  212. TEST_CASE(drop_table)
  213. {
  214. EXPECT(parse("DROP"sv).is_error());
  215. EXPECT(parse("DROP TABLE"sv).is_error());
  216. EXPECT(parse("DROP TABLE test"sv).is_error());
  217. EXPECT(parse("DROP TABLE IF test;"sv).is_error());
  218. auto validate = [](StringView sql, StringView expected_schema, StringView expected_table, bool expected_is_error_if_table_does_not_exist = true) {
  219. auto statement = TRY_OR_FAIL(parse(sql));
  220. EXPECT(is<SQL::AST::DropTable>(*statement));
  221. auto const& table = static_cast<const SQL::AST::DropTable&>(*statement);
  222. EXPECT_EQ(table.schema_name(), expected_schema);
  223. EXPECT_EQ(table.table_name(), expected_table);
  224. EXPECT_EQ(table.is_error_if_table_does_not_exist(), expected_is_error_if_table_does_not_exist);
  225. };
  226. validate("DROP TABLE test;"sv, {}, "TEST"sv);
  227. validate("DROP TABLE schema_name.test;"sv, "SCHEMA_NAME"sv, "TEST"sv);
  228. validate("DROP TABLE IF EXISTS test;"sv, {}, "TEST"sv, false);
  229. }
  230. TEST_CASE(insert)
  231. {
  232. EXPECT(parse("INSERT"sv).is_error());
  233. EXPECT(parse("INSERT INTO"sv).is_error());
  234. EXPECT(parse("INSERT INTO table_name"sv).is_error());
  235. EXPECT(parse("INSERT INTO table_name (column_name)"sv).is_error());
  236. EXPECT(parse("INSERT INTO table_name (column_name, ) DEFAULT VALUES;"sv).is_error());
  237. EXPECT(parse("INSERT INTO table_name VALUES"sv).is_error());
  238. EXPECT(parse("INSERT INTO table_name VALUES ();"sv).is_error());
  239. EXPECT(parse("INSERT INTO table_name VALUES (1)"sv).is_error());
  240. EXPECT(parse("INSERT INTO table_name VALUES SELECT"sv).is_error());
  241. EXPECT(parse("INSERT INTO table_name VALUES EXISTS"sv).is_error());
  242. EXPECT(parse("INSERT INTO table_name VALUES NOT"sv).is_error());
  243. EXPECT(parse("INSERT INTO table_name VALUES EXISTS (SELECT 1)"sv).is_error());
  244. EXPECT(parse("INSERT INTO table_name VALUES (SELECT)"sv).is_error());
  245. EXPECT(parse("INSERT INTO table_name VALUES (EXISTS SELECT)"sv).is_error());
  246. EXPECT(parse("INSERT INTO table_name VALUES ((SELECT))"sv).is_error());
  247. EXPECT(parse("INSERT INTO table_name VALUES (EXISTS (SELECT))"sv).is_error());
  248. EXPECT(parse("INSERT INTO table_name SELECT"sv).is_error());
  249. EXPECT(parse("INSERT INTO table_name SELECT * from table_name"sv).is_error());
  250. EXPECT(parse("INSERT OR INTO table_name DEFAULT VALUES;"sv).is_error());
  251. EXPECT(parse("INSERT OR foo INTO table_name DEFAULT VALUES;"sv).is_error());
  252. auto validate = [](StringView sql, SQL::AST::ConflictResolution expected_conflict_resolution, StringView expected_schema, StringView expected_table, StringView expected_alias, Vector<StringView> expected_column_names, Vector<size_t> expected_chain_sizes, bool expect_select_statement) {
  253. auto statement = TRY_OR_FAIL(parse(sql));
  254. EXPECT(is<SQL::AST::Insert>(*statement));
  255. auto const& insert = static_cast<const SQL::AST::Insert&>(*statement);
  256. EXPECT_EQ(insert.conflict_resolution(), expected_conflict_resolution);
  257. EXPECT_EQ(insert.schema_name(), expected_schema);
  258. EXPECT_EQ(insert.table_name(), expected_table);
  259. EXPECT_EQ(insert.alias(), expected_alias);
  260. auto const& column_names = insert.column_names();
  261. EXPECT_EQ(column_names.size(), expected_column_names.size());
  262. for (size_t i = 0; i < column_names.size(); ++i)
  263. EXPECT_EQ(column_names[i], expected_column_names[i]);
  264. EXPECT_EQ(insert.has_expressions(), !expected_chain_sizes.is_empty());
  265. if (insert.has_expressions()) {
  266. auto const& chained_expressions = insert.chained_expressions();
  267. EXPECT_EQ(chained_expressions.size(), expected_chain_sizes.size());
  268. for (size_t i = 0; i < chained_expressions.size(); ++i) {
  269. auto const& chained_expression = chained_expressions[i];
  270. auto const& expressions = chained_expression->expressions();
  271. EXPECT_EQ(expressions.size(), expected_chain_sizes[i]);
  272. for (auto const& expression : expressions)
  273. EXPECT(!is<SQL::AST::ErrorExpression>(expression));
  274. }
  275. }
  276. EXPECT_EQ(insert.has_selection(), expect_select_statement);
  277. EXPECT_EQ(insert.default_values(), expected_chain_sizes.is_empty() && !expect_select_statement);
  278. };
  279. validate("INSERT OR ABORT INTO table_name DEFAULT VALUES;"sv, SQL::AST::ConflictResolution::Abort, {}, "TABLE_NAME"sv, {}, {}, {}, false);
  280. validate("INSERT OR FAIL INTO table_name DEFAULT VALUES;"sv, SQL::AST::ConflictResolution::Fail, {}, "TABLE_NAME"sv, {}, {}, {}, false);
  281. validate("INSERT OR IGNORE INTO table_name DEFAULT VALUES;"sv, SQL::AST::ConflictResolution::Ignore, {}, "TABLE_NAME"sv, {}, {}, {}, false);
  282. validate("INSERT OR REPLACE INTO table_name DEFAULT VALUES;"sv, SQL::AST::ConflictResolution::Replace, {}, "TABLE_NAME"sv, {}, {}, {}, false);
  283. validate("INSERT OR ROLLBACK INTO table_name DEFAULT VALUES;"sv, SQL::AST::ConflictResolution::Rollback, {}, "TABLE_NAME"sv, {}, {}, {}, false);
  284. auto resolution = SQL::AST::ConflictResolution::Abort;
  285. validate("INSERT INTO table_name DEFAULT VALUES;"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, {}, false);
  286. validate("INSERT INTO schema_name.table_name DEFAULT VALUES;"sv, resolution, "SCHEMA_NAME"sv, "TABLE_NAME"sv, {}, {}, {}, false);
  287. validate("INSERT INTO table_name AS foo DEFAULT VALUES;"sv, resolution, {}, "TABLE_NAME"sv, "FOO"sv, {}, {}, false);
  288. validate("INSERT INTO table_name (column_name) DEFAULT VALUES;"sv, resolution, {}, "TABLE_NAME"sv, {}, { "COLUMN_NAME"sv }, {}, false);
  289. validate("INSERT INTO table_name (column1, column2) DEFAULT VALUES;"sv, resolution, {}, "TABLE_NAME"sv, {}, { "COLUMN1"sv, "COLUMN2"sv }, {}, false);
  290. validate("INSERT INTO table_name VALUES (1);"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, { 1 }, false);
  291. validate("INSERT INTO table_name VALUES (1, 2);"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, { 2 }, false);
  292. validate("INSERT INTO table_name VALUES (1, 2), (3, 4, 5);"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, { 2, 3 }, false);
  293. validate("INSERT INTO table_name VALUES ((SELECT 1));"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, { 1 }, false);
  294. validate("INSERT INTO table_name VALUES (EXISTS (SELECT 1));"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, { 1 }, false);
  295. validate("INSERT INTO table_name VALUES (NOT EXISTS (SELECT 1));"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, { 1 }, false);
  296. validate("INSERT INTO table_name VALUES ((SELECT 1), (SELECT 1));"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, { 2 }, false);
  297. validate("INSERT INTO table_name VALUES ((SELECT 1), (SELECT 1)), ((SELECT 1), (SELECT 1), (SELECT 1));"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, { 2, 3 }, false);
  298. validate("INSERT INTO table_name SELECT * FROM table_name;"sv, resolution, {}, "TABLE_NAME"sv, {}, {}, {}, true);
  299. }
  300. TEST_CASE(update)
  301. {
  302. EXPECT(parse("UPDATE"sv).is_error());
  303. EXPECT(parse("UPDATE table_name"sv).is_error());
  304. EXPECT(parse("UPDATE table_name SET"sv).is_error());
  305. EXPECT(parse("UPDATE table_name SET column_name"sv).is_error());
  306. EXPECT(parse("UPDATE table_name SET column_name=4"sv).is_error());
  307. EXPECT(parse("UPDATE table_name SET column_name=4, ;"sv).is_error());
  308. EXPECT(parse("UPDATE table_name SET (column_name)=4"sv).is_error());
  309. EXPECT(parse("UPDATE table_name SET (column_name)=EXISTS"sv).is_error());
  310. EXPECT(parse("UPDATE table_name SET (column_name)=SELECT"sv).is_error());
  311. EXPECT(parse("UPDATE table_name SET (column_name)=(SELECT)"sv).is_error());
  312. EXPECT(parse("UPDATE table_name SET (column_name)=NOT (SELECT 1)"sv).is_error());
  313. EXPECT(parse("UPDATE table_name SET (column_name)=4, ;"sv).is_error());
  314. EXPECT(parse("UPDATE table_name SET (column_name, )=4;"sv).is_error());
  315. EXPECT(parse("UPDATE table_name SET column_name=4 FROM"sv).is_error());
  316. EXPECT(parse("UPDATE table_name SET column_name=4 FROM table_name"sv).is_error());
  317. EXPECT(parse("UPDATE table_name SET column_name=4 WHERE"sv).is_error());
  318. EXPECT(parse("UPDATE table_name SET column_name=4 WHERE EXISTS"sv).is_error());
  319. EXPECT(parse("UPDATE table_name SET column_name=4 WHERE NOT"sv).is_error());
  320. EXPECT(parse("UPDATE table_name SET column_name=4 WHERE NOT EXISTS"sv).is_error());
  321. EXPECT(parse("UPDATE table_name SET column_name=4 WHERE SELECT"sv).is_error());
  322. EXPECT(parse("UPDATE table_name SET column_name=4 WHERE (SELECT)"sv).is_error());
  323. EXPECT(parse("UPDATE table_name SET column_name=4 WHERE NOT (SELECT)"sv).is_error());
  324. EXPECT(parse("UPDATE table_name SET column_name=4 WHERE 1==1"sv).is_error());
  325. EXPECT(parse("UPDATE table_name SET column_name=4 RETURNING"sv).is_error());
  326. EXPECT(parse("UPDATE table_name SET column_name=4 RETURNING *"sv).is_error());
  327. EXPECT(parse("UPDATE table_name SET column_name=4 RETURNING column_name"sv).is_error());
  328. EXPECT(parse("UPDATE table_name SET column_name=4 RETURNING column_name AS"sv).is_error());
  329. EXPECT(parse("UPDATE OR table_name SET column_name=4;"sv).is_error());
  330. EXPECT(parse("UPDATE OR foo table_name SET column_name=4;"sv).is_error());
  331. auto validate = [](StringView sql, SQL::AST::ConflictResolution expected_conflict_resolution, StringView expected_schema, StringView expected_table, StringView expected_alias, Vector<Vector<ByteString>> expected_update_columns, bool expect_where_clause, bool expect_returning_clause, Vector<StringView> expected_returned_column_aliases) {
  332. auto statement = TRY_OR_FAIL(parse(sql));
  333. EXPECT(is<SQL::AST::Update>(*statement));
  334. auto const& update = static_cast<const SQL::AST::Update&>(*statement);
  335. EXPECT_EQ(update.conflict_resolution(), expected_conflict_resolution);
  336. auto const& qualified_table_name = update.qualified_table_name();
  337. EXPECT_EQ(qualified_table_name->schema_name(), expected_schema);
  338. EXPECT_EQ(qualified_table_name->table_name(), expected_table);
  339. EXPECT_EQ(qualified_table_name->alias(), expected_alias);
  340. auto const& update_columns = update.update_columns();
  341. EXPECT_EQ(update_columns.size(), expected_update_columns.size());
  342. for (size_t i = 0; i < update_columns.size(); ++i) {
  343. auto const& update_column = update_columns[i];
  344. auto const& expected_update_column = expected_update_columns[i];
  345. EXPECT_EQ(update_column.column_names.size(), expected_update_column.size());
  346. EXPECT(!is<SQL::AST::ErrorExpression>(*update_column.expression));
  347. for (size_t j = 0; j < update_column.column_names.size(); ++j)
  348. EXPECT_EQ(update_column.column_names[j], expected_update_column[j]);
  349. }
  350. auto const& where_clause = update.where_clause();
  351. EXPECT_EQ(where_clause.is_null(), !expect_where_clause);
  352. if (where_clause)
  353. EXPECT(!is<SQL::AST::ErrorExpression>(*where_clause));
  354. auto const& returning_clause = update.returning_clause();
  355. EXPECT_EQ(returning_clause.is_null(), !expect_returning_clause);
  356. if (returning_clause) {
  357. EXPECT_EQ(returning_clause->columns().size(), expected_returned_column_aliases.size());
  358. for (size_t i = 0; i < returning_clause->columns().size(); ++i) {
  359. auto const& column = returning_clause->columns()[i];
  360. auto const& expected_column_alias = expected_returned_column_aliases[i];
  361. EXPECT(!is<SQL::AST::ErrorExpression>(*column.expression));
  362. EXPECT_EQ(column.column_alias, expected_column_alias);
  363. }
  364. }
  365. };
  366. Vector<Vector<ByteString>> update_columns { { "COLUMN_NAME" } };
  367. validate("UPDATE OR ABORT table_name SET column_name=1;"sv, SQL::AST::ConflictResolution::Abort, {}, "TABLE_NAME"sv, {}, update_columns, false, false, {});
  368. validate("UPDATE OR FAIL table_name SET column_name=1;"sv, SQL::AST::ConflictResolution::Fail, {}, "TABLE_NAME"sv, {}, update_columns, false, false, {});
  369. validate("UPDATE OR IGNORE table_name SET column_name=1;"sv, SQL::AST::ConflictResolution::Ignore, {}, "TABLE_NAME"sv, {}, update_columns, false, false, {});
  370. validate("UPDATE OR REPLACE table_name SET column_name=1;"sv, SQL::AST::ConflictResolution::Replace, {}, "TABLE_NAME"sv, {}, update_columns, false, false, {});
  371. validate("UPDATE OR ROLLBACK table_name SET column_name=1;"sv, SQL::AST::ConflictResolution::Rollback, {}, "TABLE_NAME"sv, {}, update_columns, false, false, {});
  372. auto resolution = SQL::AST::ConflictResolution::Abort;
  373. validate("UPDATE table_name SET column_name=1;"sv, resolution, {}, "TABLE_NAME"sv, {}, update_columns, false, false, {});
  374. validate("UPDATE schema_name.table_name SET column_name=1;"sv, resolution, "SCHEMA_NAME"sv, "TABLE_NAME"sv, {}, update_columns, false, false, {});
  375. validate("UPDATE table_name AS foo SET column_name=1;"sv, resolution, {}, "TABLE_NAME"sv, "FOO"sv, update_columns, false, false, {});
  376. validate("UPDATE table_name SET column_name=1;"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN_NAME"sv } }, false, false, {});
  377. validate("UPDATE table_name SET column_name=(SELECT 1);"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN_NAME"sv } }, false, false, {});
  378. validate("UPDATE table_name SET column_name=EXISTS (SELECT 1);"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN_NAME"sv } }, false, false, {});
  379. validate("UPDATE table_name SET column_name=NOT EXISTS (SELECT 1);"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN_NAME"sv } }, false, false, {});
  380. validate("UPDATE table_name SET column1=1, column2=2;"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN1"sv }, { "COLUMN2"sv } }, false, false, {});
  381. validate("UPDATE table_name SET (column1, column2)=1, column3=2;"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN1"sv, "COLUMN2"sv }, { "COLUMN3"sv } }, false, false, {});
  382. validate("UPDATE table_name SET column_name=1 WHERE 1==1;"sv, resolution, {}, "TABLE_NAME"sv, {}, update_columns, true, false, {});
  383. validate("UPDATE table_name SET column_name=1 WHERE (SELECT 1);"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN_NAME"sv } }, true, false, {});
  384. validate("UPDATE table_name SET column_name=1 WHERE EXISTS (SELECT 1);"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN_NAME"sv } }, true, false, {});
  385. validate("UPDATE table_name SET column_name=1 WHERE NOT EXISTS (SELECT 1);"sv, resolution, {}, "TABLE_NAME"sv, {}, { { "COLUMN_NAME"sv } }, true, false, {});
  386. validate("UPDATE table_name SET column_name=1 RETURNING *;"sv, resolution, {}, "TABLE_NAME"sv, {}, update_columns, false, true, {});
  387. validate("UPDATE table_name SET column_name=1 RETURNING column_name;"sv, resolution, {}, "TABLE_NAME"sv, {}, update_columns, false, true, { {} });
  388. validate("UPDATE table_name SET column_name=1 RETURNING column_name AS alias;"sv, resolution, {}, "TABLE_NAME"sv, {}, update_columns, false, true, { "ALIAS"sv });
  389. validate("UPDATE table_name SET column_name=1 RETURNING column1 AS alias1, column2 AS alias2;"sv, resolution, {}, "TABLE_NAME"sv, {}, update_columns, false, true, { "ALIAS1"sv, "ALIAS2"sv });
  390. }
  391. TEST_CASE(delete_)
  392. {
  393. EXPECT(parse("DELETE"sv).is_error());
  394. EXPECT(parse("DELETE FROM"sv).is_error());
  395. EXPECT(parse("DELETE FROM table_name"sv).is_error());
  396. EXPECT(parse("DELETE FROM table_name WHERE"sv).is_error());
  397. EXPECT(parse("DELETE FROM table_name WHERE EXISTS"sv).is_error());
  398. EXPECT(parse("DELETE FROM table_name WHERE NOT"sv).is_error());
  399. EXPECT(parse("DELETE FROM table_name WHERE NOT (SELECT 1)"sv).is_error());
  400. EXPECT(parse("DELETE FROM table_name WHERE NOT EXISTS"sv).is_error());
  401. EXPECT(parse("DELETE FROM table_name WHERE SELECT"sv).is_error());
  402. EXPECT(parse("DELETE FROM table_name WHERE (SELECT)"sv).is_error());
  403. EXPECT(parse("DELETE FROM table_name WHERE 15"sv).is_error());
  404. EXPECT(parse("DELETE FROM table_name WHERE 15 RETURNING"sv).is_error());
  405. EXPECT(parse("DELETE FROM table_name WHERE 15 RETURNING *"sv).is_error());
  406. EXPECT(parse("DELETE FROM table_name WHERE 15 RETURNING column_name"sv).is_error());
  407. EXPECT(parse("DELETE FROM table_name WHERE 15 RETURNING column_name AS;"sv).is_error());
  408. EXPECT(parse("DELETE FROM table_name WHERE (');"sv).is_error());
  409. auto validate = [](StringView sql, StringView expected_schema, StringView expected_table, StringView expected_alias, bool expect_where_clause, bool expect_returning_clause, Vector<StringView> expected_returned_column_aliases) {
  410. auto statement = TRY_OR_FAIL(parse(sql));
  411. EXPECT(is<SQL::AST::Delete>(*statement));
  412. auto const& delete_ = static_cast<const SQL::AST::Delete&>(*statement);
  413. auto const& qualified_table_name = delete_.qualified_table_name();
  414. EXPECT_EQ(qualified_table_name->schema_name(), expected_schema);
  415. EXPECT_EQ(qualified_table_name->table_name(), expected_table);
  416. EXPECT_EQ(qualified_table_name->alias(), expected_alias);
  417. auto const& where_clause = delete_.where_clause();
  418. EXPECT_EQ(where_clause.is_null(), !expect_where_clause);
  419. if (where_clause)
  420. EXPECT(!is<SQL::AST::ErrorExpression>(*where_clause));
  421. auto const& returning_clause = delete_.returning_clause();
  422. EXPECT_EQ(returning_clause.is_null(), !expect_returning_clause);
  423. if (returning_clause) {
  424. EXPECT_EQ(returning_clause->columns().size(), expected_returned_column_aliases.size());
  425. for (size_t i = 0; i < returning_clause->columns().size(); ++i) {
  426. auto const& column = returning_clause->columns()[i];
  427. auto const& expected_column_alias = expected_returned_column_aliases[i];
  428. EXPECT(!is<SQL::AST::ErrorExpression>(*column.expression));
  429. EXPECT_EQ(column.column_alias, expected_column_alias);
  430. }
  431. }
  432. };
  433. validate("DELETE FROM table_name;"sv, {}, "TABLE_NAME"sv, {}, false, false, {});
  434. validate("DELETE FROM schema_name.table_name;"sv, "SCHEMA_NAME"sv, "TABLE_NAME"sv, {}, false, false, {});
  435. validate("DELETE FROM schema_name.table_name AS alias;"sv, "SCHEMA_NAME"sv, "TABLE_NAME"sv, "ALIAS"sv, false, false, {});
  436. validate("DELETE FROM table_name WHERE (1 == 1);"sv, {}, "TABLE_NAME"sv, {}, true, false, {});
  437. validate("DELETE FROM table_name WHERE EXISTS (SELECT 1);"sv, {}, "TABLE_NAME"sv, {}, true, false, {});
  438. validate("DELETE FROM table_name WHERE NOT EXISTS (SELECT 1);"sv, {}, "TABLE_NAME"sv, {}, true, false, {});
  439. validate("DELETE FROM table_name WHERE (SELECT 1);"sv, {}, "TABLE_NAME"sv, {}, true, false, {});
  440. validate("DELETE FROM table_name RETURNING *;"sv, {}, "TABLE_NAME"sv, {}, false, true, {});
  441. validate("DELETE FROM table_name RETURNING column_name;"sv, {}, "TABLE_NAME"sv, {}, false, true, { {} });
  442. validate("DELETE FROM table_name RETURNING column_name AS alias;"sv, {}, "TABLE_NAME"sv, {}, false, true, { "ALIAS"sv });
  443. validate("DELETE FROM table_name RETURNING column1 AS alias1, column2 AS alias2;"sv, {}, "TABLE_NAME"sv, {}, false, true, { "ALIAS1"sv, "ALIAS2"sv });
  444. }
  445. TEST_CASE(select)
  446. {
  447. EXPECT(parse("SELECT"sv).is_error());
  448. EXPECT(parse("SELECT;"sv).is_error());
  449. EXPECT(parse("SELECT DISTINCT;"sv).is_error());
  450. EXPECT(parse("SELECT ALL;"sv).is_error());
  451. EXPECT(parse("SELECT *"sv).is_error());
  452. EXPECT(parse("SELECT * FROM;"sv).is_error());
  453. EXPECT(parse("SELECT table_name. FROM table_name;"sv).is_error());
  454. EXPECT(parse("SELECT column_name AS FROM table_name;"sv).is_error());
  455. EXPECT(parse("SELECT * FROM ("sv).is_error());
  456. EXPECT(parse("SELECT * FROM ()"sv).is_error());
  457. EXPECT(parse("SELECT * FROM ();"sv).is_error());
  458. EXPECT(parse("SELECT * FROM (table_name1)"sv).is_error());
  459. EXPECT(parse("SELECT * FROM (table_name1, )"sv).is_error());
  460. EXPECT(parse("SELECT * FROM (table_name1, table_name2)"sv).is_error());
  461. EXPECT(parse("SELECT * FROM table_name"sv).is_error());
  462. EXPECT(parse("SELECT * FROM table_name AS;"sv).is_error());
  463. EXPECT(parse("SELECT * FROM table_name WHERE;"sv).is_error());
  464. EXPECT(parse("SELECT * FROM table_name WHERE 1 ==1"sv).is_error());
  465. EXPECT(parse("SELECT * FROM table_name GROUP;"sv).is_error());
  466. EXPECT(parse("SELECT * FROM table_name GROUP BY;"sv).is_error());
  467. EXPECT(parse("SELECT * FROM table_name GROUP BY column_name"sv).is_error());
  468. EXPECT(parse("SELECT * FROM table_name ORDER:"sv).is_error());
  469. EXPECT(parse("SELECT * FROM table_name ORDER BY column_name"sv).is_error());
  470. EXPECT(parse("SELECT * FROM table_name ORDER BY column_name COLLATE:"sv).is_error());
  471. EXPECT(parse("SELECT * FROM table_name ORDER BY column_name COLLATE collation"sv).is_error());
  472. EXPECT(parse("SELECT * FROM table_name ORDER BY column_name NULLS;"sv).is_error());
  473. EXPECT(parse("SELECT * FROM table_name ORDER BY column_name NULLS SECOND;"sv).is_error());
  474. EXPECT(parse("SELECT * FROM table_name LIMIT;"sv).is_error());
  475. EXPECT(parse("SELECT * FROM table_name LIMIT 12"sv).is_error());
  476. EXPECT(parse("SELECT * FROM table_name LIMIT 12 OFFSET;"sv).is_error());
  477. EXPECT(parse("SELECT * FROM table_name LIMIT 12 OFFSET 15"sv).is_error());
  478. EXPECT(parse("SELECT * FROM table_name LIMIT 15, 16;"sv).is_error());
  479. struct Type {
  480. SQL::AST::ResultType type;
  481. StringView table_name_or_column_alias {};
  482. };
  483. struct From {
  484. StringView schema_name;
  485. StringView table_name;
  486. StringView table_alias;
  487. };
  488. struct Ordering {
  489. ByteString collation_name;
  490. SQL::Order order;
  491. SQL::Nulls nulls;
  492. };
  493. auto validate = [](StringView sql, Vector<Type> expected_columns, Vector<From> expected_from_list, bool expect_where_clause, size_t expected_group_by_size, bool expect_having_clause, Vector<Ordering> expected_ordering, bool expect_limit_clause, bool expect_offset_clause) {
  494. auto statement = TRY_OR_FAIL(parse(sql));
  495. EXPECT(is<SQL::AST::Select>(*statement));
  496. auto const& select = static_cast<const SQL::AST::Select&>(*statement);
  497. auto const& result_column_list = select.result_column_list();
  498. EXPECT_EQ(result_column_list.size(), expected_columns.size());
  499. for (size_t i = 0; i < result_column_list.size(); ++i) {
  500. auto const& result_column = result_column_list[i];
  501. auto const& expected_column = expected_columns[i];
  502. EXPECT_EQ(result_column->type(), expected_column.type);
  503. switch (result_column->type()) {
  504. case SQL::AST::ResultType::All:
  505. EXPECT(expected_column.table_name_or_column_alias.is_null());
  506. break;
  507. case SQL::AST::ResultType::Table:
  508. EXPECT_EQ(result_column->table_name(), expected_column.table_name_or_column_alias);
  509. break;
  510. case SQL::AST::ResultType::Expression:
  511. EXPECT_EQ(result_column->column_alias(), expected_column.table_name_or_column_alias);
  512. break;
  513. }
  514. }
  515. auto const& table_or_subquery_list = select.table_or_subquery_list();
  516. EXPECT_EQ(table_or_subquery_list.size(), expected_from_list.size());
  517. for (size_t i = 0; i < table_or_subquery_list.size(); ++i) {
  518. auto const& result_from = table_or_subquery_list[i];
  519. auto const& expected_from = expected_from_list[i];
  520. EXPECT_EQ(result_from->schema_name(), expected_from.schema_name);
  521. EXPECT_EQ(result_from->table_name(), expected_from.table_name);
  522. EXPECT_EQ(result_from->table_alias(), expected_from.table_alias);
  523. }
  524. auto const& where_clause = select.where_clause();
  525. EXPECT_EQ(where_clause.is_null(), !expect_where_clause);
  526. if (where_clause)
  527. EXPECT(!is<SQL::AST::ErrorExpression>(*where_clause));
  528. auto const& group_by_clause = select.group_by_clause();
  529. EXPECT_EQ(group_by_clause.is_null(), (expected_group_by_size == 0));
  530. if (group_by_clause) {
  531. auto const& group_by_list = group_by_clause->group_by_list();
  532. EXPECT_EQ(group_by_list.size(), expected_group_by_size);
  533. for (size_t i = 0; i < group_by_list.size(); ++i)
  534. EXPECT(!is<SQL::AST::ErrorExpression>(group_by_list[i]));
  535. auto const& having_clause = group_by_clause->having_clause();
  536. EXPECT_EQ(having_clause.is_null(), !expect_having_clause);
  537. if (having_clause)
  538. EXPECT(!is<SQL::AST::ErrorExpression>(*having_clause));
  539. }
  540. auto const& ordering_term_list = select.ordering_term_list();
  541. EXPECT_EQ(ordering_term_list.size(), expected_ordering.size());
  542. for (size_t i = 0; i < ordering_term_list.size(); ++i) {
  543. auto const& result_order = ordering_term_list[i];
  544. auto const& expected_order = expected_ordering[i];
  545. EXPECT(!is<SQL::AST::ErrorExpression>(*result_order->expression()));
  546. EXPECT_EQ(result_order->collation_name(), expected_order.collation_name);
  547. EXPECT_EQ(result_order->order(), expected_order.order);
  548. EXPECT_EQ(result_order->nulls(), expected_order.nulls);
  549. }
  550. auto const& limit_clause = select.limit_clause();
  551. EXPECT_EQ(limit_clause.is_null(), !expect_limit_clause);
  552. if (limit_clause) {
  553. auto const& limit_expression = limit_clause->limit_expression();
  554. EXPECT(!is<SQL::AST::ErrorExpression>(*limit_expression));
  555. auto const& offset_expression = limit_clause->offset_expression();
  556. EXPECT_EQ(offset_expression.is_null(), !expect_offset_clause);
  557. if (offset_expression)
  558. EXPECT(!is<SQL::AST::ErrorExpression>(*offset_expression));
  559. }
  560. };
  561. Vector<Type> all { { SQL::AST::ResultType::All } };
  562. Vector<From> from { { {}, "TABLE_NAME"sv, {} } };
  563. validate("SELECT * FROM table_name;"sv, { { SQL::AST::ResultType::All } }, from, false, 0, false, {}, false, false);
  564. validate("SELECT table_name.* FROM table_name;"sv, { { SQL::AST::ResultType::Table, "TABLE_NAME"sv } }, from, false, 0, false, {}, false, false);
  565. validate("SELECT column_name AS alias FROM table_name;"sv, { { SQL::AST::ResultType::Expression, "ALIAS"sv } }, from, false, 0, false, {}, false, false);
  566. validate("SELECT table_name.column_name AS alias FROM table_name;"sv, { { SQL::AST::ResultType::Expression, "ALIAS"sv } }, from, false, 0, false, {}, false, false);
  567. validate("SELECT schema_name.table_name.column_name AS alias FROM table_name;"sv, { { SQL::AST::ResultType::Expression, "ALIAS"sv } }, from, false, 0, false, {}, false, false);
  568. validate("SELECT column_name AS alias, *, table_name.* FROM table_name;"sv, { { SQL::AST::ResultType::Expression, "ALIAS"sv }, { SQL::AST::ResultType::All }, { SQL::AST::ResultType::Table, "TABLE_NAME"sv } }, from, false, 0, false, {}, false, false);
  569. validate("SELECT * FROM table_name;"sv, all, { { {}, "TABLE_NAME"sv, {} } }, false, 0, false, {}, false, false);
  570. validate("SELECT * FROM schema_name.table_name;"sv, all, { { "SCHEMA_NAME"sv, "TABLE_NAME"sv, {} } }, false, 0, false, {}, false, false);
  571. validate("SELECT * FROM schema_name.table_name AS alias;"sv, all, { { "SCHEMA_NAME"sv, "TABLE_NAME"sv, "ALIAS"sv } }, false, 0, false, {}, false, false);
  572. validate("SELECT * FROM schema_name.table_name AS alias, table_name2, table_name3 AS table_name4;"sv, all, { { "SCHEMA_NAME"sv, "TABLE_NAME"sv, "ALIAS"sv }, { {}, "TABLE_NAME2"sv, {} }, { {}, "TABLE_NAME3"sv, "TABLE_NAME4"sv } }, false, 0, false, {}, false, false);
  573. validate("SELECT * FROM table_name WHERE column_name IS NOT NULL;"sv, all, from, true, 0, false, {}, false, false);
  574. validate("SELECT * FROM table_name GROUP BY column_name;"sv, all, from, false, 1, false, {}, false, false);
  575. validate("SELECT * FROM table_name GROUP BY column1, column2, column3;"sv, all, from, false, 3, false, {}, false, false);
  576. validate("SELECT * FROM table_name GROUP BY column_name HAVING 'abc';"sv, all, from, false, 1, true, {}, false, false);
  577. validate("SELECT * FROM table_name ORDER BY column_name;"sv, all, from, false, 0, false, { { {}, SQL::Order::Ascending, SQL::Nulls::First } }, false, false);
  578. validate("SELECT * FROM table_name ORDER BY column_name COLLATE collation;"sv, all, from, false, 0, false, { { "COLLATION"sv, SQL::Order::Ascending, SQL::Nulls::First } }, false, false);
  579. validate("SELECT * FROM table_name ORDER BY column_name ASC;"sv, all, from, false, 0, false, { { {}, SQL::Order::Ascending, SQL::Nulls::First } }, false, false);
  580. validate("SELECT * FROM table_name ORDER BY column_name DESC;"sv, all, from, false, 0, false, { { {}, SQL::Order::Descending, SQL::Nulls::Last } }, false, false);
  581. validate("SELECT * FROM table_name ORDER BY column_name ASC NULLS LAST;"sv, all, from, false, 0, false, { { {}, SQL::Order::Ascending, SQL::Nulls::Last } }, false, false);
  582. validate("SELECT * FROM table_name ORDER BY column_name DESC NULLS FIRST;"sv, all, from, false, 0, false, { { {}, SQL::Order::Descending, SQL::Nulls::First } }, false, false);
  583. validate("SELECT * FROM table_name ORDER BY column1, column2 DESC, column3 NULLS LAST;"sv, all, from, false, 0, false, { { {}, SQL::Order::Ascending, SQL::Nulls::First }, { {}, SQL::Order::Descending, SQL::Nulls::Last }, { {}, SQL::Order::Ascending, SQL::Nulls::Last } }, false, false);
  584. validate("SELECT * FROM table_name LIMIT 15;"sv, all, from, false, 0, false, {}, true, false);
  585. validate("SELECT * FROM table_name LIMIT 15 OFFSET 16;"sv, all, from, false, 0, false, {}, true, true);
  586. }
  587. TEST_CASE(common_table_expression)
  588. {
  589. EXPECT(parse("WITH"sv).is_error());
  590. EXPECT(parse("WITH;"sv).is_error());
  591. EXPECT(parse("WITH DELETE FROM table_name;"sv).is_error());
  592. EXPECT(parse("WITH table_name DELETE FROM table_name;"sv).is_error());
  593. EXPECT(parse("WITH table_name AS DELETE FROM table_name;"sv).is_error());
  594. EXPECT(parse("WITH RECURSIVE table_name DELETE FROM table_name;"sv).is_error());
  595. EXPECT(parse("WITH RECURSIVE table_name AS DELETE FROM table_name;"sv).is_error());
  596. // Below are otherwise valid common-table-expressions, but attached to statements which do not allow them.
  597. EXPECT(parse("WITH table_name AS (SELECT * AS TABLE) CREATE TABLE test ( column1 );"sv).is_error());
  598. EXPECT(parse("WITH table_name AS (SELECT * FROM table_name) DROP TABLE test;"sv).is_error());
  599. struct SelectedTableList {
  600. struct SelectedTable {
  601. StringView table_name {};
  602. Vector<StringView> column_names {};
  603. };
  604. bool recursive { false };
  605. Vector<SelectedTable> selected_tables {};
  606. };
  607. auto validate = [](StringView sql, SelectedTableList expected_selected_tables) {
  608. auto statement = TRY_OR_FAIL(parse(sql));
  609. EXPECT(is<SQL::AST::Delete>(*statement));
  610. auto const& delete_ = static_cast<const SQL::AST::Delete&>(*statement);
  611. auto const& common_table_expression_list = delete_.common_table_expression_list();
  612. EXPECT(!common_table_expression_list.is_null());
  613. EXPECT_EQ(common_table_expression_list->recursive(), expected_selected_tables.recursive);
  614. auto const& common_table_expressions = common_table_expression_list->common_table_expressions();
  615. EXPECT_EQ(common_table_expressions.size(), expected_selected_tables.selected_tables.size());
  616. for (size_t i = 0; i < common_table_expressions.size(); ++i) {
  617. auto const& common_table_expression = common_table_expressions[i];
  618. auto const& expected_common_table_expression = expected_selected_tables.selected_tables[i];
  619. EXPECT_EQ(common_table_expression->table_name(), expected_common_table_expression.table_name);
  620. EXPECT_EQ(common_table_expression->column_names().size(), expected_common_table_expression.column_names.size());
  621. for (size_t j = 0; j < common_table_expression->column_names().size(); ++j)
  622. EXPECT_EQ(common_table_expression->column_names()[j], expected_common_table_expression.column_names[j]);
  623. }
  624. };
  625. validate("WITH table_name AS (SELECT * FROM table_name) DELETE FROM table_name;"sv, { false, { { "TABLE_NAME"sv } } });
  626. validate("WITH table_name (column_name) AS (SELECT * FROM table_name) DELETE FROM table_name;"sv, { false, { { "TABLE_NAME"sv, { "COLUMN_NAME"sv } } } });
  627. validate("WITH table_name (column1, column2) AS (SELECT * FROM table_name) DELETE FROM table_name;"sv, { false, { { "TABLE_NAME"sv, { "COLUMN1"sv, "COLUMN2"sv } } } });
  628. validate("WITH RECURSIVE table_name AS (SELECT * FROM table_name) DELETE FROM table_name;"sv, { true, { { "TABLE_NAME"sv, {} } } });
  629. }
  630. TEST_CASE(nested_subquery_limit)
  631. {
  632. auto subquery = ByteString::formatted("{:(^{}}table_name{:)^{}}", "", SQL::AST::Limits::maximum_subquery_depth - 1, "", SQL::AST::Limits::maximum_subquery_depth - 1);
  633. EXPECT(!parse(ByteString::formatted("SELECT * FROM {};"sv, subquery)).is_error());
  634. EXPECT(parse(ByteString::formatted("SELECT * FROM ({});"sv, subquery)).is_error());
  635. }
  636. TEST_CASE(bound_parameter_limit)
  637. {
  638. auto subquery = ByteString::repeated("?, "sv, SQL::AST::Limits::maximum_bound_parameters);
  639. EXPECT(!parse(ByteString::formatted("INSERT INTO table_name VALUES ({}42);"sv, subquery)).is_error());
  640. EXPECT(parse(ByteString::formatted("INSERT INTO table_name VALUES ({}?);"sv, subquery)).is_error());
  641. }
  642. TEST_CASE(describe_table)
  643. {
  644. EXPECT(parse("DESCRIBE"sv).is_error());
  645. EXPECT(parse("DESCRIBE;"sv).is_error());
  646. EXPECT(parse("DESCRIBE TABLE;"sv).is_error());
  647. EXPECT(parse("DESCRIBE table_name;"sv).is_error());
  648. auto validate = [](StringView sql, StringView expected_schema, StringView expected_table) {
  649. auto statement = TRY_OR_FAIL(parse(sql));
  650. EXPECT(is<SQL::AST::DescribeTable>(*statement));
  651. auto const& describe_table_statement = static_cast<const SQL::AST::DescribeTable&>(*statement);
  652. EXPECT_EQ(describe_table_statement.qualified_table_name()->schema_name(), expected_schema);
  653. EXPECT_EQ(describe_table_statement.qualified_table_name()->table_name(), expected_table);
  654. };
  655. validate("DESCRIBE TABLE TableName;"sv, {}, "TABLENAME"sv);
  656. validate("DESCRIBE TABLE SchemaName.TableName;"sv, "SCHEMANAME"sv, "TABLENAME"sv);
  657. }