Skip to content

Commit

Permalink
Refactor codebase to import join module and use it in place of indivi…
Browse files Browse the repository at this point in the history
…dual join types

Refactor codebase to add support for full join in SQL queries
Refactor codebase to optimize execution of logical plans and improve aggregation functionality
  • Loading branch information
holicc committed Sep 20, 2024
1 parent 98ab2f2 commit 506b280
Show file tree
Hide file tree
Showing 6 changed files with 485 additions and 542 deletions.
13 changes: 10 additions & 3 deletions qurious/src/execution/session.rs
Original file line number Diff line number Diff line change
Expand Up @@ -253,10 +253,17 @@ mod tests {
#[test]
fn test_create_table() -> Result<()> {
let session = ExecuteSession::new()?;
session.sql("create table t(v1 int, v2 int);")?;
session.sql("insert into t values (1, 1), (null, 2), (null, 3), (4, 4);")?;
session.sql("create table a(v1 int, v2 int);")?;
session.sql("create table b(v3 int, v4 int);")?;

let batch = session.sql("select v2 from t where v1 is null")?;
// session.sql("create table x(a int, b int);")?;
// session.sql("create table y(c int, d int);")?;

session.sql("insert into a values (1, 1), (2, 2), (3, 3);")?;
session.sql("insert into b values (1, 100), (3, 300), (4, 400);")?;

let batch = session.sql("select v1, v2, v3, v4 from a full join b on v1 = v3;")?;
// let batch = session.sql("select 1 > null")?;

print_batches(&batch)?;

Expand Down
Loading

0 comments on commit 506b280

Please sign in to comment.