📜  DynamoDB-创建表

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


创建表通常包括生成表,命名表,建立其主键属性以及设置属性数据类型。

利用GUI控制台,Java或其他选项来执行这些任务。

使用GUI控制台创建表

通过访问位于https://console.aws.amazon.com/dynamodb的控制台来创建表。然后选择“创建表”选项。

GUI控制台

我们的示例生成一个表,该表中填充了产品信息,其中包含由ID号(数字属性)标识的唯一属性的产品。在创建表屏幕中,在表名字段中输入表名;在分区键字段中输入主键(ID);然后输入“ Number”作为数据类型。

建立表格

输入所有信息后,选择创建

使用Java创建表

使用Java创建相同的表。它的主键包含以下两个属性-

  • ID-使用分区键,以及ScalarAttributeType N ,表示数字。

  • 命名法-使用排序键,并使用ScalarAttributeType S (表示字符串)。

Java使用createTable方法生成表;在调用中,指定了表名,主键属性和属性数据类型。

您可以查看以下示例-

import java.util.Arrays;
 
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClient; 
import com.amazonaws.services.dynamodbv2.document.DynamoDB; 
import com.amazonaws.services.dynamodbv2.document.Table; 

import com.amazonaws.services.dynamodbv2.model.AttributeDefinition; 
import com.amazonaws.services.dynamodbv2.model.KeySchemaElement; 
import com.amazonaws.services.dynamodbv2.model.KeyType; 
import com.amazonaws.services.dynamodbv2.model.ProvisionedThroughput; 
import com.amazonaws.services.dynamodbv2.model.ScalarAttributeType;
 
public class ProductsCreateTable {  
   public static void main(String[] args) throws Exception { 
      AmazonDynamoDBClient client = new AmazonDynamoDBClient() 
         .withEndpoint("http://localhost:8000");  
      
      DynamoDB dynamoDB = new DynamoDB(client); 
      String tableName = "Products";  
      try { 
         System.out.println("Creating the table, wait..."); 
         Table table = dynamoDB.createTable (tableName, 
            Arrays.asList ( 
               new KeySchemaElement("ID", KeyType.HASH), // the partition key 
                                                         // the sort key 
               new KeySchemaElement("Nomenclature", KeyType.RANGE)
            ),
            Arrays.asList ( 
               new AttributeDefinition("ID", ScalarAttributeType.N), 
               new AttributeDefinition("Nomenclature", ScalarAttributeType.S)
            ),
            new ProvisionedThroughput(10L, 10L)
         );
         table.waitForActive(); 
         System.out.println("Table created successfully.  Status: " + 
            table.getDescription().getTableStatus());
            
      } catch (Exception e) {
         System.err.println("Cannot create the table: "); 
         System.err.println(e.getMessage()); 
      } 
   } 
}

在上面的示例中,请注意端点: .withEndpoint

它指示使用本地主机的本地安装。另外,请注意必需的ProvisionedThroughput参数,该参数会被本地安装忽略。