Changeset: 2f83675e81d9 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=2f83675e81d9
Added Files:
tools/embedded/Tests/All
tools/embedded/Tests/dbi.R
tools/embedded/Tests/dbi.reqtests
tools/embedded/Tests/deps-test.R
tools/embedded/Tests/deps-test.stable.err
tools/embedded/Tests/deps-test.stable.out
tools/embedded/Tests/deps-test.timeout
tools/embedded/Tests/dplyr.R
tools/embedded/Tests/install-binary.R
tools/embedded/Tests/install-binary.stable.err
tools/embedded/Tests/install-binary.stable.out
tools/embedded/Tests/install-source.R
tools/embedded/Tests/install-source.stable.err
tools/embedded/Tests/install-source.stable.out
tools/embedded/Tests/install-source.timeout
tools/embedded/Tests/install.reqtests
tools/embedded/Tests/lowlevel.R
tools/embedded/Tests/lowlevel.reqtests
tools/embedded/Tests/lowlevel.stable.err
tools/embedded/Tests/lowlevel.stable.out
Removed Files:
tools/embedded/Tests/embedded-test.R
tools/embedded/rpackage/tests/testthat.R
tools/embedded/rpackage/tests/testthat/test_dbi.R
tools/embedded/rpackage/tests/testthat/test_dplyr.R
tools/embedded/rpackage/tests/testthat/test_lowlevel.R
Modified Files:
clients/R/Tests/install.R
Branch: embedded
Log Message:
Mtests for monetdblite/r
diffs (truncated from 1475 to 300 lines):
diff --git a/clients/R/Tests/install.R b/clients/R/Tests/install.R
--- a/clients/R/Tests/install.R
+++ b/clients/R/Tests/install.R
@@ -8,6 +8,7 @@ builddir <- file.path(basedir, "rbuild
installdir <- file.path(basedir, "rlibdir")
dir.create(builddir)
dir.create(installdir)
+file.remove(file.path(builddir, "MonetDB.R"), recursive=T, showWarnings=F)
file.copy(from=file.path(srcdir, "..", "MonetDB.R"), to=builddir, recursive=T)
dd <- capture.output(suppressMessages( {
sink(file=file(tempfile(), open = "wt"), type = "message")
diff --git a/tools/embedded/Tests/All b/tools/embedded/Tests/All
new file mode 100644
--- /dev/null
+++ b/tools/embedded/Tests/All
@@ -0,0 +1,5 @@
+NATIVE_WIN32?install-binary
+install-source
+deps-test
+lowlevel
+dbi
diff --git a/tools/embedded/Tests/dbi.R b/tools/embedded/Tests/dbi.R
new file mode 100644
--- /dev/null
+++ b/tools/embedded/Tests/dbi.R
@@ -0,0 +1,265 @@
+basedir <- Sys.getenv("TSTTRGDIR")
+if (basedir == "") {
+ stop("Need TSTTRGDIR environment vars")
+}
+library(MonetDBLite, quietly=T, lib.loc=file.path(basedir, "rlibdir"))
+library(MonetDB.R)
+library(testthat)
+
+tname <- "monetdbtest"
+data(iris)
+tsize <- function(conn, tname)
+ as.integer(dbGetQuery(conn, paste0("SELECT COUNT(*) FROM ",tname))[[1]])
+
+test_that("db starts up and accepts queries", {
+ con <<- dbConnect(MonetDB.R::MonetDB.R(), embedded=tempdir())
+ expect_is(con, "MonetDBEmbeddedConnection")
+ expect_true(dbIsValid(con))
+ res <- dbGetQuery(con, "SELECT 42")
+ expect_equal(res$single_value, 42)
+ expect_is(res, "data.frame")
+})
+
+test_that("raw sql handling", {
+ dbSendUpdate(con, "CREATE TABLE monetdbtest (a varchar(10),b integer,c
blob)")
+ expect_equal(dbExistsTable(con, tname), TRUE)
+ dbSendUpdate(con, "INSERT INTO monetdbtest VALUES ('one',1,'1111')")
+ dbSendUpdate(con, "INSERT INTO monetdbtest VALUES ('two',2,'22222222')")
+ expect_equal(dbGetQuery(con,"SELECT count(*) FROM monetdbtest")[[1]], 2)
+ #expect_equal(dbReadTable(con, "monetdbtest")[[3]],
list(charToRaw("1111"), charToRaw("22222222")))
+ # why does this not work?
+ dbRemoveTable(con, tname)
+ expect_false(dbExistsTable(con, tname))
+})
+
+test_that("import export", {
+ data(iris)
+ dbWriteTable(con, tname, iris)
+
+ expect_true(dbExistsTable(con, tname))
+ expect_false(dbExistsTable(con, "monetdbtest2"))
+
+ expect_true(tname %in% dbListTables(con))
+ expect_equal(dbListFields(con, tname), names(iris))
+
+ iris2 <- dbReadTable(con, tname)
+ expect_equal(dim(iris), dim(iris2))
+
+ res <- dbSendQuery(con, "SELECT \"Species\", \"Sepal.Width\" FROM
monetdbtest")
+ expect_true(dbIsValid(res))
+ expect_is(res, "MonetDBEmbeddedResult")
+ expect_true(res@env$success)
+ expect_equal(dbColumnInfo(res)[[1,1]], "Species")
+ expect_equal(dbColumnInfo(res)[[2,1]], "Sepal.Width")
+ expect_equal(dbGetInfo(res)$row.count, 150)
+ expect_equal(res@env$info$rows, 150)
+
+ data2 <- dbFetch(res,-1)
+ expect_equal(dim(data2)[[1]], 150)
+ expect_true(dbHasCompleted(res))
+ expect_true(dbIsValid(res))
+ dbClearResult(res)
+ expect_false(dbIsValid(res))
+
+ dbRemoveTable(con, tname)
+ expect_false(dbExistsTable(con, tname))
+ expect_error(dbFetch(res))
+})
+
+test_that("csv import", {
+ tf <- tempfile()
+ on.exit(unlink(tf))
+
+ write.table(iris, tf, sep=",", row.names=FALSE)
+ tname2 <- "Need to quote this table name"
+ monetdb.read.csv(con, tf, tname)
+ monetdb.read.csv(con, tf, tname2)
+ expect_true(dbExistsTable(con, tname))
+ expect_true(dbExistsTable(con,tname2))
+
+ iris3 <- dbReadTable(con, tname)
+ iris4 <- dbReadTable(con, tname2)
+ expect_equal(dim(iris), dim(iris3))
+ expect_equal(dim(iris), dim(iris4))
+ expect_equal(dbListFields(con,tname), names(iris))
+ expect_equal(dbListFields(con,tname2), names(iris))
+
+ dbRemoveTable(con, tname)
+ dbRemoveTable(con, tname2)
+ expect_false(dbExistsTable(con, tname))
+ expect_false(dbExistsTable(con, tname2))
+})
+
+test_that("write table with complications", {
+ # make sure table is gone before we start
+ if (dbExistsTable(con,tname))
+ dbRemoveTable(con,tname)
+
+ # table does not exist, append=F, overwrite=F, this should work
+ dbWriteTable(con, tname, mtcars, append=F, overwrite=F)
+ expect_true(dbExistsTable(con, tname))
+ expect_equal(nrow(mtcars), tsize(con, tname))
+
+ # these should throw errors
+ expect_error(dbWriteTable(con, tname, mtcars, append=F, overwrite=F))
+ expect_error(dbWriteTable(con ,tname, mtcars, overwrite=T, append=T))
+
+ # this should be fine
+ dbWriteTable(con, tname, mtcars, append=F, overwrite=T)
+ expect_true(dbExistsTable(con, tname))
+ expect_equal(nrow(mtcars), tsize(con, tname))
+
+ # append to existing table
+ dbWriteTable(con, tname, mtcars, append=T, overwrite=F)
+ expect_equal(as.integer(2*nrow(mtcars)), tsize(con, tname))
+ dbRemoveTable(con, tname)
+ expect_false(dbExistsTable(con, tname))
+
+ # use inserts
+ dbWriteTable(con, tname, mtcars, append=F, overwrite=F, insert=T)
+ expect_true(dbExistsTable(con, tname))
+ expect_equal(nrow(mtcars), tsize(con, tname))
+ dbRemoveTable(con, tname)
+ expect_false(dbExistsTable(con, tname))
+})
+
+test_that("transactions", {
+ dbSendQuery(con, "CREATE TABLE monetdbtest (a INTEGER)")
+ expect_true(dbExistsTable(con ,tname))
+ dbBegin(con)
+ dbSendQuery(con, "INSERT INTO monetdbtest VALUES (42)")
+ expect_equal(1, tsize(con, tname))
+ dbRollback(con)
+ expect_equal(0, tsize(con, tname))
+ dbBegin(con)
+ dbSendQuery(con, "INSERT INTO monetdbtest VALUES (42)")
+ expect_equal(1, tsize(con, tname))
+ dbCommit(con)
+ expect_equal(1, tsize(con, tname))
+ dbRemoveTable(con, tname)
+ expect_false(dbExistsTable(con, tname))
+})
+
+test_that("funny characters", {
+ dbBegin(con)
+ dbSendQuery(con, "CREATE TABLE monetdbtest (a string)")
+ dbSendQuery(con, "INSERT INTO monetdbtest VALUES ('Роман
Mühleisen')")
+ expect_equal("Роман Mühleisen", dbGetQuery(con, "SELECT a FROM
monetdbtest")$a[[1]])
+ dbSendQuery(con, "DELETE FROM monetdbtest")
+ dbSendUpdate(con, "INSERT INTO monetdbtest (a) VALUES (?)", "Роман
Mühleisen")
+ expect_equal("Роман Mühleisen", dbGetQuery(con, "SELECT a FROM
monetdbtest")$a[[1]])
+ dbRollback(con)
+})
+
+test_that("esoteric type MONTH_INTERVAL", {
+ expect_equal(1L, as.integer(dbGetQuery(con, "select cast('2015-03-02'
as date) - cast('2015-03-01' as date)")[[1]][[1]]))
+})
+
+test_that("reserved words in df col names", {
+ dbBegin(con)
+ dbWriteTable(con, tname, data.frame(year=42, month=12, day=24,
some.dot=12), transaction=F)
+ expect_true(dbExistsTable(con, tname))
+ dbRollback(con)
+})
+
+test_that("empty result set", {
+ expect_true(!is.null(dbGetQuery(con, "SELECT * FROM tables WHERE 1=0")))
+})
+
+test_that("evil table from survey works", {
+ dbBegin(con)
+ data(api, package="survey")
+ x <- apiclus1
+ x$idkey <- seq(nrow(x))
+ dbWriteTable(con, tname, x, transaction=F)
+ expect_true(dbExistsTable(con, tname))
+ dbRollback(con)
+})
+
+# below some DBI test cases 'borrowed' from RSQLite
+basicDf <- data.frame(
+ name = c("Alice", "Bob", "Carl", "NA", NA),
+ fldInt = as.integer(c(as.integer(1:4), NA)),
+ fldDbl = as.double(c(1.1, 2.2, 3.3, 4.4, NA)),
+ stringsAsFactors = FALSE
+)
+
+test_that("round-trip leaves data.frame unchanged", {
+ dbWriteTable(con, "t1", basicDf, row.names = FALSE)
+ expect_equivalent(dbGetQuery(con, "select * from t1"), basicDf)
+ expect_equivalent(dbReadTable(con, "t1"), basicDf)
+ dbRemoveTable(con, "t1")
+})
+
+test_that("NAs work in first row", {
+ na_first <- basicDf[c(5, 1:4), ]
+ rownames(na_first) <- NULL
+ dbWriteTable(con, "t1", na_first, row.names = FALSE)
+ expect_equivalent(dbReadTable(con, "t1"), na_first)
+ dbRemoveTable(con, "t1")
+})
+
+test_that("row-by-row fetch is equivalent", {
+ dbWriteTable(con, "t1", basicDf, row.names = FALSE)
+ rs <- dbSendQuery(con, "SELECT * FROM t1")
+ on.exit(dbClearResult(rs))
+ for (i in 1:5) {
+ row <- dbFetch(rs, 1L)
+ expect_equal(row, basicDf[i, ], check.attributes = FALSE)
+ }
+ row <- dbFetch(rs, 1L)
+ expect_equal(nrow(row), 0L)
+ expect_true(dbHasCompleted(rs))
+ dbRemoveTable(con, "t1")
+})
+
+# TODO: fix this
+# test_that("column types as expected in presence of NULLs", {
+# dbWriteTable(con, "t1", datasets::USArrests)
+# a1 <- dbGetQuery(con, "SELECT Murder/(Murder - 8.1) FROM t1 LIMIT 10")
+# expect_is(a1[[1]], "numeric")
+# dbRemoveTable(con, "t1")
+# })
+
+test_that("correct number of columns, even if 0 rows", {
+ ans <- dbGetQuery(con, "select 1 as a, 2 as b where 1=1")
+ expect_equal(dim(ans), c(1L, 2L))
+ ans <- dbGetQuery(con, "select 1 as a, 2 as b where 0=1")
+ expect_equal(dim(ans), c(0L, 2L))
+})
+
+test_that("accessing cleared result throws error", {
+ res <- dbSendQuery(con, "SELECT 1;")
+ dbClearResult(res)
+ expect_error(dbFetch(res))
+})
+
+test_that("fetch with no arguments gets all rows", {
+ df <- data.frame(x = 1:1000)
+ dbWriteTable(con, "test", df)
+ rs <- dbSendQuery(con, "SELECT * FROM test")
+ expect_equal(nrow(dbFetch(rs)), 1000)
+ dbRemoveTable(con, "test")
+})
+
+test_that("fetch progressively pulls in rows", {
+ df <- data.frame(x = 1:25)
+ dbWriteTable(con, "test", df)
+ rs <- dbSendQuery(con, "SELECT * FROM test")
+ expect_equal(nrow(dbFetch(rs, 10)), 10)
+ expect_equal(nrow(dbFetch(rs, 10)), 10)
+ expect_equal(nrow(dbFetch(rs, 10)), 5)
+ dbRemoveTable(con, "test")
+})
+
+test_that("dis/re-connect", {
+ expect_true(dbIsValid(con))
+ dbDisconnect(con)
+ expect_false(dbIsValid(con))
+ expect_error(dbSendQuery(con, "SELECT 1"))
+ # this throws a warning because we cannot re-initialize embedded monetdb
+ expect_warning(con <- dbConnect(MonetDB.R::MonetDB.R(),
embedded=tempdir()))
+ res <- dbSendQuery(con, "SELECT 1")
+ expect_true(dbIsValid(res))
+})
+
diff --git a/tools/embedded/Tests/dbi.reqtests
b/tools/embedded/Tests/dbi.reqtests
new file mode 100644
--- /dev/null
+++ b/tools/embedded/Tests/dbi.reqtests
@@ -0,0 +1,1 @@
+lowlevel
diff --git a/tools/embedded/Tests/deps-test.R b/tools/embedded/Tests/deps-test.R
new file mode 100644
--- /dev/null
_______________________________________________
checkin-list mailing list
[email protected]
https://www.monetdb.org/mailman/listinfo/checkin-list
