将适用于 java 的 AWS Aurora 数据 api 与适用于 Java 2.x 的 AWS Sdk 结合使用

Question

我一直在尝试使用我的 lambda 中的 Aurora aws 数据 API 来执行一些操作，例如在表上插入和更新。我面临的问题是官方doc 仅提供有关使用AWS SDK for Java 1.x 版的详细信息。与版本 1.0 相比，最新版本的 aws java sdk 2.x 有一些更改，这使我无法将代码移植到最新的 sdk。我找不到 java aws sdk 2.0 的数据 api 的更新文档。如果有人能给我提供一个示例代码，在最新的 sdk 上执行与以下相同的操作，那就太好了：

public void insert() {
    AWSRDSData rdsData = AWSRDSDataClient.builder().build();

    BatchExecuteStatementRequest request = new BatchExecuteStatementRequest()
            .withDatabase("test")
            .withResourceArn(RESOURCE_ARN)
            .withSecretArn(SECRET_ARN)
            .withSql("INSERT INTO test_table2 VALUES (:string, :number)")
            .withParameterSets(Arrays.asList(
                    Arrays.asList(
                            new SqlParameter().withName("string").withValue(new Field().withStringValue("Hello")),
                            new SqlParameter().withName("number").withValue(new Field().withLongValue(1L))
                    ),
                    Arrays.asList(
                            new SqlParameter().withName("string").withValue(new Field().withStringValue("World")),
                            new SqlParameter().withName("number").withValue(new Field().withLongValue(2L))
                    )
            ));

    rdsData.batchExecuteStatement(request);
}

Answer 1

所以我浏览了 aws sdk 第 2 版，发现以下代码对我有用：

public ExecuteStatementResponse insert() {
    RdsDataClient rdsData = RdsDataClient
            .builder()
            .build();
    try {
        ExecuteStatementRequest executeStatementRequest = ExecuteStatementRequest
                .builder()
                .resourceArn(resourceArn)
                .secretArn(secretArn)
                .database(database)
                .sql("INSERT INTO test_table2 VALUES (:string, :number)")
                .parameters(Arrays.asList(
                        SqlParameter.builder().name("name1").value(Field.builder().stringValue("Hello").build()).build(),
                        SqlParameter.builder().name("name2").value(Field.builder().longValue(20L).build()).build()
                ))
                .continueAfterTimeout(true)
                .build();
        return rdsData.executeStatement(executeStatementRequest);
    } catch (BadRequestException | StatementTimeoutException | InternalServerErrorException | ForbiddenException
            | ServiceUnavailableErrorException dataException) {
        LOG.error("Execute statement failed: Error Message: {}, Cause: {}",
                dataException.getMessage(), dataException.getCause());
    }
    return null;
}