如何实现仅针对活跃状态的用户订阅唯一约束？

这个需求完全合理，符合常见的订阅业务逻辑：

• 用户同一时间只能拥有一个有效的活跃订阅，否则会引发业务逻辑混乱（比如重复扣费、权益冲突）
• 非活跃状态（如inactive、processed）的订阅属于历史记录，用户可能多次产生这类记录（比如订阅过期后重新订阅、多次处理订单），允许多条是正常的业务需求

1. 数据库层面：创建部分唯一索引（核心约束） #

必须先在数据库层面实现约束，这是最可靠的防线，能避免绕过应用直接操作数据库的情况。

PostgreSQL 写法 #

CREATE UNIQUE INDEX unique_active_user_subscription 
ON user_subscription_plan (user_id) 
WHERE status = 'active';

MySQL 8.0.13+ 写法 #

MySQL 从8.0.13版本开始支持条件唯一索引，写法和PostgreSQL一致：

CREATE UNIQUE INDEX unique_active_user_subscription 
ON user_subscription_plan (user_id) 
WHERE status = 'active';

这个索引会强制：当status为active时，user_id必须唯一，其他状态的记录不受限制。

2. 实体类/应用层：添加业务校验（友好提示） #

数据库约束触发时会抛出底层异常，为了给用户更友好的错误提示，建议在实体类或业务层添加前置校验。以下以JPA（Hibernate）为例说明：

方式1：使用JPA生命周期注解（@PrePersist/@PreUpdate） #

在实体类中添加校验逻辑，在保存或更新前检查是否存在重复的活跃订阅：

import jakarta.persistence.*;

@Entity
@Table(name = "user_subscription_plan")
public class UserSubscriptionPlan {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private Long userId;

    private String status;

    // 其他字段、getter、setter省略

    @PrePersist
    @PreUpdate
    private void validateActiveSubscription() {
        if ("active".equals(this.status)) {
            // 获取EntityManager执行查询
            EntityManager em = Persistence.createEntityManagerFactory("yourPersistenceUnit").createEntityManager();
            try {
                // 查询当前用户是否已有活跃订阅（更新时排除自身）
                String jpql = "SELECT COUNT(u) FROM UserSubscriptionPlan u " +
                        "WHERE u.userId = :userId AND u.status = 'active' " +
                        "AND u.id != :currentId";
                Long count = em.createQuery(jpql, Long.class)
                        .setParameter("userId", this.userId)
                        .setParameter("currentId", this.id == null ? -1L : this.id)
                        .getSingleResult();

                if (count > 0) {
                    throw new IllegalArgumentException("该用户已存在活跃状态的订阅");
                }
            } finally {
                em.close();
            }
        }
    }
}

方式2：业务层（Service）校验 #

更推荐将校验逻辑放在Service层，保持实体类职责单一：

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserSubscriptionPlanService {
    private final UserSubscriptionPlanRepository subscriptionRepository;

    public UserSubscriptionPlanService(UserSubscriptionPlanRepository subscriptionRepository) {
        this.subscriptionRepository = subscriptionRepository;
    }

    @Transactional
    public UserSubscriptionPlan saveSubscription(UserSubscriptionPlan plan) {
        if ("active".equals(plan.getStatus())) {
            long activeCount;
            if (plan.getId() == null) {
                // 新增：直接统计用户活跃订阅数量
                activeCount = subscriptionRepository.countByUserIdAndStatus(plan.getUserId(), "active");
            } else {
                // 更新：排除当前记录
                activeCount = subscriptionRepository.countByUserIdAndStatusAndIdNot(plan.getUserId(), "active", plan.getId());
            }

            if (activeCount > 0) {
                throw new RuntimeException("用户已存在活跃订阅，无法新增或更新为活跃状态");
            }
        }
        return subscriptionRepository.save(plan);
    }
}

对应的Repository接口：

import org.springframework.data.jpa.repository.JpaRepository;

public interface UserSubscriptionPlanRepository extends JpaRepository<UserSubscriptionPlan, Long> {
    long countByUserIdAndStatus(Long userId, String status);
    long countByUserIdAndStatusAndIdNot(Long userId, String status, Long id);
}

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