MongoDB에서 배열 형태의 하위 문서(sub-document) 중 특정 조건을 만족하는 요소만 추출하여 문서를 반환하려면 $project 연산자와 함께 $filter를 사용하면 됩니다. 이 방법은 집계 파이프라인(aggregate) 내에서 원본 데이터는 그대로 유지한 채, 조건에 맞는 하위 문서만 새로운 형태로 출력해 줍니다.
1. 샘플 컬렉션 생성하기
먼저 실습에 사용할 컬렉션을 만들고 문서를 삽입해 보겠습니다.
> db.demo457.insertOne(
... {
... _id: 101,
... details: [
... { ProductName:"Product-1" , ProductPrice:90 },
... { ProductName:"Product-2" , ProductPrice:190 }
... ]
... }
... );
{ "acknowledged" : true, "insertedId" : 101 }
>
> db.demo457.insertOne(
... {
... _id: 102,
... details: [
... { ProductName:"Product-3" , ProductPrice:150},
... { ProductName:"Product-4" , ProductPrice:360 }
... ]
... }
... );
{ "acknowledged" : true, "insertedId" : 102 }2. find()로 전체 문서 확인하기
find() 메서드를 사용하여 컬렉션의 모든 문서를 조회합니다.
> db.demo457.find();
실행 결과는 다음과 같습니다.
{ "_id" : 101, "details" : [ { "ProductName" : "Product-1", "ProductPrice" : 90 }, { "ProductName"
: "Product-2", "ProductPrice" : 190 } ] }
{ "_id" : 102, "details" : [ { "ProductName" : "Product-3", "ProductPrice" : 150 }, {
"ProductName" : "Product-4", "ProductPrice" : 360 } ] }3. $filter로 하위 문서 필터링하기
이제 aggregate() 안에서 $project와 $filter를 조합하여, ProductPrice가 170 이상인 상품만 남긴 문서를 반환하는 쿼리를 작성해 보겠습니다.
> db.demo457.aggregate([
... {
... $project: {
... details: {
... $filter: {
... input: "$details",
... as: "output",
... cond: { $gte: [ "$$output.ProductPrice", 170 ] }
... }
... }
... }
... }
... ])각 옵션의 역할은 다음과 같습니다.
- input: 필터링 대상이 되는 배열 필드($details)를 지정합니다.
- as: 배열의 각 요소를 참조할 변수 이름(output)을 정의합니다.
- cond: 각 요소가 통과해야 할 조건을 설정합니다. 여기서는 $$output.ProductPrice가 170보다 크거나 같은 경우만 통과됩니다.
쿼리 실행 결과는 다음과 같습니다.
{ "_id" : 101, "details" : [ { "ProductName" : "Product-2", "ProductPrice" : 190 } ] }
{ "_id" : 102, "details" : [ { "ProductName" : "Product-4", "ProductPrice" : 360 } ] }출력 결과를 보면 각 문서에서 가격이 170 미만인 상품(Product-1, Product-3)은 제외되고, 조건을 충족하는 하위 문서만 남아 있는 것을 확인할 수 있습니다. 이처럼 $project와 $filter를 활용하면 원본 컬렉션을 변경하지 않고도 원하는 형태의 필터링된 결과를 손쉽게 얻을 수 있습니다.