| 1 | #include "catch.hpp" | 
|---|
| 2 | #include "duckdb/common/file_system.hpp" | 
|---|
| 3 | #include "dbgen.hpp" | 
|---|
| 4 | #include "test_helpers.hpp" | 
|---|
| 5 |  | 
|---|
| 6 | using namespace duckdb; | 
|---|
| 7 | using namespace std; | 
|---|
| 8 |  | 
|---|
| 9 | TEST_CASE( "Test lateral joins", "[subquery]") { | 
|---|
| 10 | unique_ptr<QueryResult> result; | 
|---|
| 11 | DuckDB db(nullptr); | 
|---|
| 12 | Connection con(db); | 
|---|
| 13 | con.EnableQueryVerification(); | 
|---|
| 14 |  | 
|---|
| 15 | return; | 
|---|
| 16 | // not supported yet | 
|---|
| 17 |  | 
|---|
| 18 | REQUIRE_NO_FAIL(con.Query( "CREATE TABLE students(id INTEGER, name VARCHAR, major VARCHAR, year INTEGER)")); | 
|---|
| 19 | REQUIRE_NO_FAIL( | 
|---|
| 20 | con.Query( "CREATE TABLE exams(sid INTEGER, course VARCHAR, curriculum VARCHAR, grade INTEGER, year INTEGER)")); | 
|---|
| 21 |  | 
|---|
| 22 | REQUIRE_NO_FAIL(con.Query( "INSERT INTO students VALUES (1, 'Mark', 'CS', 2017)")); | 
|---|
| 23 | REQUIRE_NO_FAIL(con.Query( "INSERT INTO students VALUES (2, 'Dirk', 'CS', 2017)")); | 
|---|
| 24 | REQUIRE_NO_FAIL(con.Query( "INSERT INTO exams VALUES (1, 'Database Systems', 'CS', 10, 2015)")); | 
|---|
| 25 | REQUIRE_NO_FAIL(con.Query( "INSERT INTO exams VALUES (1, 'Graphics', 'CS', 9, 2016)")); | 
|---|
| 26 | REQUIRE_NO_FAIL(con.Query( "INSERT INTO exams VALUES (2, 'Database Systems', 'CS', 7, 2015)")); | 
|---|
| 27 | REQUIRE_NO_FAIL(con.Query( "INSERT INTO exams VALUES (2, 'Graphics', 'CS', 7, 2016)")); | 
|---|
| 28 |  | 
|---|
| 29 | // // lateral join with explicit LATERAL added | 
|---|
| 30 | // result = con.Query("SELECT name, total FROM students LEFT JOIN LATERAL (SELECT SUM(grade) AS total FROM exams | 
|---|
| 31 | // WHERE exams.sid=students.id) grades ON true ORDER BY total DESC;"); REQUIRE(CHECK_COLUMN(result, 0, {"Mark", | 
|---|
| 32 | // "Dirk"})); REQUIRE(CHECK_COLUMN(result, 1, {19, 14})); | 
|---|
| 33 |  | 
|---|
| 34 | // lateral join without explicit LATERAL | 
|---|
| 35 | result = con.Query( "SELECT name, total FROM students, (SELECT SUM(grade) AS total FROM exams WHERE " | 
|---|
| 36 | "exams.sid=students.id) grades ORDER BY total DESC;"); | 
|---|
| 37 | REQUIRE(CHECK_COLUMN(result, 0, { "Mark", "Dirk"})); | 
|---|
| 38 | REQUIRE(CHECK_COLUMN(result, 1, {19, 14})); | 
|---|
| 39 | } | 
|---|
| 40 |  | 
|---|