MongoDB 쿼리 - React Native SDK

사용 사례

MongoDB 데이터 소스를 쿼리해야 하는 이유는 여러 가지가 있습니다. Atlas Device Sync를 통해 클라이언트의 데이터로 작업하는 것이 항상 실용적이거나 가능한 것은 아닙니다. 다음과 같은 경우에는 MongoDB를 쿼리해야 할 수 있습니다.

• 데이터 세트의 용량이 크거나, 클라이언트 디바이스로 데이터 세트 전체를 로드하는 데 제약이 있을 경우

• 사용자 지정 사용자 데이터 생성 또는 업데이트를 실행하려는 경우

• Realm에서 모델링되지 않은 문서를 검색하려는 경우

• 앱으로 엄격한 스키마가 없는 컬렉션에 액세스해야 하는 경우

• 비Realm 서비스를 통해 액세스하고자 하는 컬렉션을 생성할 경우

다음 내용은 MongoDB를 직접 쿼리할 수 있는 일반적인 사용 사례입니다. 단, 해당 사례들이 전부는 아닙니다.

전제 조건

React Native 애플리케이션에서 MongoDB를 쿼리하려면 먼저 App Services 앱에서 MongoDB 데이터 액세스를 설정해야 합니다. Realm SDK가 Atlas를 쿼리할 수 있도록 백엔드 앱을 설정하는 방법을 알아보려면 App Services 문서에서 MongoDB 데이터 액세스 설정 을 참조하세요.

{ _id: ObjectId("5f87976b7b800b285345a8c4"), name: "venus flytrap", sunlight: "full", color: "white", type: "perennial", _partition: "Store 42" },
{ _id: ObjectId("5f87976b7b800b285345a8c5"), name: "sweet basil", sunlight: "partial", color: "green", type: "annual", _partition: "Store 42" },
{ _id: ObjectId("5f87976b7b800b285345a8c6"), name: "thai basil", sunlight: "partial", color: "green", type: "perennial", _partition: "Store 42" },
{ _id: ObjectId("5f87976b7b800b285345a8c7"), name: "helianthus", sunlight: "full", color: "yellow", type: "annual", _partition: "Store 42" },
{ _id: ObjectId("5f87976b7b800b285345a8c8"), name: "petunia", sunlight: "full", color: "purple", type: "annual", _partition: "Store 47" }

연결된 클러스터에 연결하기

클라이언트 애플리케이션에서 연결된 클러스터에 액세스하려면 사용자를 인증하고 클러스터 이름을 User.mongoClient()에 전달합니다. 이렇게 하면 클러스터의 데이터베이스 및 컬렉션에 액세스할 때 사용할 수 있는 MongoDB 서비스 인터페이스가 반환됩니다.

@realm/react를 사용하는 경우 UserProvider로 래핑된 구성 요소의 useUser() 후크를 사용하여 MongoDB 클라이언트에 액세스할 수 있습니다.

읽기 작업

const venusFlytrap = await plants.findOne({ name: "venus flytrap" });
console.log("venusFlytrap", venusFlytrap);

{
  _id: ObjectId("5f87976b7b800b285345a8c4"),
  name: "venus flytrap",
  sunlight: "full",
  color: "white",
  type: "perennial",
  _partition: "Store 42",
}

const perennials = await plants.find({ type: "perennial" });
console.log("perennials", perennials);

[
  { _id: ObjectId("5f87976b7b800b285345a8c4"), name: 'venus flytrap', sunlight: 'full', color: 'white', type: 'perennial', _partition: 'Store 42' },
  { _id: ObjectId("5f87976b7b800b285345a8c6"), name: 'thai basil', sunlight: 'partial', color: 'green', type: 'perennial', _partition: 'Store 42' },
  { _id: ObjectId("5f879f83fc9013565c23360e"), name: 'lily of the valley', sunlight: 'full', color: 'white', type: 'perennial', _partition: 'Store 47' },
  { _id: ObjectId("5f87a0defc9013565c233611"), name: 'rhubarb', sunlight: 'full', color: 'red', type: 'perennial', _partition: 'Store 47' },
  { _id: ObjectId("5f87a0dffc9013565c233612"), name: 'wisteria lilac', sunlight: 'partial', color: 'purple', type: 'perennial', _partition: 'Store 42' },
  { _id: ObjectId("5f87a0dffc9013565c233613"), name: 'daffodil', sunlight: 'full', color: 'yellow', type: 'perennial', _partition: 'Store 42' }
]

const numPlants = await plants.count();
console.log(`There are ${numPlants} plants in the collection`);

"There are 9 plants in the collection"

쓰기 작업

const result = await plants.insertOne({
  name: "lily of the valley",
  sunlight: "full",
  color: "white",
  type: "perennial",
  _partition: "Store 47",
});
console.log(result);

{
  insertedId: "5f879f83fc9013565c23360e",
}

const result = await plants.insertMany([
  {
    name: "rhubarb",
    sunlight: "full",
    color: "red",
    type: "perennial",
    _partition: "Store 47",
  },
  {
    name: "wisteria lilac",
    sunlight: "partial",
    color: "purple",
    type: "perennial",
    _partition: "Store 42",
  },
  {
    name: "daffodil",
    sunlight: "full",
    color: "yellow",
    type: "perennial",
    _partition: "Store 42",
  },
]);
console.log(result);

{
  insertedIds: [
    "5f87a0defc9013565c233611",
    "5f87a0dffc9013565c233612",
    "5f87a0dffc9013565c233613",
  ],
}

const result = await plants.updateOne(
  { name: "petunia" },
  { $set: { sunlight: "partial" } }
);
console.log(result);

{ matchedCount: 1, modifiedCount: 1 }

const result = await plants.updateMany(
  { _partition: "Store 47" },
  { $set: { _partition: "Store 51" } }
);
console.log(result);

{ matchedCount: 3, modifiedCount: 3 }

const result = await plants.updateOne(
  {
    sunlight: "full",
    type: "perennial",
    color: "green",
    _partition: "Store 47",
  },
  { $set: { name: "sweet basil" } },
  { upsert: true }
);
console.log(result);

{
  matchedCount: 0,
  modifiedCount: 0,
  upsertedId: ObjectId("5f1f63055512f2cb67f460a3"),
}

const result = await plants.deleteOne({ color: "green" });
console.log(result);

{ deletedCount: 1 }

const result = await plants.deleteMany({
  _partition: "Store 51",
});
console.log(result);

{ deletedCount: 3 }

실시간 변경 알림

collection.watch() 를 호출하여 컬렉션의 문서가 추가, 수정 또는 삭제될 때마다 MongoDB가 보내는 실시간 변경 알림을 구독할 수 있습니다. 각 알림은 변경된 문서, 변경 방법, 이벤트를 일으킨 작업 이후의 전체 문서를 지정합니다.

collection.watch() 비동기 생성기 를 반환합니다. 이를 통해 작업이 발생할 때 작업에 대한 변경 이벤트 를 비동기적으로 가져올 수 있습니다.

collection.watch() React Native 클라이언트 앱과 함께 작동하려면 몇 가지 설정이 필요합니다. 컬렉션의 변경 사항을 관찰하려면 먼저 react-native-polyfill-globals를 설치해야 합니다.및 @babel/plugin-proposal-async-generator-functions 패키지.

collection.watch()를 사용하려면:

1. 종속 요소를 설치합니다.

   npm install react-native-polyfill-globals text-encoding
   npm install --save-dev @babel/plugin-proposal-async-generator-functions

2. 사용해야 하는 위치보다 더 높은 범위에서 폴리필을 가져옵니다. 예를 들어 index.js이 있습니다.

   import { polyfill as polyfillReadableStream } from "react-native-polyfill-globals/src/readable-stream";
   import { polyfill as polyfillEncoding } from "react-native-polyfill-globals/src/encoding";
   import { polyfill as polyfillFetch } from "react-native-polyfill-globals/src/fetch";
   polyfillReadableStream();
   polyfillEncoding();
   polyfillFetch();

for await (const change of plants.watch({
  filter: {
    operationType: "insert",
    "fullDocument.type": "perennial",
  },
})) {
  // The change event will always represent a newly inserted perennial
  const { documentKey, fullDocument } = change;
  console.log(`new document: ${documentKey}`, fullDocument);
}

집계 작업

집계 작업은 집계 파이프라인 이라는 일련의 단계를 통해 컬렉션의 모든 문서를 실행합니다. 애그리게이션을 사용하면 문서를 필터링 및 변환하고, 관련 문서 그룹에 대한 요약 데이터를 수집하는 등의 복잡한 데이터 작업을 수행할 수 있습니다.

const result = await plants.aggregate([
  {
    $group: {
      _id: "$type",
      total: { $sum: 1 },
    },
  },
  { $sort: { _id: 1 } },
]);
console.log(result);

[
  { _id: "annual", total: 1 },
  { _id: "perennial", total: 5 },
]

{
  "$match": {
    "<Field Name>": <Query Expression>,
    ...
  }
}

const perennials = await plants.aggregate([
  { $match: { type: { $eq: "perennial" } } },
]);
console.log(perennials);

{
  "$group": {
    "_id": <Group By Expression>,
    "<Field Name>": <Aggregation Expression>,
    ...
  }
}

const result = await plants.aggregate([
  {
    $group: {
      _id: "$type",
      numItems: { $sum: 1 },
    },
  },
  { $sort: { _id: 1 } },
]);
console.log(result);

// Paginates through list of plants
// in ascending order by plant name (A -> Z)
async function paginateCollectionAscending(
  collection,
  nPerPage,
  startValue
) {
  const pipeline = [{ $sort: { name: 1 } }, { $limit: nPerPage }];
  // If not starting from the beginning of the collection,
  // only match documents greater than the previous greatest value.
  if (startValue !== undefined) {
    pipeline.unshift({
      $match: {
        name: { $gt: startValue },
      },
    });
  }
  const results = await collection.aggregate(pipeline);
  return results;
}
// Number of results to show on each page
const resultsPerPage = 3;
const pageOneResults = await paginateCollectionAscending(
  plants,
  resultsPerPage
);
const pageTwoStartValue = pageOneResults[pageOneResults.length - 1].name;
const pageTwoResults = await paginateCollectionAscending(
  plants,
  resultsPerPage,
  pageTwoStartValue
);
// ... can keep paginating for as many plants as there are in the collection

{
  "$project": {
    "<Field Name>": <0 | 1 | Expression>,
    ...
  }
}

const result = await plants.aggregate([
  {
    $project: {
      _id: 0,
      name: 1,
      storeNumber: {
        $arrayElemAt: [{ $split: ["$_partition", " "] }, 1],
      },
    },
  },
]);
console.log(result);

{ $addFields: { <newField>: <expression>, ... } }

const result = await plants.aggregate([
  {
    $addFields: {
      storeNumber: {
        $arrayElemAt: [{ $split: ["$_partition", " "] }, 1],
      },
    },
  },
]);
console.log(result);

{
  $unwind: {
    path: <Array Field Path>,
    includeArrayIndex: <string>,
    preserveNullAndEmptyArrays: <boolean>
  }
}

const result = await plants.aggregate([
  { $group: { _id: "$type", colors: { $addToSet: "$color" } } },
  { $unwind: { path: "$colors" } },
  { $sort: { _id: 1, colors: 1 } },
]);
console.log(result);