我已经创建了一个单元测试,它使用embedded-cassandra
并执行一些脚本。但是我不能确定脚本是否成功运行。
我看到下面的两个打印结果(可能是因为我有两个语句)。有没有办法得到执行的结果,并把它打印在控制台上。
WARN c.d.d.c.Connection - /127.0.0.1:9042 did not send an authentication challenge; This is suspicious because the driver expects authentication (configured auth provider = com.datastax.driver.core.PlainTextAuthProvider)
WARN c.d.d.c.Connection - /127.0.0.1:9042 did not send an authentication challenge; This is suspicious because the driver expects authentication (configured auth provider = com.datastax.driver.core.PlainTextAuthProvider)
"UsersRepository Specs" should {
"create keyspace" in {
val factory = new LocalCassandraFactory
println(s"factory is ${factory}")
factory.setVersion(("3.11.1")) //TODOM . shall I pick these fromm a config file?
val statement1 =
"""
|CREATE KEYSPACE myspace
| WITH REPLICATION = {
| 'class' : 'SimpleStrategy',
| 'replication_factor' : 1
| };
""".stripMargin
val statement2 =
"""
|SELECT * FROM system_schema.keyspaces
""".stripMargin
val cqlStatements:CqlStatements = new CqlStatements(statement1,statement2)
val cassandraFactory = factory.create
val testCassandra = new TestCassandra();
try {
testCassandra.start()
testCassandra.executeScripts(cqlStatements)
} finally testCassandra.stop()
}
}
可能还有另一个用法问题。虽然我正在创建TestCassandra
。但我没有将cassandraFactory示例传递给它。所以我想知道embedded-cassandra
是否已经启动!!
我尝试通过传递cassandraFactory
和cqlStatements
来创建TestCassandra
,但得到了错误too many arguments in TestCassandra
1条答案
按热度按时间xcitsw881#
无法从配置文件中设置版本。
是否使用任何
slf4j
提供程序进行日志记录?查看脚本是否已执行的最简单方法是为
com.github.nosan.embedded.cassandra.test.util.CqlUtils
启用 debug 级别。如果您没有看到任何异常,则说明脚本执行没有问题。
我尝试通过传递cassandraFactory和cqlStatements来创建TestCassandra,但在TestCassandra中出现参数过多错误
我认为您应该使用此构造函数。