DynamoDB - 獲取專案

在DynamoDB中檢索專案需要使用GetItem，並指定表名和專案主鍵。請確保包含完整的主鍵，而不是省略部分主鍵。

例如，省略複合鍵的排序鍵。

GetItem的行為符合三個預設值：

它作為最終一致讀取執行。
它提供所有屬性。
它不詳細說明其容量單元消耗。

這些引數允許您覆蓋預設的GetItem行為。

檢索專案

DynamoDB透過在多個伺服器上維護專案的多個副本以確保可靠性。每次成功的寫入都會建立這些副本，但執行需要大量時間；這意味著最終一致性。這意味著您不能在寫入專案後立即嘗試讀取。

您可以更改GetItem的預設最終一致讀取，但是，獲取更即時資料的成本仍然是消耗更多容量單元；具體來說，是兩倍。

您可以使用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專案中的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());
      }
   }
}

列印頁面