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

고유 필드 값 검색

이 페이지의 내용

  • 개요
  • 샘플 데이터
  • distinct() 메서드
  • 컬렉션 전체에서 고유 값 검색
  • 지정된 문서에서 고유 값 검색
  • 고유 동작 수정
  • 추가 정보
  • API 문서

컬렉션 내에서 서로 다른 문서에 단일 필드 에 대해 서로 다른 값이 포함될 수 있습니다. 예를 예시 restaurant 컬렉션 의 한 문서 는 borough 값이 "Manhattan" 이고 다른 문서의 borough 값은 "Queens" 입니다. Java Reactive Streams 운전자 를 사용하면 컬렉션 의 여러 문서에서 필드 에 포함된 고유 값을 모두 조회 할 수 있습니다.

이 가이드 의 예제에서는 Atlas 샘플 데이터 세트sample_restaurants.restaurants 컬렉션 을 사용합니다. 무료 MongoDB Atlas cluster 를 생성하고 샘플 데이터 세트를 로드하는 방법을 학습 보려면 시작하기를 참조하세요.

중요

프로젝트 리액터 라이브러리

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

지정된 필드의 고유 값을 검색하려면 distinct() 메서드를 호출하고 고유 값을 찾으려는 필드의 이름을 전달합니다.

다음 예에서는 restaurants 컬렉션에 있는 borough 필드의 고유 값을 검색합니다.

DistinctPublisher<String> distinctPublisher = collection
.distinct("borough", String.class);
Flux.from(distinctPublisher)
.doOnNext(System.out::println)
.blockLast();
Bronx
Brooklyn
Manhattan
Missing
Queens
Staten Island

결과에는 컬렉션의 모든 문서에서 borough 필드에 나타나는 모든 고유 값이 표시됩니다. 여러 문서의 borough 필드에 동일한 값이 있지만 각 값은 결과에 한 번만 표시됩니다.

distinct() 메서드에 쿼리 필터 를 제공하여 컬렉션의 문서 하위 집합에서 고유 필드 값을 찾을 수 있습니다. 쿼리 필터는 작업에서 문서를 일치시키는 데 사용되는 Atlas Search 기준을 지정하는 표현식입니다. 쿼리 필터 만들기에 대한 자세한 내용은 쿼리 지정을 참조하세요.

다음 예에서는 cuisine 필드 값이 "Italian" 인 모든 문서에 대해 borough 필드의 고유 값을 검색합니다.

Bson filter = Filters.eq("cuisine", "Italian");
DistinctPublisher<String> distinctPublisher = collection
.distinct("borough", String.class)
.filter(filter);
Flux.from(distinctPublisher)
.doOnNext(System.out::println)
.blockLast();
Bronx
Brooklyn
Manhattan
Queens
Staten Island

distinct() 메서드는 메서드를 distinct() 메서드 호출에 연결하여 수정할 수 있습니다. 옵션을 지정하지 않으면 운전자 는 작업을 사용자 지정하지 않습니다.

다음 표에서는 distinct() 작업을 사용자 지정하는 데 사용할 수 있는 몇 가지 메서드를 설명합니다.

메서드
설명
batchSize()
Sets the number of documents to return per batch.
collation()
Specifies the kind of language collation to use when sorting results. For more information, see Collation in the MongoDB Server manual.
comment()
Specifies a comment to attach to the operation.
filter()
Sets the query filter to apply to the query.
maxTime()
Sets the maximum amount of time to allow the operation to run, in milliseconds.

메서드를 수정하는 데 사용할 수 있는 메서드의 전체 목록은 distinct() DistinctPublisher 를 참조하세요. API 문서.

다음 예시에서는 borough 필드 값이 "Bronx" 이고 cuisine 필드 값이 "Pizza" 인 모든 문서에 대해 name 필드의 고유 값을 검색합니다. 또한 comment 옵션을 사용하여 작업에 주석을 추가합니다.

Bson filter = Filters.and(
Filters.eq("borough", "Bronx"),
Filters.eq("cuisine", "Pizza")
);
DistinctPublisher<String> distinctPublisher = collection
.distinct("name", String.class)
.filter(filter)
.comment("Bronx pizza restaurants");
Flux.from(distinctPublisher)
.doOnNext(System.out::println)
.blockLast();
$1.25 Pizza
18 East Gunhill Pizza
2 Bros
Aenos Pizza
Alitalia Pizza Restaurant
...

distinct 명령에 학습 보려면 MongoDB Server 매뉴얼의 Distinct 가이드 를 참조하세요.

이 가이드에서 사용되는 메서드 또는 유형에 대해 자세히 알아보려면 다음 API 설명서를 참조하세요.

  • distinct()

  • Distinctpublisher

돌아가기

문서 수 계산