Learn R Programming

⚠️There's a newer version (6.3.3) of this package.Take me there.

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,303

Version

6.3.2

License

Apache License

Issues

Pull Requests

Stars

Forks

Maintainer

Martijn Schuemie

Last Published

December 11th, 2023

Functions in DatabaseConnector (6.3.2)

createDbiConnectionDetails

Create DBI connection details
DatabaseConnectorDriver-class

DatabaseConnectorDriver class.
computeDataHash

Compute hash of data
assertTempEmulationSchemaSet

Assert the temp emulation schema is set
DatabaseConnectorDriver

Create a DatabaseConnectorDriver object
createConnectionDetails

createConnectionDetails
connect

connect
DatabaseConnectorJdbcResult-class

DatabaseConnector JDBC results class.
DatabaseConnectorDbiResult-class

DatabaseConnector DBI results class.
DatabaseConnector-package

DatabaseConnector: Connecting to Various Database Platforms
dateAdd

Add an interval to a date
createZipFile

Compress files and/or folders into a single zip file
dbColumnInfo,DatabaseConnectorDbiResult-method

Information about result types
dbClearResult,DatabaseConnectorJdbcResult-method

Clear a result set
dbClearResult,DatabaseConnectorDbiResult-method

Clear a result set
dateDiff

Compute difference between dates
dateFromParts

Construct a date from parts
dbColumnInfo,DatabaseConnectorJdbcResult-method

Information about result types
dbDisconnect,DatabaseConnectorConnection-method

Disconnect (close) a connection
dbGetInfo,DatabaseConnectorConnection-method

Get DBMS metadata
dbExistsTable,DatabaseConnectorConnection,character-method

Does a table exist?
day

Extract the day from a date
dbAppendTable,DatabaseConnectorConnection,character-method

Insert rows into a table
dbFetch,DatabaseConnectorJdbcResult-method

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

Execute an update statement, query number of rows affected, and then close result set
dbCreateTable,DatabaseConnectorConnection-method

Create a table in the database
dbConnect,DatabaseConnectorDriver-method

Create a connection to a DBMS
dbFetch,DatabaseConnectorDbiResult-method

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

Get DBMS metadata
dbGetQuery,DatabaseConnectorConnection,character-method

Send query, retrieve results and then clear result set
dbIsValid,DatabaseConnectorJdbcConnection-method

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

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

Completion status
dbHasCompleted,DatabaseConnectorDbiResult-method

Completion status
dbGetRowCount,DatabaseConnectorDbiResult-method

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

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

Get the statement associated with a result set
dbGetRowsAffected,DatabaseConnectorDbiResult-method

The number of rows affected
dbGetRowsAffected,DatabaseConnectorJdbcResult-method

The number of rows affected
dbWriteTable,DatabaseConnectorConnection,ANY-method

Copy data frames to database tables
dbGetRowCount,DatabaseConnectorJdbcResult-method

The number of rows fetched so far
dbms

Get the database platform from a connection
dbSendQuery,DatabaseConnectorDbiConnection,character-method

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

Execute a data manipulation statement on a given database connection
dbUnloadDriver,DatabaseConnectorDriver-method

Load and unload database drivers
executeSql

Execute SQL code
existsTable

Does the table exist?
dbListTables,DatabaseConnectorConnection-method

List remote tables
dbRemoveTable,DatabaseConnectorConnection,ANY-method

Remove a table from the database
dbListFields,DatabaseConnectorConnection,character-method

List field names of a remote table
dbReadTable,DatabaseConnectorConnection,character-method

Copy data frames from database tables
extractQueryTimes

Extract query times from a ParallelLogger log file
dbSendQuery,DatabaseConnectorJdbcConnection,character-method

Execute a query on a given database connection
dropEmulatedTempTables

Drop all emulated temp tables.
getAvailableJavaHeapSpace

Get available Java heap space
month

Extract the month from a date
disconnect

Disconnect from the server
lowLevelExecuteSql

Execute SQL code
querySql

Retrieve data to a data.frame
jdbcDrivers

How to download and use JDBC drivers for the various data platforms.
downloadJdbcDrivers

Download DatabaseConnector JDBC Jar files
querySqlToAndromeda

Retrieves data to a local Andromeda object
renderTranslateQueryApplyBatched

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

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

Low level function for retrieving data to a data frame
eoMonth

Return the end of the month
renderTranslateQuerySql

Render, translate, and query to data.frame
getTableNames

List all tables in a database schema.
renderTranslateExecuteSql

Render, translate, execute SQL code
renderTranslateQuerySqlToAndromeda

Render, translate, and query to local Andromeda
inDatabaseSchema

Refer to a table in a database schema
year

Extract the year from a date
requiresTempEmulation

Does the DBMS require temp table emulation?
insertTable

Insert a table on the server
isSqlReservedWord

Test a character vector of SQL names for SQL reserved words