快捷導(dǎo)航

springboot mybatis調(diào)用多個數(shù)據(jù)源引發(fā)的錯誤問題

更新時間：2022年01月14日 10:23:56 作者：如是雨林

這篇文章主要介紹了springboot mybatis調(diào)用多個數(shù)據(jù)源引發(fā)的錯誤問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

springboot mybatis調(diào)用多個數(shù)據(jù)源錯誤

報錯

'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]

從后往前復(fù)制的，加粗的是重點。

因為有多個數(shù)據(jù)源使用同一個mapper接口，但是都用@Primary,則會引起此錯誤。

如圖所示：

從上面兩圖可以看出都用了同一個mapper接口，都添加了@Primary。

解決方法

解決方法有兩種，一種是把其中一個數(shù)據(jù)源去掉@Primary，動態(tài)調(diào)用數(shù)據(jù)源，就是需要代碼切換使用的數(shù)據(jù)源。

如果要同時使用兩個數(shù)據(jù)源，那就用不同的mapper，相當(dāng)于postgre用postgre部分的mapper，sqlserver用sqlserver部分的mapper，大家互不干擾，就算@primary也沒事

如圖所示，我將postgre的MapperScan改了

springboot-mybatis多數(shù)據(jù)源及踩坑

springboot項目結(jié)構(gòu)如下

springboot配置文件內(nèi)容如下

動態(tài)數(shù)據(jù)源的配置類如下

（必須保證能被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中寫一個數(shù)據(jù)庫訪問操作，再開放兩個簡單的接口，分別觸發(fā)master和slave的數(shù)據(jù)看訪問操作。

至此沒項目基本結(jié)構(gòu)搭建已完成，啟動項目，進(jìn)行測試。

我們會發(fā)現(xiàn)這樣master的數(shù)據(jù)庫訪問是能正常訪問的，但是slave的數(shù)據(jù)庫操作是不行的，報錯信息如下：

org.apache.ibatis.binding.BindingException: Invalid bound statement (not found):***

對于這樣錯誤，起初企圖通過百度解決，大部分都是說xml文件的命名空間和dao接口全名不對應(yīng)或者說是接口方法和xml中的方法不對應(yīng)等等解決方法，

本人檢查了自己的代碼多遍重啟多遍均無法解決，并不是說這些方法不對，但是本案例的問題卻不是這些問題導(dǎo)致的。最后無奈，只能硬著頭皮去看源碼，最后發(fā)現(xiàn)了問題所在。

debug源碼調(diào)試到最后，發(fā)現(xiàn)不論是執(zhí)行mater還是slave的數(shù)據(jù)庫操作，使用了相同的SqlSession，同一個?。?！這個肯定是有問題的。

繼續(xù)看源碼進(jìn)行查，看SqlSession的注入過程。

我們知道m(xù)ybatis只要寫接口不用寫實現(xiàn)類（應(yīng)該是3.0之后的版本），實際上是使用了代理，每個dao接口，在spring容器中其實是對應(yīng)一個MapperFactoryBean（不懂FactoryBean的可以去多看看spring的一些核心接口，要想看懂spring源碼必須要知道的）。

當(dāng)從容器中獲取bean的時候，MapperFactoryBean的getObject方法就會根據(jù)SqlSession實例生產(chǎn)一個MapperProxy對象的代理類。

問題的關(guān)鍵就在于MapperFactoryBean，他繼承了SqlSessionDaoSupport類，他有一個屬性，就是SqlSession，而且剛才所說的創(chuàng)建代理類所依賴的SqlSession實例就是這個。那我們看這個SqlSession實例是什么時候注入的就可以了，就能找到為什么注入了同一個對象了。

找spring注入的地方，spring注入的方式個人目前知道的有注解處理器如@Autowired的注解處理器AutowiredAnnotationBeanPostProcessor等類似的BeanPostProcessor接口的實現(xiàn)類，還有一種就是在BeanDefinition中定義器屬性的注入方式，在bean的定義階段就決定了的，前者如果不知道的可以看看，在此不做贅述，后者的處理過程源碼如下（只截取核心部分，感興趣的可以自己看一下處理過程，調(diào)用鏈比較深，貼代碼會比較多，看著眼花繚亂）：

debug到dao接口類的的BeanDefinition（上文已說過其實是MapperFactoryBean），發(fā)現(xiàn)他的autowiremode是2，參照源碼

即可發(fā)現(xiàn)為按照類型自動裝配

最關(guān)鍵的來了

debug的時候發(fā)現(xiàn)，master的dao接口執(zhí)行到this.autowireByType(beanName, mbd, bw, newPvs)方法中，給MapperFactoryBean中SqlSession屬性注入的實例是masterSqlSessionTemplate對象，

slave的dao接口執(zhí)行該方法時注入的也是masterSqlSessionTemplate對象，按類型注入，spring容器中找到一個即注入（此時slaveSqlSessionTemplate也在容器中，為什么按類型注入找到了masterSqlSessionTemplate卻沒報錯，應(yīng)該是@Primary的作用）

至此，問題產(chǎn)生的原因已基本找到，那該如何解決呢？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行是關(guān)鍵，但是有個條件，這個條件成立的原因就是@MapperScan注解沒有指定過sqlSessionTemplateRef或者sqlSessionFactoryRef，正因為沒有指定特定的sqlSessionTemplate或者sqlSessionFactory，mybatis默認(rèn)采用按類型自動裝配的方式進(jìn)行注入。

至此，問題解決方案已出：

代碼中的兩個@MapperScan用法分別改為：

@MapperScan(basePackages = "com.letzgo.dao.master", sqlSessionFactoryRef = "masterSqlSessionFactory", sqlSessionTemplateRef = "masterSqlSessionTemplate")??
@MapperScan(basePackages = "com.letzgo.dao.slave", sqlSessionFactoryRef = "slaveSqlSessionFactory", sqlSessionTemplateRef = "slaveSqlSessionTemplate")

重啟進(jìn)行測試，問題解決。

PS：

還是對各種注解使用方法不了解（或者說對框架的源碼不了解），導(dǎo)致搞了這么久的問題，還好最后查到了，記錄于此，給自己加深印象，以后還是要多看源碼。以上僅為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: