我无法确定我的脚本是否在embedded-cassandra中正确执行

cuxqih21  于 2022-11-05  发布在  Cassandra
关注(0)|答案(1)|浏览(189)

我已经创建了一个单元测试,它使用embedded-cassandra并执行一些脚本。但是我不能确定脚本是否成功运行。
我看到下面的两个打印结果(可能是因为我有两个语句)。有没有办法得到执行的结果,并把它打印在控制台上。

  1. 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)
  2. 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)
  3. "UsersRepository Specs" should {
  4. "create keyspace" in {
  5. val factory = new LocalCassandraFactory
  6. println(s"factory is ${factory}")
  7. factory.setVersion(("3.11.1")) //TODOM . shall I pick these fromm a config file?
  8. val statement1 =
  9. """
  10. |CREATE KEYSPACE myspace
  11. | WITH REPLICATION = {
  12. | 'class' : 'SimpleStrategy',
  13. | 'replication_factor' : 1
  14. | };
  15. """.stripMargin
  16. val statement2 =
  17. """
  18. |SELECT * FROM system_schema.keyspaces
  19. """.stripMargin
  20. val cqlStatements:CqlStatements = new CqlStatements(statement1,statement2)
  21. val cassandraFactory = factory.create
  22. val testCassandra = new TestCassandra();
  23. try {
  24. testCassandra.start()
  25. testCassandra.executeScripts(cqlStatements)
  26. } finally testCassandra.stop()
  27. }
  28. }

可能还有另一个用法问题。虽然我正在创建TestCassandra。但我没有将cassandraFactory示例传递给它。所以我想知道embedded-cassandra是否已经启动!!
我尝试通过传递cassandraFactorycqlStatements来创建TestCassandra,但得到了错误too many arguments in TestCassandra

xcitsw88

xcitsw881#

无法从配置文件中设置版本
是否使用任何slf4j提供程序进行日志记录?
查看脚本是否已执行的最简单方法是为com.github.nosan.embedded.cassandra.test.util.CqlUtils启用 debug 级别。
如果您没有看到任何异常,则说明脚本执行没有问题。
我尝试通过传递cassandraFactory和cqlStatements来创建TestCassandra,但在TestCassandra中出现参数过多错误
我认为您应该使用此构造函数。

  1. public TestCassandra(CassandraFactory cassandraFactory, CqlScript... scripts) {}
  2. new TestCassandra(cassandraFactory, CqlScripts.statemets(...,...))

相关问题