1. 程式人生 > >Mybatis配置多個數據源

Mybatis配置多個數據源

1.編寫2個以上資料來源
<bean id="dataSource1" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
        <property name="driverClass" value="${jdbc.km.driverClassName}" />
        <property name="jdbcUrl" value="${jdbc.km.url}" />
        <property name="user" value="${jdbc.km.username}" />
        <property name="password" value="${jdbc.km.password}" />
    </bean>
    
    <bean id="dataSource2" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
        <property name="driverClass" value="${jdbc.pm.driverClassName}" />
        <property name="jdbcUrl" value="${jdbc.pm.url}" />
        <property name="user" value="${jdbc.pm.username}" />
        <property name="password" value="${jdbc.pm.password}" />
    </bean>
2.建立MultipleDataSource類用於切換資料來源 需要 extends

org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource


package com.km.db;

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

public class MultipleDataSource extends AbstractRoutingDataSource {
    private static final ThreadLocal<String> dataSourceKey = new InheritableThreadLocal<String>();

    public static void setDataSourceKey(String dataSource) {
        dataSourceKey.set(dataSource);
    }

    @Override
    protected Object determineCurrentLookupKey() {
        return dataSourceKey.get();
    }
}
3.配置
<bean id="dataSource" class="com.km.db.MultipleDataSource">
        <property name="defaultTargetDataSource" ref="dataSource1"/>
        <property name="targetDataSources">
            <map>
                <entry key="data1" value-ref="dataSource1"/>
                <entry key="data2" value-ref="dataSource2"/>
            </map>
        </property>
</bean>


<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="mapperLocations" value="classpath:com/km/mapper/*.xml" />
    </bean>

4.呼叫
在訪問資料操作前呼叫

MultipleDataSource.setDataSourceKey(data2)
List<User> users = synchronizeDataDao.queryUser();