单领域模型适配多数据源：Spring Boot同构数据库数据同步方案选型

作为常年深耕Spring Boot数据层开发的开发者，我明确推荐复用同一领域模型 + @Qualified注解指定数据源的方案，这不仅更符合Spring生态的设计理念，还能从根本上提升代码的可维护性，避免冗余带来的潜在风险。下面具体分析两种方案的优劣：

为什么复用领域模型的方案更合理？ #

• 严格遵循DRY原则：既然两个数据库的表结构、数据模型完全一致，复制领域模型纯粹是无意义的重复劳动。后续如果表结构调整（比如新增字段、修改字段类型），你只需要维护一份模型类，不用同步修改多个重复类，从根源上避免了漏改导致的不一致问题。
• 贴合Spring原生设计：@Qualified注解本身就是Spring为解决同类型Bean依赖注入歧义而提供的标准方案，多数据源场景正是它的典型应用场景。你只需要配置两套独立的数据源、会话工厂（MyBatis的SqlSessionFactory或JPA的EntityManagerFactory），然后在DAO层通过@Qualified指定对应的Bean即可，完全契合Spring的依赖注入逻辑。
• 提升代码可读性与维护性：所有业务模型的定义集中在一处，其他开发者一眼就能明白两个库共享同一数据结构，不会对重复的模型类产生困惑。而且跨库复制时，直接用同一个模型对象在两个库之间传递，无需额外的对象转换逻辑，减少了出错的可能性。

复制领域模型方案的弊端 #

这种方案看似简单直接，但实际上是短期省事、长期埋坑的选择：

• 冗余代码爆炸：每一次模型的修改（比如添加校验注解、调整字段映射）都要同步修改两个甚至多个重复类，随着业务迭代，维护成本会指数级上升。
• 隐含不一致风险：万一某次修改漏了其中一个模型类，就会导致实体与数据库表的映射不一致，出现诸如插入失败、查询结果缺失等难以排查的问题。
• 违背面向对象思想：重复定义本质上是对同一业务概念的重复实现，既不符合“单一职责”原则，也浪费了面向对象的复用特性。

简单实现示例 #

1. 多数据源配置

@Configuration
public class DataSourceConfig {
    // 源数据库数据源
    @Bean("sourceDb")
    @ConfigurationProperties(prefix = "spring.datasource.source")
    public DataSource sourceDataSource() {
        return DataSourceBuilder.create().build();
    }

    // 目标数据库数据源
    @Bean("targetDb")
    @ConfigurationProperties(prefix = "spring.datasource.target")
    public DataSource targetDataSource() {
        return DataSourceBuilder.create().build();
    }

    // 源数据库对应的MyBatis会话工厂
    @Bean("sourceSqlSessionFactory")
    public SqlSessionFactory sourceSqlSessionFactory(@Qualifier("sourceDb") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
        sessionFactoryBean.setDataSource(dataSource);
        // 指定Mapper文件位置等配置
        sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/source/*.xml"));
        return sessionFactoryBean.getObject();
    }

    // 目标数据库对应的MyBatis会话工厂
    @Bean("targetSqlSessionFactory")
    public SqlSessionFactory targetSqlSessionFactory(@Qualifier("targetDb") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
        sessionFactoryBean.setDataSource(dataSource);
        sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/target/*.xml"));
        return sessionFactoryBean.getObject();
    }
}

2. 复用领域模型与DAO层实现

// 唯一的领域模型类
public class User {
    private Long id;
    private String username;
    private String email;
    
    // getter、setter、构造方法省略
}

// 源数据库的DAO
@Mapper
@Qualifier("sourceSqlSessionFactory")
public interface SourceUserDao {
    @Select("SELECT id, username, email FROM user WHERE id = #{userId}")
    User getSourceUserById(@Param("userId") Long userId);
}

// 目标数据库的DAO
@Mapper
@Qualifier("targetSqlSessionFactory")
public interface TargetUserDao {
    @Insert("INSERT INTO user(username, email) VALUES(#{username}, #{email})")
    int insertTargetUser(User user);
}

3. 业务层跨库复制逻辑

@Service
public class UserCopyService {
    private final SourceUserDao sourceUserDao;
    private final TargetUserDao targetUserDao;

    // 构造方法注入，通过@Qualifier区分不同数据源的DAO
    public UserCopyService(@Qualifier("sourceUserDao") SourceUserDao sourceUserDao,
                           @Qualifier("targetUserDao") TargetUserDao targetUserDao) {
        this.sourceUserDao = sourceUserDao;
        this.targetUserDao = targetUserDao;
    }

    public void copyUserToTarget(Long userId) {
        User user = sourceUserDao.getSourceUserById(userId);
        if (Objects.nonNull(user)) {
            targetUserDao.insertTargetUser(user);
        }
    }
}

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