在Spring Boot中使用嵌入式Cassandra进行单元测试

Question

我正在尝试测试一个Spring Boot应用程序，其中包括保存到cassandra DB中。对于单元测试，我使用了EmbeddedCassandra。

这些是依赖项。

compile group: "com.datastax.cassandra", name: "cassandra-driver-core", version:"2.1.7"
    compile group: "com.datastax.cassandra", name: "cassandra-driver-dse", version:"2.1.7"
    testCompile('org.springframework.boot:spring-boot-starter-test')
    testCompile  ("org.cassandraunit:cassandra-unit-spring:2.1.9.2"){
        exclude group:"org.cassandraunit",module:"cassandra-unit"
    }

这些是我用过的注解

@RunWith(SpringRunner.class)
@WebMvcTest(value = MyController.class)
@Import(value = {MyDao.class})
@ContextConfiguration
@TestExecutionListeners(listeners = {
        CassandraUnitDependencyInjectionTestExecutionListener.class,
        CassandraUnitTestExecutionListener.class,
        ServletTestExecutionListener.class,
        DependencyInjectionTestExecutionListener.class,
        DirtiesContextTestExecutionListener.class}
)
@EmbeddedCassandra(timeout = 60000)
@CassandraDataSet(keyspace = "test", value = {"test.cql"})

但是在单元测试中保存的值是填充原始cassandra数据库的。有人能帮我解决这个问题吗？

Answer 1

Cassandra单元使用: native_transport_port: 9142，但是spring boot需要9042端口，所以您应该在配置中更改端口或使用cassandra.yaml文件。作为另一种选择，你可以看看这个：

https://github.com/nosan/embedded-cassandra/blob/master/README.adoc#spring-boot

它还提供@Cql注释，以便在每次测试之前或/和之后执行cql脚本。

希望，这会对你有用。