📌  相关文章
📜  DynamoDB-获取项目

📅  最后修改于: 2020-11-28 13:58:18             🧑  作者: Mango

要在DynamoDB中检索项目，需要使用GetItem，并指定表名称和项目主键。确保包括完整的主键，而不要省略一部分。

例如，省略组合键的排序键。

GetItem行为符合三个默认值-

  • 它作为最终一致的读取执行。
  • 它提供了所有属性。
  • 它没有详细说明其容量单位消耗。

这些参数使您可以覆盖默认的GetItem行为。

检索项目

DynamoDB通过在多台服务器上维护项目的多个副本来确保可靠性。每次成功写入都会创建这些副本，但是需要花费大量时间才能执行。含义最终保持一致。这意味着您不能在写入项目后立即尝试读取。

您可以更改GetItem的默认最终一致性读取，但是，更多当前数据的成本仍然消耗了更多容量单位。具体来说是两倍。注意DynamoDB通常可以在一秒钟内在每个副本上实现一致性。

您可以使用GUI控制台，Java或其他工具来执行此任务。

使用Java检索项目

在项目检索操作中使用Java需要创建DynamoDB类实例，表类实例，并调用表实例的getItem方法。然后指定项目的主键。

您可以查看以下示例-

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

在某些情况下，您需要指定此操作的参数。

以下示例将.withProjectionExpression和GetItemSpec用于检索规范-

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

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

您也可以查看以下更大的示例，以更好地理解。

注–以下示例可能假定以前创建的数据源。在尝试执行之前，请获取支持库并创建必要的数据源(具有所需特征的表或其他引用的源)。

此样本还使用Eclipse IDE，AWS凭证文件和Eclipse AWS Java Project中的AWS Toolkit。

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