Learn R Programming

DatabaseConnector

DatabaseConnector is part of HADES.

Introduction

This R package provides function for connecting to various DBMSs. Together with the SqlRender package, the main goal of DatabaseConnector is to provide a uniform interface across database platforms: the same code should run and produce equivalent results, regardless of the database back end.

Features

  • Create connections to the various database platforms:
    • MicrosoftSQL Server
    • Oracle
    • PostgresSql
    • Microsoft Parallel Data Warehouse (a.k.a. Analytics Platform System)
    • Amazon Redshift
    • Apache Impala
    • Google BigQuery
    • IBM Netezza
    • SQLite
    • Spark
  • Statements for executing queries with
    • Error reporting to file
    • Progress reporting
    • Multiple statements per query
  • Support for fetching data to Andromeda objects
  • Insert data frame to a database table
  • Supports the DBI interface, with SQL statements automatically translated to the appropriate dialect.
  • Supports the dbplyr interface.
  • Integrates with RStudio's Connections tab

Examples

connectionDetails <- createConnectionDetails(dbms="postgresql", 
                                             server="localhost",
                                             user="root",
                                             password="blah")
conn <- connect(connectionDetails)
querySql(conn,"SELECT COUNT(*) FROM person")
disconnect(conn)

Technology

DatabaseConnector is an R package using Java's JDBC drivers and other DBI drivers.

System Requirements

Running the package requires R with the package rJava installed. Also requires Java 1.8 or higher.

Installation

  1. See the instructions here for configuring your R environment, including Java.

  2. To install the latest stable version, install from CRAN:

install.packages("DatabaseConnector")
  1. Download the database drivers as described here.

  2. (Optionally) To use Windows Authentication for SQL Server, download the authentication DDL file as described here.

User Documentation

Documentation can be found on the package website.

PDF versions of the documentation are also available:

Support

  • Developer questions/comments/feedback: OHDSI Forum
  • We use the GitHub issue tracker for all bugs/issues/enhancements

Contributing

Read here how you can contribute to this package.

License

DatabaseConnector is licensed under Apache License 2.0. The JDBC drivers fall under their own respective licenses.

Development

DatabaseConnector is being developed in R Studio.

Development status

Stable. The code is actively being used in several projects.

Acknowledgements

  • This project is supported in part through the National Science Foundation grant IIS 1251151.

Copy Link

Version

Install

install.packages('DatabaseConnector')

Monthly Downloads

3,404

Version

6.3.3

License

Apache License

Issues

Pull Requests

Stars

Forks

Maintainer

Martijn Schuemie

Last Published

January 16th, 2025

Functions in DatabaseConnector (6.3.3)

day

Extract the day from a date
dateAdd

Add an interval to a date
dbClearResult,DatabaseConnectorDbiResult-method

Clear a result set
dbColumnInfo,DatabaseConnectorJdbcResult-method

Information about result types
dbAppendTable,DatabaseConnectorConnection,character-method

Insert rows into a table
dbClearResult,DatabaseConnectorJdbcResult-method

Clear a result set
dbFetch,DatabaseConnectorJdbcResult-method

Fetch records from a previously executed query
dbGetInfo,DatabaseConnectorConnection-method

Get DBMS metadata
dbDisconnect,DatabaseConnectorConnection-method

Disconnect (close) a connection
dbConnect,DatabaseConnectorDriver-method

Create a connection to a DBMS
dbGetInfo,DatabaseConnectorDriver-method

Get DBMS metadata
dbExistsTable,DatabaseConnectorConnection,character-method

Does a table exist?
dbFetch,DatabaseConnectorDbiResult-method

Fetch records from a previously executed query
dbGetQuery,DatabaseConnectorConnection,character-method

Retrieve results from a query
dbExecute,DatabaseConnectorConnection,character-method

Change database state
dbCreateTable,DatabaseConnectorConnection-method

Create a table in the database
dbHasCompleted,DatabaseConnectorDbiResult-method

Completion status
dbHasCompleted,DatabaseConnectorJdbcResult-method

Completion status
dbIsValid,DatabaseConnectorDbiConnection-method

Is this DBMS object still valid?
dbIsValid,DatabaseConnectorJdbcConnection-method

Is this DBMS object still valid?
dbGetRowsAffected,DatabaseConnectorJdbcResult-method

The number of rows affected
dbGetRowsAffected,DatabaseConnectorDbiResult-method

The number of rows affected
dbGetStatement,DatabaseConnectorDbiResult-method

Get the statement associated with a result set
dbGetStatement,DatabaseConnectorJdbcResult-method

Get the statement associated with a result set
dbGetRowCount,DatabaseConnectorJdbcResult-method

The number of rows fetched so far
dbGetRowCount,DatabaseConnectorDbiResult-method

The number of rows fetched so far
dbSendQuery,DatabaseConnectorJdbcConnection,character-method

Execute a query on a given database connection
dbListTables,DatabaseConnectorConnection-method

List remote tables
dbSendStatement,DatabaseConnectorConnection,character-method

Execute a data manipulation statement on a given database connection
dbSendQuery,DatabaseConnectorDbiConnection,character-method

Execute a query on a given database connection
dbListFields,DatabaseConnectorConnection,character-method

List field names of a remote table
dbUnloadDriver,DatabaseConnectorDriver-method

Load and unload database drivers
dbReadTable,DatabaseConnectorConnection,character-method

Read database tables as data frames
dbWriteTable,DatabaseConnectorConnection,ANY-method

Copy data frames to database tables
dbRemoveTable,DatabaseConnectorConnection,ANY-method

Remove a table from the database
dbms

Get the database platform from a connection
disconnect

Disconnect from the server
inDatabaseSchema

Refer to a table in a database schema
extractQueryTimes

Extract query times from a ParallelLogger log file
executeSql

Execute SQL code
dropEmulatedTempTables

Drop all emulated temp tables.
eoMonth

Return the end of the month
getTableNames

List all tables in a database schema.
getAvailableJavaHeapSpace

Get available Java heap space
downloadJdbcDrivers

Download DatabaseConnector JDBC Jar files
existsTable

Does the table exist?
month

Extract the month from a date
lowLevelQuerySql

Low level function for retrieving data to a data frame
querySql

Retrieve data to a data.frame
lowLevelQuerySqlToAndromeda

Low level function for retrieving data to a local Andromeda object
year

Extract the year from a date
isSqlReservedWord

Test a character vector of SQL names for SQL reserved words
insertTable

Insert a table on the server
querySqlToAndromeda

Retrieves data to a local Andromeda object
renderTranslateExecuteSql

Render, translate, execute SQL code
renderTranslateQueryApplyBatched

Render, translate, and perform process to batches of data.
renderTranslateQuerySql

Render, translate, and query to data.frame
requiresTempEmulation

Does the DBMS require temp table emulation?
renderTranslateQuerySqlToAndromeda

Render, translate, and query to local Andromeda
lowLevelExecuteSql

Execute SQL code
jdbcDrivers

How to download and use JDBC drivers for the various data platforms.
DatabaseConnectorDriver-class

DatabaseConnectorDriver class.
assertTempEmulationSchemaSet

Assert the temp emulation schema is set
createDbiConnectionDetails

Create DBI connection details
connect

connect
DatabaseConnectorDriver

Create a DatabaseConnectorDriver object
computeDataHash

Compute hash of data
createConnectionDetails

createConnectionDetails
dbColumnInfo,DatabaseConnectorDbiResult-method

Information about result types
dateFromParts

Construct a date from parts
createZipFile

Compress files and/or folders into a single zip file
DatabaseConnector-package

DatabaseConnector: Connecting to Various Database Platforms
dateDiff

Compute difference between dates
DatabaseConnectorDbiResult-class

DatabaseConnector DBI results class.
DatabaseConnectorJdbcResult-class

DatabaseConnector JDBC results class.