spring-projects#224 - Use external or embedded (if external Apache Cassandra is not available) for Cassandra examples.

We now check whether an external Apache Cassandra instance is available at localhost:9042 and use it to run the examples. Otherwise, if no external Apache Cassandra instance is available, we start an embedded Cassandra instance.

Author: mp911de

.travis.yml

@@ -10,7 +10,6 @@ addons:
 
 services:
   - redis-server
-  - cassandra
 
 cache:
   directories:

cassandra/example/Readme.MD

@@ -19,21 +19,20 @@
 import static org.junit.Assert.*;
 import static org.junit.Assume.*;
 
+import example.springdata.cassandra.util.CassandraKeyspace;
+import example.springdata.cassandra.util.CassandraVersion;
+
 import org.junit.Before;
 import org.junit.ClassRule;
 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.data.util.Version;
 import org.springframework.test.context.junit4.SpringRunner;
 
 import com.datastax.driver.core.Session;
 
-import example.springdata.cassandra.util.CassandraVersion;
-import example.springdata.cassandra.util.RequiresCassandraKeyspace;
-
 /**
  * Integration test showing the basic usage of {@link BasicUserRepository}.
  * 
@@ -48,7 +47,7 @@ public class BasicUserRepositoryTests {
 
 	public final static Version CASSANDRA_3_4 = Version.parse("3.4");
 
-	@ClassRule public final static RequiresCassandraKeyspace CASSANDRA_KEYSPACE = RequiresCassandraKeyspace.onLocalhost();
+	@ClassRule public final static CassandraKeyspace CASSANDRA_KEYSPACE = CassandraKeyspace.onLocalhost();
 
 	@Autowired BasicUserRepository repository;
 	@Autowired Session session;

cassandra/example/src/test/java/example/springdata/cassandra/basic/BasicUserRepositoryTests.java

@@ -18,6 +18,8 @@
 import static org.hamcrest.Matchers.*;
 import static org.junit.Assert.*;
 
+import example.springdata.cassandra.util.CassandraKeyspace;
+
 import java.util.Collection;
 import java.util.List;
 import java.util.Map;
@@ -28,7 +30,6 @@
 import org.junit.ClassRule;
 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.data.cassandra.core.CassandraOperations;
@@ -40,18 +41,16 @@
 import com.datastax.driver.core.querybuilder.Insert;
 import com.datastax.driver.core.querybuilder.QueryBuilder;
 
-import example.springdata.cassandra.util.RequiresCassandraKeyspace;
-
 /**
  * Integration test showing the basic usage of {@link CassandraTemplate}.
  * 
  * @author Mark Paluch
  */
 @RunWith(SpringRunner.class)
-@SpringBootTest(classes = BasicConfiguration.CassandraConfig.class)
+@SpringBootTest(classes = BasicConfiguration.class)
 public class CassandraOperationsIntegrationTests {
 
-	@ClassRule public final static RequiresCassandraKeyspace CASSANDRA_KEYSPACE = RequiresCassandraKeyspace.onLocalhost();
+	@ClassRule public final static CassandraKeyspace CASSANDRA_KEYSPACE = CassandraKeyspace.onLocalhost();
 
 	@Autowired CassandraOperations template;
 

cassandra/example/src/test/java/example/springdata/cassandra/basic/CassandraOperationsIntegrationTests.java

@@ -18,13 +18,14 @@
 import static org.hamcrest.MatcherAssert.*;
 import static org.hamcrest.Matchers.*;
 
+import example.springdata.cassandra.util.CassandraKeyspace;
+
 import java.util.Arrays;
 
 import org.junit.Before;
 import org.junit.ClassRule;
 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.data.cassandra.core.CassandraOperations;
@@ -33,16 +34,14 @@
 import com.datastax.driver.core.Row;
 import com.datastax.driver.core.querybuilder.QueryBuilder;
 
-import example.springdata.cassandra.util.RequiresCassandraKeyspace;
-
 /**
  * @author Mark Paluch
  */
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = ConverterConfiguration.class)
 public class ConversionIntegrationTests {
 
-	@ClassRule public final static RequiresCassandraKeyspace CASSANDRA_KEYSPACE = RequiresCassandraKeyspace.onLocalhost();
+	@ClassRule public final static CassandraKeyspace CASSANDRA_KEYSPACE = CassandraKeyspace.onLocalhost();
 
 	@Autowired CassandraOperations operations;
 

cassandra/example/src/test/java/example/springdata/cassandra/convert/ConversionIntegrationTests.java

@@ -18,20 +18,19 @@
 import static org.hamcrest.Matchers.*;
 import static org.junit.Assert.*;
 
+import example.springdata.cassandra.util.CassandraKeyspace;
+
 import java.util.Collection;
 
 import org.junit.Before;
 import org.junit.ClassRule;
 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.data.projection.TargetAware;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
-import example.springdata.cassandra.util.RequiresCassandraKeyspace;
-
 /**
  * Integration tests for {@link CustomerRepository} to show projection capabilities.
  * 
@@ -41,7 +40,7 @@
 @SpringBootTest(classes = ProjectionConfiguration.class)
 public class CustomerRepositoryIntegrationTest {
 
-	@ClassRule public final static RequiresCassandraKeyspace CASSANDRA_KEYSPACE = RequiresCassandraKeyspace.onLocalhost();
+	@ClassRule public final static CassandraKeyspace CASSANDRA_KEYSPACE = CassandraKeyspace.onLocalhost();
 
 	@Autowired CustomerRepository customers;
 

cassandra/example/src/test/java/example/springdata/cassandra/projection/CustomerRepositoryIntegrationTest.java

@@ -19,18 +19,3 @@ public interface PersonRepository extends CrudRepository<Person, String> {
 ```
 
 The test cases in `PersonRepositoryIntegrationTest` oppose a plain `List` based query method with one that uses a `Stream` and shows how the former pulls all data into memory first and the iteration is done over the pre-populated list. The execution of the `Stream`-based method in contrast shows that the individual elements are read and converted while iterating the stream.
-
-## Preparation
-
-### Install Cassandra
-Before we can start we have to install Cassandra, e.g. via brew on Max OS.
-
-More details can be found here: https://wiki.apache.org/cassandra/GettingStarted
-
-### Start Cassandra
-```
-/usr/local/bin/cassandra -f 
-```
-
-That should be enough to get you started.
-Now you can simply type ```mvn clean install``` to run the example.

cassandra/java8/README.md

@@ -15,10 +15,11 @@
  */
 package example.springdata.cassandra.java8;
 
-import example.springdata.cassandra.util.RequiresCassandraKeyspace;
 import static org.hamcrest.Matchers.*;
 import static org.junit.Assert.*;
 
+import example.springdata.cassandra.util.CassandraKeyspace;
+
 import java.util.Optional;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
@@ -41,8 +42,8 @@
 @SpringBootTest(classes = CassandraConfiguration.class)
 public class Java8IntegrationTests {
 
-	@ClassRule
-	public final static RequiresCassandraKeyspace CASSANDRA_KEYSPACE = RequiresCassandraKeyspace.onLocalhost().atLeast(Version.parse("3.0"));
+	@ClassRule public final static CassandraKeyspace CASSANDRA_KEYSPACE = CassandraKeyspace.onLocalhost()
+			.atLeast(Version.parse("3.0"));
 
 	@Autowired PersonRepository repository;
 

cassandra/java8/src/test/java/example/springdata/cassandra/java8/Java8IntegrationTests.java

@@ -18,6 +18,8 @@
 import static org.hamcrest.Matchers.*;
 import static org.junit.Assert.*;
 
+import example.springdata.cassandra.util.CassandraKeyspace;
+
 import java.time.LocalDate;
 import java.time.ZoneId;
 
@@ -30,8 +32,6 @@
 import org.springframework.data.util.Version;
 import org.springframework.test.context.junit4.SpringRunner;
 
-import example.springdata.cassandra.util.RequiresCassandraKeyspace;
-
 /**
  * Integration test to show the usage of JSR-310 date/time types with Spring Data Cassandra.
  * 
@@ -41,7 +41,7 @@
 @SpringBootTest(classes = CassandraConfiguration.class)
 public class Jsr310IntegrationTests {
 
-	@ClassRule public final static RequiresCassandraKeyspace CASSANDRA_KEYSPACE = RequiresCassandraKeyspace.onLocalhost()
+	@ClassRule public final static CassandraKeyspace CASSANDRA_KEYSPACE = CassandraKeyspace.onLocalhost()
 			.atLeast(Version.parse("3.0"));
 
 	@Autowired OrderRepository repository;

cassandra/java8/src/test/java/example/springdata/cassandra/java8/Jsr310IntegrationTests.java

@@ -37,9 +37,6 @@ public interface ReactivePersonRepository extends ReactiveCrudRepository<Person,
 	Flux<Person> findByLastname(Mono<String> lastname);
 
 	Mono<Person> findByFirstnameAndLastname(Mono<String> firstname, String lastname);
-
-	@InfiniteStream // Use a tailable cursor
-	Flux<Person> findWithTailableCursorBy();
 }
 ```
 
@@ -55,25 +52,5 @@ public interface RxJava1PersonRepository extends RxJava1CrudRepository<Person, S
 	Observable<Person> findByLastname(Single<String> lastname);
 
 	Single<Person> findByFirstnameAndLastname(Single<String> firstname, String lastname);
-
-	@InfiniteStream // Use a tailable cursor
-	Observable<Person> findWithTailableCursorBy();
 }
 ```
-
-## Preparation
-
-### Install Cassandra
-
-Before we can start we have to install Cassandra, e.g. via brew on Max OS.
-
-More details can be found here: https://wiki.apache.org/cassandra/GettingStarted
-
-### Start Cassandra
-
-```
-/usr/local/bin/cassandra -f
-```
-
-That should be enough to get you started.
-Now you can simply type ```mvn clean install``` to run the example.