如何在TestCassandra中获取Cassandra会话的实例

Question

我不知道如何对访问Cassandra的类进行单元测试。我可能需要重新设计！

我已经创建了一个Play Components类(https://www.playframework.com/documentation/2.6.x/api/scala/index.html#play.api.BuiltInComponentsFromContext)，它在应用程序启动时创建一个cassandra会话。

trait CassandraRepositoryComponents {
  def environment: Environment
  def configuration: Configuration
  def applicationLifecycle: ApplicationLifecycle
...
lazy private val cassandraSession: Session = {
val cluster = new Cluster.Builder().
      addContactPoints(uri.hosts.toArray: _*).
      withPort(uri.port).
      withQueryOptions(new QueryOptions().setConsistencyLevel(defaultConsistencyLevel)).build
val session = cluster.connect
}

}

这样创建的会话将在实例化repo类时传递给我的repo类

class UsersRepository(utilities:HelperMethods, session: Session,tablename:String) 
  extends CassandraRepository[UserKeys,User](session, tablename, List("bucket","email"))  { 

//UsersRepository类不直接使用session。它将会话传递给最终调用session.execute来运行查询的CassandraRepository ...}

我想对UsersRepository进行单元测试。我正在使用embedded-cassandra来测试它，但是embedded-cassandra似乎没有提供一种方法来获取它创建的会话的实例。

question1 -有没有办法让TestCassandra启动Cassandra的会话？question2 -有没有更好的方法来组织课程？

Answer 1

question1 -有没有办法让TestCassandra启动Cassandra的会话？

没有办法让TestCassandra启动Cassandra的Session。

您可以使用com.github.nosan.embedded.cassandra.test.ClusterFactory或com.github.nosan.embedded.cassandra.test.CqlSessionFactory来创建Cluster或CqlSession类。