Nothing
context("ClickhouseConnection")
library(DBI, warn.conflicts=F)
library(dplyr, warn.conflicts=F)
source("utils.R")
test_that("show__ClickhouseConnection", {
conn <- getRealConnection()
targetString <- '<ClickhouseConnection> default@localhost:9000'
expect_equal(paste(capture.output(RClickhouse::show(conn)), collapse = ''), targetString)
# cleanup
dbDisconnect(conn)
})
# # not sure on how to adequately test this method
# test_that("dbGetInfo__ClickhouseConnection", {
# # conn <- getRealConnection()
# # target <- dbGetQuery(conn, "SELECT version() as version, uptime() as uptime,
# # currentDatabase() as database")
# # targetString <- '<ClickhouseConnection> default@localhost:9000'
# # expect_equal(RClickhouse::dbGetInfo(conn), list(name="ClickhouseConnection",db.version="20.1.6.30",uptime=target$uptime,dbname=target$database,username="default",host="localhost",port=9000))
# })
# # not sure on how to adequately test this method
# test_that("dbIsValid__ClickhouseConnection", {
# })
test_that("dbListTables__ClickhouseConnection", {
conn <- getRealConnection()
dbWriteTable(conn, "tableOne", 1:4, overwrite=T)
dbWriteTable(conn, "tableTwo", 1:4, overwrite=T)
targetString <- '[1] "tableOne" "tableTwo"'
expect_equal(paste(capture.output(dbListTables(conn)), collapse = ''), targetString)
# cleanup
dbRemoveTable(conn,"tableOne")
dbRemoveTable(conn,"tableTwo")
dbDisconnect(conn)
})
test_that("dbExistsTable__ClickhouseConnection", {
conn <- getRealConnection()
# before Table is created should return False
expect_false(dbExistsTable(conn, 'test_dbExistsTable'))
dbExecute(conn, "CREATE TABLE test_dbExistsTable (`name` String) ENGINE = TinyLog")
# after Table is created should return True
expect_true(dbExistsTable(conn, 'test_dbExistsTable'))
# cleanup...
dbRemoveTable(conn, "test_dbExistsTable")
dbDisconnect(conn)
})
test_that("dbReadTable__ClickhouseConnection", {
conn <- getRealConnection()
dbWriteTable(conn, "test_dbReadTable", 1:4, overwrite=T)
# checks if read values same as input values
testthat::expect_equivalent(dbReadTable(conn, "test_dbReadTable"), data.frame(x=1:4))
# cleanup
dbRemoveTable(conn, "test_dbReadTable")
dbDisconnect(conn)
})
test_that("dbRemoveTable__ClickhouseConnection", {
conn <- getRealConnection()
dbExecute(conn, "CREATE TABLE test_dbRemoveTable (`name` String) ENGINE = TinyLog")
# precondition for test failed, "test_dbRemoveTable" was not created
expect_true(dbExistsTable(conn, 'test_dbRemoveTable'))
dbRemoveTable(conn, "test_dbRemoveTable")
expect_false(dbExistsTable(conn, 'test_dbRemoveTable'))
# cleanup
dbDisconnect(conn)
})
# test_that("dbListFields__ClickhouseConnection", {
# })
#
# test_that("dbSendQuery__ClickhouseConnection", {
# })
#
# test_that("dbWriteTable__ClickhouseConnection", {
# })
test_that("dbCreateTable", {
conn <- getRealConnection()
tablename <- "PersonalInfo"
fields <- c(Name="String",ID="Int32",Age="Int8",Profession="String")
dbCreateTable(conn, tablename, fields=fields, overwrite=TRUE)
expect_equal(tablename,dbListTables(conn))
concatenatedOutput = '[1] \"Name\" \"ID\" \"Age\" \"Profession\"'
expect_equal(paste(capture.output(RClickhouse::dbListFields(conn,"PersonalInfo")), collapse = ''),concatenatedOutput)
# cleanup
dbRemoveTable(conn,"PersonalInfo")
dbDisconnect(conn)
})
test_that("dbAppendTable", {
conn <- getRealConnection()
tablename <- "PersonalInfo"
fields <- c(Name="String",ID="Int32",Age="Int8",Profession="String")
dbCreateTable(conn, tablename, fields=fields, overwrite=TRUE)
NameVALUES=c('John Smith','Peter Norwind',"Alexander Mightsby")
IDVALUES=c(1:3)
AgeVALUES=c(25,22,26)
ProfessionVALUES=c('Software Engineer','Software Engineer','Assistant Software Engineer')
appendThis <- data.frame(Name=NameVALUES,ID=IDVALUES,Age=AgeVALUES,Profession=ProfessionVALUES)
dbAppendTable(conn, tablename, value=appendThis, row.names=FALSE)
afterRead <- dbReadTable(conn, "PersonalInfo")
expect_true(all(appendThis==afterRead))
# cleanup
RClickhouse::dbRemoveTable(conn,"PersonalInfo")
dbDisconnect(conn)
})
# test_that("dbDataType__ClickhouseConnection", {
# })
#
# test_that("dbQuoteIdentifier__ClickhouseConnection", {
# })
#
# test_that("dbQuoteString__ClickhouseConnection_1", {
# })
#
# test_that("dbQuoteString__ClickhouseConnection_2", {
# })
#
# test_that("dbBegin__ClickhouseConnection", {
# })
#
# test_that("dbCommit__ClickhouseConnection", {
# })
#
# test_that("dbRollback__ClickhouseConnection", {
# })
#
# test_that("dbDisconnect__ClickhouseConnection", {
# })
Any scripts or data that you put into this service are public.
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.