SpringBoot项目结合JPA与Webflux改造及PostgreSQL连接问题求助

一、先搞定R2DBC PostgreSQL URL错误 #

R2DBC的URL格式和JDBC完全不同，用JDBC格式直接套肯定报错，正确配置方式：

正确URL格式 #

spring.r2dbc.url=r2dbc:postgresql://localhost:5432/你的数据库名
spring.r2dbc.username=你的用户名
spring.r2dbc.password=你的密码

注意点：

• 前缀是r2dbc:postgresql，不是JDBC的jdbc:postgresql
• 别把用户名密码拼进URL里（非要拼的话，参数名是username和password，不是JDBC的user/pass）
• 必须引入正确的依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
<dependency>
    <groupId>io.r2dbc</groupId>
    <artifactId>r2dbc-postgresql</artifactId>
    <scope>runtime</scope>
</dependency>

二、保留@OneToMany/@OneToOne关联的响应式改造 #

JPA的关联注解是阻塞式ORM的产物，R2DBC不直接支持，得换响应式的玩法：

1. 保留实体关联字段，手动实现关联查询（最灵活） #

先把实体类的JPA注解去掉，换成R2DBC的@Table/@Id：

@Table("users")
public class User {
    @Id
    private Long id;
    private String name;
    // 保留关联字段，不用JPA注解
    private List<Order> orders;
    // getters/setters
}

@Table("orders")
public class Order {
    @Id
    private Long id;
    private Long userId;
    private BigDecimal amount;
    // getters/setters
}

然后在Repository写联合查询，Service层组装数据：

// Repository
public interface UserRepository extends ReactiveCrudRepository<User, Long> {
    @Query("SELECT u.id as user_id, u.name, o.id as order_id, o.amount FROM users u LEFT JOIN orders o ON u.id = o.user_id WHERE u.id = :userId")
    Flux<UserOrderDTO> findUserWithOrders(Long userId);
}

// 投影DTO接收查询结果
public class UserOrderDTO {
    private Long userId;
    private String name;
    private Long orderId;
    private BigDecimal amount;
    // getters/setters
}

// Service层组装
public Mono<User> getUserWithOrders(Long userId) {
    return userRepository.findUserWithOrders(userId)
            .collectList()
            .map(dtos -> {
                if (dtos.isEmpty()) return null;
                User user = new User();
                user.setId(dtos.get(0).getUserId());
                user.setName(dtos.get(0).getName());
                List<Order> orders = dtos.stream()
                        .filter(dto -> dto.getOrderId() != null)
                        .map(dto -> {
                            Order order = new Order();
                            order.setId(dto.getOrderId());
                            order.setAmount(dto.getAmount());
                            return order;
                        })
                        .collect(Collectors.toList());
                user.setOrders(orders);
                return user;
            });
}

2. 用@Relation简化关联（Spring Data R2DBC 1.2+可用） #

如果你的Spring Data R2DBC版本够新，直接用@Relation注解声明关联：

@Table("users")
public class User {
    @Id
    private Long id;
    private String name;
    // 声明关联：orders是集合关系，关联字段是userId
    @Relation(collectionRelation = "orders", joinColumns = @JoinColumn(name = "user_id"))
    private List<Order> orders;
    // getters/setters
}

@Table("orders")
public class Order {
    @Id
    private Long id;
    private Long userId;
    private BigDecimal amount;
    // getters/setters
}

Repository直接用派生查询：

public interface UserRepository extends ReactiveCrudRepository<User, Long> {
    Mono<User> findByIdWithOrders(Long id);
}

这种方式底层会自动做JOIN查询，但要注意性能，数据量大的时候建议还是手动写查询。

三、整体改造的必做步骤 #

• 替换Spring Web为WebFlux：删掉spring-boot-starter-web，加spring-boot-starter-webflux依赖
• 所有DAO、Service方法的返回类型从List/Optional改成Flux/Mono
• 控制器方法保持@RestController，返回Flux/Mono，走响应式处理
• 事务改用响应式事务管理器：

@Bean
public ReactiveTransactionManager transactionManager(ConnectionFactory connectionFactory) {
    return new R2dbcTransactionManager(connectionFactory);
}

内容的提问来源于stack exchange，提问作者Madara Uchiha