Dynamodb 简明教程

DynamoDB - Getting Items

在 DynamoDB 中检索项目需要使用 GetItem，并指定表名和项目主键。请务必包含一个完整的主键，而不是省略一部分。

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

GetItem 行为符合三个默认值−

  1. 以最终一致读取执行。

  2. It provides all attributes.

  3. 不详细说明其预留单元消耗。

这些参数允许您覆盖默认的 GetItem 行为。

Retrieve an Item

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

然而，您可以更改 GetItem 的默认最终一致读取，但获取最新数据的成本仍然是消耗更多的预留单元；具体来说，消耗的资源是原来的两倍。请注意，DynamoDB 通常在一秒内使每个副本保持一致。

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

Item Retrieval Using 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());

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

Note − 以下示例可能假设之前创建过数据源。在尝试执行之前，获取支持库并创建必要的数据源（具有所需特性的表，或其他参考源）。

此示例还使用 Eclipse IDE、AWS 凭据文件和 Eclipse AWS Java 项目中的 AWS 工具包。

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