FMWK-695 Add demo applications and tests (#146)

Author: agrgr

asciidoc/getting-started.adoc

@@ -78,7 +78,7 @@ Movie document class will look the following way:
 [source,java]
 ----
 @Value // <1>
-@Document(collection = "demo-service-movies") // <2>
+@Document(collection = "demo-simplecrud-set") // <2>
 @Builder(toBuilder = true) // <3>
 // Spring Data object creation can use all-args constructor instead of reflection which is much faster
 @AllArgsConstructor // <4>
@@ -107,7 +107,10 @@ Document explained:
 <1> https://projectlombok.org/features/Value[`@Value`] makes class immutable, all fields are made private and final,
 `toString()`, `equals()`, `hashCode()`, field getters and all args constructor are generated.
 
-<2> `@Document(collection = "demo-service-movies")` marks a class as an entity to be persisted to Aerospike. It also allows to specify set name, expiration and touch on read values. In current example custom set name is specified via `collection`. Please note that a set name cannot contain the ':' or ';' characters. (See more https://www.aerospike.com/docs/guide/limitations.html[limitations])
+<2> `@Document(collection = "demo-simplecrud-set")` marks a class as an entity to be persisted to Aerospike.
+It also allows to specify set name, expiration and touch on read values. In current example custom set name is specified
+via `collection`. Please note that a set name cannot contain the ':' or ';' characters
+(see more https://www.aerospike.com/docs/guide/limitations.html[limitations]).
 
 <3> `@Builder` provide Builder API for a class.
 
@@ -222,8 +225,15 @@ public class MovieRepositoryTests extends SimpleCrudAerospikeDemoApplicationTest
     }
 
     @Test
-    void deleteById_doesNothingForNonExistingMovie() {
+    void deleteById_skipsNonExistingMovie() {
         repository.deleteById(id);
+        repository.deleteById(id);
+        assertThat(repository.findById(id)).isNotPresent();
+
+        repository.save(movie);
+        repository.deleteById("testId");
+        assertThat(repository.findById(id)).isPresent();
+        assertThat(repository.findById(id).get()).isEqualTo(movie);
     }
 }
 ----

asciidoc/optimistic-locking.adoc

@@ -123,7 +123,7 @@ public class WatchedMoviesService {
     private WatchedMoviesDocument updateExistingDocument(WatchedMoviesDocument existingDocument, String newWatchedMovie) {
         // NOTE: we do not create new document here, but only update existing while retaining the version
         return existingDocument.toBuilder()
-                .watchedMovie(newWatchedMovie)
+                .watchedMovie(newWatchedMovie) // add to the List
                 .build();
     }
 
@@ -185,7 +185,7 @@ public class WatchedMoviesConcurrentTest extends OptimisticLockingAerospikeDemoA
 
     @Test
     void addWatchedMovie_addsMoviesConcurrently() throws Exception {
-        String id = "age::" + UUID.randomUUID();
+        String id = "watched::" + UUID.randomUUID();
         runTasksAndWaitForCompletion(() -> watchedMoviesService.addWatchedMovie(id, "Movie " + UUID.randomUUID()));
 
         List<String> watchedMovies = watchedMoviesService.getWatchedMovies(id);

examples-reactive/pom.xml

@@ -17,4 +17,19 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>com.aerospike</groupId>
+            <artifactId>spring-data-aerospike</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.aerospike</groupId>
+            <artifactId>aerospike-reactor-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
 </project>

examples-reactive/src/main/java/com/demo/reactive/batchread/README.adoc

@@ -0,0 +1,16 @@
+[[demo-simple-crud]]
+= Reactive Batch Read Operations Demo
+
+This directory contains a sample project for demonstration of using basic batch read operations with Spring Data Aerospike reactively.
+
+== Prerequisites
+
+- JDK 17
+- Docker installed and running (optional)
+
+== Tests
+
+:base_path_reactive: ../../../../../../../..
+:tests_path_reactive: examples-reactive/src/test/java/com/demo/reactive
+
+To see tests go to link:{base_path_reactive}/{tests_path_reactive}/batchread[reactive batch read tests].

examples-reactive/src/main/java/com/demo/reactive/batchread/ReactiveBatchReadAerospikeDemoApplication.java

@@ -0,0 +1,12 @@
+package com.demo.reactive.batchread;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ReactiveBatchReadAerospikeDemoApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(ReactiveBatchReadAerospikeDemoApplication.class, args);
+	}
+}

examples-reactive/src/main/java/com/demo/reactive/batchread/configuration/AerospikeConfiguration.java

@@ -0,0 +1,17 @@
+package com.demo.reactive.batchread.configuration;
+
+import com.demo.reactive.batchread.repository.ReactiveMovieRepositoryForBatchRead;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.aerospike.config.AbstractReactiveAerospikeDataConfiguration;
+import org.springframework.data.aerospike.config.AerospikeDataSettings;
+import org.springframework.data.aerospike.repository.config.EnableReactiveAerospikeRepositories;
+
+@Configuration
+@EnableReactiveAerospikeRepositories(basePackageClasses = ReactiveMovieRepositoryForBatchRead.class)
+public class AerospikeConfiguration extends AbstractReactiveAerospikeDataConfiguration {
+
+    @Override
+    protected void configureDataSettings(AerospikeDataSettings dataSettings) {
+        dataSettings.setScansEnabled(true); // allow scan operations required for finding by entities (findAll)
+    }
+}

examples-reactive/src/main/java/com/demo/reactive/batchread/entity/MovieDocumentForBatchRead.java

@@ -0,0 +1,35 @@
+package com.demo.reactive.batchread.entity;
+
+import com.aerospike.client.query.IndexCollectionType;
+import com.aerospike.client.query.IndexType;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Value;
+import org.springframework.data.aerospike.annotation.Indexed;
+import org.springframework.data.aerospike.mapping.Document;
+import org.springframework.data.aerospike.mapping.Field;
+import org.springframework.data.annotation.Id;
+
+@Value
+@Document(collection = "demo-batchRead-reactive-set")
+@Builder(toBuilder = true)
+// Spring Data object creation can use all-args constructor instead of reflection which is much faster
+@AllArgsConstructor
+public class MovieDocumentForBatchRead {
+
+    @Id
+    String id;
+
+    @Field
+    String name;
+
+    @Field("desc")
+    String description;
+
+    @Indexed(type = IndexType.NUMERIC, collectionType = IndexCollectionType.DEFAULT)
+    @Field
+    int likes;
+
+    @Field
+    double rating;
+}

examples-reactive/src/main/java/com/demo/reactive/batchread/repository/ReactiveMovieRepositoryForBatchRead.java

@@ -0,0 +1,8 @@
+package com.demo.reactive.batchread.repository;
+
+import com.demo.reactive.batchread.entity.MovieDocumentForBatchRead;
+import org.springframework.data.aerospike.repository.ReactiveAerospikeRepository;
+
+public interface ReactiveMovieRepositoryForBatchRead extends ReactiveAerospikeRepository<MovieDocumentForBatchRead, String> {
+
+}

examples-reactive/src/main/java/com/demo/reactive/batchwrite/README.adoc

@@ -0,0 +1,16 @@
+[[demo-simple-crud]]
+= Reactive Batch Write Operations Demo
+
+This directory contains a sample project for demonstration of using basic batch write operations with Spring Data Aerospike reactively.
+
+== Prerequisites
+
+- JDK 17
+- Docker installed and running (optional)
+
+== Tests
+
+:base_path_reactive: ../../../../../../../..
+:tests_path_reactive: examples-reactive/src/test/java/com/demo/reactive
+
+To see tests go to link:{base_path_reactive}/{tests_path_reactive}/batchwrite[reactive batch write tests].

examples-reactive/src/main/java/com/demo/reactive/batchwrite/ReactiveBatchWriteAerospikeDemoApplication.java

@@ -0,0 +1,12 @@
+package com.demo.reactive.batchwrite;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ReactiveBatchWriteAerospikeDemoApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(ReactiveBatchWriteAerospikeDemoApplication.class, args);
+	}
+}