JPA之EntityManager踩坑及解決:更改PersistenceContext

更新時(shí)間：2022年02月24日 11:12:33 作者：Jim~LoveQ

這篇文章主要介紹了JPA之EntityManager踩坑及解決:更改PersistenceContext方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

JPA EntityManager踩坑之更改PersistenceContext

一、原因

項(xiàng)目中配置兩個(gè)Spring JPA的數(shù)據(jù)源，使用EntityManager的時(shí)候默認(rèn)是選擇第一個(gè)，導(dǎo)致查詢不到第二個(gè)數(shù)據(jù)源的數(shù)據(jù)。

二、Spring JPA多數(shù)據(jù)源怎么使用EntityManager

1. Spring JPA多數(shù)據(jù)源的配置請(qǐng)查看此文章：SpringData JPA基本/高級(jí)/多數(shù)據(jù)源使用

2. 引入EntityManager：

@PersistenceContext(unitName = "primaryPersistenceUnit")
private EntityManager entityManager;

@PersistenceContext中的unitName指的是使用哪一個(gè)數(shù)據(jù)源的persistenceUnit，persistenceUnit是在配置數(shù)據(jù)源的時(shí)候配置的，每一個(gè)數(shù)據(jù)源的persistenceUnit都是不一樣的，這樣就可以使用不同的數(shù)據(jù)源來查詢數(shù)據(jù)了。

配置persistenceUnit：

@Bean(name = "entityManagerFactoryPrimary")
@Primary
public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary (EntityManagerFactoryBuilder builder) {
? ? return builder
? ? ? ? ? ? .dataSource(primaryDataSource)
? ? ? ? ? ? .properties(vendorProperties)
? ? ? ? ? ? .packages("com.neo.model") //設(shè)置實(shí)體類所在位置
? ? ? ? ? ? .persistenceUnit("primaryPersistenceUnit")
? ? ? ? ? ? .build();
}

三、使用EntityManager

String SQL = "select id ,code,name,'desc' from drgo_cd10_dx_code where name like ('%"+content.trim()+"%') "?
logger.info("search getProductOwnerId SQL:"+SQL);
Query query = entityManager.createNativeQuery(SQL);
List<Object[]> dbList = query.getResultList();
List<ICD10CodeData> resultList = new ArrayList<ICD10CodeData>();
if (dbList!=null && dbList.size()>0){
??? ?for (int i =0;i<dbList.size();i++){
? ? ? Object[] o = dbList.get(i);
? ? ? String id = o[0]==null?"":o[0].toString();
? ? ? String code = o[1]==null?"":o[1].toString();
? ? ? String name = o[0]==null?"":o[2].toString();
? ? ? String desc = o[1]==null?"":o[3].toString();
? ? ? ICD10CodeData tempCode = new ICD10CodeData(Long.parseLong(id), code, name, desc);
?? ? ?resultList.add(tempCode);
? ? ?}
?}

@PersistenceContext(unitName = "entityManagerFactory")

@Configuration
@EnableTransactionManagement(mode = AdviceMode.ASPECTJ, proxyTargetClass = true)
@ComponentScan({cn.com.appName.manager,cn.com.appName.dao,cn.com.appName.dao.jpa}) 
public class AppConfig extends AbstractManager
{
     @Bean(name = "entityManagerFactory")
    public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean()
    {
        LocalContainerEntityManagerFactoryBean factoryBean = new LocalContainerEntityManagerFactoryBean();
        factoryBean.setDataSource(dataSource(null));
        factoryBean.setPackagesToScan(new String[] { "cn.com." + AppConfig.APP_NAME + ".entity" });
        HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        vendorAdapter.setDatabasePlatform(hibernateDialect);
        if (logger.isDebugEnabled())
        {
            // vendorAdapter.setShowSql(true);
            // vendorAdapter.setGenerateDdl(true);
        }
        //vendorAdapter.setGenerateDdl(true);
        factoryBean.setJpaVendorAdapter(vendorAdapter);
        // factoryBean.setJpaProperties(this.additionlProperties());
        return factoryBean;
    } 
} 
public abstract class MyBaseDao<E extends BaseEntity> extends BaseDaoJpa<E>
{
    protected MyBaseDao()
    {    }
 
  //unitName與LocalContainerEntityManagerFactoryBean類的容器對(duì)象的名稱一致
    @PersistenceContext(unitName = "entityManagerFactory")
    public void setJpaEntityManager(EntityManager entityManager)
    {
        super.setEntityManager(entityManager);
    } 
}

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: