欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

springboot mybatis调用多个数据源引发的错误问题

程序员文章站 2022-03-19 21:13:14
目录springboot mybatis调用多个数据源错误报错解决方法springboot-mybatis多数据源及踩坑springboot项目结构如下springboot配置文件内容如下动态数据源的...

springboot mybatis调用多个数据源错误

报错

'org.springframework.boot.autoconfigure.jdbc.datasourceinitializerinvoker': invocation of init method failed; nested exception is org.springframework.beans.factory.nouniquebeandefinitionexception: no qualifying bean of type 'javax.sql.datasource' available: more than one 'primary' bean found among candidates: [mssqldatasource, postgredatasource]

从后往前复制的,加粗的是重点。

因为有多个数据源使用同一个mapper接口,但是都用@primary,则会引起此错误。

如图所示:

springboot mybatis调用多个数据源引发的错误问题

springboot mybatis调用多个数据源引发的错误问题

从上面两图可以看出都用了同一个mapper接口,都添加了@primary。

解决方法

解决方法有两种,一种是把其中一个数据源去掉@primary,动态调用数据源,就是需要代码切换使用的数据源。

如果要同时使用两个数据源,那就用不同的mapper,相当于postgre用postgre部分的mapper,sqlserver用sqlserver部分的mapper,大家互不干扰,就算@primary也没事

如图所示,我将postgre的mapperscan改了

springboot mybatis调用多个数据源引发的错误问题

springboot-mybatis多数据源及踩坑

springboot项目结构如下

springboot mybatis调用多个数据源引发的错误问题

springboot配置文件内容如下

springboot mybatis调用多个数据源引发的错误问题

动态数据源的配置类如下

(必须保证能被componentscan扫描到):

package com.letzgo.config;

import com.alibaba.druid.pool.druiddatasource;
import org.apache.ibatis.session.sqlsessionfactory;
import org.mybatis.spring.sqlsessionfactorybean;
import org.mybatis.spring.sqlsessiontemplate;
import org.mybatis.spring.annotation.mapperscan;
import org.springframework.beans.factory.annotation.qualifier;
import org.springframework.boot.context.properties.configurationproperties;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
import org.springframework.context.annotation.primary;
import org.springframework.core.io.support.pathmatchingresourcepatternresolver;
import org.springframework.jdbc.datasource.datasourcetransactionmanager;

import javax.sql.datasource;

/**
 * @author allen
 * @date 2019-01-10 15:08
 */
public class dynamicdatasourceconfig {

    @configuration
    @mapperscan(basepackages = "com.letzgo.dao.master")
    public static class master {
        @primary
        @bean("masterdatasource")
        @qualifier("masterdatasource")
        @configurationproperties(prefix = "spring.datasource.master")
        public datasource datasource() {
            return new druiddatasource();
        }

        @primary
        @bean("mastersqlsessionfactory")
        @qualifier("mastersqlsessionfactory")
        public sqlsessionfactory sqlsessionfactory(@qualifier("masterdatasource") datasource datasource) throws exception {
            sqlsessionfactorybean factorybean = new sqlsessionfactorybean();
            factorybean.setdatasource(datasource);
            factorybean.setmapperlocations(new pathmatchingresourcepatternresolver().getresources("classpath:mapper/master/*.xml"));
            return factorybean.getobject();
        }

        @primary
        @bean("mastertransactionmanager")
        @qualifier("mastertransactionmanager")
        public datasourcetransactionmanager transactionmanager(@qualifier("masterdatasource") datasource datasource) {
            return new datasourcetransactionmanager(datasource);
        }

        @primary
        @bean("mastersqlsessiontemplate")
        @qualifier("mastersqlsessiontemplate")
        public sqlsessiontemplate sqlsessiontemplate(@qualifier("mastersqlsessionfactory") sqlsessionfactory sqlsessionfactory) {
            return new sqlsessiontemplate(sqlsessionfactory);
        }

    }

    @configuration
    @mapperscan(basepackages = "com.letzgo.dao.slave")
    public static class slave {
        @bean("slavedatasource")
        @qualifier("slavedatasource")
        @configurationproperties(prefix = "spring.datasource.slave")
        public datasource datasource() {
            return new druiddatasource();
        }

        @bean("slavesqlsessionfactory")
        @qualifier("slavesqlsessionfactory")
        public sqlsessionfactory sqlsessionfactory(@qualifier("slavedatasource") datasource datasource) throws exception {
            sqlsessionfactorybean factorybean = new sqlsessionfactorybean();
            factorybean.setdatasource(datasource);
            factorybean.setmapperlocations(new pathmatchingresourcepatternresolver().getresources("classpath:mapper/slave/*.xml"));
            return factorybean.getobject();
        }

        @bean("slavetransactionmanager")
        @qualifier("slavetransactionmanager")
        public datasourcetransactionmanager transactionmanager(@qualifier("slavedatasource") datasource datasource) {
            return new datasourcetransactionmanager(datasource);
        }

        @bean("slavesqlsessiontemplate")
        @qualifier("slavesqlsessiontemplate")
        public sqlsessiontemplate sqlsessiontemplate(@qualifier("slavesqlsessionfactory") sqlsessionfactory sqlsessionfactory) {
            return new sqlsessiontemplate(sqlsessionfactory);
        }
    }

}

完成基本配置之后,分别在master和slave中写一个数据库访问操作,再开放两个简单的接口,分别触发master和slave的数据看访问操作。

至此没项目基本结构搭建已完成,启动项目,进行测试。

我们会发现这样master的数据库访问是能正常访问的,但是slave的数据库操作是不行的,报错信息如下:

org.apache.ibatis.binding.bindingexception: invalid bound statement (not found):***

对于这样错误,起初企图通过百度解决,大部分都是说xml文件的命名空间和dao接口全名不对应或者说是接口方法和xml中的方法不对应等等解决方法,

本人检查了自己的代码多遍重启多遍均无法解决,并不是说这些方法不对,但是本案例的问题却不是这些问题导致的。最后无奈,只能硬着头皮去看源码,最后发现了问题所在。

debug源码调试到最后,发现不论是执行mater还是slave的数据库操作,使用了相同的sqlsession,同一个!!!这个肯定是有问题的。

继续看源码进行查,看sqlsession的注入过程。

我们知道mybatis只要写接口不用写实现类(应该是3.0之后的版本),实际上是使用了代理,每个dao接口,在spring容器中其实是对应一个mapperfactorybean(不懂factorybean的可以去多看看spring的一些核心接口,要想看懂spring源码必须要知道的)。

当从容器中获取bean的时候,mapperfactorybean的getobject方法就会根据sqlsession实例生产一个mapperproxy对象的代理类。

问题的关键就在于mapperfactorybean,他继承了sqlsessiondaosupport类,他有一个属性,就是sqlsession,而且刚才所说的创建代理类所依赖的sqlsession实例就是这个。那我们看这个sqlsession实例是什么时候注入的就可以了,就能找到为什么注入了同一个对象了。

找spring注入的地方,spring注入的方式个人目前知道的有注解处理器如@autowired的注解处理器autowiredannotationbeanpostprocessor等类似的beanpostprocessor接口的实现类,还有一种就是在beandefinition中定义器属性的注入方式,在bean的定义阶段就决定了的,前者如果不知道的可以看看,在此不做赘述,后者的处理过程源码如下(只截取核心部分,感兴趣的可以自己看一下处理过程,调用链比较深,贴代码会比较多,看着眼花缭乱):

springboot mybatis调用多个数据源引发的错误问题

debug到dao接口类的的beandefinition(上文已说过其实是mapperfactorybean),发现他的autowiremode是2,参照源码

springboot mybatis调用多个数据源引发的错误问题

即可发现为按照类型自动装配

最关键的来了

debug的时候发现,master的dao接口执行到this.autowirebytype(beanname, mbd, bw, newpvs)方法中,给mapperfactorybean中sqlsession属性注入的实例是mastersqlsessiontemplate对象,

slave的dao接口执行该方法时注入的也是mastersqlsessiontemplate对象,按类型注入,spring容器中找到一个即注入(此时slavesqlsessiontemplate也在容器中,为什么按类型注入找到了mastersqlsessiontemplate却没报错,应该是@primary的作用)

至此,问题产生的原因已基本找到,那该如何解决呢?beandefinition为什么会定义成autowiremode=2呢,只能找@mapperscan看了,看这个注解的处理源码,最后找到classpathmapperscanner以下方法:

private void processbeandefinitions(set<beandefinitionholder> beandefinitions) {
        iterator var3 = beandefinitions.iterator();

        while(var3.hasnext()) {
            beandefinitionholder holder = (beandefinitionholder)var3.next();
            genericbeandefinition definition = (genericbeandefinition)holder.getbeandefinition();
            if (this.logger.isdebugenabled()) {
                this.logger.debug("creating mapperfactorybean with name '" + holder.getbeanname() + "' and '" + definition.getbeanclassname() + "' mapperinterface");
            }

            definition.getconstructorargumentvalues().addgenericargumentvalue(definition.getbeanclassname());
            definition.setbeanclass(this.mapperfactorybean.getclass());
            definition.getpropertyvalues().add("addtoconfig", this.addtoconfig);
            boolean explicitfactoryused = false;
            if (stringutils.hastext(this.sqlsessionfactorybeanname)) {
                definition.getpropertyvalues().add("sqlsessionfactory", new runtimebeanreference(this.sqlsessionfactorybeanname));
                explicitfactoryused = true;
            } else if (this.sqlsessionfactory != null) {
                definition.getpropertyvalues().add("sqlsessionfactory", this.sqlsessionfactory);
                explicitfactoryused = true;
            }

            if (stringutils.hastext(this.sqlsessiontemplatebeanname)) {
                if (explicitfactoryused) {
                    this.logger.warn("cannot use both: sqlsessiontemplate and sqlsessionfactory together. sqlsessionfactory is ignored.");
                }

                definition.getpropertyvalues().add("sqlsessiontemplate", new runtimebeanreference(this.sqlsessiontemplatebeanname));
                explicitfactoryused = true;
            } else if (this.sqlsessiontemplate != null) {
                if (explicitfactoryused) {
                    this.logger.warn("cannot use both: sqlsessiontemplate and sqlsessionfactory together. sqlsessionfactory is ignored.");
                }

                definition.getpropertyvalues().add("sqlsessiontemplate", this.sqlsessiontemplate);
                explicitfactoryused = true;
            }

            if (!explicitfactoryused) {
                if (this.logger.isdebugenabled()) {
                    this.logger.debug("enabling autowire by type for mapperfactorybean with name '" + holder.getbeanname() + "'.");
                }

                definition.setautowiremode(2);
            }
        }

    }

44行是关键,但是有个条件,这个条件成立的原因就是@mapperscan注解没有指定过sqlsessiontemplateref或者sqlsessionfactoryref,正因为没有指定特定的sqlsessiontemplate或者sqlsessionfactory,mybatis默认采用按类型自动装配的方式进行注入。

至此,问题解决方案已出:

代码中的两个@mapperscan用法分别改为:

@mapperscan(basepackages = "com.letzgo.dao.master", sqlsessionfactoryref = "mastersqlsessionfactory", sqlsessiontemplateref = "mastersqlsessiontemplate")  
@mapperscan(basepackages = "com.letzgo.dao.slave", sqlsessionfactoryref = "slavesqlsessionfactory", sqlsessiontemplateref = "slavesqlsessiontemplate")

重启进行测试,问题解决。

ps:

还是对各种注解使用方法不了解(或者说对框架的源码不了解),导致搞了这么久的问题,还好最后查到了,记录于此,给自己加深印象,以后还是要多看源码。以上仅为个人经验,希望能给大家一个参考,也希望大家多多支持。