Обнаружена множественная транзакция в appCtx NoUniqueBeanDefinitionException - PullRequest
Новая
       22

Обнаружена множественная транзакция в appCtx NoUniqueBeanDefinitionException

0 голосов
/ 18 октября 2018

Я работаю над веб-приложением на основе Spring MVC, в котором у меня есть два источника данных, для которых мне нужно поддерживать две транзакции **DataSourceTransactionManager**,

Я ничего не сделал, просто скопировал мой EXISTING Txn фрагмент транзакции иизмените его в соответствии с другим источником данных, посмотрите пожалуйста на мой

app-ctx.xml 

<!----- EXISTING Txn-------->
     <bean id="transactionManager"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource" />

        </bean> 
     <!----- NEWLY ADDED Txn-------->   
        <bean id="erptransactionManager"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSourcePayroll" />
        </bean>

Теперь класс обслуживания где именно мне нужно использовать. 

package com.awzpact.prayas.service;

import com.awzpact.prayas.dao.HRMSPickSalaryDataDAO;
import com.awzpact.uam.domain.SalaryDetailReport;
import com.awzpact.uam.domain.Userdetail;
import com.awzpact.uam.exceptions.MyExceptionHandler;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

/**
 *
 * @author jack
 */
@Service
public class NewPayrollService {

    final TransactionDefinition erpTxnDefination = new DefaultTransactionDefinition();
    final TransactionDefinition prayasTxnDefination = new DefaultTransactionDefinition();
    final int BATCH_SIZE = 500;

    public void getSalarayData(final String yearMonth, final String regionId, final String circleId, final Userdetail loginUser) {
        final String tableSuffix = yearMonth.substring(4, 6) + yearMonth.substring(0, 4);
        final TransactionStatus erpTransaction = erpTransactionManager.getTransaction(erpTxnDefination);
        try {
            List<SalaryDetailReport> list = hRMSPickSalaryDataDAO.findAll(yearMonth, regionId, circleId);
        } catch (Exception e) {
        }
        final TransactionStatus prayasTransaction = prayasTransactionManager.getTransaction(prayasTxnDefination);

    }

    @Autowired
    DataSourceTransactionManager prayasTransactionManager;

    @Autowired
    DataSourceTransactionManager erpTransactionManager;

    @Autowired
    HRMSPickSalaryDataDAO hRMSPickSalaryDataDAO;
}

ЖУРНАЛ ОШИБКИ 

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'newPayrollService': Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire field: org.springframework.jdbc.datasource.DataSourceTransactionManager com.awzpact.prayas.service.NewPayrollService.prayasTransactionManager; nested exception is org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type [org.springframework.jdbc.datasource.DataSourceTransactionManager] is defined: expected single matching bean but found 2: transactionManager,erptransactionManager
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessPropertyValues(AutowiredAnnotationBeanPostProcessor.java:334)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1214)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:543)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:482)
    at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:772)
    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:838)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:537)
    at org.springframework.web.context.ContextLoader.configureAndRefreshWebApplicationContext(ContextLoader.java:446)
    at org.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:328)
    at org.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:107)
    at org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:5003)
    at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5517)
    at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
    at org.apache.catalina.core.StandardContext.reload(StandardContext.java:4020)
    at org.apache.catalina.manager.ManagerServlet.reload(ManagerServlet.java:1012)
    at org.apache.catalina.manager.ManagerServlet.doGet(ManagerServlet.java:381)
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:624)
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:731)
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:303)
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208)
    at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241)
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208)
    at org.apache.catalina.filters.SetCharacterEncodingFilter.doFilter(SetCharacterEncodingFilter.java:108)
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241)
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208)
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:220)
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:122)
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:614)
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:170)
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:103)
    at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:956)
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:116)
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:423)
    at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1079)
    at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:625)
    at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:316)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
    at java.lang.Thread.run(Thread.java:745)
Caused by: org.springframework.beans.factory.BeanCreationException: Could not autowire field: org.springframework.jdbc.datasource.DataSourceTransactionManager com.awzpact.prayas.service.NewPayrollService.prayasTransactionManager; nested exception is org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type [org.springframework.jdbc.datasource.DataSourceTransactionManager] is defined: expected single matching bean but found 2: transactionManager,erptransactionManager
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:573)
    at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:88)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessPropertyValues(AutowiredAnnotationBeanPostProcessor.java:331)
    ... 44 more
Caused by: org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type [org.springframework.jdbc.datasource.DataSourceTransactionManager] is defined: expected single matching bean but found 2: transactionManager,erptransactionManager
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1126)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1014)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:545)
    ... 46 more

Я не могу понять это, я выделяю bean id какТакже я ссылаюсь на другие datasource i, e dataSourcePayroll.

Пожалуйста, дайте мне знать лучшее решение для достижения этой цели, или есть альтернативное решение для этого?

Ответы [ 2 ]

0 голосов
/ 18 октября 2018

Проблема в том, что вы получили другой идентификатор компонента в определении компонента, и вы используете это свойство с другим именем.Таким образом, контейнер Spring не может определить, какой один компонент назначен для prayasTransactionManager и erpTransactionManager ..

. Решение состоит в том, чтобы использовать один и тот же идентификатор компонента для определения компонента, который используется в качестве имени свойства.в вашем случае: 

<!----- EXISTING Txn-------->
 <bean id="prayasTransactionManager"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />

    </bean> 
 <!----- NEWLY ADDED Txn-------->   
    <bean id="erpTransactionManager"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSourcePayroll" />
    </bean>

или используйте это со своим старым кодом. 

  @Autowired
@Qualifier("transactionManager")
DataSourceTransactionManager prayasTransactionManager;

@Autowired
@Qualifier("erptransactionManager")
DataSourceTransactionManager erpTransactionManager;

PS: Лучшая практика для присвоения идентификатора компонента и имени свойства (Dependency) - использовать шаблон camelCase сзначимые имена.

0 голосов
/ 18 октября 2018

Один из способов - указать имя вашего боба 

<bean id="transactionManager"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager" name="oldOne">
            <property name="dataSource" ref="dataSource" />

        </bean> 
     <!----- NEWLY ADDED Txn-------->   
        <bean id="erptransactionManager"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager" name="newOne">
            <property name="dataSource" ref="dataSourcePayroll" />
        </bean>

, а затем использовать квалификатор 

package com.awzpact.prayas.service;

import com.awzpact.prayas.dao.HRMSPickSalaryDataDAO;
import com.awzpact.uam.domain.SalaryDetailReport;
import com.awzpact.uam.domain.Userdetail;
import com.awzpact.uam.exceptions.MyExceptionHandler;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

/**
 *
 * @author jack
 */
@Service
public class NewPayrollService {

    final TransactionDefinition erpTxnDefination = new DefaultTransactionDefinition();
    final TransactionDefinition prayasTxnDefination = new DefaultTransactionDefinition();
    final int BATCH_SIZE = 500;

    public void getSalarayData(final String yearMonth, final String regionId, final String circleId, final Userdetail loginUser) {
        final String tableSuffix = yearMonth.substring(4, 6) + yearMonth.substring(0, 4);
        final TransactionStatus erpTransaction = erpTransactionManager.getTransaction(erpTxnDefination);
        try {
            List<SalaryDetailReport> list = hRMSPickSalaryDataDAO.findAll(yearMonth, regionId, circleId);
        } catch (Exception e) {
        }
        final TransactionStatus prayasTransaction = prayasTransactionManager.getTransaction(prayasTxnDefination);

    }

    @Autowired
    @Qualifier("oldOne")
    DataSourceTransactionManager prayasTransactionManager;


    @Autowired
    @Qualifier("newOne")
    DataSourceTransactionManager erpTransactionManager;

    @Autowired
    HRMSPickSalaryDataDAO hRMSPickSalaryDataDAO;
}
...