Docs Menu
Docs Home
/ / /
Rust 드라이버
/ / /

Retrieve Data

이 페이지의 내용

  • 개요
  • 예시용 샘플 데이터
  • 작업 찾기
  • 일치하는 모든 문서 찾기
  • 하나의 문서 찾기
  • 검색 동작 수정
  • 예시
  • 집계 작업
  • 문서 데이터 집계
  • 애그리게이션 동작 수정
  • 예시
  • 추가 정보
  • API 문서

이 가이드에서는 읽기 작업 을 사용하여 MongoDB collection에서 데이터를 검색하는 방법에 대해 설명합니다. 읽기 작업은 서버에서 문서를 검색하는 명령입니다.

읽기 작업에는 두 가지 유형이 있습니다.

  • collection에서 문서를 검색할 수 있는 찾기 작업

  • collection의 데이터를 변환할 수 있는 애그리게이션 작업

이 가이드에는 다음 섹션이 포함되어 있습니다.

  • 예제용 샘플 데이터는 읽기 작업 예제에서 사용되는 샘플 데이터를 제공합니다.

  • 찾기 작업 에서는 운전자 를 사용하여 찾기 작업을 실행하는 방법을 설명합니다.

  • 애그리게이션 작업 에서는 운전자 를 사용하여 집계 작업을 실행하는 방법을 설명합니다.

  • 추가 정보에서 이 가이드에 언급된 유형 및 메소드에 대한 리소스 및 API 문서 링크를 찾을 수 있습니다.

이 가이드의 예에서는 다음 샘플 문서를 사용합니다. 각 문서는 매장 재고에 있는 품목을 나타내며 분류 및 단가에 대한 정보를 포함합니다.

let docs = vec![
Inventory {
item: "candle".to_string(),
category: "decor".to_string(),
unit_price: 2.89,
},
Inventory {
item: "blender".to_string(),
category: "kitchen".to_string(),
unit_price: 38.49,
},
Inventory {
item: "placemat".to_string(),
category: "kitchen".to_string(),
unit_price: 3.19,
},
Inventory {
item: "watering can".to_string(),
category: "garden".to_string(),
unit_price: 11.99,
},
];

이 데이터를 컬렉션 에 삽입하는 방법을 학습 보려면 문서 삽입 가이드 를 참조하세요.

찾기 작업을 사용하여 MongoDB에서 데이터를 검색합니다. 찾기 작업은 find()find_one() 메서드로 구성됩니다.

기준과 일치 하는 모든 문서 를 찾으려면 find() 메서드를 사용합니다. 이 메서드는 쿼리 필터를 매개 변수로 사용합니다. 쿼리 필터는 문서가 일치시킬 기준을 형성하는 필드와 값으로 구성됩니다.

이 메서드는 필터 기준과 일치하는 문서를 검색하기 위해 반복할 수 있는 Cursor 유형을 반환합니다.

이 메서드를 사용하여 데이터를 검색하는 예제를 보려면 find() 예제를 참조하세요.

쿼리 지정에 대해 자세히 알아보려면 쿼리 지정 가이드를 참조하세요.

기준과 일치 하는 첫 번째 문서 를 찾으려면 find_one() 메서드를 사용합니다. 이 메서드는 쿼리 필터를 매개 변수로 사용합니다. 쿼리 필터는 문서가 일치시킬 기준을 형성하는 필드와 값으로 구성됩니다.

문서가 필터 기준과 일치하면 메서드는 값이 SomeResult<Option<T>> 유형을 반환합니다. 필터 기준과 일치하는 문서가 없는 경우 find_one() 는 값이 NoneResult<Option<T>> 유형을 반환합니다.

이 메서드를 사용하여 데이터를 조회 하는 예시 를 보려면 find_one() 예시 를 참조하세요.

FindOptions 옵션 빌더 메서드를 find() 에 연결하여 find() 메서드의 동작을 수정하고 FindOneOptions 옵션 빌더 메서드를 find_one() 에 연결하여 find_one() 메서드의 동작을 수정할 수 있습니다.

다음 표에서는 해당 빌더 메서드를 호출하여 설정하다 수 있는 일반적으로 사용되는 FindOptionsFindOneOptions 필드에 대해 설명합니다.

필드
설명

collation

The collation to use when sorting results. To learn more about collations, see the Collations guide.

Type: Collation
Default: None

hint

The index to use for the operation. To learn more about indexes, see Indexes in the Server manual.

Type: Hint
Default: None

projection

The projection to use when returning results.

Type: Document
Default: None

read_concern

The read concern to use for the find operation. If you don't set this option, the operation inherits the read concern set for the collection. To learn more about read concerns, see Read Concern in the Server manual.

Type: ReadConcern

skip

The number of documents to skip when returning results. To learn more about how to use the skip() builder method, see Skip Returned Results.

Type: u64
Default: None

sort

The sort to use when returning results. By default, the driver returns documents in their natural order, or as they appear in the database. To learn more, see natural order in the Server manual glossary. To learn more about how to use the sort() builder method, see Sort Results.

Type: Document
Default: None

참고

설정 옵션

옵션 빌더 메서드를 찾기 작업 메서드 호출에 직접 연결하여 FindOptionsFindOneOptions 필드를 설정하다 수 있습니다. 이전 버전의 운전자 를 사용하는 경우 옵션 빌더 메서드를 builder() 메서드에 연결하여 FindOptions 또는 FindOneOptions 인스턴스 를 구성해야 합니다. 그런 다음 옵션 인스턴스 를 find() 또는 find_one() 에 매개 변수로 전달합니다.

각 유형에 대해 지정할 수 있는 설정의 전체 목록은 FindOptionsFindOneOptions에 대한 API 설명서를 참조하세요.

다음 섹션에는 find()findOne() 메서드를 사용하여 필터 기준과 일치하는 샘플 문서를 조회하는 예가 포함되어 있습니다.

이 예에서는 다음 조치를 수행합니다.

  • find() 메서드 호출

  • find() 값이 unit_price 보다 작고 이 아닌 문서와 일치하는 쿼리 필터하다 12.00 를 에 전달합니다.category "kitchen"

  • 일치하는 문서를 unit_price 기준으로 내림차순으로 정렬하기 위해 sort() 메서드를 find() 에 연결합니다.

let mut cursor = my_coll
.find(doc! { "$and": vec!
[
doc! { "unit_price": doc! { "$lt": 12.00 } },
doc! { "category": doc! { "$ne": "kitchen" } }
] })
.sort(doc! { "unit_price": -1 })
.await?;
while let Some(result) = cursor.try_next().await? {
println!("{:?}", result);
}
Inventory { item: "watering can", category: "garden", unit_price: 11.99 }
Inventory { item: "candle", category: "decor", unit_price: 2.89 }

이 예에서는 다음 조치를 수행합니다.

  • find_one() 메서드 호출

  • unit_price 20.00보다 작거나 같은 문서와 일치하는 쿼리 필터하다 를 find_one() 에 전달합니다.

  • 일치하는 처음 두 문서를 건너뛰기 위해 skip() 메서드를 find_one() 으)로 연결합니다.

let result = my_coll
.find_one(doc! { "unit_price": doc! { "$lte": 20.00 } })
.skip(2)
.await?;
println!("{:#?}", result);
Some(
Inventory {
item: "watering can",
category: "garden",
unit_price: 11.99,
},
)

애그리게이션 작업을 사용하여 collection에서 데이터를 검색하고 변환합니다. aggregate() 메서드를 사용하여 애그리게이션 작업을 수행할 수 있습니다.

aggregate() 메서드는 집계 파이프라인 을 매개 변수로 사용합니다. 집계 파이프라인에는 데이터를 변환하는 방법을 지정하는 하나 이상의 단계 가 포함됩니다. 단계에는 애그리게이션 연산자(접두사 $)와 해당 연산자에 대한 필수 매개변수가 포함됩니다.

애그리게이션에 대해 자세히 알아보고 애그리게이션 예제를 보려면 애그리 게이션 가이드를 참조하세요.

이 메서드는 결과 문서를 Cursor 유형으로 반환합니다. 집계 파이프라인에 $match 단계가 포함되어 있지 않은 경우 파이프라인은 컬렉션의 모든 문서를 처리합니다.

AggregateOptions 옵션 빌더 메서드를 aggregate() 에 연결하여 aggregate() 메서드의 동작을 수정할 수 있습니다.

다음 표에서는 해당 빌더 메서드를 호출하여 설정하다 수 있는 일반적으로 사용되는 AggregateOptions 필드에 대해 설명합니다.

필드
설명

allow_disk_use

Enables writing to temporary files. If true, aggregation stages can write data to the _tmp subdirectory in the dbPath directory.

Type: bool
Default: false

batch_size

Specifies the maximum number of documents the server returns per cursor batch. This option sets the number of documents the cursor keeps in memory rather than the number of documents the cursor returns.

Type: u32
Default: 101 documents initially, 16 MB maximum for subsequent batches

collation

The collation to use when sorting results. To learn more about collations, see the Collations guide.

Type: Collation
Default: None

hint

The index to use for the operation. To learn more about indexes, see Indexes in the Server manual.

Type: Hint
Default: None

read_concern

The read concern to use for the find operation. If you don't set this option, the operation inherits the read concern set for the collection. To learn more about read concerns, see Read Concern in the Server manual.

Type: ReadConcern

write_concern

The write concern for the operation. If you don't set this option, the operation inherits the write concern set for the collection. To learn more about write concerns, see Write Concern in the Server manual.

Type: WriteConcern

전체 설정 목록은 AggregateOptions에 대한 API 설명서를 참조하세요.

이 예시에서는 다음 단계가 포함된 파이프라인을 사용하여 aggregate() 메서드를 호출하는 방법을 보여 줍니다.

  • $group category 필드 의 각 값에 대해 unit_price 필드 의 평균을 계산하는 단계

  • $sort avg_price 기준으로 결과를 오름차순으로 정렬하는 단계

let pipeline = vec![
doc! { "$group": doc! { "_id" : doc! {"category": "$category"} ,
"avg_price" : doc! { "$avg" : "$unit_price" } } },
doc! { "$sort": { "_id.avg_price" : 1 } },
];
let mut cursor = my_coll.aggregate(pipeline).await?;
while let Some(result) = cursor.try_next().await? {
println!("{:?}", result);
}
Document({"_id": Document({"category": String("decor")}), "avg_price": Double(2.890000104904175)})
Document({"_id": Document({"category": String("kitchen")}), "avg_price": Double(20.840000867843628)})
Document({"_id": Document({"category": String("garden")}), "avg_price": Double(11.989999771118164)})

찾기 작업의 실행 가능한 예는 다음과 같은 사용의 예를 참조하세요.

이 가이드의 작업에 대해 자세히 알아보려면 다음 문서를 참조하세요.

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

돌아가기

읽기