DynamoDB - Obtendo itens

A recuperação de um item no DynamoDB requer o uso de GetItem e a especificação do nome da tabela e da chave primária do item. Certifique-se de incluir uma chave primária completa em vez de omitir uma parte.

Por exemplo, omitir a chave de classificação de uma chave composta.

O comportamento de GetItem está em conformidade com três padrões -

  • Ele é executado como uma leitura eventualmente consistente.
  • Ele fornece todos os atributos.
  • Não detalha o consumo da unidade de capacidade.

Esses parâmetros permitem que você substitua o comportamento padrão de GetItem.

Recuperar um Item

O DynamoDB garante confiabilidade por meio da manutenção de várias cópias de itens em vários servidores. Cada gravação bem-sucedida cria essas cópias, mas leva um tempo considerável para ser executada; significado eventualmente consistente. Isso significa que você não pode tentar uma leitura imediatamente após escrever um item.

Você pode alterar a leitura padrão eventualmente consistente de GetItem, no entanto, o custo de dados mais atuais continua sendo o consumo de mais unidades de capacidade; especificamente, duas vezes mais. Observação O DynamoDB normalmente atinge consistência em todas as cópias em um segundo.

Você pode usar o console da GUI, Java ou outra ferramenta para executar esta tarefa.

Recuperação de item usando Java

Usar Java em operações de recuperação de item requer a criação de uma instância de classe DynamoDB, instância de classe de tabela e chamar o método getItem da instância de tabela. Em seguida, especifique a chave primária do item.

Você pode revisar o seguinte exemplo -

DynamoDB dynamoDB = new DynamoDB(new AmazonDynamoDBClient( 
   new ProfileCredentialsProvider()));  
Table table = dynamoDB.getTable("ProductList");  
Item item = table.getItem("IDnum", 109);

Em alguns casos, você precisa especificar os parâmetros para esta operação.

O exemplo a seguir usa .withProjectionExpression e GetItemSpec para especificações de recuperação -

GetItemSpec spec = new GetItemSpec() 
   .withPrimaryKey("IDnum", 122) 
   .withProjectionExpression("IDnum, EmployeeName, Department") 
   .withConsistentRead(true);

Item item = table.getItem(spec);
System.out.println(item.toJSONPretty());

Você também pode revisar o seguinte exemplo maior para melhor compreensão.

Note- O exemplo a seguir pode assumir uma fonte de dados criada anteriormente. Antes de tentar executar, adquira bibliotecas de suporte e crie as fontes de dados necessárias (tabelas com as características necessárias ou outras fontes referenciadas).

Este exemplo também usa Eclipse IDE, um arquivo de credenciais AWS e o AWS Toolkit em um projeto Eclipse AWS Java.

package com.amazonaws.codesamples.document;

import java.io.IOException
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;

import com.amazonaws.auth.profile.ProfileCredentialsProvider;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClient;
import com.amazonaws.services.dynamodbv2.document.DeleteItemOutcome;
import com.amazonaws.services.dynamodbv2.document.DynamoDB;
import com.amazonaws.services.dynamodbv2.document.Item;
import com.amazonaws.services.dynamodbv2.document.Table;

import com.amazonaws.services.dynamodbv2.document.UpdateItemOutcome;
import com.amazonaws.services.dynamodbv2.document.spec.DeleteItemSpec;
import com.amazonaws.services.dynamodbv2.document.spec.UpdateItemSpec;
import com.amazonaws.services.dynamodbv2.document.utils.NameMap;
import com.amazonaws.services.dynamodbv2.document.utils.ValueMap;
import com.amazonaws.services.dynamodbv2.model.ReturnValue;

public class GetItemOpSample {
   static DynamoDB dynamoDB = new DynamoDB(new AmazonDynamoDBClient(
      new ProfileCredentialsProvider()));
   
   static String tblName = "ProductList";
   public static void main(String[] args) throws IOException {
      createItems();
      retrieveItem();
      
      // Execute updates
      updateMultipleAttributes();
      updateAddNewAttribute();
      updateExistingAttributeConditionally();
      
      // Item deletion
      deleteItem();
   }
   private static void createItems() {
      Table table = dynamoDB.getTable(tblName);
      try {
         Item item = new Item()
            .withPrimaryKey("ID", 303)
            .withString("Nomenclature", "Polymer Blaster 4000")
            .withStringSet( "Manufacturers",
            new HashSet<String>(Arrays.asList("XYZ Inc.", "LMNOP Inc.")))
            .withNumber("Price", 50000)
            .withBoolean("InProduction", true)
            .withString("Category", "Laser Cutter");
            table.putItem(item);
            
         item = new Item()
            .withPrimaryKey("ID", 313)
            .withString("Nomenclature", "Agitatatron 2000")
            .withStringSet( "Manufacturers",
            new HashSet<String>(Arrays.asList("XYZ Inc,", "CDE Inc.")))
            .withNumber("Price", 40000)
            .withBoolean("InProduction", true)
            .withString("Category", "Agitator");
         
         table.putItem(item);
      } catch (Exception e) {
         System.err.println("Cannot create items.");
         System.err.println(e.getMessage());
      }
   }
   private static void retrieveItem() {
      Table table = dynamoDB.getTable(tableName);
      try {
         Item item = table.getItem("ID", 303, "ID, Nomenclature, Manufacturers", null);
         System.out.println("Displaying retrieved items...");
         System.out.println(item.toJSONPretty());
      } catch (Exception e) {
         System.err.println("Cannot retrieve items.");
         System.err.println(e.getMessage());
      }
   }
}