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