DynamoDB - รับรายการ

การดึงข้อมูลใน 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());

คุณยังสามารถทบทวนตัวอย่างที่ใหญ่กว่าต่อไปนี้เพื่อความเข้าใจที่ดีขึ้น

Note- ตัวอย่างต่อไปนี้อาจถือว่าเป็นแหล่งข้อมูลที่สร้างขึ้นก่อนหน้านี้ ก่อนที่จะพยายามดำเนินการให้จัดหาไลบรารีที่สนับสนุนและสร้างแหล่งข้อมูลที่จำเป็น (ตารางที่มีคุณสมบัติที่ต้องการหรือแหล่งอ้างอิงอื่น ๆ )

ตัวอย่างนี้ยังใช้ Eclipse IDE, ไฟล์ข้อมูลรับรอง AWS และ AWS Toolkit ภายใน Eclipse AWS Java Project

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