前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >spring+mybatis 多数据源切换

spring+mybatis 多数据源切换

原创
作者头像
用户1503405
修改2021-09-27 10:28:27
3650
修改2021-09-27 10:28:27
举报
文章被收录于专栏:棒棒小飞人

spring + mybatis 多数据源切换

DbContextHolder

代码语言:javascript
复制
public class DbContextHolder {
    //线程安全的ThreadLocal
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();

    public static void setDbType(String dbType) {
        contextHolder.set(dbType);
    }

    public static String getDbType() {
        return ((String)contextHolder.get());
    }
    public static void clearDbType() {
        contextHolder.remove();
    }

}

DynamicDataSource

代码语言:javascript
复制
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

public class DynamicDataSource extends AbstractRoutingDataSource {

    @Override
    public Object determineCurrentLookupKey() {
        return  DbContextHolder.getDbType();
    }

}

spring.xml

代码语言:javascript
复制
<!-- 数据源属性配置文件 -->
    <context:property-placeholder location="classpath:ibatis.properties" />

    <bean id="jksh" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <!-- Connection Info -->
        <property name="driverClassName" value="${driver.jksh}" />
        <property name="url" value="${url.jksh}" />
        <property name="username" value="${username.jksh}" />
        <property name="password" value="${password.jksh}" />

        <!-- Connection Pooling Info -->
        <property name="maxIdle" value="${maxIdle.jksh}" />
        <property name="maxActive" value="${maxActive.jksh}" />
        <property name="defaultAutoCommit" value="false" />
        <property name="timeBetweenEvictionRunsMillis"
            value="${timeBetweenEvictionRunsMillis.jksh}" />
        <property name="minEvictableIdleTimeMillis" value="${minEvictableIdleTimeMillis.jksh}" />
    </bean>

    <bean id="jclt" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <!-- Connection Info -->
        <property name="driverClassName" value="${driver.jclt}" />
        <property name="url" value="${url.jclt}" />
        <property name="username" value="${username.jclt}" />
        <property name="password" value="${password.jclt}" />

        <!-- Connection Pooling Info -->
        <property name="maxIdle" value="${maxIdle.jclt}" />
        <property name="maxActive" value="${maxActive.jclt}" />
        <property name="defaultAutoCommit" value="false" />
        <property name="timeBetweenEvictionRunsMillis" value="${timeBetweenEvictionRunsMillis.jclt}" />
        <property name="minEvictableIdleTimeMillis" value="${minEvictableIdleTimeMillis.jclt}" />
    </bean>

    <bean id="dataSource" class="com.jclt.service.commons.DynamicDataSource">
        <property name="targetDataSources">
            <map key-type="java.lang.String">
                <entry key="jksh" value-ref="jksh" />
                <entry key="jclt" value-ref="jclt" />
            </map>
        </property>
        <property name="defaultTargetDataSource" ref="jksh" />
    </bean>

main方法

代码语言:javascript
复制
import javax.sql.DataSource;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext; 
import org.springframework.core.io.FileSystemResource;
import org.springframework.core.io.Resource;

import com.jclt.service.commons.DbContextHolder;
import com.jclt.service.model.User;

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;

public class Text {

    /**
     * @param args
     */
    public static void main(String[] args) {
        ApplicationContext appContext = new ClassPathXmlApplicationContext("client-beans.xml");

        DbContextHolder.setDbType("jclt");
        String res="src/main/resources/ibatis-config.xml";
        DataSource datasource=(DataSource) appContext.getBean("dataSource");

        SqlSessionFactoryBean bean=new SqlSessionFactoryBean();
        bean.setDataSource(datasource);
        Resource resource=new FileSystemResource(res);
        bean.setConfigLocation(resource);
        try {
            SqlSessionFactory sessionfactory = bean.getObject();
            SqlSession session=sessionfactory.openSession();
            User user=session.selectOne("com.jclt.service.Dao.readJKSH.findOne");
            System.out.println(user.getName());
        } catch (Exception e) {
            e.printStackTrace();
        }

        DbContextHolder.setDbType("jksh");
        String res1="src/main/resources/ibatis-config.xml";
        DataSource datasource1=(DataSource) appContext.getBean("dataSource");

        SqlSessionFactoryBean bean1=new SqlSessionFactoryBean();
        bean1.setDataSource(datasource1);
        Resource resource1=new FileSystemResource(res1);
        bean1.setConfigLocation(resource1);

        try {
            SqlSessionFactory sessionfactory = bean.getObject();
            SqlSession session=sessionfactory.openSession();
            User user=session.selectOne("com.jclt.service.Dao.readJKSH.findOne");
            System.out.println(user.getName());
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

}

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档