多数据源_木可baby的博客-程序员秘密

技术标签: 多数据源  

多数据源处理,且自动切换数据源

1.配置数据源地址、账号、密码
#数据源 1
url:jdbc:mysql://ip1:3306/test1?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8
driverClassName:com.mysql.jdbc.Driver
username:root
password:root

#数据源 2
url2:jdbc:mysql://ip2:3306/test2?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8 
driverClassName2:com.mysql.jdbc.Driver
username2:root
password2:root
2.xml中配置数据源

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:aop="http://www.springframework.org/schema/aop" 
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
						http://www.springframework.org/schema/beans/spring-beans.xsd
						http://www.springframework.org/schema/aop 
						http://www.springframework.org/schema/aop/spring-aop.xsd
						http://www.springframework.org/schema/context 
						http://www.springframework.org/schema/context/spring-context.xsd
						http://www.springframework.org/schema/tx 
						http://www.springframework.org/schema/tx/spring-tx.xsd
	">

	<!--配置整合mybatis过程-->


	<context:property-placeholder location="classpath:jdbc.properties" ignore-unresolvable="true"/>

	<!--2、 数据源druid -->
	<!-- 数据源1 start -->
	<bean id="dataSource1" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
		<!-- 数据库基本信息配置 -->
		<property name="url" value="${url}" />
		<property name="username" value="${username}" />
		<property name="password" value="${password}" />
		<property name="driverClassName" value="${driverClassName}" />
		
	</bean>
	<!-- 数据源1 end -->

	<!-- 数据源2 start -->
	<bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
		<property name="url" value="${url2}" />
		<property name="username" value="${username2}" />
		<property name="password" value="${password2}" />
		<property name="driverClassName" value="${driverClassName2}" />
	</bean>
	<!-- 数据源2 end -->


	<bean id="dynamicDataSource" class="com.muke.datasource.DynamicDataSource">
		<property name="targetDataSources">
			<map key-type="java.lang.String">
				<entry key="key1" value-ref="dataSource1"/>
				<entry key="key2" value-ref="dataSource2"/>
			</map>
		</property>
		<!--默认数据源-->
		<property name="defaultTargetDataSource" ref="dataSource1"/>
	</bean>

	<!--3、 配置SqlSessionFactory对象 -->
	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
		<!-- 注入数据库连接池 -->
		<property name="dataSource" ref="dynamicDataSource"/>
		<!-- 配置mybatis全局配置文件:mybatis-config.xml -->
		<property name="configLocation" value="classpath:spring/mybatis-config.xml"/>
		<property name="typeAliasesPackage" value="com.muke.dto"/>
		<!-- 扫描sql配置文件:mapper需要的xml文件 -->
		<property name="mapperLocations" value="classpath:mapper/**/*.xml"></property>
		<!--  -->
		<!--  -->
	</bean>

	<!--4、配置扫描Dao接口包,动态实现DAO接口,注入到spring容器-->
	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
		<!--注入SqlSessionFactory-->
		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
		<!-- 给出需要扫描的Dao接口-->
		<property name="basePackage" value="com.muke.dao.infirmary,com.muke.dao.local"/>
	</bean>

	<bean name="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dynamicDataSource"></property>
	</bean>
</beans>

3.数据源切换工具类
  • (1).枚举类
package com.muke.datasource;

/**
 * @author muke
 * @date 2019/9/1 18:21
 */
public enum DataSourceEnum {

    DS1("key1"), DS2("key2");

    private String key;

    DataSourceEnum(String key) { this.key = key; }

    public String getKey() { return key; }

    public void setKey(String key) {  this.key = key; }
}

  • (2).创建DynamicDataSourceHolder用于持有当前线程中使用的数据源标识
package com.muke.datasource;

/**
 * @author muke
 * @date 2019/8/21 16:58
 * DynamicDataSourceHolder用于持有当前线程中使用的数据源标识
 */
public class DataSourceHolder {

    private static final ThreadLocal<String> dataSources = new ThreadLocal<String>();

    public static void setDataSources(String dataSource) {
        dataSources.set(dataSource);
    }

    public static String getDataSources() {
        return dataSources.get();
    }

    public static void clearDataSourceKey() {
        dataSources.remove();
    }
}

  • (3).创建DynamicDataSource的类,继承AbstractRoutingDataSource并重写determineCurrentLookupKey方法
package com.muke.datasource;

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

/**
 * @author muke
 * @date 2019/8/21 16:56
 * DynamicDataSource的类,继承AbstractRoutingDataSource并重写determineCurrentLookupKey方法
 */
public class DynamicDataSource extends AbstractRoutingDataSource {

    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceHolder.getDataSources();
    }
}

4.(检测)手动切换数据源到这一步,已经可以试用各个数据源了,只需要在Service中查询前,调用一下即可
@Override
public TeacherVO getVOById(Integer id) {
   //切换数据源
    DataSourceHolder.setDataSources(DataSourceEnum.DS2.getKey());
    return teacherDao.getVOById(id);
}

@Override
public Product getPOById(Integer id) {
    //切换数据源
    DataSourceHolder.setDataSources(DataSourceEnum.DS1.getKey());
    return productDao.getPOById(id);
5.自动切换数据源(做此步骤必须要达到手动的切换的配置)
  • (1).虽然可以手动切换数据源,但每个方法都切换太过麻烦,很容易忘记,所以可以利用AOP,进行自动切换数据源
    创建切面类DataSourceExchange,切面的规则可以自定义,根据自己的项目做自己的规则,我这边是demo,我是从dao层切换的,dao下面有两个包,infirmary是主要源,local是第二数据源,第一源是默认源,如果调用第二源时需要切换
package com.muke.datasource;

import org.aspectj.lang.JoinPoint;

/**
 * @author muke
 * @date 2019/9/1 17:37
 */
public class DataSourceExchange {

    public void before(JoinPoint point) {

        System.out.println("切换了数据源");
        DataSourceHolder.setDataSources(DataSourceEnum.DS2.getKey());
    }

    /**
     * 执行后将数据源置为空
     */
    public void after() {

        System.out.println("清除数据源--------------------------");
        DataSourceHolder.clearDataSourceKey();
    }

    /**
     * @param joinPoint
     * @param ex
     * 针对当前拦截的切点方法中出现异常时所做的处理
     */
    public void afterThrow(JoinPoint joinPoint, Exception ex) {
        DataSourceHolder.clearDataSourceKey();
    }

}

  • (2).配置切面
<bean id="dataSourceExchange" class="com.muke.datasource.DataSourceExchange"/>
	<aop:config>
		<aop:aspect ref="dataSourceExchange">
			<aop:pointcut id="dataSourcePointcut" expression="execution(* com.muke.dao.local.*.*(..)))"/>
			<aop:before pointcut-ref="dataSourcePointcut" method="before"/>
			<aop:after pointcut-ref="dataSourcePointcut" method="after"/>
			<aop:after-throwing method="afterThrow" pointcut-ref="dataSourcePointcut" throwing="ex" />
		</aop:aspect>
	</aop:config>
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/yumu1234567/article/details/100555188

智能推荐

PyCharm vs Spyder:两个Python IDE的快速比较_cumei1658的博客-程序员秘密

If you have followed my blog you may have noticed that a lot of focus have been put on how to learn programming (particularly in Python). I have also written about Integrated Development Environments ...

961计算机组成原理,2018考研华中科技大学961计算机组成原理(二)考试大纲_祈盟的博客-程序员秘密

华中科技大学研究生考试大纲为广大想报考华中科技大学的考生划出了大致的考试范围以及试卷的结构和题型,是广大考研学生的重要参考文件之一。下面是研招网小编为大家整理的最新2018考研华中科技大学961计算机组成原理(二)考试大纲,以供大家参考。硕士研究生入学考试大纲――《计算机组成原理(二)》科目代码(961)一、考试性质《计算机组成原理》是报考我校协和医院生物医学工程学硕士的专业基础课,旨在考察学生是...

JS本地存储和会话存储的区别_Serena_tz的博客-程序员秘密_本地存储和会话存储的区别

1、localStorage本地存储localStorage生命周期是永久,这意味着除非用户显示在浏览器提供的UI上清除localStorage信息,否则这些信息将永远存在。存放数据大小为一般为5MB,而且它仅在客户端(即浏览器)中保存,不参与和服务器的通信。2、sessionStorage会话存储sessionStorage仅在当前会话下有效,关闭页面或浏览器后被清除。存放数据大小为一般为5MB,而且它仅在客户端(即浏览器)中保存,不参与和服务器的通信。源生接口可以接受,亦可再次封装来对Object

校本课程中计算机工作原理,信息技术校本课程纲要_成都蹦迪阿亮的博客-程序员秘密

《信息技术校本课程纲要》由会员分享,可在线阅读,更多相关《信息技术校本课程纲要(4页珍藏版)》请在人人文库网上搜索。1、信息技术校本课程纲要课程名称:如何构建家庭局域网课程类型:科学素养类教学材料:自编授课课时: 30 课时主讲教师:张刚授课对象:初一、初二学生一、 课程目标:(一)、知识与技能:1、通过本课程的学习, 培养学生在信息技术方面的动手能力, 拓 展学生的知识面,从而提高学生的综合信息...

产品经理看哪吒之魔童降世_weixin_30820077的博客-程序员秘密

前戏哪吒在这个暑假,一下子变成了红人。本来他人是红色的,这个也许是他能红的原因吧,一个小朋友这样说到。其实,对于整天对着电脑和媒体的程序员来说,哪吒的出现概率太高了,博客有介绍的,朋友圈内推荐的,同事饭后八卦的。都红成西红柿了,不想看都难。其实,每年出来那么多电影,能让大家广泛讨论并且有那么大群众基础的作品并不多。无论从什么角度,我都要去看一下。 看看这个新出的作品为什么火的一塌糊度...

随便推点

华中科技大学计算机组成原理慕课第四章 存储系统(一) 单元测验(习题+答案+详细解析)_Code_流苏的博客-程序员秘密_sram中的存储单元

华中科技大学计算机组成原理慕课第四章 存储系统(一) 单元测验(习题+答案+详细解析)

Pycharm IDE安装pandas库失败解决方法_ChiFanLAM的博客-程序员秘密_安装pandas库失败

Pycharm IDE安装pandas库失败解决方法作为一名python新手,我们利用Pychram IDE进行编程时总是会遇到一些配置上的难题。比如,在配置第三方库文件时,我们会遇到漫长的等待安装时间后,却发现安装失败!!!具体的安装失败错误提示为:Error occur when installing " "找遍了各种方法,发现下面的解决方案真的屡试不爽:进入Pycharm的terminal:输入:python -m pip install -upgrade pip或者在P

linux 挂载存储命令,Linux挂载存储及命令_知乎汽车的博客-程序员秘密

常用命令一、网卡部分1、确认IP地址命令ifconfigifconfig -aifconfig ethX2、关闭命令ifdown ethXservice network stop3、开启命令ifup ethXservice network start4、重启命令service network restart/etc/init.d/network restart5、修改IP地址命令vi /etc/s...

华东理工大学计算机组成原理试题,华中科技大学计算机组成原理1999年考研真题考研试题硕士研究生入学考试试题(原华东理工大学)..._Z-JO的博客-程序员秘密

华中理工大学1999硕士入学计算机组成原理真题一.填空(每空1分,共20分)1.计算机中数值数据表示长采用的格式有 和 两种。2.已知十进制数,则相应的二进制数X= ,[X]补= 。3.若X=-0.X1X2……Xn,则[X]原= ,[-X]补= 。4.主机与外部设备之间以软件方式控制信息交换的方式有 ...

python try catch finally_Java try catch finally异常处理(Exception)_金雪锋的博客-程序员秘密

1、Java Exceptions执行Java代码时,可能会发生不同的错误异常:程序员编写的编码错误,由于输入错误引起的错误或其他不可预见的情况。发生错误时,Java通常会停止并生成错误消息。 技术术语是:Java将引发异常(引发错误)。2、Java try catchtry语句允许定义要执行的错误代码块。如果在try块中发生错误,则catch语句允许定义要执行的代码块。try和catch关键字...

java异常处理_weixin_34228387的博客-程序员秘密

可直接看这篇文章即可:http://www.importnew.com/26613.htmljava异常类图非检查异常(unckecked exception):Error 和 RuntimeException 以及他们的子类。javac在编译时,不会提示和发现这样的异常,不要求在程序处理这些异常。所以如果愿意,我们可以编写代码处理(使用try…catch…finally)这样的异常,...

推荐文章

热门文章

相关标签