SpringMVC + Mybatis 多数据源配置

快来打我* 2023-06-02 05:25 93阅读 0赞

比较常用的配置，多数据源、主从等等。

大概的逻辑是：

1、spring-mybatis.xml中配置多个数据源

2、使用Spring提供的AbstractRoutingDataSource类来根据请求路由到不同的数据源

3、ThreadLocal解决线程安全问题

详情参考：

[【Java】一次SpringMVC+ Mybatis 配置多数据源经历][Java_SpringMVC_ Mybatis]

[利用Spring的AbstractRoutingDataSource解决多数据源的问题][Spring_AbstractRoutingDataSource]

spring官网demo：[Dynamic DataSource Routing][]

一直没调通，切换后仍是默认数据库！！！

=================放弃spring动态数据源，用mybatis的environments来解决=============

关于mybatis的environments，请查询官网文档：[http://www.mybatis.org/mybatis-3/zh/configuration.html\#environments][http_www.mybatis.org_mybatis-3_zh_configuration.html_environments]

一、mybatis-conf.xml 配置两个数据源：<environment id="env\_stg">，<environment id="env\_vtp">

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE configuration PUBLIC
            "-//mybatis.org//DTD Config 3.0//EN"
            "http://mybatis.org/dtd/mybatis-3-config.dtd">
    <configuration>
        
        <properties resource="jdbc.properties"/>
        <settings>
            
            <setting name="mapUnderscoreToCamelCase" value="true"/>
        </settings>
        
        <typeAliases>
            <package name="qa.vop.model" />
        </typeAliases>
        
        <environments default="env_stg">
            <environment id="env_stg">
                <transactionManager type="JDBC" />
                <dataSource type="POOLED">
                    <property name="driver" value="${driver}" />
                    <property name="url" value="${url}" />
                    <property name="username" value="${username}" />
                    <property name="password" value="${password}" />
                </dataSource>
            </environment>
            <environment id="env_vtp">
                <transactionManager type="JDBC" />
                <dataSource type="POOLED">
                    <property name="driver" value="${driver}" />
                    <property name="url" value="${url_vtp}" />
                    <property name="username" value="${username_vtp}" />
                    <property name="password" value="${password_vtp}" />
                </dataSource>
            </environment>
        </environments>
         
         <mappers>  
            <package name="qa.vop.dao"/>  
        </mappers>
    </configuration>

二、写一个类，根据不同的环境来build SqlSessionFactory

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

public class MySQLSessionFactory {
    
        private SqlSessionFactory sqlSessionFactory = null;
    
        public SqlSessionFactory getSqlSessionFactory(String cfgFilePath,String env) {
            InputStream is = null;
            try {
                is = Resources.getResourceAsStream("mybatis-conf.xml");
                if (null == env || env.isEmpty()) {
                    sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
                } else {
                    sqlSessionFactory = new SqlSessionFactoryBuilder().build(is,env);
                }
            } catch (IOException e) {
                System.out.println(e.getMessage());
            }
            return sqlSessionFactory;
        }
    }

三、controller中，根据不同环境，来切换数据源。

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

@Controller
    public class SuperController{
    
        private static final String MYBATIS_CFG = "mybatis-conf.xml";
        private static SqlSession session = new MySQLSessionFactory().getSqlSessionFactory(MYBATIS_CFG,null).openSession();
        
    
        @RequestMapping("/queryJit")
        public ModelAndView getJit(ModelAndView mv){        
            mv.addObject("jitList", session.getMapper(JitMapper.class).selectAllJits() );
            mv.setViewName("jit");
            return mv;
        }
        
        @RequestMapping("/queryVTP")
        public ModelAndView getVTPRunResult(ModelAndView mv){    
            SqlSession session1 = new MySQLSessionFactory().getSqlSessionFactory(MYBATIS_CFG,"env_vtp").openSession();
            mv.addObject("vtpRunResultList", session1.getMapper(VtpRunResultMapper.class).selectAllResults() );
            mv.setViewName("quality-vtp");
            return mv;
        }
    }

转载于:https://www.cnblogs.com/dannyyao/p/6636242.html

[Java_SpringMVC_ Mybatis]: http://www.cnblogs.com/puyangsky/p/6133553.html
[Spring_AbstractRoutingDataSource]: http://blog.csdn.net/alaahong/article/details/8707915
[Dynamic DataSource Routing]: http://spring.io/blog/2007/01/23/dynamic-datasource-routing
[http_www.mybatis.org_mybatis-3_zh_configuration.html_environments]: http://www.mybatis.org/mybatis-3/zh/configuration.html#environments
[ContractedBlock.gif]: https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif
[ExpandedBlockStart.gif]: /images/20230601/232005ef64bc456b85f5804d9552f72d.png