DynamoDB - อัปเดตรายการ

การอัปเดตรายการใน DynamoDB ส่วนใหญ่ประกอบด้วยการระบุคีย์หลักแบบเต็มและชื่อตารางสำหรับรายการ ต้องใช้ค่าใหม่สำหรับแต่ละแอตทริบิวต์ที่คุณแก้ไข การดำเนินการใช้UpdateItemซึ่งแก้ไขรายการที่มีอยู่หรือสร้างขึ้นจากการค้นพบรายการที่หายไป

ในการอัปเดตคุณอาจต้องการติดตามการเปลี่ยนแปลงโดยการแสดงค่าเดิมและค่าใหม่ก่อนและหลังการดำเนินการ UpdateItem ใช้ไฟล์ReturnValues พารามิเตอร์เพื่อให้บรรลุสิ่งนี้

Note - การดำเนินการไม่ได้รายงานการใช้หน่วยความจุ แต่คุณสามารถใช้ไฟล์ ReturnConsumedCapacity พารามิเตอร์.

ใช้คอนโซล GUI, Java หรือเครื่องมืออื่น ๆ เพื่อทำงานนี้

จะอัปเดตรายการโดยใช้เครื่องมือ GUI ได้อย่างไร

ไปที่คอนโซล ในบานหน้าต่างนำทางทางด้านซ้ายให้เลือกTables. เลือกตารางที่ต้องการจากนั้นเลือกItems แท็บ

เลือกรายการที่ต้องการสำหรับการอัปเดตและเลือก Actions | Edit.

แก้ไขแอตทริบิวต์หรือค่าที่จำเป็นในไฟล์ Edit Item หน้าต่าง.

อัปเดตรายการโดยใช้ Java

การใช้ Java ในการดำเนินการอัพเดตไอเท็มจำเป็นต้องสร้างอินสแตนซ์คลาส Table และเรียกใช้ updateItemวิธี. จากนั้นคุณระบุคีย์หลักของรายการและระบุไฟล์UpdateExpression รายละเอียดการปรับเปลี่ยนแอตทริบิวต์

ต่อไปนี้เป็นตัวอย่างของสิ่งเดียวกัน -

DynamoDB dynamoDB = new DynamoDB(new AmazonDynamoDBClient(
   new ProfileCredentialsProvider()));
   
Table table = dynamoDB.getTable("ProductList");

Map<String, String> expressionAttributeNames = new HashMap<String, String>();
expressionAttributeNames.put("#M", "Make");
expressionAttributeNames.put("#P", "Price
expressionAttributeNames.put("#N", "ID");

Map<String, Object> expressionAttributeValues = new HashMap<String, Object>();
expressionAttributeValues.put(":val1",
   new HashSet<String>(Arrays.asList("Make1","Make2")));
expressionAttributeValues.put(":val2", 1);       //Price

UpdateItemOutcome outcome =  table.updateItem(
   "internalID",                                 // key attribute name
   111,                                          // key attribute value
   "add #M :val1 set #P = #P - :val2 remove #N", // UpdateExpression
   expressionAttributeNames,
   expressionAttributeValues);

updateItem วิธีนี้ยังอนุญาตให้ระบุเงื่อนไขซึ่งสามารถดูได้ในตัวอย่างต่อไปนี้ -

Table table = dynamoDB.getTable("ProductList");
Map<String, String> expressionAttributeNames = new HashMap<String, String>();
expressionAttributeNames.put("#P", "Price");

Map<String, Object> expressionAttributeValues = new HashMap<String, Object>();
expressionAttributeValues.put(":val1", 44);  // change Price to 44
expressionAttributeValues.put(":val2", 15);  // only if currently 15

UpdateItemOutcome outcome = table.updateItem (new PrimaryKey("internalID",111),
   "set #P = :val1",                        // Update
   "#P = :val2",                            // Condition 
   expressionAttributeNames,
   expressionAttributeValues);

อัปเดตรายการโดยใช้ตัวนับ

DynamoDB อนุญาตให้ตัวนับอะตอมซึ่งหมายถึงการใช้ UpdateItem เพื่อเพิ่ม / ลดค่าแอตทริบิวต์โดยไม่ส่งผลกระทบต่อคำขออื่น ๆ นอกจากนี้ตัวนับจะอัปเดตอยู่เสมอ

ต่อไปนี้เป็นตัวอย่างที่อธิบายว่าสามารถทำได้อย่างไร

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 UpdateItemOpSample {  
   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 updateAddNewAttribute() { 
      Table table = dynamoDB.getTable(tableName);  
      try {  
         Map<String, String> expressionAttributeNames = new HashMap<String, String>(); 
         expressionAttributeNames.put("#na", "NewAttribute");  
         UpdateItemSpec updateItemSpec = new UpdateItemSpec() 
            .withPrimaryKey("ID", 303) 
            .withUpdateExpression("set #na = :val1") 
            .withNameMap(new NameMap() 
            .with("#na", "NewAttribute")) 
            .withValueMap(new ValueMap() 
            .withString(":val1", "A value")) 
            .withReturnValues(ReturnValue.ALL_NEW);  
            UpdateItemOutcome outcome =  table.updateItem(updateItemSpec);  
         
         // Confirm 
         System.out.println("Displaying updated item..."); 
         System.out.println(outcome.getItem().toJSONPretty());             
      } catch (Exception e) { 
         System.err.println("Cannot add an attribute in " + tableName); 
         System.err.println(e.getMessage()); 
      }         
   } 
}