Package index • CDMConnector

CDM Object

Create or transform a CDM reference object. These accept and return cdm objects.

assertTables() assert_tables(): Assert that tables exist in a cdm object

assert_write_schema() assertWriteSchema(): Assert that cdm has a writable schema

cdmCon(): Get underlying database connection

cdmDisconnect() cdm_disconnect(): Disconnect the connection of the cdm object

cdmFlatten() cdm_flatten(): Flatten a cdm into a single observation table

cdmFromCon() cdm_from_con(): Create a CDM reference object from a database connection

cdmFromEnvironment() cdm_from_environment(): Create a CDM object from a pre-defined set of environment variables

cdmFromFiles() cdm_from_files() deprecated: Create a CDM reference from a folder containing parquet, csv, or feather files

cdmSample() cdm_sample(): Subset a cdm object to a random sample of individuals

cdmSelectTbl() cdm_select_tbl(): Select a subset of tables in a cdm reference object

cdmSubset() cdm_subset(): Subset a cdm object to a set of persons

cdmSubsetCohort() cdm_subset_cohort(): Subset a cdm to the individuals in one or more cohorts

cdmWriteSchema(): Get cdm write schema

cdm_from_tables() deprecated: Create a cdm object from local tables

cdm_name(): Get the CDM name

copyCdmTo() copy_cdm_to(): Copy a cdm object from one database to another

dbSource(): Create a source for a cdm in a database.

snapshot(): Extract CDM metadata

stow(): Collect a list of lazy queries and save the results as files

tblGroup() tbl_group(): CDM table selection helper

validateCdm() validate_cdm(): Validation report for a CDM

version(): Get the CDM version

Cohort Creation and Transformation

A cohort is a set of person-days representing the time during which people in a CDM exhibited some observable characteristics. Cohorts are often the foundation of downstream analyses.

cohortAttrition() cohort_attrition() deprecated: Get attrition table from a cohort_table object

cohortErafy() cohort_erafy() deprecated: Collapse cohort records within a certain number of days

cohortSet() cohort_set() deprecated: Get cohort settings from a cohort_table object

cohortUnion() cohort_union() deprecated: Union all cohorts in a cohort set with cohorts in a second cohort set

cohort_count() deprecated: Get cohort counts from a generated_cohort_set object.

generateCohortSet() generate_cohort_set() experimental: Generate a cohort set on a cdm object

generateConceptCohortSet() generate_concept_cohort_set(): Create a new generated cohort set from a list of concept sets

intersectCohorts() intersect_cohorts() deprecated: Intersect all cohorts in a single cohort table

new_generated_cohort_set() newGeneratedCohortSet() deprecated: Constructor for cohort_table objects

readCohortSet() read_cohort_set(): Read a set of cohort definitions into R

record_cohort_attrition(): Add attrition reason to a cohort_table object

unionCohorts() union_cohorts() deprecated: Union all cohorts in a single cohort table

dbplyr workarounds

Functions that can be used in cross database dplyr pipelines

appendPermanent() append_permanent() deprecated: Run a dplyr query and add the result set to an existing

asDate() as_date(): as.Date dbplyr translation wrapper

computeQuery() compute_query(): Execute dplyr query and save result in remote database

dateadd(): Add days or years to a date in a dplyr query

datediff(): Compute the difference between two days

datepart(): Extract the day, month or year of a date in a dplyr pipeline

inSchema() in_schema(): Helper for working with compound schemas

summariseQuantile() summarize_quantile() summarise_quantile() summarizeQuantile(): Quantile calculation using dbplyr

unique_table_name() deprecated: Create a unique table name for temp tables

DBI connection

Functions that accept DBI connections and are useful in cross database DBI code

dbms(): Get the database management system (dbms) from a cdm_reference or DBI connection

listTables() list_tables(): List tables in a schema

Eunomia example CDM

Easily create and use example CDMs in a duckdb database

downloadEunomiaData() download_eunomia_data(): Download Eunomia data files

eunomiaDir() eunomia_dir(): Create a copy of an example OMOP CDM dataset

eunomiaIsAvailable() eunomia_is_available() deprecated: Has the Eunomia dataset been cached?

exampleDatasets() example_datasets() deprecated: List the available example CDM datasets

requireEunomia() require_eunomia() deprecated: Require eunomia to be available. The function makes sure that you can later create a eunomia database with eunomiaDir().

Benchmarking

Run benchmarking of simple queries against your CDM reference

benchmarkCDMConnector(): Run benchmark of tasks using CDMConnector