Add testing setup

DESCRIPTION

@@ -27,7 +27,8 @@ Imports:
 Suggests:
     odbc,
     RJDBC,
-    nycflights13
+    nycflights13,
+    testthat
 SystemRequirements: Impala driver to support a 'DBI'-compatible R interface
 NeedsCompilation: no
 License: Apache License 2.0 | file LICENSE

tests/testthat.R

@@ -0,0 +1,4 @@
+library(testthat)
+library(implyr)
+
+test_check("implyr")

tests/testthat/helper-src.R

@@ -0,0 +1,40 @@
+library(RJDBC)
+library(nycflights13)
+
+java_home <- Sys.getenv("JAVA_HOME", unset = NA)
+jdbc_url <- Sys.getenv("IMPLYR_TEST_JDBC", unset = NA)
+jdbc_host <- Sys.getenv("IMPLYR_TEST_HOST", unset = NA)
+jdbc_port <- Sys.getenv("IMPLYR_TEST_PORT", unset = NA)
+jdbc_user <- Sys.getenv("IMPLYR_TEST_USER", unset = NA)
+jdbc_pass <- Sys.getenv("IMPLYR_TEST_PASS", unset = NA)
+
+run_tests <- FALSE
+if (!is.na(java_home) & !is.na(jdbc_url) & !is.na(jdbc_host) &
+    !is.na(jdbc_port) & !is.na(jdbc_user) & !is.na(jdbc_pass)) {
+  jdbc_path <- tempdir()
+  jdbc_zip <- file.path(jdbc_path, basename(jdbc_url))
+  unlink(jdbc_zip)
+  download.file(jdbc_url, jdbc_zip)
+  jdbc_jars <- tools::file_path_sans_ext(jdbc_zip)
+  unlink(jdbc_jars, recursive = TRUE)
+  dir.create(jdbc_jars)
+  unzip(jdbc_zip, exdir = jdbc_jars)
+  impala_classpath <- list.files(path = jdbc_jars, pattern = "\\.jar$", full.names = TRUE)
+  rJava::.jinit(classpath = impala_classpath)
+  drv <- RJDBC::JDBC("com.cloudera.impala.jdbc41.Driver", impala_classpath, "`")
+  jdbc_conn_str <- paste0("jdbc:impala://", jdbc_host, ":", jdbc_port)
+  impala <- implyr::src_impala(drv, jdbc_conn_str, jdbc_user, jdbc_pass)
+  run_tests <- TRUE
+}
+
+check_impala <- function() {
+  if (!run_tests) {
+    skip("This environment not configured for tests")
+  }
+}
+
+disconnect <- function() {
+  if (run_tests) {
+    dbDisconnect(impala)
+  }
+}

tests/testthat/test-basic.R

@@ -0,0 +1,9 @@
+context("basic tests")
+
+test_that("tbl_impala matches tbl_df", {
+  check_impala()
+  test_op <- function(x) {
+    x %>% arrange(carrier) %>% collect()
+  }
+  compare_tbls(list(tbl(impala, "airlines"), nycflights13::airlines), op = test_op)
+})

tests/testthat/zzz-disconnect.R

@@ -0,0 +1 @@
+disconnect()