연습 - Cosmos DB에서 사용할 JavaScript 코드 추가

  • 15분

이 단원에서는 LIKE, JOIN 및 WHERE와 같은 SQL 키워드를 사용하여 Cosmos SDK를 통해 데이터를 찾는 스크립트를 만들고 실행합니다.

컨테이너에서 제품을 찾는 스크립트 만들기

  1. Visual Studio Code의 [파일] 메뉴에서 [새 텍스트 파일]을 선택합니다.

  2. 파일 메뉴에서 다른 이름으로 저장을 선택합니다. 이름이 2-contoso-products-find.js인 새 파일을 저장합니다.

  3. 다음 JavaScript를 복사하여 파일에 붙여넣습니다.

    import * as path from "path";
import { promises as fs } from "fs";
import { fileURLToPath } from "url";
const __dirname = path.dirname(fileURLToPath(import.meta.url));

// Get environment variables from .env
import * as dotenv from "dotenv";
dotenv.config();

// Get Cosmos Client
import { CosmosClient } from "@azure/cosmos";

// Provide required connection from environment variables
const cosmosSecret = process.env.COSMOS_CONNECTION_STRING;

// Authenticate to Azure Cosmos DB
const cosmosClient = new CosmosClient(cosmosSecret);

// Set Database name and container name
const databaseName = process.env.COSMOS_DATABASE_NAME;
const containerName = process.env.COSMOS_CONTAINER_NAME;

// Get Container
const container = await cosmosClient
  .database(databaseName)
  .container(containerName);

// Find all products that match a property with a value like `value`
async function executeSqlFind(property, value) {
  // Build query
  const querySpec = {
    query: `select * from products p where p.${property} LIKE @propertyValue`,
    parameters: [
      {
        name: "@propertyValue",
        value: `${value}`,
      },
    ],
  };

  // Show query
  console.log(querySpec);

  // Get results
  const { resources } = await container.items.query(querySpec).fetchAll();

  let i = 0;

  // Show results of query
  for (const item of resources) {
    console.log(`${++i}: ${item.id}: ${item.name}, ${item.sku}`);
  }
}

// Find inventory of products with property/value and location
async function executeSqlInventory(propertyName, propertyValue, locationPropertyName, locationPropertyValue) {
  // Build query
  const querySpec = {
    query: `select p.id, p.name, i.location, i.inventory from products p JOIN i IN p.inventory where p.${propertyName} LIKE @propertyValue AND i.${locationPropertyName}=@locationPropertyValue`,

    parameters: [
      {
        name: "@propertyValue",
        value: `${propertyValue}`,
      },
      { 
        name: "@locationPropertyValue", 
        value: `${locationPropertyValue}` },
    ],
  };

  // Show query
  console.log(querySpec);

  // Get results
  const { resources } = await container.items.query(querySpec).fetchAll();

  let i = 0;

  // Show results of query
  console.log(`Looking for ${propertyName}=${propertyValue}, ${locationPropertyName}=${locationPropertyValue}`);
  for (const item of resources) {
    console.log(
      `${++i}: ${item.id}: '${item.name}': current inventory = ${
        item.inventory
      }`
    );
  }
}

// Example queries
/*

// find all bikes based on partial match to property value

node 2-contoso-products-find.js find categoryName '%Bikes%'
node 2-contoso-products-find.js find name '%Blue%'

// find inventory at location on partial match to property value and specific location

node 2-contoso-products-find.js find-inventory categoryName '%Bikes%' location Seattle
node 2-contoso-products-find.js find-inventory name '%Blue%' location Dallas

*/
const args = process.argv;

if (args && args[2] == "find") {
  await executeSqlFind(args[3], args[4]);
} else if (args && args[2] == "find-inventory") {
  await executeSqlInventory(args[3], args[4], args[5], args[6]);
} else {
  console.log("products: no args used");
}

  4. Visual Studio Code 터미널에서 JavaScript 파일을 실행해 모든 자전거를 찾습니다.

    node 2-contoso-products-find.js find categoryName '%Bikes%'

    bikes 용어는 부분 일치를 나타내는 백분율 기호(%)로 래핑됩니다.

    컨테이너에 대한 executeSqlFind 메서드의 SQL 쿼리는 LIKE 키워드 및 쿼리 매개 변수를 사용하여 Bikes를 포함하는 categoryName이 있는 항목을 찾습니다.

  5. 다른 쿼리를 실행하여 이름에 단어 Blue이(가) 있는 모든 제품을 찾습니다.

    node 2-contoso-products-find.js find name '%Blue%'

  6. 또 다른 쿼리를 실행하여 시애틀에서 자전거에 대한 제품 인벤토리를 찾습니다.

    node 2-contoso-products-find.js find-inventory categoryName '%Bikes%' location Seattle

  7. 다른 쿼리를 실행하여 달라스에서 이름에 단어 Blue이(가) 있는 모든 인벤토리를 찾습니다.

    node 2-contoso-products-find.js find-inventory name '%Blue%' location Dallas

컨테이너에 제품을 upsert하는 스크립트 만들기

  1. Visual Studio Code의 [파일] 메뉴에서 [새 텍스트 파일]을 선택합니다.

  2. 파일 메뉴에서 다른 이름으로 저장을 선택합니다. 이름이 3-contoso-products-upsert.js인 새 파일을 저장합니다.

  3. 다음 JavaScript를 복사하여 파일에 붙여넣습니다.

    import * as path from "path";
import { promises as fs } from "fs";
import { fileURLToPath } from "url";
const __dirname = path.dirname(fileURLToPath(import.meta.url));

// Get environment variables from .env
import * as dotenv from "dotenv";
dotenv.config();

// Get Cosmos Client
import { CosmosClient } from "@azure/cosmos";

// Provide required connection from environment variables
const cosmosSecret = process.env.COSMOS_CONNECTION_STRING;

// Authenticate to Azure Cosmos DB
const cosmosClient = new CosmosClient(cosmosSecret);

// Set Database name and container name
const databaseName = process.env.COSMOS_DATABASE_NAME;
const containerName = process.env.COSMOS_CONTAINER_NAME;

// Get Container
const container = await cosmosClient.database(databaseName).container(containerName);

// Either insert or update item
async function upsert(fileAndPathToJson, encoding='utf-8') {

  // Get item from file
  const data = JSON.parse(await fs.readFile(path.join(__dirname, fileAndPathToJson), encoding));

  // Process request
  // result.resource is the returned item
  const result = await container.items.upsert(data);

  if(result.statusCode===201){
    console.log("Inserted data");
  } else if (result.statusCode===200){
    console.log("Updated data");
  } else {
    console.log(`unexpected statusCode ${result.statusCode}`);
  }
}

// Insert data - statusCode = 201
await upsert('./3-contoso-products-upsert-insert.json');

// Update data - statusCode = 200
await upsert('./3-contoso-products-upsert-update.json');

// Get item from container and partition key
const { resource } = await container.item("123", "xyz").read();

// Show final item
console.log(resource);

  4. 제품에 대한 새 파일 3-contoso-products-upsert-insert.json을 만들고 다음 JSON 개체를 붙여넣습니다.

    {
    "id": "123",
    "categoryName": "xyz",
    "name": "_a new item inserted"
}

    ID 123이(가) 있는 이 개체에는 인벤토리가 없습니다.

  5. 제품에 대한 새 파일 3-contoso-products-upsert-update.json을 만들고 다음 JSON 개체를 붙여넣습니다.

    {
  "id": "123",
  "categoryName": "xyz",
  "name": "_a new item updated",
  "inventory": [
    {
      "location": "Dallas",
      "inventory": 100
    }
  ]
}

    이 개체는 인벤토리가 있습니다.

  6. Visual Studio Code 터미널에서 JavaScript 파일을 실행해 새 제품을 upsert합니다.

    node 3-contoso-products-upsert.js

    해당 ID가 있는 제품이 없으므로 제품이 삽입됩니다. 그런 다음 스크립트는 인벤토리를 사용하여 제품을 업데이트합니다. 삽입 및 업데이트 기능 모두 동일한 코드를 사용하여 upsert합니다.