Exercício – Adicionar código JavaScript para trabalhar com o Cosmos DB

15 minutos

Nesta unidade, você cria e executa scripts, que usam palavras-chave SQL como LIKE, JOIN e WHERE para encontrar dados com o Cosmos SDK.

Criar o script para localizar produtos no contêiner

No Visual Studio Code, no menu Arquivo , selecione Novo arquivo de texto.
No menu File (Ficheiro), selecione Save As (Guardar Como). Salve o novo arquivo com o nome 2-contoso-products-find.js.

Copie o seguinte JavaScript e cole-o nesse arquivo:

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");
}

No terminal do Visual Studio Code, execute o arquivo JavaScript para localizar todas as bicicletas:
```
node 2-contoso-products-find.js find categoryName '%Bikes%'
```
O bikes termo é envolvido com sinais de porcentagem, %indicando correspondência parcial.

A consulta SQL no executeSqlFind método para o contêiner usa a palavra-chave LIKE e os parâmetros de consulta para localizar quaisquer itens com um categoryName que inclua Bikes.
Execute outra consulta para encontrar todos os produtos com a palavra Blue no nome.
```
node 2-contoso-products-find.js find name '%Blue%'
```
Execute outra consulta para encontrar o inventário de produtos para bicicletas em Seattle.
```
node 2-contoso-products-find.js find-inventory categoryName '%Bikes%' location Seattle
```
Execute outra consulta para encontrar o inventário de todos os produtos com a palavra Blue no nome em Dallas.
```
node 2-contoso-products-find.js find-inventory name '%Blue%' location Dallas
```

Criar o script para upsert produtos para um contêiner

No Visual Studio Code, no menu Arquivo , selecione Novo arquivo de texto.
No menu File (Ficheiro), selecione Save As (Guardar Como). Salve o novo arquivo com o nome 3-contoso-products-upsert.js.

Copie o seguinte JavaScript e cole-o nesse arquivo:

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);

Crie um novo arquivo para o produto, 3-contoso-products-upsert-insert.json e cole o seguinte objeto JSON.
```
{
    "id": "123",
    "categoryName": "xyz",
    "name": "_a new item inserted"
}
```
Observe que este objeto com ID 123 não tem nenhum inventário.

Crie um novo arquivo para o produto, 3-contoso-products-upsert-update.json e cole o seguinte objeto JSON.

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

Observe que este objeto tem inventário.

No terminal de código do Visual Studio, execute o arquivo JavaScript para atualizar o novo produto.
```
node 3-contoso-products-upsert.js
```
Como o produto com esse ID não existe, o produto é inserido. Em seguida, o script atualiza o produto com o inventário. Tanto a funcionalidade de inserção quanto a de atualização usam o mesmo código para upsert.

Exercício – Adicionar código JavaScript para trabalhar com o Cosmos DB

Criar o script para localizar produtos no contêiner

Criar o script para upsert produtos para um contêiner

Comentários