如何为同一数据源下不同Schema的同名表创建JPA Repository？

我们可以通过JPA的@Table注解指定实体对应的数据库Schema，示例如下：

@Table(name = "...", schema = "...")

假设有这样的场景：

• 存在两个表名相同但Schema不同的表，分别对应两个实体：

  @Table(name = "Table1", schema = "Schema1")
  

  和

  @Table(name = "Table1", schema = "Schema2")
  

• Hibernate的默认Schema已设置为Schema1
• 当前创建JPA Repository时，只能获取到Schema1.Table1的数据，因为默认Schema的影响

现需解决：是否可以为这两个表创建独立的JPA Repository，分别从Schema1和Schema2获取数据？若可以，如何实现？

注：两个Schema来自同一数据源。

目前多数资料仅讲解如何为表定义Schema或多数据源处理，未覆盖该场景。

完全可以实现，以下两种方案是常用的解决方式：

方案一：多EntityManagerFactory隔离配置（推荐复杂场景） #

通过为每个Schema创建独立的EntityManagerFactory和事务管理器，让不同的Repository绑定对应的配置，实现完全隔离的操作。

步骤1：区分两个实体类 #

给对应不同Schema的实体起不同的类名，避免冲突：

@Entity
@Table(name = "Table1", schema = "Schema1")
public class Table1Schema1 {
    // 主键、字段等与表结构匹配的定义
}

@Entity
@Table(name = "Table1", schema = "Schema2")
public class Table1Schema2 {
    // 和上面完全一致的字段定义（因为两张表结构相同）
}

步骤2：创建对应Repository接口 #

分别为两个实体创建独立的Repository：

public interface Table1Schema1Repository extends JpaRepository<Table1Schema1, Long> {
    // 自定义查询方法按需添加
}

public interface Table1Schema2Repository extends JpaRepository<Table1Schema2, Long> {
    // 自定义查询方法按需添加
}

步骤3：配置两套JPA环境 #

在Spring Boot中编写两个配置类，分别绑定不同的Schema、实体包和Repository包：

Schema1的JPA配置

@Configuration
@EnableJpaRepositories(
        basePackages = "com.yourproject.repository.schema1", // Schema1的Repository所在包
        entityManagerFactoryRef = "schema1EntityManagerFactory",
        transactionManagerRef = "schema1TransactionManager"
)
public class Schema1JpaConfig {

    @Autowired
    private Environment env;

    @Bean
    public LocalContainerEntityManagerFactoryBean schema1EntityManagerFactory() {
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(sharedDataSource());
        em.setPackagesToScan("com.yourproject.entity.schema1"); // Schema1的实体所在包

        HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);

        HashMap<String, Object> properties = new HashMap<>();
        properties.put("hibernate.dialect", env.getProperty("spring.jpa.properties.hibernate.dialect"));
        properties.put("hibernate.default_schema", "Schema1"); // 指定该环境的默认Schema
        em.setJpaPropertyMap(properties);

        return em;
    }

    @Bean
    public PlatformTransactionManager schema1TransactionManager() {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(schema1EntityManagerFactory().getObject());
        return transactionManager;
    }
}

Schema2的JPA配置

@Configuration
@EnableJpaRepositories(
        basePackages = "com.yourproject.repository.schema2", // Schema2的Repository所在包
        entityManagerFactoryRef = "schema2EntityManagerFactory",
        transactionManagerRef = "schema2TransactionManager"
)
public class Schema2JpaConfig {

    @Autowired
    private Environment env;

    @Bean
    public LocalContainerEntityManagerFactoryBean schema2EntityManagerFactory() {
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(sharedDataSource());
        em.setPackagesToScan("com.yourproject.entity.schema2"); // Schema2的实体所在包

        HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);

        HashMap<String, Object> properties = new HashMap<>();
        properties.put("hibernate.dialect", env.getProperty("spring.jpa.properties.hibernate.dialect"));
        properties.put("hibernate.default_schema", "Schema2"); // 指定该环境的默认Schema
        em.setJpaPropertyMap(properties);

        return em;
    }

    @Bean
    public PlatformTransactionManager schema2TransactionManager() {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(schema2EntityManagerFactory().getObject());
        return transactionManager;
    }
}

共享数据源配置

单独抽离共用的数据源配置，让两个EntityManager复用：

@Configuration
public class SharedDataSourceConfig {
    @Autowired
    private Environment env;

    @Bean
    public DataSource sharedDataSource() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setJdbcUrl(env.getProperty("spring.datasource.url"));
        dataSource.setUsername(env.getProperty("spring.datasource.username"));
        dataSource.setPassword(env.getProperty("spring.datasource.password"));
        dataSource.setDriverClassName(env.getProperty("spring.datasource.driver-class-name"));
        return dataSource;
    }
}

步骤4：规划包结构 #

按Schema拆分实体和Repository的存放位置，避免扫描冲突：

com.yourproject
├── entity
│   ├── schema1
│   │   └── Table1Schema1.java
│   └── schema2
│       └── Table1Schema2.java
├── repository
│   ├── schema1
│   │   └── Table1Schema1Repository.java
│   └── schema2
│       └── Table1Schema2Repository.java
└── config
    ├── SharedDataSourceConfig.java
    ├── Schema1JpaConfig.java
    └── Schema2JpaConfig.java

方案二：手动指定Schema的原生查询（轻量方案） #

如果只是简单查询场景，不想配置多套JPA环境，可以在Repository方法中用@Query手动指定Schema前缀。

步骤1：定义通用实体类（可选） #

如果两张表结构完全一致，可以只定义一个实体类，不指定Schema：

@Entity
@Table(name = "Table1")
public class Table1 {
    // 主键、字段定义
}

步骤2：编写带Schema的查询方法 #

在两个Repository中分别编写指定Schema的查询：

public interface Table1Schema1Repository extends JpaRepository<Table1, Long> {
    @Query(value = "SELECT * FROM Schema1.Table1 WHERE id = ?1", nativeQuery = true)
    Table1 findByIdFromSchema1(Long id);

    // 其他CRUD方法都需要用类似方式手动指定Schema前缀
    @Query(value = "SELECT * FROM Schema1.Table1", nativeQuery = true)
    List<Table1> findAllFromSchema1();
}

public interface Table1Schema2Repository extends JpaRepository<Table1, Long> {
    @Query(value = "SELECT * FROM Schema2.Table1 WHERE id = ?1", nativeQuery = true)
    Table1 findByIdFromSchema2(Long id);

    @Query(value = "SELECT * FROM Schema2.Table1", nativeQuery = true)
    List<Table1> findAllFromSchema2();
}

注意：这种方式下，JPA自动生成的方法（如默认的findAll()）仍会走默认Schema，所以需要覆盖所有用到的CRUD方法，只适合简单场景。

方案对比 #

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