Skip to content

Commit a41f4a3

Browse files
committed
add sql_translation method for duckdb
1 parent 0d00a30 commit a41f4a3

2 files changed

Lines changed: 11 additions & 0 deletions

File tree

NAMESPACE

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ S3method(listDatabaseConnectorColumns,DatabaseConnectorDbiConnection)
1818
S3method(listDatabaseConnectorColumns,default)
1919
S3method(sql_escape_logical,DatabaseConnectorJdbcConnection)
2020
S3method(sql_query_select,DatabaseConnectorJdbcConnection)
21+
S3method(sql_translation,DatabaseConnectorDbiConnection)
2122
S3method(sql_translation,DatabaseConnectorJdbcConnection)
2223
export(DatabaseConnectorDriver)
2324
export(assertTempEmulationSchemaSet)

R/backend-DatabaseConnector.R

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,16 @@ sql_translation.DatabaseConnectorJdbcConnection <- function(con) {
8888
rlang::abort("Sql dialect is not supported!"))
8989
}
9090

91+
#' @export
92+
#' @importFrom dbplyr sql_translation
93+
sql_translation.DatabaseConnectorDbiConnection <- function(con) {
94+
95+
switch(dbms(con),
96+
"sqlite" = utils::getFromNamespace("sql_translation.SQLiteConnection", "dbplyr")(con),
97+
"duckdb" = utils::getFromNamespace("sql_translation.duckdb_connection", "duckdb")(con),
98+
NextMethod())
99+
}
100+
91101

92102
#' @importFrom dbplyr sql_escape_logical
93103
#' @export

0 commit comments

Comments
 (0)