[BAEL-14847] - Fix tests in spring-activi, spring-data-cassandra-reactive modules

persistence-modules/spring-data-cassandra-reactive/pom.xml

@@ -46,6 +46,13 @@
             <artifactId>reactor-test</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.cassandraunit</groupId>
+            <artifactId>cassandra-unit-spring</artifactId>
+            <version>${cassandra-unit-spring.version}</version>
+            <scope>test</scope>
+        </dependency>
+        
     </dependencies>
 
     <properties>
@@ -53,6 +60,7 @@
         <project.reporting.outputEncoding>UTF-8
         </project.reporting.outputEncoding>
         <spring-data-cassandra.version>2.1.2.RELEASE</spring-data-cassandra.version>
+        <cassandra-unit-spring.version>3.11.2.0</cassandra-unit-spring.version>
     </properties>
 
 </project>

persistence-modules/spring-data-cassandra-reactive/src/test/java/com/baeldung/cassandra/reactive/ReactiveEmployeeRepositoryIntegrationTest.java

@@ -1,13 +1,23 @@
 package com.baeldung.cassandra.reactive;
 
-import com.baeldung.cassandra.reactive.model.Employee;
-import com.baeldung.cassandra.reactive.repository.EmployeeRepository;
+import org.cassandraunit.spring.CassandraDataSet;
+import org.cassandraunit.spring.CassandraUnitDependencyInjectionTestExecutionListener;
+import org.cassandraunit.spring.CassandraUnitTestExecutionListener;
+import org.cassandraunit.spring.EmbeddedCassandra;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.TestExecutionListeners;
 import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.test.context.support.DependencyInjectionTestExecutionListener;
+import org.springframework.test.context.support.DirtiesContextTestExecutionListener;
+import org.springframework.test.context.web.ServletTestExecutionListener;
+
+import com.baeldung.cassandra.reactive.model.Employee;
+import com.baeldung.cassandra.reactive.repository.EmployeeRepository;
+
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
@@ -15,6 +25,15 @@ import reactor.test.StepVerifier;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest
+@TestExecutionListeners(listeners = {
+        CassandraUnitDependencyInjectionTestExecutionListener.class,
+        CassandraUnitTestExecutionListener.class,
+        ServletTestExecutionListener.class,
+        DependencyInjectionTestExecutionListener.class,
+        DirtiesContextTestExecutionListener.class
+})
+@EmbeddedCassandra(timeout = 60000, configuration = "cassandra-server.yaml")
+@CassandraDataSet(value = {"cassandra-init.cql"}, keyspace = "practice")
 public class ReactiveEmployeeRepositoryIntegrationTest {
 
 	@Autowired

persistence-modules/spring-data-cassandra-reactive/src/test/resources/cassandra-init.cql

@@ -0,0 +1,7 @@
+CREATE TABLE employee(
+    id int PRIMARY KEY,
+    name text,
+    address text,
+    email text,
+    age int
+);

spring-activiti/src/test/java/com/baeldung/SpringContextIntegrationTest.java

@@ -2,6 +2,7 @@ package com.baeldung;
 
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 
@@ -9,6 +10,7 @@ import com.baeldung.activitiwithspring.ActivitiWithSpringApplication;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = ActivitiWithSpringApplication.class)
+@AutoConfigureTestDatabase
 public class SpringContextIntegrationTest {
 
     @Test

spring-activiti/src/test/java/com/baeldung/activitiwithspring/ActivitiSpringSecurityIntegrationTest.java

@@ -4,6 +4,7 @@ import org.activiti.engine.IdentityService;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.security.core.userdetails.UsernameNotFoundException;
 import org.springframework.test.context.junit4.SpringRunner;
@@ -14,6 +15,7 @@ import com.baeldung.activiti.security.withspring.ActivitiSpringSecurityApplicati
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = ActivitiSpringSecurityApplication.class)
 @WebAppConfiguration
+@AutoConfigureTestDatabase
 public class ActivitiSpringSecurityIntegrationTest {
     @Autowired
     private IdentityService identityService;

spring-activiti/src/test/java/com/baeldung/activitiwithspring/ActivitiWithSpringApplicationIntegrationTest.java

@@ -2,11 +2,13 @@ package com.baeldung.activitiwithspring;
 
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 
 @RunWith(SpringRunner.class)
-@SpringBootTest
+@SpringBootTest(classes = ActivitiWithSpringApplication.class)
+@AutoConfigureTestDatabase
 public class ActivitiWithSpringApplicationIntegrationTest {
 
     @Test

spring-activiti/src/test/java/com/baeldung/activitiwithspring/ProcessEngineCreationIntegrationTest.java

@@ -4,7 +4,7 @@ import org.activiti.engine.ProcessEngine;
 import org.activiti.engine.ProcessEngineConfiguration;
 import org.activiti.engine.ProcessEngines;
 import org.junit.Test;
-
+import org.junit.After;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNotNull;
 
@@ -62,4 +62,9 @@ public class ProcessEngineCreationIntegrationTest {
         assertNotNull(processEngine);
         assertEquals("sa", processEngine.getProcessEngineConfiguration().getJdbcUsername());
     }
+    
+    @After
+    public void cleanup() {
+        ProcessEngines.destroy();
+    }
 }