Skip to content

Commit a4c1fdf

Browse files
committed
fix bugs
1 parent e0118cc commit a4c1fdf

2 files changed

Lines changed: 7 additions & 3 deletions

File tree

src/QueryOperators.jl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@ struct GroupOfRows{Group, Row}
2323
row::Row
2424
end
2525

26-
function key(group_of_rows::GroupOfRows)
27-
translate(getfield(group_of_rows, :group))
26+
function QueryOperators.key(group_of_rows::GroupOfRows)
27+
getfield(group_of_rows, :group)
2828
end
2929

3030
function getproperty(group_of_rows::GroupOfRows, column_name::Symbol)

src/realize.jl

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,12 +100,16 @@ function realize(sql_expression::SQLExpression)
100100
end
101101

102102
function realize_final(sql_expression::SQLExpression)
103-
if sql_expression.call == :FROM
103+
if sql_expression.call in (:FROM, Symbol("GROUP BY"), Symbol("INNER JOIN"))
104104
realize(SQLExpression(:SELECT, sql_expression, :*))
105105
else
106106
realize(sql_expression)
107107
end
108108
end
109109

110+
function realize_final(something)
111+
something
112+
end
113+
110114
text(source_code::SourceCode) =
111115
realize_final(translate(source_code.code))

0 commit comments

Comments
 (0)