JAVA-6511 - Removed Mongo DB Reactive and Mongo DB Tail cursor.
This commit is contained in:
@@ -1,17 +0,0 @@
|
||||
package com.baeldung;
|
||||
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
import com.baeldung.reactive.Spring5ReactiveApplication;
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(classes = Spring5ReactiveApplication.class)
|
||||
public class SpringContextTest {
|
||||
|
||||
@Test
|
||||
public void whenSpringContextIsBootstrapped_thenNoExceptions() {
|
||||
}
|
||||
}
|
||||
-70
@@ -1,70 +0,0 @@
|
||||
package com.baeldung.reactive.repository;
|
||||
|
||||
|
||||
import com.baeldung.reactive.Spring5ReactiveApplication;
|
||||
import com.baeldung.reactive.model.Account;
|
||||
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.junit4.SpringRunner;
|
||||
import reactor.core.publisher.Flux;
|
||||
import reactor.core.publisher.Mono;
|
||||
import reactor.test.StepVerifier;
|
||||
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertNotNull;
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = Spring5ReactiveApplication.class)
|
||||
public class AccountCrudRepositoryManualTest {
|
||||
|
||||
@Autowired
|
||||
AccountCrudRepository repository;
|
||||
|
||||
@Test
|
||||
public void givenValue_whenFindAllByValue_thenFindAccount() {
|
||||
repository.save(new Account(null, "Bill", 12.3)).block();
|
||||
Flux<Account> accountFlux = repository.findAllByValue(12.3);
|
||||
|
||||
StepVerifier.create(accountFlux)
|
||||
.assertNext(account -> {
|
||||
assertEquals("Bill", account.getOwner());
|
||||
assertEquals(Double.valueOf(12.3) , account.getValue());
|
||||
assertNotNull(account.getId());
|
||||
})
|
||||
.expectComplete()
|
||||
.verify();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void givenOwner_whenFindFirstByOwner_thenFindAccount() {
|
||||
repository.save(new Account(null, "Bill", 12.3)).block();
|
||||
Mono<Account> accountMono = repository.findFirstByOwner(Mono.just("Bill"));
|
||||
|
||||
StepVerifier.create(accountMono)
|
||||
.assertNext(account -> {
|
||||
assertEquals("Bill", account.getOwner());
|
||||
assertEquals(Double.valueOf(12.3) , account.getValue());
|
||||
assertNotNull(account.getId());
|
||||
})
|
||||
.expectComplete()
|
||||
.verify();
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
public void givenAccount_whenSave_thenSaveAccount() {
|
||||
Mono<Account> accountMono = repository.save(new Account(null, "Bill", 12.3));
|
||||
|
||||
StepVerifier
|
||||
.create(accountMono)
|
||||
.assertNext(account -> assertNotNull(account.getId()))
|
||||
.expectComplete()
|
||||
.verify();
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
-67
@@ -1,67 +0,0 @@
|
||||
package com.baeldung.reactive.repository;
|
||||
|
||||
import com.baeldung.reactive.Spring5ReactiveApplication;
|
||||
import com.baeldung.reactive.model.Account;
|
||||
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.domain.Example;
|
||||
import org.springframework.data.domain.ExampleMatcher;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import reactor.core.publisher.Flux;
|
||||
import reactor.core.publisher.Mono;
|
||||
import reactor.test.StepVerifier;
|
||||
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertNotNull;
|
||||
import static org.springframework.data.domain.ExampleMatcher.GenericPropertyMatchers.startsWith;
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = Spring5ReactiveApplication.class)
|
||||
public class AccountMongoRepositoryManualTest {
|
||||
|
||||
@Autowired
|
||||
AccountMongoRepository repository;
|
||||
|
||||
@Test
|
||||
public void givenExample_whenFindAllWithExample_thenFindAllMacthings() {
|
||||
repository.save(new Account(null, "john", 12.3)).block();
|
||||
ExampleMatcher matcher = ExampleMatcher.matching().withMatcher("owner", startsWith());
|
||||
Example<Account> example = Example.of(new Account(null, "jo", null), matcher);
|
||||
Flux<Account> accountFlux = repository.findAll(example);
|
||||
|
||||
StepVerifier
|
||||
.create(accountFlux)
|
||||
.assertNext(account -> assertEquals("john", account.getOwner()))
|
||||
.expectComplete()
|
||||
.verify();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void givenAccount_whenSave_thenSave() {
|
||||
Mono<Account> accountMono = repository.save(new Account(null, "john", 12.3));
|
||||
|
||||
StepVerifier
|
||||
.create(accountMono)
|
||||
.assertNext(account -> assertNotNull(account.getId()))
|
||||
.expectComplete()
|
||||
.verify();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void givenId_whenFindById_thenFindAccount() {
|
||||
Account inserted = repository.save(new Account(null, "john", 12.3)).block();
|
||||
Mono<Account> accountMono = repository.findById(inserted.getId());
|
||||
|
||||
StepVerifier
|
||||
.create(accountMono)
|
||||
.assertNext(account -> {
|
||||
assertEquals("john", account.getOwner());
|
||||
assertEquals(Double.valueOf(12.3), account.getValue());
|
||||
assertNotNull(account.getId());
|
||||
})
|
||||
.expectComplete()
|
||||
.verify();
|
||||
}
|
||||
}
|
||||
-58
@@ -1,58 +0,0 @@
|
||||
package com.baeldung.reactive.repository;
|
||||
|
||||
import com.baeldung.reactive.Spring5ReactiveApplication;
|
||||
import com.baeldung.reactive.model.Account;
|
||||
import io.reactivex.Observable;
|
||||
import io.reactivex.Single;
|
||||
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.junit4.SpringRunner;
|
||||
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertNotNull;
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = Spring5ReactiveApplication.class)
|
||||
public class AccountRxJavaRepositoryManualTest {
|
||||
|
||||
@Autowired
|
||||
AccountRxJavaRepository repository;
|
||||
|
||||
@Test
|
||||
public void givenValue_whenFindAllByValue_thenFindAccounts() throws InterruptedException {
|
||||
repository.save(new Account(null, "bruno", 12.3)).blockingGet();
|
||||
Observable<Account> accountObservable = repository.findAllByValue(12.3);
|
||||
|
||||
accountObservable
|
||||
.test()
|
||||
.await()
|
||||
.assertComplete()
|
||||
.assertValueAt(0, account -> {
|
||||
assertEquals("bruno", account.getOwner());
|
||||
assertEquals(Double.valueOf(12.3), account.getValue());
|
||||
return true;
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
public void givenOwner_whenFindFirstByOwner_thenFindAccount() throws InterruptedException {
|
||||
repository.save(new Account(null, "bruno", 12.3)).blockingGet();
|
||||
Single<Account> accountSingle = repository.findFirstByOwner(Single.just("bruno"));
|
||||
|
||||
accountSingle
|
||||
.test()
|
||||
.await()
|
||||
.assertComplete()
|
||||
.assertValueAt(0, account -> {
|
||||
assertEquals("bruno", account.getOwner());
|
||||
assertEquals(Double.valueOf(12.3), account.getValue());
|
||||
assertNotNull(account.getId());
|
||||
return true;
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
-48
@@ -1,48 +0,0 @@
|
||||
package com.baeldung.reactive.template;
|
||||
|
||||
import com.baeldung.reactive.Spring5ReactiveApplication;
|
||||
import com.baeldung.reactive.model.Account;
|
||||
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.junit4.SpringRunner;
|
||||
import reactor.core.publisher.Flux;
|
||||
import reactor.core.publisher.Mono;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.*;
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = Spring5ReactiveApplication.class)
|
||||
public class AccountTemplateOperationsManualTest {
|
||||
|
||||
@Autowired
|
||||
AccountTemplateOperations accountTemplate;
|
||||
|
||||
@Test
|
||||
public void givenAccount_whenSave_thenSave() {
|
||||
Account account = accountTemplate.save(Mono.just(new Account(null, "Raul", 12.3))).block();
|
||||
assertNotNull( account.getId() );
|
||||
}
|
||||
|
||||
@Test
|
||||
public void givenId_whenFindById_thenFindAccount() {
|
||||
Mono<Account> accountMono = accountTemplate.save(Mono.just(new Account(null, "Raul", 12.3)));
|
||||
Mono<Account> accountMonoResult = accountTemplate.findById(accountMono.block().getId());
|
||||
assertNotNull(accountMonoResult.block().getId());
|
||||
assertEquals(accountMonoResult.block().getOwner(), "Raul");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void whenFindAll_thenFindAllAccounts() {
|
||||
Account account1 = accountTemplate.save(Mono.just(new Account(null, "Raul", 12.3))).block();
|
||||
Account account2 = accountTemplate.save(Mono.just(new Account(null, "Raul Torres", 13.3))).block();
|
||||
Flux<Account> accountFlux = accountTemplate.findAll();
|
||||
List<Account> accounts = accountFlux.collectList().block();
|
||||
assertTrue(accounts.stream().anyMatch(x -> account1.getId().equals(x.getId()) ));
|
||||
assertTrue(accounts.stream().anyMatch(x -> account2.getId().equals(x.getId()) ));
|
||||
}
|
||||
|
||||
}
|
||||
-112
@@ -1,112 +0,0 @@
|
||||
package com.baeldung.tailablecursor.service;
|
||||
|
||||
import com.baeldung.tailablecursor.domain.Log;
|
||||
import com.baeldung.tailablecursor.domain.LogLevel;
|
||||
import com.mongodb.MongoClient;
|
||||
import com.mongodb.client.MongoCollection;
|
||||
import com.mongodb.client.MongoDatabase;
|
||||
import com.mongodb.client.model.CreateCollectionOptions;
|
||||
import de.flapdoodle.embed.mongo.MongodExecutable;
|
||||
import de.flapdoodle.embed.mongo.MongodProcess;
|
||||
import de.flapdoodle.embed.mongo.MongodStarter;
|
||||
import de.flapdoodle.embed.mongo.config.MongodConfigBuilder;
|
||||
import de.flapdoodle.embed.mongo.config.Net;
|
||||
import de.flapdoodle.embed.mongo.distribution.Version;
|
||||
import de.flapdoodle.embed.process.runtime.Network;
|
||||
import org.bson.Document;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Test;
|
||||
import org.springframework.data.mongodb.core.MongoTemplate;
|
||||
import org.springframework.util.SocketUtils;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.stream.IntStream;
|
||||
|
||||
import static org.hamcrest.Matchers.is;
|
||||
import static org.junit.Assert.assertThat;
|
||||
|
||||
public class ErrorLogsCounterManualTest {
|
||||
|
||||
private static final String SERVER = "localhost";
|
||||
private static final int PORT = SocketUtils.findAvailableTcpPort(10000);
|
||||
private static final String DB_NAME = "test";
|
||||
private static final String COLLECTION_NAME = Log.class.getName().toLowerCase();
|
||||
|
||||
private static final MongodStarter starter = MongodStarter.getDefaultInstance();
|
||||
private static final int MAX_DOCUMENTS_IN_COLLECTION = 3;
|
||||
|
||||
private ErrorLogsCounter errorLogsCounter;
|
||||
private MongodExecutable mongodExecutable;
|
||||
private MongodProcess mongoDaemon;
|
||||
private MongoDatabase db;
|
||||
|
||||
@Before
|
||||
public void setup() throws Exception {
|
||||
MongoTemplate mongoTemplate = initMongoTemplate();
|
||||
|
||||
MongoCollection<Document> collection = createCappedCollection();
|
||||
|
||||
persistDocument(collection, -1, LogLevel.ERROR, "my-service", "Initial log");
|
||||
|
||||
errorLogsCounter = new ErrorLogsCounter(mongoTemplate, COLLECTION_NAME);
|
||||
Thread.sleep(1000L); // wait for initialization
|
||||
}
|
||||
|
||||
private MongoTemplate initMongoTemplate() throws IOException {
|
||||
mongodExecutable = starter.prepare(new MongodConfigBuilder()
|
||||
.version(Version.Main.PRODUCTION)
|
||||
.net(new Net(SERVER, PORT, Network.localhostIsIPv6()))
|
||||
.build());
|
||||
mongoDaemon = mongodExecutable.start();
|
||||
|
||||
MongoClient mongoClient = new MongoClient(SERVER, PORT);
|
||||
db = mongoClient.getDatabase(DB_NAME);
|
||||
|
||||
return new MongoTemplate(mongoClient, DB_NAME);
|
||||
}
|
||||
|
||||
private MongoCollection<Document> createCappedCollection() {
|
||||
db.createCollection(COLLECTION_NAME, new CreateCollectionOptions()
|
||||
.capped(true)
|
||||
.sizeInBytes(100000)
|
||||
.maxDocuments(MAX_DOCUMENTS_IN_COLLECTION));
|
||||
return db.getCollection(COLLECTION_NAME);
|
||||
}
|
||||
|
||||
private void persistDocument(MongoCollection<Document> collection,
|
||||
int i, LogLevel level, String service, String message) {
|
||||
Document logMessage = new Document();
|
||||
logMessage.append("_id", i);
|
||||
logMessage.append("level", level.toString());
|
||||
logMessage.append("service", service);
|
||||
logMessage.append("message", message);
|
||||
collection.insertOne(logMessage);
|
||||
}
|
||||
|
||||
@After
|
||||
public void tearDown() {
|
||||
errorLogsCounter.close();
|
||||
mongoDaemon.stop();
|
||||
mongodExecutable.stop();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void whenErrorLogsArePersisted_thenTheyAreReceivedByLogsCounter() throws Exception {
|
||||
MongoCollection<Document> collection = db.getCollection(COLLECTION_NAME);
|
||||
|
||||
IntStream.range(1, 10)
|
||||
.forEach(i -> persistDocument(collection,
|
||||
i,
|
||||
i > 5 ? LogLevel.ERROR : LogLevel.INFO,
|
||||
"service" + i,
|
||||
"Message from service " + i)
|
||||
);
|
||||
|
||||
Thread.sleep(1000L); // wait to receive all messages from the reactive mongodb driver
|
||||
|
||||
assertThat(collection.countDocuments(), is((long) MAX_DOCUMENTS_IN_COLLECTION));
|
||||
assertThat(errorLogsCounter.count(), is(5));
|
||||
}
|
||||
|
||||
}
|
||||
-75
@@ -1,75 +0,0 @@
|
||||
package com.baeldung.tailablecursor.service;
|
||||
|
||||
import com.baeldung.tailablecursor.LogsCounterApplication;
|
||||
import com.baeldung.tailablecursor.domain.Log;
|
||||
import com.baeldung.tailablecursor.domain.LogLevel;
|
||||
import com.baeldung.tailablecursor.repository.LogsRepository;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
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.data.mongodb.core.CollectionOptions;
|
||||
import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import reactor.core.publisher.Flux;
|
||||
|
||||
import static org.hamcrest.Matchers.is;
|
||||
import static org.junit.Assert.assertThat;
|
||||
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(classes = LogsCounterApplication.class)
|
||||
@Slf4j
|
||||
public class InfoLogsCounterManualTest {
|
||||
@Autowired
|
||||
private LogsRepository repository;
|
||||
|
||||
@Autowired
|
||||
private ReactiveMongoTemplate template;
|
||||
|
||||
@Before
|
||||
public void setUp() {
|
||||
createCappedCollectionUsingReactiveMongoTemplate(template);
|
||||
|
||||
persistDocument(Log.builder()
|
||||
.level(LogLevel.INFO)
|
||||
.service("Service 2")
|
||||
.message("Initial INFO message")
|
||||
.build());
|
||||
}
|
||||
|
||||
private void createCappedCollectionUsingReactiveMongoTemplate(ReactiveMongoTemplate reactiveMongoTemplate) {
|
||||
reactiveMongoTemplate.dropCollection(Log.class).block();
|
||||
reactiveMongoTemplate.createCollection(Log.class, CollectionOptions.empty()
|
||||
.maxDocuments(5)
|
||||
.size(1024 * 1024L)
|
||||
.capped()).block();
|
||||
}
|
||||
|
||||
private void persistDocument(Log log) {
|
||||
repository.save(log).block();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void wheInfoLogsArePersisted_thenTheyAreReceivedByLogsCounter() throws Exception {
|
||||
InfoLogsCounter infoLogsCounter = new InfoLogsCounter(repository);
|
||||
|
||||
Thread.sleep(1000L); // wait for initialization
|
||||
|
||||
Flux.range(0,10)
|
||||
.map(i -> Log.builder()
|
||||
.level(i > 5 ? LogLevel.WARN : LogLevel.INFO)
|
||||
.service("some-service")
|
||||
.message("some log message")
|
||||
.build())
|
||||
.map(entity -> repository.save(entity).subscribe())
|
||||
.blockLast();
|
||||
|
||||
Thread.sleep(1000L); // wait to receive all messages from the reactive mongodb driver
|
||||
|
||||
assertThat(infoLogsCounter.count(), is(7));
|
||||
infoLogsCounter.close();
|
||||
}
|
||||
}
|
||||
-75
@@ -1,75 +0,0 @@
|
||||
package com.baeldung.tailablecursor.service;
|
||||
|
||||
import com.baeldung.tailablecursor.LogsCounterApplication;
|
||||
import com.baeldung.tailablecursor.domain.Log;
|
||||
import com.baeldung.tailablecursor.domain.LogLevel;
|
||||
import com.baeldung.tailablecursor.repository.LogsRepository;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
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.data.mongodb.core.CollectionOptions;
|
||||
import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import reactor.core.publisher.Flux;
|
||||
|
||||
import static org.hamcrest.Matchers.is;
|
||||
import static org.junit.Assert.assertThat;
|
||||
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(classes = LogsCounterApplication.class)
|
||||
@Slf4j
|
||||
public class WarnLogsCounterManualTest {
|
||||
@Autowired
|
||||
private LogsRepository repository;
|
||||
|
||||
@Autowired
|
||||
private ReactiveMongoTemplate template;
|
||||
|
||||
@Before
|
||||
public void setUp() {
|
||||
createCappedCollectionUsingReactiveMongoTemplate(template);
|
||||
|
||||
persistDocument(Log.builder()
|
||||
.level(LogLevel.WARN)
|
||||
.service("Service 1")
|
||||
.message("Initial Warn message")
|
||||
.build());
|
||||
}
|
||||
|
||||
private void createCappedCollectionUsingReactiveMongoTemplate(ReactiveMongoTemplate reactiveMongoTemplate) {
|
||||
reactiveMongoTemplate.dropCollection(Log.class).block();
|
||||
reactiveMongoTemplate.createCollection(Log.class, CollectionOptions.empty()
|
||||
.maxDocuments(5)
|
||||
.size(1024 * 1024L)
|
||||
.capped()).block();
|
||||
}
|
||||
|
||||
private void persistDocument(Log log) {
|
||||
repository.save(log).block();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void whenWarnLogsArePersisted_thenTheyAreReceivedByLogsCounter() throws Exception {
|
||||
WarnLogsCounter warnLogsCounter = new WarnLogsCounter(template);
|
||||
|
||||
Thread.sleep(1000L); // wait for initialization
|
||||
|
||||
Flux.range(0,10)
|
||||
.map(i -> Log.builder()
|
||||
.level(i > 5 ? LogLevel.WARN : LogLevel.INFO)
|
||||
.service("some-service")
|
||||
.message("some log message")
|
||||
.build())
|
||||
.map(entity -> repository.save(entity).subscribe())
|
||||
.blockLast();
|
||||
|
||||
Thread.sleep(1000L); // wait to receive all messages from the reactive mongodb driver
|
||||
|
||||
assertThat(warnLogsCounter.count(), is(5));
|
||||
warnLogsCounter.close();
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user