如何使用 AWS Redshift Data API 使用 Java 执行 SQL？ [关闭]

Question

有人可以帮我获取使用 Java 和 Redshift Data API 执行 SQL 的确切代码吗？

我们将在 Spring Boot 中使用 Java 创建 API，它将执行请求正文中提供的 SQL。后端将是 Redshift。在这种情况下，希望使用 Redshift Data API 来执行 SQL 而不是 JDBCTemplate，因为 AWS 提供了很好的功能，例如异步调用，避免 DB 连接池等。

Answer 1

要执行 SQL 语句（不使用 Java JDBC API），您可以调用 executeStatement 方法并使用 ExecuteStatementRequest object's sql method 指定 SQL 语句（例如 - CREATE 语句）。

这是一个使用 Redshift Data API 运行 SQL 语句的示例，该语句创建了一个名为 work1 的表。

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
import software.amazon.awssdk.services.redshiftdata.RedshiftDataClient;
import software.amazon.awssdk.services.redshiftdata.model.ExecuteStatementRequest;
import software.amazon.awssdk.services.redshiftdata.model.ExecuteStatementResponse;
import software.amazon.awssdk.services.redshiftdata.model.RedshiftDataException;

public class CreateTable {

    public static void main(String[] args) {

        String clusterIdentifier = "redshift-items";
        String dataBase = "dev";
        String user = "root";

        String sqlStatement = "CREATE TABLE work1(\n" +
                "    idwork VARCHAR(45) PRIMARY KEY,\n" +
                "    date Date,\n" +
                "    description VARCHAR(400),\n" +
                "    guide VARCHAR(45),\n" +
                "    status VARCHAR(400),\n" +
                "    username VARCHAR(45),\n" +
                "    archive BOOLEAN\n" +
                ")  ;";

        Region region = Region.US_EAST_1;
        RedshiftDataClient redshiftDataClient = RedshiftDataClient.builder()
                .region(region)
                .build();

    try {
        ExecuteStatementRequest statementRequest = ExecuteStatementRequest.builder()
               .clusterIdentifier(clusterIdentifier)
                .dbUser(user)
                .database(dataBase)
                .sql(sqlStatement)
                .build();

        ExecuteStatementResponse resp = redshiftDataClient.executeStatement(statementRequest);
        System.out.println("The query id is " +resp.id());

    } catch (RedshiftDataException e) {
        System.err.println(e.getMessage());
        System.exit(1);
    }

}
}

这行得通，我可以在 Redshift 控制台中查看表格：

对于 Java Data API V2，确保将此依赖项添加到 POM 文件中（如果您使用的是 Gradle 文件，请将其转换为 Gradle）：

  <dependency>
      <groupId>software.amazon.awssdk</groupId>
      <artifactId>redshiftdata</artifactId>
   </dependency>

对于此示例，凭据位于凭据文件中，该文件位于 Windows 上的 C:\Users\USERNAME.aws\credentials。