-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #29 from TidierOrg/oracle_odbc-support
add oracle support via odbc
- Loading branch information
Showing
7 changed files
with
206 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,174 @@ | ||
| function expr_to_sql_oracle(expr, sq; from_summarize::Bool) | ||
| expr = parse_char_matching(expr) | ||
| expr = exc_capture_bug(expr, names_to_modify) | ||
| MacroTools.postwalk(expr) do x | ||
| # Handle basic arithmetic and functions | ||
| if @capture(x, a_ + b_) | ||
| return :($a + $b) | ||
| elseif @capture(x, a_ - b_) | ||
| return :($a - $b) | ||
| elseif @capture(x, a_ * b_) | ||
| return :($a * $b) | ||
| elseif @capture(x, a_ / b_) | ||
| return :($a / $b) | ||
| elseif @capture(x, a_ ^ b_) | ||
| return :(POWER($a, $b)) | ||
| elseif @capture(x, round(a_)) | ||
| return :(ROUND($a)) | ||
| elseif @capture(x, round(a_, b_)) | ||
| return :(ROUND($a, $b)) | ||
| elseif @capture(x, mean(a_)) | ||
| if from_summarize | ||
| return :(AVG($a)) | ||
| else | ||
| window_clause = construct_window_clause(sq) | ||
| return "AVG($(string(a))) $(window_clause)" | ||
| end | ||
| elseif @capture(x, minimum(a_)) | ||
| if from_summarize | ||
| return :(MIN($a)) | ||
| else | ||
| window_clause = construct_window_clause(sq) | ||
| return "MIN($(string(a))) $(window_clause)" | ||
| end | ||
| elseif @capture(x, maximum(a_)) | ||
| if from_summarize | ||
| return :(MAX($a)) | ||
| else | ||
| window_clause = construct_window_clause(sq) | ||
| return "MAX($(string(a))) $(window_clause)" | ||
| end | ||
| elseif @capture(x, sum(a_)) | ||
| if from_summarize | ||
| return :(SUM($a)) | ||
| else | ||
| window_clause = construct_window_clause(sq) | ||
| return "SUM($(string(a))) $(window_clause)" | ||
| end | ||
| elseif @capture(x, cumsum(a_)) | ||
| if from_summarize | ||
| error("cumsum is only available through a windowed @mutate") | ||
| else | ||
| # sq.windowFrame = "ROWS UNBOUNDED PRECEDING " | ||
| window_clause = construct_window_clause(sq, from_cumsum = true) | ||
| return "SUM($(string(a))) $(window_clause)" | ||
| end | ||
| #stats agg | ||
| elseif @capture(x, std(a_)) | ||
| if from_summarize | ||
| return :(STDDEV_SAMP($a)) | ||
| else | ||
| window_clause = construct_window_clause(sq, ) | ||
| return "STDDEV_SAMP($(string(a))) $(window_clause)" | ||
| end | ||
| elseif @capture(x, cor(a_, b_)) | ||
| if from_summarize | ||
| return :(CORR($a)) | ||
| else | ||
| window_clause = construct_window_clause(sq) | ||
| return "CORR($(string(a))) $(window_clause)" | ||
| end | ||
| elseif @capture(x, cov(a_, b_)) | ||
| if from_summarize | ||
| return :(COVAR_SAMP($a)) | ||
| else | ||
| window_clause = construct_window_clause(sq) | ||
| return "COVAR_SAMP($(string(a))) $(window_clause)" | ||
| end | ||
| elseif @capture(x, var(a_)) | ||
| if from_summarize | ||
| return :(VAR_SAMP($a)) | ||
| else | ||
| window_clause = construct_window_clause(sq) | ||
| return "VAR_SAMP($(string(a))) $(window_clause)" | ||
| end | ||
| #elseif @capture(x, sql_agg(str_)) | ||
| # if from_summarize | ||
| # return error("sql_agg is only needed with aggregate functions in @mutate") | ||
| # else | ||
| # window_clause = construct_window_clause(sq) | ||
| # return "$(str) $(window_clause)" | ||
| # end | ||
| #stringr functions, have to use function that removes _ so capture can capture name | ||
| elseif @capture(x, strreplaceall(str_, pattern_, replace_)) | ||
| return :(REPLACE($str, $pattern, $replace)) | ||
| elseif @capture(x, strreplace(str_, pattern_, replace_)) | ||
| return error("str_replace is not yet supported for oracle support. Only str_replace_all") | ||
| elseif @capture(x, strremoveall(str_, pattern_)) | ||
| return :(REPLACE($str, $pattern, "")) | ||
| elseif @capture(x, strremove(str_, pattern_)) | ||
| return error("str_remove is not yet supported for oracle support. Only str_remove_all ") | ||
| elseif @capture(x, ismissing(a_)) | ||
| return "($(string(a)) IS NULL)" | ||
| # Date extraction functions | ||
| elseif @capture(x, year(a_)) | ||
| return "DATE(YEAR FROM " * string(a) * ")" | ||
| elseif @capture(x, month(a_)) | ||
| return "DATE(MONTH FROM " * string(a) * ")" | ||
| elseif @capture(x, day(a_)) | ||
| return "DATE(DAY FROM " * string(a) * ")" | ||
| elseif @capture(x, hour(a_)) | ||
| return "DATE(HOUR FROM " * string(a) * ")" | ||
| elseif @capture(x, minute(a_)) | ||
| return "DATE(MINUTE FROM " * string(a) * ")" | ||
| elseif @capture(x, second(a_)) | ||
| return "DATE(SECOND FROM " * string(a) * ")" | ||
| elseif @capture(x, floordate(time_column_, unit_)) | ||
| return floordate_to_oracle(unit, time_column) | ||
| elseif @capture(x, difftime(endtime_, starttime_, unit_)) | ||
| return :(DATE_DIFF($unit, $starttime, $endtime)) | ||
| elseif @capture(x, replacemissing(column_, replacement_value_)) | ||
| return :(COALESCE($column, $replacement_value)) | ||
| elseif @capture(x, missingif(column_, value_to_replace_)) | ||
| return :(NULLIF($column, $value_to_replace)) | ||
| elseif isa(x, Expr) && x.head == :call | ||
| if x.args[1] == :if_else && length(x.args) == 4 | ||
| return parse_if_else(x) | ||
| elseif x.args[1] == :as_float && length(x.args) == 2 | ||
| column = x.args[2] | ||
| return "CAST(" * string(column) * " AS DECIMAL)" | ||
| elseif x.args[1] == :as_integer && length(x.args) == 2 | ||
| column = x.args[2] | ||
| return "CAST(" * string(column) * " AS INTEGER)" | ||
| elseif x.args[1] == :as_string && length(x.args) == 2 | ||
| column = x.args[2] | ||
| return "CAST(" * string(column) * " AS STRING)" | ||
| elseif x.args[1] == :case_when | ||
| return parse_case_when(x) | ||
| elseif isa(x, Expr) && x.head == :call && x.args[1] == :! && x.args[1] != :!= && length(x.args) == 2 | ||
| inner_expr = expr_to_sql_oracle(x.args[2], sq, from_summarize = false) # Recursively transform the inner expression | ||
| return string("NOT (", inner_expr, ")") | ||
| elseif x.args[1] == :str_detect && length(x.args) == 3 | ||
| column, pattern = x.args[2], x.args[3] | ||
| return string(column, " LIKE \'%", pattern, "%'") | ||
| elseif isa(x, Expr) && x.head == :call && x.args[1] == :n && length(x.args) == 1 | ||
| return "COUNT(*)" | ||
| end | ||
| end | ||
| return x | ||
| end | ||
| end | ||
|
|
||
|
|
||
| function floordate_to_oracle(unit::String, time_column::Symbol) | ||
| sql_command = "" | ||
|
|
||
| if unit == "second" | ||
| # Flooring to the nearest second requires a different anchor, like '2000-01-01' | ||
| sql_command = "DATEADD(SECOND, DATEDIFF(SECOND, '2000-01-01', $(string(time_column))), '2000-01-01')" | ||
| elseif unit == "minute" | ||
| sql_command = "DATEADD(MINUTE, DATEDIFF(MINUTE, 0, $(string(time_column))), 0)" | ||
| elseif unit == "hour" | ||
| sql_command = "DATEADD(HOUR, DATEDIFF(HOUR, 0, $(string(time_column))), 0)" | ||
| elseif unit == "day" | ||
| sql_command = "DATEADD(DAY, DATEDIFF(DAY, 0, $(string(time_column))), 0)" | ||
| elseif unit == "month" | ||
| sql_command = "DATEADD(MONTH, DATEDIFF(MONTH, 0, $(string(time_column))), 0)" | ||
| elseif unit == "year" | ||
| sql_command = "DATEADD(YEAR, DATEDIFF(YEAR, 0, $(string(time_column))), 0)" | ||
| else | ||
| throw(ArgumentError("Unsupported unit: $unit")) | ||
| end | ||
|
|
||
| return sql_command | ||
| end |