Spring+Mybatis 通过databaseIdProvider支持多数据库

╰半夏微凉° 2022-04-25 01:06 209阅读 0赞

### 概述 ###

本人最近接到一个任务，就是将原来的一个可**自配置信息管理系统**升级成可同时兼容*oracle*数据库版本(原来是仅支持*mysql*的)。即便大部分的sql语句通用，但是还有许多语法存在差异，所以我们可以通过mybatis自身提供的databaseIdProvider解决这个问题，这里记录一下过程。

### 官方描述 ###

> databaseId 如果配置了 databaseIdProvider，MyBatis 会加载所有的不带 databaseId 或匹配当前 databaseId 的语句；如果带或者不带的语句都有，则不带的会被忽略。

### 配置 ###

1.配置文件目录结构

![Image 1][]

image.png

2.config.properties

![Image 1][]

image.png

把两个jdbc的信息整合在一起。

3.datasource.xml

<bean id="mysql" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
            <property name="driverClassName" value="${mysql.driver}"/>
            
            <property name="url" value="${mysql.url}"/>
            <property name="username" value="${mysql.username}"/>
            <property name="password" value="${mysql.password}"/>
    
            
            <property name="initialSize" value="${mysql.initialSize}"/>
            <property name="minIdle" value="${mysql.initialSize}"/>
            <property name="maxActive" value="${mysql.maxActive}"/>
    
            <property name="filters" value="config"/>
            <property name="connectionProperties"
                      value="config.decrypt=${mysql.password.decrypt};config.decrypt.key=${mysql.publickey}"/>
    
            
            
    
            
            <property name="timeBetweenEvictionRunsMillis" value="60000"/>
    
            
            <property name="minEvictableIdleTimeMillis" value="300000"/>
    
            <property name="validationQuery" value="SELECT 'x'"/>
            <property name="testWhileIdle" value="true"/>
            <property name="testOnBorrow" value="false"/>
            <property name="testOnReturn" value="false"/>
    
            
            <property name="poolPreparedStatements" value="false"/>
            <property name="maxPoolPreparedStatementPerConnectionSize" value="-1"/>
    
    
        </bean>
    
        <bean id="oracle" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
            <property name="driverClassName" value="${oracle.driver}"/>
            
            <property name="url" value="${oracle.url}"/>
            <property name="username" value="${oracle.username}"/>
            <property name="password" value="${oracle.password}"/>
            
            <property name="initialSize" value="${oracle.initialSize}"/>
            <property name="minIdle" value="${oracle.initialSize}"/>
            <property name="maxActive" value="${oracle.maxActive}"/>
            <property name="filters" value="config"/>
            <property name="connectionProperties"
                      value="config.decrypt=${oracle.password.decrypt};config.decrypt.key=${oracle.publickey}"/>
            
            
            
            <property name="timeBetweenEvictionRunsMillis" value="60000"/>
            
            <property name="minEvictableIdleTimeMillis" value="300000"/>
            <property name="validationQuery" value="SELECT 'x' from dual"/>
            <property name="testWhileIdle" value="true"/>
            <property name="testOnBorrow" value="false"/>
            <property name="testOnReturn" value="false"/>
            
            <property name="poolPreparedStatements" value="false"/>
            <property name="maxPoolPreparedStatementPerConnectionSize" value="-1"/>
        </bean>
        <bean id="vendorProperties"
              class="org.springframework.beans.factory.config.PropertiesFactoryBean">
            <property name="properties">
                <props>
                    <prop key="Oracle">oracle</prop>
                    <prop key="MySQL">mysql</prop>
                </props>
            </property>
        </bean>
        <bean id="databaseIdProvider" class="org.apache.ibatis.mapping.VendorDatabaseIdProvider">
            <property name="properties" ref="vendorProperties"/>
        </bean>

这里两个数据源的bean对象大同小异，主要是下方增加了databseIdProvider的配置。

4.spring-mybatis.xml

增加sqlSessionFactory对databaseProvider的引入。

### 测试 ###

至此，配置的工作已经结束，我们来进行一下本地测试。  
1.DAO

public interface TestDBMapper {
        String selectTime();
    }

2.mapper

<mapper namespace="com.hengzhe.hz.manager.data.biz.dao.TestDBMapper">
     
        <select id="selectTime"  resultType="String">
            select
            <if test="_databaseId == 'mysql'">
              now()
            </if>
            <if test="_databaseId == 'oracle'">
              sysdate
            </if>
            from dual
        </select>
    </mapper>

此处注释掉的是第一种方法，就是一开始mybatis官方文档上说的，增加databaId就可以在运行时选择执行那一句sql。  
第二种方法更为方便，可以节省很多重复性的代码。  
3.JUnit测试用例

public class TestDBMapperTest extends AbstractTestBase {
        @Autowired TestDBMapper testDBMapper;
        @Test
        public void testSelectTime () {
            String time = testDBMapper.selectTime();
            System.out.println(time);
        }
    }

输出结果:

![Image 1][]

image.png

由于目前配置的是mysql数据库，所以输出sql语句用的是now()函数。

作者：超人有点忙  
链接：https://www.jianshu.com/p/b21a8b3fbd53  
来源：简书  
简书著作权归作者所有，任何形式的转载都请联系作者获得授权并注明出处。

[Image 1]: