From d539a5df90d92657dbe024f8c674ca91ed1dd542 Mon Sep 17 00:00:00 2001
From: Antonios Chalkiopoulos <Antwnis@gmail.com>
Date: Fri, 22 Aug 2014 23:08:54 +0100
Subject: Refactoring into src/test/scala
---
.../jdbc/example/JdbcSourceExampleTest.scala | 54 ----------------------
1 file changed, 54 deletions(-)
delete mode 100644 src/test/scala/parallelai/spyglass/jdbc/example/JdbcSourceExampleTest.scala
(limited to 'src/test/scala/parallelai/spyglass/jdbc/example/JdbcSourceExampleTest.scala')
diff --git a/src/test/scala/parallelai/spyglass/jdbc/example/JdbcSourceExampleTest.scala b/src/test/scala/parallelai/spyglass/jdbc/example/JdbcSourceExampleTest.scala
deleted file mode 100644
index b268fa1..0000000
--- a/src/test/scala/parallelai/spyglass/jdbc/example/JdbcSourceExampleTest.scala
+++ /dev/null
@@ -1,54 +0,0 @@
-package parallelai.spyglass.jdbc.example
-
-import org.scalatest.junit.JUnitRunner
-import org.junit.runner.RunWith
-import org.scalatest.FunSpec
-import com.twitter.scalding.{Tsv, JobTest, TupleConversions}
-import org.slf4j.LoggerFactory
-import cascading.tuple.{Tuple, Fields}
-import parallelai.spyglass.jdbc.JDBCSource
-
-/**
- * Simple example of JDBCSource testing
- */
-@RunWith(classOf[JUnitRunner])
-class JdbcSourceExampleTest extends FunSpec with TupleConversions {
-
- val output = "src/test/resources/outputs/testOutput"
-
- val log = LoggerFactory.getLogger(this.getClass.getName)
-
- val sampleData = List(
- (1, "c11", "c12", 11),
- (2, "c21", "c22", 22)
- )
-
- JobTest("parallelai.spyglass.jdbc.example.JdbcSourceExample")
- .arg("test", "")
- .arg("app.conf.path", "app.conf")
- .arg("output", output)
- .arg("debug", "true")
- .source(
- new JDBCSource(
- "db_name",
- "com.mysql.jdbc.Driver",
- "jdbc:mysql://<hostname>:<port>/<db_name>?zeroDateTimeBehavior=convertToNull",
- "user",
- "password",
- List("KEY_ID", "COL1", "COL2", "COL3"),
- List("bigint(20)", "varchar(45)", "varchar(45)", "bigint(20)"),
- List("key_id"),
- new Fields("key_id", "col1", "col2", "col3")), sampleData)
- .sink[Tuple](Tsv(output.format("get_list"))) {
- outputBuffer =>
- log.debug("Output => " + outputBuffer)
-
- it("should return the mock data provided.") {
- assert(outputBuffer.size === 2)
- }
- }
- .run
- .finish
-
-
-}
--
cgit v1.2.3