Spring环境下单活跃数据库时多数据库实体注解与仓库配置咨询

一、通用User基类设计 #

要实现通用属性与方法复用，同时让子类适配不同数据库，可采用抽象基类作为通用模板，子类继承后添加对应数据库的注解：

1. 通用基类（无数据库注解） #

public abstract class User {
    protected Long id;
    protected String username;
    protected String email;

    // 通用getter/setter
    public Long getId() { return id; }
    public void setId(Long id) { this.id = id; }
    public String getUsername() { return username; }
    public void setUsername(String username) { this.username = username; }
    public String getEmail() { return email; }
    public void setEmail(String email) { this.email = email; }

    // 通用业务方法
    public String getFullProfile() {
        return String.format("%s (%s)", username, email);
    }
}

2. H2数据库实体子类 #

继承基类并添加JPA注解，处理主键与字段约束：

@Entity
@Table(name = "users")
public class UserH2 extends User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Override
    public Long getId() {
        return super.getId();
    }

    @Column(nullable = false, unique = true)
    @Override
    public String getUsername() {
        return super.getUsername();
    }

    @Column(nullable = false)
    @Override
    public String getEmail() {
        return super.getEmail();
    }
}

3. MongoDB实体子类 #

继承基类并添加MongoDB注解：

@Document(collection = "users")
public class UserMongo extends User {
    @Id
    @Override
    public Long getId() {
        return super.getId();
    }

    @Indexed(unique = true)
    @Override
    public String getUsername() {
        return super.getUsername();
    }
}

4. UserFactory实现 #

根据配置创建对应实体实例：

@Component
public class UserFactory {
    @Value("${myapp.db.active}")
    private String activeDb;

    public User createUser() {
        return switch (activeDb) {
            case "h2" -> new UserH2();
            case "mongo" -> new UserMongo();
            default -> throw new IllegalArgumentException("不支持的数据库类型: " + activeDb);
        };
    }
}

二、仓库结构修正与可行性分析 #

你原有的仓库设计存在Java单继承限制（类无法同时继承两个类），需调整为接口多继承的方式，具体如下：

1. 通用Repository接口（定义业务方法） #

public interface UserRepository {
    User findByUsername(String username);
    <T extends User> T save(T user);
}

2. H2仓库实现（条件激活） #

继承通用接口与Spring Data JPA的CrudRepository，通过@ConditionalOnProperty控制仅当H2为活跃数据库时实例化：

@Repository
@ConditionalOnProperty(name = "myapp.db.active", havingValue = "h2")
public interface UserRepositoryH2 extends UserRepository, CrudRepository<UserH2, Long> {
    // Spring Data JPA自动实现查询方法
    @Override
    UserH2 findByUsername(String username);

    @Override
    default UserH2 save(User user) {
        return save((UserH2) user);
    }
}

3. MongoDB仓库实现（条件激活） #

同理，继承通用接口与Spring Data MongoDB的MongoRepository：

@Repository
@ConditionalOnProperty(name = "myapp.db.active", havingValue = "mongo")
public interface UserRepositoryMongo extends UserRepository, MongoRepository<UserMongo, Long> {
    @Override
    UserMongo findByUsername(String username);

    @Override
    default UserMongo save(User user) {
        return save((UserMongo) user);
    }
}

4. Service层依赖通用接口 #

Service直接注入UserRepository，Spring会根据配置自动注入对应实现类：

@Service
public class UserService {
    private final UserRepository userRepository;
    private final UserFactory userFactory;

    public UserService(UserRepository userRepository, UserFactory userFactory) {
        this.userRepository = userRepository;
        this.userFactory = userFactory;
    }

    public User createUser(String username, String email) {
        User user = userFactory.createUser();
        user.setUsername(username);
        user.setEmail(email);
        return userRepository.save(user);
    }
}

关键注意点 #

• 基类不要添加任何数据库相关注解（如@Entity/@Document），避免冲突；
• 子类需重写基类属性并添加对应数据库的字段注解（如JPA的@Column、Mongo的@Indexed）；
• 仓库必须用接口多继承，因为Java类无法多继承，但接口可以；
• 通过@ConditionalOnProperty确保同一时间只有一个仓库实例被Spring管理，符合“单个活跃数据库”的需求。

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