委托DataSourceSpring引导

Question

 org.springframework.beans.factory.BeanCurrentlyInCreationException: Error creating bean with name 'dataSource': Requested bean is currently in creation: Is there an unresolvable circular reference?

编辑1:AOP-我尝试添加pointcut执行(public*javax.sql.datasource+.getConnection(..))。这仅在Spring datasource与用户名/密码一起使用时才起作用。一旦我用JNDI在Jboss中部署，我就会得到WildFlyDataSource代理错误。因此，我考虑使用delegatingDataSource而不是AOP方法

   // AOP Example

    @Pointcut("execution(public * javax.sql.DataSource+.getConnection(..))")
    void prepareConnectionPointcut() {
        logger.debug("prepareConnectionPointcut");
    }
    
    @AfterReturning(pointcut = "prepareConnectionPointcut()", returning = "connection")
    void afterPrepareConnection(Connection connection) {
        // Set context in Connection - return same connection for query execution
    }

但是当我在JBoss中部署这段代码时--我会得到WildFlyDataSource datasource bean创建错误。

创建名为'org.springframework.boot.autoconfigure.orm.jpa.Hibernatejpaconfiguration'的bean时出错：通过构造函数参数0表示的依赖项不满足；嵌套异常是org.springframework.beans.factory.beanCreationException：创建类路径资源[org/springframework/boot/autoconfiguration/jdbc/jndidatasourceautoconfiguration.class]中定义的名称为“data source”的bean时出错：bean初始化失败；嵌套异常是org.springframework.aop.framework.aopconfigException：无法生成org.jboss.as.connector.subsystems.datasources.wildflydatasource类的CGLIB子类：此问题的常见原因包括使用最终类或不可见类；嵌套异常是org.springframework.cglib.core.codeGenerationException:java.lang.noClassDefFounderRor-->org/jboss/as/connector/subsystems/datasources/WildFlyDataSource

我还在初始化期间添加了proxyTargetClass标志

@enableAspectJAutoProxyProxtargetClass=true

Answer 1

感谢@M.Deinum推荐使用BeanPostProcessor&实现DelegatingDataSource来设置客户端信息。请找到下面的代码片段，我在Spring Boot中实现了这一点，它可以很好地与JBoos、JNDI连接或Spring Boot URL数据源连接一起工作。

@Component
public class MyBeanPostProcessor implements BeanPostProcessor {

    private static Logger logger = LoggerFactory.getLogger(MyBeanPostProcessor.class);

    @Override
    public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {

        if (bean instanceof DataSource) {
            // Check DataSource bean initialization & enclose it with DelegatingDataSource 
            logger.debug("MyBeanPostProcessor:: postProcessAfterInitialization:: DataSource");

            DataSource beanDs = (DataSource) bean;
            return new MyDelegateDS(beanDs);
        }

        return BeanPostProcessor.super.postProcessAfterInitialization(bean, beanName);
    }

    @Override
    public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
        if (bean instanceof DataSource) {
            logger.debug("MyBeanPostProcessor:: postProcessBeforeInitialization:: DataSource");
        }

        logger.debug("MyBeanPostProcessor:: postProcessBeforeInitialization:: " + beanName);

        return BeanPostProcessor.super.postProcessBeforeInitialization(bean, beanName);
    }

}

我实现delegatingDataSource来处理每个用户请求以在DB连接会话中设置客户端上下文

 public class MyDelegateDS extends DelegatingDataSource {

    private static Logger logger = LoggerFactory.getLogger(MyDelegateDS.class);

    public MyDelegateDS(DataSource delegate) {
        super(delegate);
        logger.debug("MyDelegateDS:: constructor");
    }

    @Override
    public Connection getConnection() throws SQLException {
        logger.debug("MyDelegateDS:: getConnection");

        // To do this context only for user Request - to avoid this during Server initialization
        if (RequestContextHolder.getRequestAttributes() != null
                && ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest() != null) {

            logger.debug("MyDelegateDS:: getConnection: valid user request");

            HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes())
                    .getRequest();
                    
            // Checking each user request & calling SP to set client context before invoking actual native query/SP
        }

        logger.debug("MyDelegateDS:: getConnection: Not User Request");

        return super.getConnection();
    }

}

希望这对面临同样问题的人有所帮助