AWSRDS中没有Vert.x上下文时的Hibernate响应式问题。
创始人
2024-09-26 20:01:31
0

当使用 Hibernate 响应式与 AWS RDS 时,必须确保在操作数据库时存在 Vert.x 上下文。解决此问题的一种方法是使用 AWS SDK for Java 的 AWS Secrets Manager 凭据提供程序,并将其与 Vert.x 或 Vert.x RxJava 集成。以下是使用 Vert.x RxJava 的示例代码:

// 从 AWS Secrets Manager 中获取凭据
AWSClientCredentials awsCreds = AWSClientCredentials.create(new DefaultAWSCredentialsProviderChain());

SecretsManagerClient secretsManagerClient = SecretsManagerClient.builder()
        .credentialsProvider(awsCreds.getProvider())
        .region(Region.US_EAST_1)
        .build();

GetSecretValueRequest getSecretValueRequest = GetSecretValueRequest.builder()
        .secretId("myDatabaseCredentials")
        .build();

// 获取数据库凭据并使用 Vert.x 上下文创建数据库连接
Maybe connectionMaybe = Single.fromFuture(secretsManagerClient.getSecretValue(getSecretValueRequest))
        .map(secret -> Json.decodeValue(secret.secretString(), JsonObject.class))
        .map(credentials -> PgPool.pool(Vertx.vertx(), new PgConnectOptions()
                .setHost(credentials.getString("host"))
                .setPort(credentials.getInteger("port"))
                .setDatabase(credentials.getString("database"))
                .setUser(credentials.getString("username"))
                .setPassword(credentials.getString("password")),
                new PoolOptions().setMaxSize(5)));

// 在 Vert.x 上下文中使用响应式 Hibernate 实体类和数据库连接执行操作
context.runOnContext(() -> {
    Uni.createFrom().item(new ExampleEntity("John", "Doe"))
            .flatMap(entity -> Uni.createFrom().voidItem()
                    .invoke(() -> System.out.println("Saving entity: " + entity)))
            .flatMap(() -> connectionMaybe.toUni())
            .flatMap(connection -> ReactiveSqlClient.newInstance(connection)
                    .preparedQuery("INSERT INTO example_entity (first_name, last_name) VALUES ($1, $2)")
                    .execute(Tuple.of("John", "Doe")))
            .flatMap(resultSet -> Uni.createFrom().voidItem()
                    .invoke(() -> System.out.println("Rows inserted: " + resultSet.rowCount())))
            .flatMap

相关内容

热门资讯

出现新变化!福建大玩家辅助操作... 您好:福建大玩家辅助操作视频这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用...
第九分钟开挂!微信小程序微乐挖... 第九分钟开挂!微信小程序微乐挖坑辅助免费,花花生活圈可以开挂,教你教程-2026最新版本微信小程序微...
此事引发广泛关注!三哥玩摆头注... 此事引发广泛关注!三哥玩摆头注可以控制(辅助挂)其实是有挂(有挂法门)-哔哩哔哩 【无需打开直接搜索...
九分钟开挂!皮皮透视辅助软件工... 九分钟开挂!皮皮透视辅助软件工具,皇豪互众控制系统下载,分享教程-2026最新版本1、九分钟开挂!皮...
今天上午!蜀山四川辅助脚本(辅... 今天上午!蜀山四川辅助脚本(辅助挂)一直真的有挂(有挂方案)-哔哩哔哩;亲,蜀山四川辅助脚本这款游戏...
四分钟开挂!闲逸同花插件,欢聚... 四分钟开挂!闲逸同花插件,欢聚水鱼辅助视频,必备教程-2026最新版本1、欢聚水鱼辅助视频透视辅助简...
为切实保障!牌乐门安全黑科技是... 为切实保障!牌乐门安全黑科技是真的吗(辅助挂)其实真的是有挂(有挂方针)-哔哩哔哩您好:牌乐门安全黑...
五分钟开挂!约局吧辅助器下载,... 五分钟开挂!约局吧辅助器下载,兴动互娱辅助工具,介绍教程-2026最新版本1、该软件可以轻松地帮助玩...
据了解!今日长牌破解(辅助挂)... 据了解!今日长牌破解(辅助挂)原来是有挂的(有挂机巧)-哔哩哔哩 了解更多开挂安装加(1367043...
3分钟开挂!广西老友玩友破解视... 3分钟开挂!广西老友玩友破解视频,玄龙辅助工具,教你教程-2026最新版本1)广西老友玩友破解视频辅...