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

Concluído

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

  1. No Visual Studio Code, no menu Arquivo , selecione Novo arquivo de texto.

  2. No menu File (Ficheiro), selecione Save As (Guardar Como). Salve o novo arquivo com o nome 2-contoso-products-find.js.

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

  5. Execute outra consulta para encontrar todos os produtos com a palavra Blue no nome.

    node 2-contoso-products-find.js find name '%Blue%'
    
  6. 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
    
  7. 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

  1. No Visual Studio Code, no menu Arquivo , selecione Novo arquivo de texto.

  2. No menu File (Ficheiro), selecione Save As (Guardar Como). Salve o novo arquivo com o nome 3-contoso-products-upsert.js.

  3. 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);
    
  4. 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.

  5. 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.

  6. 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.