Creare una tabella DynamoDB con uno o più indici secondari globali con un SDK AWS. - Esempi di codice per SDK AWS

Sono disponibili altri esempi per SDK AWS nel repository GitHub della documentazione degli esempi per SDK AWS.

Creare una tabella DynamoDB con uno o più indici secondari globali con un SDK AWS.

L’esempio di codice seguente mostra come creare una tabella con un indice secondario globale.

Java
SDK per Java 2.x

Crea una tabella DynamoDB con un indice secondario globale con AWS SDK for Java 2.x.

import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider; import software.amazon.awssdk.core.waiters.WaiterResponse; import software.amazon.awssdk.regions.Region; import software.amazon.awssdk.services.dynamodb.DynamoDbClient; import software.amazon.awssdk.services.dynamodb.model.AttributeDefinition; import software.amazon.awssdk.services.dynamodb.model.AttributeValue; import software.amazon.awssdk.services.dynamodb.model.CreateTableRequest; import software.amazon.awssdk.services.dynamodb.model.DeleteTableRequest; import software.amazon.awssdk.services.dynamodb.model.DescribeTableRequest; import software.amazon.awssdk.services.dynamodb.model.DescribeTableResponse; import software.amazon.awssdk.services.dynamodb.model.DynamoDbException; import software.amazon.awssdk.services.dynamodb.model.GlobalSecondaryIndex; import software.amazon.awssdk.services.dynamodb.model.KeySchemaElement; import software.amazon.awssdk.services.dynamodb.model.KeyType; import software.amazon.awssdk.services.dynamodb.model.Projection; import software.amazon.awssdk.services.dynamodb.model.ProjectionType; import software.amazon.awssdk.services.dynamodb.model.ProvisionedThroughput; import software.amazon.awssdk.services.dynamodb.model.PutItemRequest; import software.amazon.awssdk.services.dynamodb.model.QueryRequest; import software.amazon.awssdk.services.dynamodb.model.QueryResponse; import software.amazon.awssdk.services.dynamodb.model.ScalarAttributeType; import software.amazon.awssdk.services.dynamodb.waiters.DynamoDbWaiter; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; public void createTable() { try { // Attribute definitions final List<AttributeDefinition> attributeDefinitions = new ArrayList<>(); attributeDefinitions.add(AttributeDefinition.builder() .attributeName(ISSUE_ID_ATTR) .attributeType(ScalarAttributeType.S) .build()); attributeDefinitions.add(AttributeDefinition.builder() .attributeName(TITLE_ATTR) .attributeType(ScalarAttributeType.S) .build()); attributeDefinitions.add(AttributeDefinition.builder() .attributeName(CREATE_DATE_ATTR) .attributeType(ScalarAttributeType.S) .build()); attributeDefinitions.add(AttributeDefinition.builder() .attributeName(DUE_DATE_ATTR) .attributeType(ScalarAttributeType.S) .build()); // Key schema for table final List<KeySchemaElement> tableKeySchema = new ArrayList<>(); tableKeySchema.add(KeySchemaElement.builder() .attributeName(ISSUE_ID_ATTR) .keyType(KeyType.HASH) .build()); // Partition key tableKeySchema.add(KeySchemaElement.builder() .attributeName(TITLE_ATTR) .keyType(KeyType.RANGE) .build()); // Sort key // Initial provisioned throughput settings for the indexes final ProvisionedThroughput ptIndex = ProvisionedThroughput.builder() .readCapacityUnits(1L) .writeCapacityUnits(1L) .build(); // CreateDateIndex final List<KeySchemaElement> createDateKeySchema = new ArrayList<>(); createDateKeySchema.add(KeySchemaElement.builder() .attributeName(CREATE_DATE_ATTR) .keyType(KeyType.HASH) .build()); createDateKeySchema.add(KeySchemaElement.builder() .attributeName(ISSUE_ID_ATTR) .keyType(KeyType.RANGE) .build()); final Projection createDateProjection = Projection.builder() .projectionType(ProjectionType.INCLUDE) .nonKeyAttributes(DESCRIPTION_ATTR, STATUS_ATTR) .build(); final GlobalSecondaryIndex createDateIndex = GlobalSecondaryIndex.builder() .indexName(CREATE_DATE_INDEX) .keySchema(createDateKeySchema) .projection(createDateProjection) .provisionedThroughput(ptIndex) .build(); // TitleIndex final List<KeySchemaElement> titleKeySchema = new ArrayList<>(); titleKeySchema.add(KeySchemaElement.builder() .attributeName(TITLE_ATTR) .keyType(KeyType.HASH) .build()); titleKeySchema.add(KeySchemaElement.builder() .attributeName(ISSUE_ID_ATTR) .keyType(KeyType.RANGE) .build()); final Projection titleProjection = Projection.builder().projectionType(ProjectionType.KEYS_ONLY).build(); final GlobalSecondaryIndex titleIndex = GlobalSecondaryIndex.builder() .indexName(TITLE_INDEX) .keySchema(titleKeySchema) .projection(titleProjection) .provisionedThroughput(ptIndex) .build(); // DueDateIndex final List<KeySchemaElement> dueDateKeySchema = new ArrayList<>(); dueDateKeySchema.add(KeySchemaElement.builder() .attributeName(DUE_DATE_ATTR) .keyType(KeyType.HASH) .build()); final Projection dueDateProjection = Projection.builder().projectionType(ProjectionType.ALL).build(); final GlobalSecondaryIndex dueDateIndex = GlobalSecondaryIndex.builder() .indexName(DUE_DATE_INDEX) .keySchema(dueDateKeySchema) .projection(dueDateProjection) .provisionedThroughput(ptIndex) .build(); final CreateTableRequest createTableRequest = CreateTableRequest.builder() .tableName(TABLE_NAME) .keySchema(tableKeySchema) .attributeDefinitions(attributeDefinitions) .globalSecondaryIndexes(createDateIndex, titleIndex, dueDateIndex) .provisionedThroughput(ProvisionedThroughput.builder() .readCapacityUnits(1L) .writeCapacityUnits(1L) .build()) .build(); System.out.println("Creating table " + TABLE_NAME + "..."); dynamoDbClient.createTable(createTableRequest); // Wait for table to become active System.out.println("Waiting for " + TABLE_NAME + " to become ACTIVE..."); final DynamoDbWaiter waiter = dynamoDbClient.waiter(); final DescribeTableRequest describeTableRequest = DescribeTableRequest.builder().tableName(TABLE_NAME).build(); final WaiterResponse<DescribeTableResponse> waiterResponse = waiter.waitUntilTableExists(describeTableRequest); waiterResponse.matched().response().ifPresent(response -> System.out.println("Table is now ready for use")); } catch (DynamoDbException e) { System.err.println("Error creating table: " + e.getMessage()); e.printStackTrace(); } }
  • Per informazioni dettagliate sull’API, consulta CreateTable nella documentazione di riferimento dell’API AWS SDK for Java 2.x.