Skip to content

Commit

Permalink
keep current join syntax support
Browse files Browse the repository at this point in the history
  • Loading branch information
drizk1 committed Dec 22, 2024
1 parent 28ea561 commit 724ad69
Showing 1 changed file with 11 additions and 4 deletions.
15 changes: 11 additions & 4 deletions src/db_parsing.jl
Original file line number Diff line number Diff line change
Expand Up @@ -477,12 +477,19 @@ end

function parse_join_expression(expr)
if isa(expr, Expr) && expr.head == :(=)
# Handle equality condition (e.g., ticker = ticker)
rhs_column = expr.args[1]
lhs_column = expr.args[2]
lhs_cols = String[]
rhs_cols = String[]
closests = String[]
as_of = ""

lhs_column = expr.args[1]
rhs_column = expr.args[2]
lhs_col_str = string(lhs_column)
rhs_col_str = string(rhs_column)
return lhs_col_str, rhs_col_str
push!(lhs_cols, lhs_col_str)
push!(rhs_cols, rhs_col_str)
return lhs_cols, rhs_cols , closests, as_of

elseif expr.head == :call && expr.args[1] == :join_by
lhs_cols = String[]
rhs_cols = String[]
Expand Down

0 comments on commit 724ad69

Please sign in to comment.