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

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,则会引起此错误。

如图所示：

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

解决方法

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

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

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

springboot-mybatis多数据源及踩坑

springboot项目结构如下

springboot配置文件内容如下

动态数据源的配置类如下

（必须保证能被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的定义阶段就决定了的，前者如果不知道的可以看看，在此不做赘述，后者的处理过程源码如下（只截取核心部分，感兴趣的可以自己看一下处理过程，调用链比较深，贴代码会比较多，看着眼花缭乱）：

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

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

最关键的来了

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：

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