FIX Mongo Reactive

Author: liuzidong

Chapter10/README.md

@@ -0,0 +1 @@
+#### Mongo Reactive

Chapter10/pom.xml

@@ -9,7 +9,7 @@
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>2.0.5.RELEASE</version>
+		<version>2.1.4.RELEASE</version>
 	</parent>
 
 	<properties>

Chapter10/src/main/java/net/liuzd/spring/boot/v2/domain/Person.java

@@ -3,16 +3,20 @@
 import org.springframework.data.annotation.Id;
 import org.springframework.data.mongodb.core.mapping.Document;
 
+import lombok.AllArgsConstructor;
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
 @Data
-@Document
+@AllArgsConstructor
+@NoArgsConstructor
+@Document(collection = "person")
 public class Person {
 
-    private @Id String   id;
-    private final String firstname;
-    private final String lastname;
-    private final int    age;
+    private @Id String id;
+    private String     firstname;
+    private String     lastname;
+    private int        age;
 
     public Person(String firstname, String lastname, int age) {
         super();

Chapter10/src/main/java/net/liuzd/spring/boot/v2/repository/ReactivePersonRepository.java

@@ -12,7 +12,8 @@
  *
  * @author Mark Paluch
  */
-public interface ReactivePersonRepository extends ReactiveCrudRepository<Person, String> {
+public interface ReactivePersonRepository extends ReactiveCrudRepository<Person, String>  {
+    
 
 	/**
 	 * Derived query selecting by {@code lastname}.

Chapter10/src/main/java/net/liuzd/spring/boot/v2/repository/RxJava2PersonRepository.java

@@ -8,12 +8,7 @@
 import io.reactivex.Single;
 import net.liuzd.spring.boot.v2.domain.Person;
 
-/**
- * Repository interface to manage {@link Person} instances.
- *
- * @author Mark Paluch
- * @author Christoph Strobl
- */
+
 public interface RxJava2PersonRepository extends RxJava2CrudRepository<Person, String> {
 
 	/**

Chapter10/src/main/java/net/liuzd/spring/boot/v2/repository/UserRepository.java

@@ -3,13 +3,13 @@
 
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
+import org.springframework.data.mongodb.repository.MongoRepository;
 import org.springframework.data.mongodb.repository.Query;
-import org.springframework.data.repository.CrudRepository;
 
 import net.liuzd.spring.boot.v2.domain.User;
 
 //Repository
-public interface UserRepository extends CrudRepository<User, Long> {
+public interface UserRepository extends MongoRepository<User, Long> {
 
     /**
      * Like（模糊查询）

Chapter10/src/main/resources/application.properties

@@ -2,7 +2,7 @@ spring.application.name=spring-boot-mongodb
 #
 spring.data.mongodb.host=127.0.0.1
 spring.data.mongodb.port=27017
-#spring.data.mongodb.authentication-database=admin
+spring.data.mongodb.authentication-database=admin
 spring.data.mongodb.database=admin
 #
 spring.data.mongodb.username=admin

Chapter10/src/test/java/net/liuzd/spring/boot/v2/ReactivePersonRepositoryTest.java

@@ -1,5 +1,9 @@
 package net.liuzd.spring.boot.v2;
 
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.slf4j.Logger;
@@ -22,14 +26,24 @@ public class ReactivePersonRepositoryTest {
     @Autowired
     private ReactivePersonRepository reactivePersonRepository;
 
+    @Before
+    public void before() {
+        reactivePersonRepository.deleteAll();
+    }
+
     @Test
     public void testAdd() throws Exception {
         // ReactiveMongoTemplate t = null;
         // 创建多个User，并验证User总数
         int size = 20;
-        for (int i = 0; i < size; i++) {
-            reactivePersonRepository.save(new Person("liu" + i, "felix" + i, 22 + i));
+        List<Person> pps = new ArrayList<>();
+        for (int i = 1; i <= size; i++) {
+            Person p = new Person("liu" + i, "felix" + i, 22 + i);
+            pps.add(p);
         }
+        Flux<Person> f = reactivePersonRepository.saveAll(pps);
+        this.logger.info(f.blockFirst().toString());
+        // 必须加上：Flux<Person> f = 才会插入到Mongo
     }
 
     @Test

Chapter10/src/test/java/net/liuzd/spring/boot/v2/RxJava2PersonRepositoryTest.java

@@ -1,5 +1,8 @@
 package net.liuzd.spring.boot.v2;
 
+import java.util.ArrayList;
+import java.util.List;
+
 import javax.annotation.Resource;
 
 import org.junit.Test;
@@ -28,9 +31,14 @@ public class RxJava2PersonRepositoryTest {
     public void testAdd() throws Exception {
         // 创建多个User，并验证User总数
         int size = 20;
-        for (int i = 0; i < size; i++) {
-            rxJava2PersonRepository.save(new Person("liu" + i, "felix" + i, 22 + i));
+        List<Person> pps = new ArrayList<>();
+        for (int i = 1; i <= size; i++) {
+            Person p = new Person("liu" + i, "felix" + i, 22 + i);
+            pps.add(p);
         }
+        //
+        Flowable<Person> f = rxJava2PersonRepository.saveAll(pps);
+        this.logger.info(f.blockingFirst().toString());
     }
 
     @Test

Chapter10/src/test/java/net/liuzd/spring/boot/v2/UserRepositoryTest.java

@@ -2,6 +2,7 @@
 
 import java.util.List;
 
+import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.slf4j.Logger;
@@ -20,18 +21,22 @@
 @SpringBootTest
 public class UserRepositoryTest {
 
-    private final Logger logger = LoggerFactory.getLogger(getClass());
+    private final Logger   logger = LoggerFactory.getLogger(getClass());
 
     @Autowired
     private UserRepository userRepository;
 
+    @Before
+    public void before() {
+       // userRepository.deleteAll();
+    }
 
     @Test
     public void testAdd() throws Exception {
         // 创建多个User，并验证User总数
         userRepository.save(new User(1L, "felix", 22));
         userRepository.save(new User(2L, "tim", 23));
-        userRepository.save(new User(3L, "cc", 23));    
+        userRepository.save(new User(3L, "cc", 23));
         userRepository.save(new User(4L, "pyh", 22));
         userRepository.save(new User(5L, "simba", 28));
         userRepository.save(new User(6L, "felix2", 10));
@@ -46,16 +51,8 @@ public void testAdd() throws Exception {
         userRepository.save(new User(15L, "felix10", 100));
         userRepository.save(new User(16L, "", 50));
         userRepository.save(new User(17L, null, 50));
-    }
-    
-    @Test
-    public void testDel() throws Exception {
-        // 删除一个User，再验证User总数
-        User u = userRepository.findById(1L).orElse(null);
-        this.logger.info(u.toString());
-        userRepository.delete(u);
-    }
-    
+    }   
+
     @Test
     public void testFindMore() throws Exception {
 
@@ -77,9 +74,9 @@ public void testFindMore() throws Exception {
         this.logger.info(u8.toString());
 
     }
-    
+
     @Test
-    public void test3() throws Exception {
+    public void testPage() throws Exception {
 
         Pageable pageable = PageRequest.of(0, 10);
         Page<User> u1 = userRepository.findByNameAndAgeRange("felix", 50, pageable);
@@ -92,6 +89,13 @@ public void test3() throws Exception {
         this.logger.info(u3.toString());
         u3.getContent().stream().forEach(n -> System.out.println(n.toString()));
     }
-
+    
+    @Test
+    public void testDel() throws Exception {
+        // 删除一个User，再验证User总数
+        User u = userRepository.findById(1L).orElse(null);
+        this.logger.info(u.toString());
+        userRepository.delete(u);
+    }
 
 }