Skip to content

Commit

Permalink
removed unneeded param writeDBResults
Browse files Browse the repository at this point in the history
  • Loading branch information
katy-sadowski committed Nov 3, 2023
1 parent c3d375a commit 460ffb1
Show file tree
Hide file tree
Showing 3 changed files with 16 additions and 23 deletions.
12 changes: 4 additions & 8 deletions R/writeDBResultsTo.R
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@
#' Write DQD results database table to json
#'
#' @param connection A connection object
#' @param connectionDetails A connectionDetails object for connecting to the CDM database
#' @param resultsDatabaseSchema The fully qualified database name of the results schema
#' @param cdmDatabaseSchema The fully qualified database name of the CDM schema
#' @param writeTableName Name of DQD results table in the database to read from
Expand All @@ -28,7 +27,6 @@
#'

writeDBResultsToJson <- function(connection,
connectionDetails,
resultsDatabaseSchema,
cdmDatabaseSchema,
writeTableName,
Expand All @@ -37,18 +35,16 @@ writeDBResultsToJson <- function(connection,
metadata <- DatabaseConnector::renderTranslateQuerySql(
connection,
sql = "select * from @cdmDatabaseSchema.cdm_source;",
cdmDatabaseSchema = cdmDatabaseSchema,
targetDialect = connectionDetails$dbms,
snakeCaseToCamelCase = TRUE
snakeCaseToCamelCase = TRUE,
cdmDatabaseSchema = cdmDatabaseSchema
)

checkResults <- DatabaseConnector::renderTranslateQuerySql(
connection,
sql = "select * from @resultsDatabaseSchema.@writeTableName;",
snakeCaseToCamelCase = TRUE,
resultsDatabaseSchema = resultsDatabaseSchema,
writeTableName = writeTableName,
targetDialect = connectionDetails$dbms,
snakeCaseToCamelCase = TRUE
writeTableName = writeTableName
)

# Quick patch for missing value issues related to SQL Only Implementation
Expand Down
3 changes: 0 additions & 3 deletions man/writeDBResultsToJson.Rd

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

24 changes: 12 additions & 12 deletions tests/testthat/test-writeDBResultsTo.R
Original file line number Diff line number Diff line change
Expand Up @@ -8,25 +8,26 @@ test_that("Write DB results to json", {
resultsDatabaseSchemaEunomia <- "main"
writeTableName <- "dqdashboard_results"

results <- DataQualityDashboard::executeDqChecks(
connectionDetails = connectionDetailsEunomia,
cdmDatabaseSchema = cdmDatabaseSchemaEunomia,
resultsDatabaseSchema = resultsDatabaseSchemaEunomia,
cdmSourceName = "Eunomia",
checkNames = "measurePersonCompleteness",
outputFolder = outputFolder,
writeToTable = TRUE,
writeTableName = writeTableName
expect_warning(
results <- DataQualityDashboard::executeDqChecks(
connectionDetails = connectionDetailsEunomia,
cdmDatabaseSchema = cdmDatabaseSchemaEunomia,
resultsDatabaseSchema = resultsDatabaseSchemaEunomia,
cdmSourceName = "Eunomia",
checkNames = "measurePersonCompleteness",
outputFolder = outputFolder,
writeToTable = TRUE,
writeTableName = writeTableName
),
regexp = "^Missing check names.*"
)


connection <- DatabaseConnector::connect(connectionDetailsEunomia)

testExportFile <- "dq-result-test.json"

DataQualityDashboard::writeDBResultsToJson(
connection,
connectionDetailsEunomia,
resultsDatabaseSchemaEunomia,
cdmDatabaseSchemaEunomia,
writeTableName,
Expand All @@ -46,7 +47,6 @@ test_that("Write DB results to json", {
sql = "select count(*) from @resultsDatabaseSchema.@writeTableName;",
resultsDatabaseSchema = resultsDatabaseSchemaEunomia,
writeTableName = writeTableName,
targetDialect = connectionDetailsEunomia$dbms,
snakeCaseToCamelCase = TRUE
)
expect_true(length(results$CheckResults) == table_rows)
Expand Down

0 comments on commit 460ffb1

Please sign in to comment.