This function renders, and translates SQL, sends it to the server, and returns the results as a data.frame.
renderTranslateQuerySql(
connection,
sql,
errorReportFile = file.path(getwd(), "errorReportSql.txt"),
snakeCaseToCamelCase = FALSE,
tempEmulationSchema = getOption("sqlRenderTempEmulationSchema"),
integerAsNumeric = getOption("databaseConnectorIntegerAsNumeric", default = TRUE),
integer64AsNumeric = getOption("databaseConnectorInteger64AsNumeric", default = TRUE),
...
)
The connection to the database server created using either
connect()
or DBI::dbConnect()
.
The SQL to be send.
The file where an error report will be written if an error occurs. Defaults to 'errorReportSql.txt' in the current working directory.
If true, field names are assumed to use snake_case, and are converted to camelCase.
Some database platforms like Oracle and Impala do not truly support temp tables. To emulate temp tables, provide a schema with write privileges where temp tables can be created.
Logical: should 32-bit integers be converted to numeric (double) values? If FALSE
32-bit integers will be represented using R's native Integer
class.
Logical: should 64-bit integers be converted to numeric (double) values? If FALSE
64-bit integers will be represented using bit64::integer64
.
Parameters that will be used to render the SQL.
A data frame.
Fields will be automatically converted for improved consistenty in these situations:
SQLite: Fields with names ending in _date
will be converted to DATE fields. Rationale: SQLite
does not support DATE fields.
SQLite: Fields with names ending in _datetime
will be converted to POSIXct fields. Rationale:
SQLite does not support DATETIME fields.
BigQuery and Snowflake: Integer fields will be converted to Integer if it fits in an integer, or will remain Integer64 otherwise. Rationale: these platforms do not distinguish between INT and BIGINT.
This function calls the render
and translate
functions in the SqlRender
package before
calling querySql()
.
if (FALSE) { # \dontrun{
connectionDetails <- createConnectionDetails(
dbms = "postgresql",
server = "localhost",
user = "root",
password = "blah",
schema = "cdm_v4"
)
conn <- connect(connectionDetails)
persons <- renderTranslatequerySql(conn,
sql = "SELECT TOP 10 * FROM @schema.person",
schema = "cdm_synpuf"
)
disconnect(conn)
} # }