Loading date for each test

6 views
Skip to first unread message

Guillermo Ortiz

unread,
Apr 1, 2018, 3:54:07 PM4/1/18
to cassandra-unit-users
I use cassandra unit with scalaTest. I load a main dataset but before each test I have to load some data.

In the main dataset I use a CQL file with some create tables and before each test I insert some data. I'm trying to do it in the same way:

class MyTest extends FunSuite with StreamingActionBase {
  var cluster: Cluster = _
  var session: Session = _
  var dataLoader: CQLDataLoader = _

  override def beforeAll(): Unit = {
    super.beforeAll()

    EmbeddedCassandraServerHelper.startEmbeddedCassandra(file, 10000)
    cluster = EmbeddedCassandraServerHelper.getCluster()
    session = cluster.connect()

    dataLoader = new CQLDataLoader(session)
    dataLoader.load(new ClassPathCQLDataSet("cql/simple.cql", "ks"))
  }

  override def afterAll(): Unit = {
    super.afterAll()
    EmbeddedCassandraServerHelper.cleanEmbeddedCassandra()
  }


  test("Delete") {
    dataLoader = new CQLDataLoader(session)
    dataLoader.load(new ClassPathCQLDataSet("cql/delete_test.cql", "ks")) --> ERROR
...

When I execute the line I get an error: "unreconized table XXXX", but if I execute the sentence directly works
dataLoader.load(new ClassPathCQLDataSet("cql/delete_test.cql", "ks")) --> It doesn't work
session.execute("INSERT INTO my_table .....") --> it works


Reply all
Reply to author
Forward
0 new messages