Docs Menu
Docs Home
/
언어
/
Java
/
Java Reactive Streams 드라이버

MongoDB 에서 데이터 읽기

이 페이지의 내용

  • 개요
  • 프로젝트 리액터 구현
  • 샘플 애플리케이션
  • find one
  • 여러 항목 찾기
  • 컬렉션의 문서 수 계산
  • 쿼리에서 반환된 문서 수 계산
  • 예상 문서 수
  • Retrieve Distinct Values
  • 데이터 변경 사항 모니터링

개요

이 페이지에는 MongoDB 에서 데이터를 읽는 데 사용할 수 있는 Java Reactive Streams 운전자 메서드의 복사 가능한 코드 예제가 포함되어 있습니다.

팁

이 페이지에 표시된 메서드에 대해 자세히 알아보려면 각 섹션에 제공된 링크를 참조하세요.

이 페이지의 예제를 사용하려면 코드 예제를 샘플 애플리케이션 또는 자체 애플리케이션에 복사합니다. 코드 예제의 모든 자리 표시자(예: <connection string>)를 MongoDB 배포에 필요한 관련 값으로 바꿔야 합니다.

프로젝트 리액터 구현

이 가이드 에서는 Project Reactor 라이브러리를 Publisher 사용하여 Java Reactive Streams 운전자 메서드에서 반환된 인스턴스를 사용합니다. 프로젝트 Reactor 라이브러리와 사용 방법에 학습 보려면 Reactor 문서에서 시작하기 를 참조하세요.

Publisher 인스턴스를 사용하는 다른 방법도 있습니다. RxJava 와 같은 많은 대체 라이브러리 중 하나를 사용할 Publisher.subscribe() 수 Subscriber 있습니다. 또는 를 직접 호출하여 의 구현 을 전달할 수 있습니다.

이 가이드 의 예제에서는 Reactor의 Flux.blockLast() 메서드를 사용하여 Publisher 를 구독 하고 Publisher 가 종료 상태 에 도달할 때까지 현재 스레드를 차단 합니다. Reactive Streams 이니셔티브에 학습 보려면 Reactive Streams를 참조하세요.

중요

반환된 게시자는 콜드

Java Reactive Streams 운전자 메서드가 반환하는 모든 Publisher 인스턴스는 콜드 인스턴스이므로 반환된 Publisher 을(를) 구독 하지 않는 한 해당 작업이 발생하지 않습니다. 반환된 Publisher 를 한 번만 구독 하는 것이 좋습니다. 두 번 이상 구독 하면 오류가 발생할 수 있기 때문입니다.

샘플 애플리케이션

다음 샘플 애플리케이션을 사용하여 이 페이지의 코드 예제를 테스트할 수 있습니다. 샘플 애플리케이션을 사용하려면 다음 단계를 수행하세요.

  1. IDE에서 새 Java 프로젝트 를 만듭니다.

  2. Java 프로젝트 에 Java Reactive Streams 운전자 를 설치합니다.

  3. 프로젝트 리액터 라이브러리 설치 Java 프로젝트 에서 .

  4. 다음 코드를 복사하여 ReadOperations.java 이라는 새 Java 파일 에 붙여넣습니다.

  5. 이 페이지에서 코드 예제를 복사하여 파일의 지정된 줄에 붙여넣습니다.

1import com.mongodb.MongoException;
2import com.mongodb.ConnectionString;
3import com.mongodb.MongoClientSettings;
4import com.mongodb.ServerApi;
5import com.mongodb.ServerApiVersion;
6
7import com.mongodb.reactivestreams.client.MongoCollection;
8
9import org.bson.Document;
10
11import com.mongodb.reactivestreams.client.MongoClient;
12import com.mongodb.reactivestreams.client.MongoClients;
13import com.mongodb.reactivestreams.client.MongoDatabase;
14import com.mongodb.reactivestreams.client.FindPublisher;
15import com.mongodb.reactivestreams.client.DistinctPublisher;
16import com.mongodb.reactivestreams.client.ChangeStreamPublisher;
17import reactor.core.publisher.Flux;
18
19import java.util.ArrayList;
20import java.util.Arrays;
21import java.util.List;
22
23import static com.mongodb.client.model.Filters.eq;
24
25class ReadOperations {
26    public static void main(String[] args) throws InterruptedException {
27        // Replace the placeholder with your Atlas connection string
28        String uri = "<connection string>";
29
30        // Construct a ServerApi instance using the ServerApi.builder() method
31        ServerApi serverApi = ServerApi.builder()
32                .version(ServerApiVersion.V1)
33                .build();
34
35        MongoClientSettings settings = MongoClientSettings.builder()
36                .applyConnectionString(new ConnectionString(uri))
37                .serverApi(serverApi)
38                .build();
39        
40        // Create a new client and connect to the server
41        try (MongoClient mongoClient = MongoClients.create(settings)) {
42            MongoDatabase database = mongoClient.getDatabase("<database name>");
43            MongoCollection<Document> collection = database.getCollection("<collection name>");
44
45            // Start example code here
46
47            // End example code here
48        }
49    }
50}

find one

다음 예시 에서는 지정된 필터하다 에 지정된 기준과 일치하는 문서 를 조회합니다.

FindPublisher<Document> findDocPublisher = collection
        .find(eq("<field name>", "<value>")).first();
Flux.from(findDocPublisher)
        .doOnNext(System.out::println)
        .blockLast();

find().first() 구문에 학습 보려면 데이터 조회 가이드 를 참조하세요.

여러 항목 찾기

다음 예시 에서는 지정된 필터하다 에 지정된 기준과 일치하는 모든 문서를 조회합니다.

FindPublisher<Document> findDocPublisher = collection
        .find(eq("<field name>", "<value>"));
        
Flux.from(findDocPublisher)
        .doOnNext(System.out::println)
        .blockLast();

find() 메서드에 대해 자세히 알아보려면 데이터 조회 가이드를 참조하세요.

컬렉션의 문서 수 계산

다음 예시 에서는 지정된 컬렉션 의 문서 수를 반환합니다.

Publisher<Long> countPublisher = collection.countDocuments();
Flux.from(countPublisher)
        .doOnNext(System.out::println)
        .blockLast();

countDocuments() 메서드에 학습 보려면 문서 수 가이드 를 참조하세요.

쿼리에서 반환된 문서 수 계산

다음 예시 에서는 지정된 필터하다 에 지정된 기준과 일치하는 지정된 컬렉션 의 문서 수를 반환합니다.

Publisher<Long> countPublisher = collection.countDocuments(
           eq("<field name>", "<value>"));
Flux.from(countPublisher)
        .doOnNext(System.out::println)
        .blockLast();

countDocuments() 메서드에 학습 보려면 문서 수 가이드 를 참조하세요.

예상 문서 수

다음 예시 에서는 컬렉션 메타데이터 를 기반으로 지정된 컬렉션 의 대략적인 문서 수를 반환합니다.

Publisher<Long> countPublisher = collection.estimatedDocumentCount();
Flux.from(countPublisher)
        .doOnNext(System.out::println)
        .blockLast();

estimatedDocumentCount() 메서드에 학습 보려면 문서 수 가이드 를 참조하세요.

Retrieve Distinct Values

다음 예시 에서는 지정된 컬렉션 에 지정된 필드 이름의 모든 고유 값을 반환합니다.

DistinctPublisher<String> distinctPublisher = collection.distinct(
           "<field name>", <type>.class);
Flux.from(distinctPublisher)
        .doOnNext(System.out::println)
        .blockLast();

distinct() 메서드에 대해 자세히 알아보려면 고유 필드 값 조회 가이드를 참조하세요.

데이터 변경 사항 모니터링

다음 예시 에서는 지정된 컬렉션 에 대한 변경 스트림 을 생성하고 해당 컬렉션 의 후속 변경 이벤트를 출력합니다.

ChangeStreamPublisher<Document> changePublisher = collection.watch();
Flux.from(changePublisher)
        .doOnNext(System.out::println)
        .blockLast();

watch() 메서드에 학습 보려면 데이터 변경 모니터링 가이드 를 참조하세요.

돌아가기

데이터베이스 명령 실행

다음

쿼리