Spring JPA 在存储库接口上指定实体的表名

Question

我有一个场景，我想为同一个实体类创建多个存储库。 第一个也是最简单的场景我想将我的类的一些实例保存为与主表（在实体本身上指定）不同的表中的行。 其他情况是创建远程备份，因此整个数据源会有所不同。 Spring 允许这样的事情吗？

Answer 1

我不确定你会想要这个，但无论如何它都在这里......我可以找到使用 Spring Data Repositories 的最佳方法如下：

(1a) 手动定义 2 个存储库 bean 以使用 2 个数据源：

@Bean
@Qualifier("db1")
public ModelJpaRepository modelJpaRepositoryDb1() {
    JpaRepositoryFactoryBean<ModelJpaRepository, Model, String> myFactory = new JpaRepositoryFactoryBean<ModelJpaRepository, Model, String>();
    myFactory.setRepositoryInterface(ModelJpaRepository.class);
    myFactory.setEntityManager(entityManagerFactory1().createEntityManager());
    myFactory.afterPropertiesSet();
    return myFactory.getObject();
}

@Bean
@Qualifier("db2")
public ModelJpaRepository modelJpaRepositoryDb2() {
    JpaRepositoryFactoryBean<ModelJpaRepository, Model, String> myFactory = new JpaRepositoryFactoryBean<ModelJpaRepository, Model, String>();
    myFactory.setRepositoryInterface(ModelJpaRepository.class);
    myFactory.setEntityManager(entityManagerFactory2().createEntityManager());
    myFactory.afterPropertiesSet();
    return myFactory.getObject();
}

(1b)：定义2个数据源（由前面的存储库定义引用）：

@Bean(name = "dataSource1")
public DataSource dataSource1() {
    BasicDataSource bds = new BasicDataSource();
    bds.setDriverClassName(...);
    bds.setUrl(...);
    bds.setUsername(...);
    bds.setPassword(...);
    return bds;
}

@Bean(name = "dataSource2")
public DataSource dataSource2() {
    BasicDataSource bds = new BasicDataSource();
    bds.setDriverClassName(...);
    bds.setUrl(...);
    bds.setUsername(...);
    bds.setPassword(...);
    return bds;
}

(1c)：定义 2 个 entityManager - 每个数据源 1 个（由之前的存储库定义引用）：

@Bean
public EntityManagerFactory entityManagerFactory1() {
    LocalContainerEntityManagerFactoryBean entityManagerFactory = new LocalContainerEntityManagerFactoryBean();
    entityManagerFactory.setDataSource(dataSource1());
    entityManagerFactory.setPersistenceUnitName("pu1");
    entityManagerFactory.setJpaVendorAdapter(jpaVendorAdapter());
    entityManagerFactory.setJpaProperties(jpaProperties());
    entityManagerFactory.afterPropertiesSet();
    return entityManagerFactory.getNativeEntityManagerFactory();
}

@Bean
public EntityManagerFactory entityManagerFactory2() {
    LocalContainerEntityManagerFactoryBean entityManagerFactory = new LocalContainerEntityManagerFactoryBean();
    entityManagerFactory.setDataSource(dataSource2());
    entityManagerFactory.setPersistenceUnitName("pu2");
    entityManagerFactory.setJpaVendorAdapter(jpaVendorAdapter());
    entityManagerFactory.setJpaProperties(jpaProperties());
    entityManagerFactory.afterPropertiesSet();
    return entityManagerFactory.getNativeEntityManagerFactory();
}

(2) 注入 2 个存储库并使用它们：

@Autowired
@Qualifier("db1")
private ModelJpaRepository modelJpaRepositoryDb1;

@Autowired
@Qualifier("db2")
private ModelJpaRepository modelJpaRepositoryDb2;

...

modelJpaRepositoryDb1.save(model);
modelJpaRepositoryDb2.save(model);

(3) 定义“OtherModel”并将“Model”嵌入：

@Entity
@Table(name = "OTHER_TABLE")
public class OtherTable {

    @Id
    @Column(name = "ID", nullable = false)
    private long id;

    @Embedded
    private Model model;

    public OtherTable(Model model) {
        this.model = model;
        this.id = model.getId();
    }
}

供参考，This answer 建议使用@Inheritance(strategy=InheritanceType.TABLE_PER_CLASS) 来实现定义附加模型（继承与组合）。

(4) 为 OtherTable 定义 2 个存储库：

@Bean
@Qualifier("db1")
public OtherTableJpaRepository otherTableJpaRepositoryDb1() {
    JpaRepositoryFactoryBean<OtherTableJpaRepository, OtherTable, String> myFactory = new JpaRepositoryFactoryBean<OtherTableJpaRepository, OtherTable, String>();
    myFactory.setRepositoryInterface(OtherTableJpaRepository.class);
    myFactory.setEntityManager(entityManagerFactory1().createEntityManager());
    myFactory.afterPropertiesSet();
    return myFactory.getObject();
}

@Bean
@Qualifier("db2")
public OtherTableJpaRepository otherTableJpaRepositoryDb2() {
    JpaRepositoryFactoryBean<OtherTableJpaRepository, OtherTable, String> myFactory = new JpaRepositoryFactoryBean<OtherTableJpaRepository, OtherTable, String>();
    myFactory.setRepositoryInterface(OtherTableJpaRepository.class);
    myFactory.setEntityManager(entityManagerFactory2().createEntityManager());
    myFactory.afterPropertiesSet();
    return myFactory.getObject();
}

(5) 全部注入使用：

@Autowired
@Qualifier("db1")
private ModelJpaRepository modelJpaRepositoryDb1;

@Autowired
@Qualifier("db2")
private ModelJpaRepository modelJpaRepositoryDb2;

@Autowired
@Qualifier("db1")
private OtherTableJpaRepository otherTableJpaRepositoryDb1;

@Autowired
@Qualifier("db2")
private OtherTableJpaRepository otherTableJpaRepositoryDb2;

// ...

modelJpaRepositoryDb1.save(model);
otherTableJpaRepositoryDb1.save(new OtherTable(model));

modelJpaRepositoryDb2.save(model);
otherTableJpaRepositoryDb2.save(new OtherTable(model));