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

目录

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

如图所示：

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

解决方法

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

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

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

springboot-mybatis多数据源及踩坑

springboot项目结构如下

springboot配置文件内容如下

动态数据源的配置类如下

（必须保证能被componentscan扫描到）：

package com.letzgo.config;import com.alibaba.druid.pool.druiddatasource;import org.apache.ibatis.ssion.sqlssionfactory;import org.mybatis.spring.sqlssionfactorybean;import org.mybatis.spring.sqlssiontemplate;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(bapackages = "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("mastersqlssionfactory")        @qualifier("mastersqlssionfactory")        public sqlssionfactory sqlssionfactory(@qualifier("masterdatasource") datasource datasource) throws exception {            sqlssionfactorybean factorybean = new sqlssionfactorybean();            factorybean.tdatasource(datasource);            factorybean.tmapperlocations(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("mastersqlssiontemplate")        @qualifier("mastersqlssiontemplate")        public sqlssiontemplate sqlssiontemplate(@qualifier("mastersqlssionfactory") sqlssionfactory sqlssionfactory) {            return new sqlssiontemplate(sqlssionfactory);        }    }    @configuration    @mapperscan(bapackages = "com.letzgo.dao.slave")    public static class slave {        @bean("slavedatasource")        @qualifier("slavedatasource")        @configurationproperties(prefix = "spring.datasource.slave")        public datasource datasource() {            return new druiddatasource();        }        @bean("slavesqlssionfactory")        @qualifier("slavesqlssionfactory")        public sqlssionfactory sqlssionfactory(@qualifier("slavedatasource") datasource datasource) throws exception {            sqlssionfactorybean factorybean = new sqlssionfactorybean();            factorybean.tdatasource(datasource);            factorybean.tmapperlocations(new pathmatchingresourcepatternresolver().getresources("classpath:mapper/slave/*.xml"));            return factorybean.geto怎么设置默认的浏览器bject();        }        @bean("slavetransactionmanager")        @qualifier("slavetransactionmanager")        public datasourcetransactionmanager transactionmanager(@qualifier("slavedatasource") datasource datasource) {            return new datasourcetransactionmanager(datasource);        }        @bean("slavesqlssiontemplate")        @qualifier("slavesqlssiontemplate")        public sqlssiontemplate sqlssiontemplate(@qualifier("slavesqlssionfactory") sqlssionfactory sqlssionfactory) {            return new sqlssiontemplate(sqlssionfactory);        }    }}

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

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

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

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

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

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

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

继续看源码进行查，看sqlssion的注入过程。

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

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

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

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

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

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

最关键的来了

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

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

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

private void processbeandefinitions(t<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.tbeanclass(this.mapperfactorybean.getclass());            definition.getpropertyvalues().add("addtoconfig", this.addtoconfig);            boolean explicitfactoryud = fal;            if (stringutils.hastext(this.sqlssionfactorybeanname)) {                definition.getpropertyvalues().add("sqlssionfactory", new runtimebeanreference(this.sqlssionfactorybeanname));                explicitfactoryud = true;            } el if (this.sqlssionfactory != null) {                definition.getpropertyvalues().add("sqlssionfactory", this.sqlssionfactory);                explicitfactoryud = true;            }            if (stringutils.hastext(this.sqlssiontemplatebeanname)) {                if (explicitfactoryud) {                    this.logger.warn("cannot u both: sqlssiontemplate and sqlssionfactory t退伍待遇ogether. sqlssionfactory is ignored.");                }                definition.getpropertyvalues().add("sqlssiontemplate", new runtimebeanreference(this.sqlssiontemplatebeanname));                explicitfactoryud = true;            } el if (this.sqlssiontemplate != null) {                if (explicitfactoryud) {                    this.logger.warn("cannot u both: sqlssiontemplate and sqlssionfactory together. sqlssionfactory is ignored.");                }                definition.getpropertyvalues().add("sqlssiontemplate", this.sqlssiontemplate);                explicitfactoryud = true;            }            if (!explicitfactoryud) {                if (this.logger.isdebugenabled()) {                    this.logger.debug("enabling autowire by type for mapperfactorybean with name '" + holder.getbeanname() + "'.");                }                definition.tautowiremode(2);            }        }    }

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

至此，问题解决方案已出：

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

@mappers母亲节图片简笔画can(bapackages = "com.letzgo.dao.master", sqlssionfactoryref = "mastersqlssionfactory", sqlssiontemplateref = "mastersqlssiontemplate")@mapperscan(bapackages = "com.letzgo.dao.slave", sqlssionfactoryref = "slavesqlssionfactory", sqlssiontemplateref = "slavesqlssiontemplate")

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

ps：

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