dynamodbmapper batchdelete方法在Java中不起作用

Question

您好，我正在使用以下依赖性来读取/写作对Spring Boot中的DynamoDB。 在内部，此API调用DynamoDBMapper执行其任何操作。 DynamoDbmapper是AWS SDK。 我相信，DynampMapper批次delete Call in AWS SDK

<dependency>
            <groupId>com.github.derjust</groupId>
            <artifactId>spring-data-dynamodb</artifactId>
            <version>5.1.0</version>
        </dependency>

java.lang.reflect.InaccessibleObjectException: Unable to make final void java.lang.Throwable.setCause(java.lang.Throwable) accessible: module java.base does not "opens java.lang" to unnamed module @1b083826

调用代码看起来像

 List<Matchup> matchups = (List<Matchup>) matchupRepository.findAll();

        DynamoDBMapper dynamoDBMapper = new DynamoDBMapper(amazonDynamoDBClient);
        try {
            dynamoDBMapper.batchDelete(matchups);
        }

        catch(Exception e) {
            log.error(e.toString());
        }

实体类的样子，因此

@Data
@NoArgsConstructor
@AllArgsConstructor
@DynamoDBTable(tableName = "Sportsbook")
public class Matchup {

    @DynamoDBAttribute(attributeName = "MatchupId")
    private String matchupId;

    @DynamoDBAttribute(attributeName = "SportsKey")
    private String sportsKey;

    @DynamoDBAttribute(attributeName = "CommenceTime")
    private String commenceTime;

    @DynamoDBAttribute(attributeName = "HomeTeam")
    private String homeTeam;

    @DynamoDBAttribute(attributeName = "AwayTeam")
    private String awayTeam;


    @DynamoDBHashKey(attributeName = "PK")
    public String getPK() {
        return "MATCHUP#"+ matchupId;
    }

    public void setPK(String pk) {
        //do nothing
    }

}

我注意到除了BatchDelete之外，DynamoDBMapper工作的所有其他方法。它具有以下方法签名

List<FailedBatch> batchDelete(Iterable<? extends Object> var1);

Answer 1

您没有使用最新的AWS Java API执行此任务。 dynamodbmapper 是Java V1的 AWS SDK的一部分，不再被视为最佳实践 。这是DynamoDBMAPPER，它是V1 Dev指南的一部分=“ nofollow noreferrer”> https://docs.aws.amazon.com/sdk-for-java/v1/developer-guide/examples-dynamodb-items.htmls.html

Amazon States：

Java 2.x的AWS SDK是版本1.x代码库的主要重写。它建在Java 8+之上，并添加了几个经常要求的功能。其中包括对非阻滞I/O的支持以及在运行时插入其他HTTP实现的能力。

执行此用例如 aws java v2 dev指南：

https://docs.aws.aws.amazon.com/sdk-for-java/latest/latest/deeverice-guide-guide/dynamodb-enhanced-client .html

这是一个代码示例，使用增强的客户端显示H OW ow 。首先 - 假设您有一个带有此数据的客户表，并且要删除批处理记录。

这是增强端客户端的完整代码示例。

package com.example.dynamodb;

// snippet-start:[dynamodb.java2.mapping.batchdelete.import]

import software.amazon.awssdk.auth.credentials.ProfileCredentialsProvider;
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClient;
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbTable;
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
import software.amazon.awssdk.enhanced.dynamodb.model.BatchWriteItemEnhancedRequest;
import software.amazon.awssdk.enhanced.dynamodb.model.DeleteItemEnhancedRequest;
import software.amazon.awssdk.enhanced.dynamodb.model.WriteBatch;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
import software.amazon.awssdk.services.dynamodb.model.DynamoDbException;
import software.amazon.awssdk.enhanced.dynamodb.Key;

import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
// snippet-end:[dynamodb.java2.mapping.batchdelete.import]

/*
 * Before running this code example, create an Amazon DynamoDB table named Customer with these columns:
 *   - id - the id of the record that is the key
 *   - custName - the customer name
 *   - email - the email value
 *   - registrationDate - an instant value when the item was added to the table
 *
 * Also, ensure that you have set up your development environment, including your credentials.
 *
 * For information, see this documentation topic:
 *
 * https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
 */
public class EnhancedBatchDeleteItems {

    public static void main(String[] args) {

        ProfileCredentialsProvider credentialsProvider = ProfileCredentialsProvider.create();
        Region region = Region.US_EAST_1;
        DynamoDbClient ddb = DynamoDbClient.builder()
                .region(region)
                .credentialsProvider(credentialsProvider)
                .build();

        DynamoDbEnhancedClient enhancedClient = DynamoDbEnhancedClient.builder()
                .dynamoDbClient(ddb)
                .build();

        deleteBatchRecords(enhancedClient);
        ddb.close();
    }

    // snippet-start:[dynamodb.java2.mapping.batchdelete.main]
    public static void deleteBatchRecords(DynamoDbEnhancedClient enhancedClient) {

        try {
            DynamoDbTable<Customer> mappedTable = enhancedClient.table("Customer", TableSchema.fromBean(Customer.class));
            Key key1 = Key.builder()
                    .partitionValue("id110")
                    .build();

            Key key2 = Key.builder()
                    .partitionValue("id120")
                    .build();

            BatchWriteItemEnhancedRequest request =  BatchWriteItemEnhancedRequest.builder()
                    .writeBatches(WriteBatch.builder(Customer.class)
                                    .mappedTableResource(mappedTable)
                                    .addDeleteItem(DeleteItemEnhancedRequest.builder()
                                            .key(key1)
                                            .build())
                                    .build(),
                            WriteBatch.builder(Customer.class)
                                    .mappedTableResource(mappedTable)
                                    .addDeleteItem(DeleteItemEnhancedRequest.builder()
                                            .key(key2)
                                            .build())
                                    .build())
                    .build();

            // Delete these two items from the table.
            enhancedClient.batchWriteItem(request);
            System.out.println("Records deleted");

        } catch (DynamoDbException e) {
            System.err.println(e.getMessage());
            System.exit(1);
        }
    }
    // snippet-end:[dynamodb.java2.mapping.batchdelete.main]
}

More information here:

https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/DynamoDbEnhancedClient.html#batchWriteItem-software.amazon.awssdk 。

​

​=“ https://i.sstatic.net/sc7yr.png” alt =“在此处输入图像说明”>

最后，您可以找到 customer class class，pom file等在 。