diff --git a/src/Query.jl b/src/Query.jl index 70b7e520..e5702732 100644 --- a/src/Query.jl +++ b/src/Query.jl @@ -32,6 +32,8 @@ include("queryable/queryable.jl") include("queryable/queryable_select.jl") include("queryable/queryable_where.jl") +include("backends/juliadb/juliadb.jl") + include("query_translation.jl") include("sources/source_iterable.jl") diff --git a/src/backends/juliadb/juliadb.jl b/src/backends/juliadb/juliadb.jl new file mode 100644 index 00000000..edd591ea --- /dev/null +++ b/src/backends/juliadb/juliadb.jl @@ -0,0 +1,13 @@ +@require JuliaDB begin + +function select(source::JuliaDB.DTable, f, f_expr) + map(f, source) +end + +function where(source::JuliaDB.DTable, filter::Function, filter_expr::Expr) + JuliaDB.filter(filter, source) +end + +query(source::JuliaDB.DTable) = source + +end