Упражнение. Добавление кода JavaScript для работы с Cosmos DB
В этом уроке вы создадите и запустите скрипты, которые используют ключевое слово SQL, такие как LIKE, JOIN и WHERE для поиска данных с помощью пакета SDK Cosmos.
Создание скрипта для поиска продуктов в контейнере
В Visual Studio Code в меню "Файл " выберите новый текстовый файл.
В меню Файл выберите команду Сохранить как. Сохраните новый файл с именем 2-contoso-products-find.js.
Скопируйте следующий Код 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"); }
В терминале Visual Studio Code выполните файл JavaScript, чтобы найти все велосипеды:
node 2-contoso-products-find.js find categoryName '%Bikes%'
Термин
bikes
упаковывается с знаками процента,%
указывающими на частичное сопоставление.SQL-запрос в методе
executeSqlFind
для контейнера использует параметры LIKE ключевое слово и запроса для поиска элементов с именем категории, который включаетBikes
.Выполните другой запрос, чтобы найти все продукты со словом
Blue
в имени.node 2-contoso-products-find.js find name '%Blue%'
Выполните другой запрос, чтобы найти инвентаризацию продуктов для велосипедов в Сиэтле.
node 2-contoso-products-find.js find-inventory categoryName '%Bikes%' Seattle
Выполните другой запрос, чтобы найти инвентаризацию для всех продуктов со словом
Blue
в имени в Далласе.node 2-contoso-products-find.js find-inventory name '%Blue%' Dallas
Создание скрипта для upsert продуктов в контейнер
В Visual Studio Code в меню "Файл " выберите новый текстовый файл.
В меню Файл выберите команду Сохранить как. Сохраните новый файл с именем 3-contoso-products-upsert.js.
Скопируйте следующий Код 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);
Создайте новый файл для продукта, 3-contoso-products-upsert-insert.json и вставьте следующий объект JSON.
{ "id": "123", "categoryName": "xyz", "name": "_a new item inserted" }
Обратите внимание, что этот объект с идентификатором
123
не имеет инвентаризации.Создайте новый файл для продукта, 3-contoso-products-upsert-update.json и вставьте следующий объект JSON.
{ "id": "123", "categoryName": "xyz", "name": "_a new item updated", "inventory": [ { "location": "Dallas", "inventory": 100 } ] }
Обратите внимание, что этот объект имеет инвентаризацию.
В терминале Visual Studio Code выполните файл JavaScript для обновления нового продукта.
3-contoso-products-upsert.js
Так как продукт с идентификатором не существует, он вставляется. Затем скрипт обновляет продукт с инвентаризацией. Функции вставки и обновления используют один и тот же код для upsert.