175 lines
6.8 KiB
R
175 lines
6.8 KiB
R
library(DatabaseConnector)
|
|
|
|
##### Oracle Testing
|
|
oracleConnect <- DatabaseConnector::createConnectionDetails(dbms = "oracle",
|
|
user = Sys.getenv("CDM5_ORACLE_USER"),
|
|
password = Sys.getenv("CDM5_ORACLE_PASSWORD"),
|
|
server = Sys.getenv("CDM5_ORACLE_SERVER"),
|
|
schema = Sys.getenv("CDM5_ORACLE_CDM_SCHEMA"))
|
|
|
|
conn <- DatabaseConnector::connect(connectionDetails = oracleConnect)
|
|
|
|
## Run oracle ddl
|
|
sql <- SqlRender::readSql(paste0("output/oracle/OMOP CDM oracle ", cdmVersion," ddl.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run oracle primary keys
|
|
sql <- SqlRender::readSql(paste0("output/oracle/OMOP CDM oracle ", cdmVersion," primary keys.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run oracle constraints
|
|
sql <- SqlRender::readSql(paste0("output/oracle/OMOP CDM oracle ", cdmVersion," constraints.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run oracle indices
|
|
sql <- SqlRender::readSql(paste0("output/oracle/OMOP CDM oracle ", cdmVersion," indices.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Remove oracle tables
|
|
sql <- SqlRender::readSql(paste0("output/oracle/oracle testCleanUp ", "v5_3_1",".sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
|
|
DatabaseConnector::disconnect(conn)
|
|
|
|
##########################################################################
|
|
##### Postgres Testing
|
|
postgresConnect <- DatabaseConnector::createConnectionDetails(dbms = "postgresql",
|
|
user = Sys.getenv("CDM5_POSTGRESQL_USER"),
|
|
password = Sys.getenv("CDM5_POSTGRESQL_PASSWORD"),
|
|
server = Sys.getenv("CDM5_POSTGRESQL_SERVER"),
|
|
schema = Sys.getenv("CDM5_POSTGRESQL_OHDSI_SCHEMA"))
|
|
|
|
conn <- DatabaseConnector::connect(connectionDetails = postgresConnect)
|
|
|
|
## Run postgres ddl
|
|
sql <- SqlRender::readSql(paste0("output/postgresql/OMOP CDM postgresql ", cdmVersion," ddl.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run postgres primary keys
|
|
sql <- SqlRender::readSql(paste0("output/postgresql/OMOP CDM postgresql", cdmVersion," primary keys.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run postgres constraints
|
|
sql <- SqlRender::readSql(paste0("output/postgresql/OMOP CDM postgresql ", cdmVersion," constraints.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run postgres indices
|
|
sql <- SqlRender::readSql(paste0("output/postgresql/OMOP CDM postgresql ", cdmVersion," indices.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Remove postgres tables
|
|
sql <- SqlRender::readSql(paste0("output/postgresql/postgresql testCleanUp ", "v5_3_1",".sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
|
|
DatabaseConnector::disconnect(conn)
|
|
|
|
##### Sql Server Testing
|
|
sqlServerConnect <- DatabaseConnector::createConnectionDetails(dbms = "sql server",
|
|
user = Sys.getenv("CDM5_SQL_SERVER_USER"),
|
|
password = Sys.getenv("CDM5_SQL_SERVER_PASSWORD"),
|
|
server = Sys.getenv("CDM5_SQL_SERVER_SERVER"),
|
|
schema = Sys.getenv("CDM5_SQL_SERVER_OHDSI_SCHEMA"))
|
|
|
|
conn <- DatabaseConnector::connect(connectionDetails = sqlServerConnect)
|
|
|
|
## Create sql server tables
|
|
sql <- SqlRender::readSql(paste0("output/sql server/OMOP CDM sql server ", cdmVersion," ddl.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run sql server primary keys and indices
|
|
sql <- SqlRender::readSql(paste0("output/sql server/OMOP CDM sql server ", cdmVersion," primary keys.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run sql server constraints
|
|
sql <- SqlRender::readSql(paste0("output/sql server/OMOP CDM sql server ", cdmVersion," constraints.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Run sql server indices
|
|
sql <- SqlRender::readSql(paste0("output/sql server/OMOP CDM sql server ", cdmVersion," indices.sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
## Remove sql server tables
|
|
sql <- SqlRender::readSql(paste0("output/sql server/sql server testCleanUp ", "v6_0",".sql"))
|
|
|
|
DatabaseConnector::executeSql(connection = conn,
|
|
sql = sql,
|
|
progressBar = FALSE,
|
|
reportOverallTime = FALSE
|
|
)
|
|
|
|
|
|
DatabaseConnector::disconnect(conn)
|
|
|