Spring Boot：“字段需要“javax.persistence.EntityManagerFactory”类型的bean，但找不到该bean。”

Question

我有一个java项目，它将Spring Boot与JPA结合使用，并将Hibernate用于数据库。我正在尝试建立一个访问数据库的微服务。（我不熟悉微服务和Spring Boot）。

以下是主要课程：

@SpringBootApplication
@RestController
@EnableAutoConfiguration
@EnableJpaRepositories
public class CircularsMicroservice {

    @Autowired
    private CircularsService circularsService;



    //microservice called here
    @RequestMapping(value="/circulars-list", method=RequestMethod.POST)
    List<GmCirculars> getAllCircularsForOrganization(@RequestBody  CircularsParams circularsParams)
    {


        List<GmCirculars> circularsList =
                circularsService.fetchAllCircularsForOrganization(circularsParams.getOrganization(), circularsParams.isActiveOnly(), circularsParams.getStartOffset());//invoke the method to get the circulars list
        return circularsList;
    }

    public static void main(String[] args) throws Exception{ 


        SpringApplication springApp= new SpringApplication(CircularsMicroservice.class);

        Map<String, Object> prop= new HashMap<String, Object>();
        prop.put("spring.application.name", "circulars-microservice");
        prop.put("server.port", "8081");
        prop.put("spring.jpa.properties.hibernate.current_session_context_class", "org.springframework.orm.hibernate5.SpringSessionContext");

        //db config
        prop.put("spring.datasource.driver-class-name", "oracle.jdbc.driver.OracleDriver");
        prop.put("spring.datasource.url", "--");
        prop.put("spring.datasource.username", "--");
        prop.put("spring.datasource.password", "--");
        prop.put("spring.jpa.show-sql", "false");
        prop.put("spring.jpa.hibernate.ddl-auto", "create-drop");
        prop.put("spring.jpa.properties.hibernate.dialect", "org.hibernate.dialect.Oracle10gDialect");

        springApp.setDefaultProperties(prop); //configure programmatically

        springApp.run(args);
        System.out.println("done");


    }    



}

IGmCircularsDAO. class：

@Repository
public interface IGmCircularsDAO {


    /**
     * Save or update.
     *
     * @param obj the obj
     * @return the gm circulars
     */
    GmCirculars saveOrUpdate(GmCirculars obj);




    /**
     * Mark as deleted.
     *
     * @param rowId the row id
     * @return true, if successful
     */
    boolean markAsDeleted(BigDecimal rowId);



    /**
     * Find.
     *
     * @param obj the obj
     * @param activeOnly the active only
     * @param startOffset the start offset
     * @param maxRows the max rows
     * @return the list
     */
    List<GmCirculars> find(GmCirculars obj, boolean activeOnly, int startOffset, int maxRows);



}

GMCircularsDAOImpl。类别：

@Repository
@Transactional
@SuppressWarnings("unchecked")
public class GmCircularsDaoImpl extends ParentDAO implements IGmCircularsDAO {

    @Override
    public GmCirculars saveOrUpdate(GmCirculars obj) {

        Session session = null;

        try {
            //session = sessionFactory.openSession(); //commented by Zaid
            session= this.getSession(); //Added by Zaid

            session.beginTransaction();
            session.saveOrUpdate(obj);
            session.flush();
            session.getTransaction().commit();

        }
        catch (Exception ex) {
            ex.printStackTrace();
        }
        finally {
            session.close();
        }
        return obj;
    }


    @Override
    public List<GmCirculars> find(GmCirculars obj, boolean activeOnly, int startOffset, int maxRows) {
        Session session = null;
        List<GmCirculars> discounts = null;

        try {
            if (null != obj) {

                //session = sessionFactory.openSession(); //commented by Zaid
                session= this.getSession(); //Added by Zaid

                Criteria criteria = session.createCriteria(GmCirculars.class);

                if (null != obj.getId() && !BigDecimal.ZERO.equals(obj.getId())) {
                    criteria.add(Restrictions.eq("id", obj.getId()));
                }

                if (StringUtil.isNotNullOrEmpty(obj.getTitle())) {
                    criteria.add(Restrictions.ilike("title", obj.getTitle(), MatchMode.ANYWHERE));
                }

                if(null != obj.getOrganization()) {
                    criteria.add(Restrictions.eq("organization", obj.getOrganization()));
                }

                //commented by zaid
                /*if (null != obj.getType() && null != obj.getType().getValueId() && !BigDecimal.ZERO.equals(obj.getType().getValueId())) {
                    criteria.add(Restrictions.eq("type.valueId", obj.getType().getValueId()));
                }*/


                if (null != obj.getSerialNo() && !BigDecimal.ZERO.equals(obj.getSerialNo())) {
                    criteria.add(Restrictions.eq("serialNo", obj.getSerialNo()));
                }

                if (null != obj.getYear() && !BigDecimal.ZERO.equals(obj.getYear())) {
                    criteria.add(Restrictions.eq("year", obj.getYear()));
                }


                if (activeOnly) {
                    criteria.add(Restrictions.eq("active", BigDecimal.ONE));
                }
                else {
                    criteria.add(Restrictions.or(Restrictions.ne("active", CommonConstants.DELETED_STATUS), Restrictions.isNull("active"))); //Except for deleted ones -> NVL(active,2)
                }


                //LIMIT startOffset, maxRows;
                criteria.setFirstResult(startOffset);
                criteria.setMaxResults(maxRows);

                criteria.addOrder(Order.desc("id"));
                criteria.setResultTransformer(Criteria.DISTINCT_ROOT_ENTITY);
                discounts = criteria.list();

            }

        }
        catch (Exception e) {
            e.printStackTrace();
        }
        finally {
            session.close();
        }
        return discounts;
    }


    @Override
    public boolean markAsDeleted(BigDecimal rowId) {

        Session session = null;
        int updatedRows = 0;
        try {

            //session = sessionFactory.openSession(); //commented by Zaid
            session= this.getSession(); //Added by Zaid

            Query query = session.createQuery("update GmCirculars set active = :statusForDel where id = :rowId");
            query.setParameter("statusForDel", CommonConstants.DELETED_STATUS);
            query.setParameter("rowId", rowId);

            updatedRows = query.executeUpdate();
            session.flush();
        }
        catch (Exception ex) {
            ex.printStackTrace();
        }
        finally {
            session.close();
        }

        return updatedRows > 0;
    }


}

ParentDAO。班

@Transactional
public class ParentDAO {

    //commented by zaid
    //@Autowired
    //protected SessionFactory sessionFactory;

        //added by Zaid //spring boot way
        //@Autowired

        @PersistenceContext
        protected EntityManager entityManager;

        protected Session getSession() {
            return entityManager.unwrap(Session.class);

        }



}

循环服务。班

@org.springframework.stereotype.Service
public class CircularsService {

    @Autowired
    private IGmCircularsDAO gmCircularDao;



    @Value("${circulars.maxRows}")
    private int circularsMaxRows;


    /**
     * Save or update.
     *
     * @param obj the obj
     * @return the gm circulars
     */
    public GmCirculars saveOrUpdate(GmCirculars obj) {
        return gmCircularDao.saveOrUpdate(obj);
    }


    /**
     * Find.
     *
     * @param obj the obj
     * @param activeOnly the active only
     * @param startOffset the start offset
     * @return the list
     */
    public List<GmCirculars> find(GmCirculars obj, boolean activeOnly, int startOffset) {
        return gmCircularDao.find(obj, activeOnly, startOffset, circularsMaxRows);
    }


    /**
     * Fetch all circulars for organization.
     *
     * @param userOrg the user org
     * @param activeOnly the active only
     * @param startOffset the start offset
     * @return the list
     */
    public List<GmCirculars> fetchAllCircularsForOrganization(Organization userOrg, boolean activeOnly, int startOffset) {

        GmCirculars criteria = new GmCirculars();
        criteria.setOrganization(userOrg);
        return gmCircularDao.find(criteria, activeOnly, startOffset, circularsMaxRows);
    }


    /**
     * Find by id.
     *
     * @param id the id
     * @return the gm circulars
     */
    public GmCirculars findById(BigDecimal id) {
        GmCirculars result = null;

        List<GmCirculars> discs = gmCircularDao.find(new GmCirculars(id), false, 0, circularsMaxRows);

        if (null != discs && !discs.isEmpty()) {
            result = discs.get(0);
        }
        return result;
    }


    /**
     * Mark as deleted.
     *
     * @param entryId the entry id
     * @return true, if successful
     */
    public boolean markAsDeleted(BigDecimal entryId) {
        return gmCircularDao.markAsDeleted(entryId);
    }
}

当我运行这段代码时，我遇到了以下错误，我已经陷入其中一段时间了。

ERROR LoggingFailureAnalysisReporter 

***************************
APPLICATION FAILED TO START
***************************

Description:

Field gmCircularDao in service.CircularsService required a bean of type 'javax.persistence.EntityManagerFactory' that could not be found.

The injection point has the following annotations:
    - @org.springframework.beans.factory.annotation.Autowired(required=true)


Action:

Consider defining a bean of type 'javax.persistence.EntityManagerFactory' in your configuration.

怎么修？谢谢。

Answer 1

问题是spring boot 2使用的hibernate版本。x释放。添加以下hibernate版本解决了此问题，

<properties>
    <hibernate.version>5.2.14.Final</hibernate.version>
</properties>

Answer 2

Spring是对的：

您正在使用Spring data（@Repository公共接口IGmCircularsDAO扩展JpaRepository

spring数据的要点是在运行时基于此接口生成一个实现。此实现注册为一个bean，该bean实现IGMCrourcardAO接口）

现在，在下面创建一个bean：

@Repository
@Transactional
@SuppressWarnings("unchecked")
public class GmCircularsDaoImpl extends ParentDAO implements IGmCircularsDAO {
...

因此，spring再次扫描并找到该存储库，并尝试将其注册为bean。它还实现了相同的接口，因此spring有两个bean，它们相互竞争注入服务的权利：

public class CircularsService {

    @Autowired
    private IGmCircularsDAO gmCircularDao; // <-- what should spring chose? an autogenerated spring data proxy or your own implementation???
...

因此出现了例外。。。

您应该了解是否要维护实现相同接口的两个存储库，如果是，当您想要将其中任何一个注入到服务中时，如何区分它们（就像在循环服务中一样）。

您可以使用限定符和不同的接口—有许多解决方案，但同样，您应该首先了解最适合您的用法