spring+mybatis 配置双数据源

时间:2022-11-05 21:14:10

配置好后,发现网上已经做好的了, 不过,跟我的稍有不同, 我这里再拿出来现个丑:

properties 文件自不必说,关键是这里的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:mvc="http://www.springframework.org/schema/mvc"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:cache="http://www.springframework.org/schema/cache"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/cache
http://www.springframework.org/schema/cache/spring-cache-3.2.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.2.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.0.xsd"> <!-- 属性文件读入 -->
<bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>classpath:dfintop.properties</value>
</list>
</property>
</bean> <!-- 它背后注册了很多用于解析注解的处理器,其中就包括<context:annotation-config/>配置的注解所使用的处理器 -->
<!-- 所以配置了<context:component-scan base-package="">之后,便无需再配置<context:annotation-config> -->
<context:component-scan base-package="com.dffk.dfintop.**.controller,com.dffk.dfintop.**.service,com.dffk.dfintop.**.quartz,com.dffk.dfintop.**.shiro,com.dffk.dfintop.common.util,com.dffk.dfintop.common.listener,com.dffk.dfintop.framework.websocket,org.activiti.rest.editor">
<!-- <context:component-scan base-package="com.dffk.dfintop"> -->
<context:include-filter type="annotation" expression="org.springframework.stereotype.Controller" />
<!-- <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Service" /> -->
</context:component-scan> <!-- 启用SpringMVC的注解功能,它会自动注册HandlerMapping、HandlerAdapter、ExceptionResolver的相关实例 -->
<mvc:annotation-driven/> <!-- json处理 -->
<bean id="objectMapper" class="com.fasterxml.jackson.databind.ObjectMapper"></bean> <!-- 数据源配置, 使用 BoneCP 数据库连接池 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
init-method="init" destroy-method="close">
<!-- 数据源驱动类可不写,Druid默认会自动根据URL识别DriverClass -->
<property name="driverClassName" value="${jdbc.driver}" />
<!-- 基本属性 url、user、password -->
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<!-- 配置初始化大小、最小、最大 -->
<property name="initialSize" value="${jdbc.pool.init}" />
<property name="minIdle" value="${jdbc.pool.minIdle}" />
<property name="maxActive" value="${jdbc.pool.maxActive}" />
<!-- 配置获取连接等待超时的时间 -->
<property name="maxWait" value="" />
<!-- 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 -->
<property name="timeBetweenEvictionRunsMillis" value="" />
<!-- 配置一个连接在池中最小生存的时间,单位是毫秒 -->
<property name="minEvictableIdleTimeMillis" value="" />
<property name="validationQuery" value="${jdbc.testSql}" />
<property name="testWhileIdle" value="true" />
<property name="testOnBorrow" value="false" />
<property name="testOnReturn" value="false" />
<!-- 打开PSCache,并且指定每个连接上PSCache的大小(Oracle使用) <property name="poolPreparedStatements"
value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize"
value="" /> -->
<!-- 配置监控统计拦截的filters -->
<property name="filters" value="stat" />
</bean> <!-- 数据源配置, 使用 BoneCP 数据库连接池 -->
<bean id="dataSource_2" class="com.alibaba.druid.pool.DruidDataSource"
init-method="init" destroy-method="close">
<!-- 数据源驱动类可不写,Druid默认会自动根据URL识别DriverClass -->
<property name="driverClassName" value="${jdbc_2.driver}" />
<!-- 基本属性 url、user、password -->
<property name="url" value="${jdbc_2.url}" />
<property name="username" value="${jdbc_2.username}" />
<property name="password" value="${jdbc_2.password}" />
<!-- 配置初始化大小、最小、最大 -->
<property name="initialSize" value="${jdbc_2.pool.init}" />
<property name="minIdle" value="${jdbc_2.pool.minIdle}" />
<property name="maxActive" value="${jdbc_2.pool.maxActive}" />
<!-- 配置获取连接等待超时的时间 -->
<property name="maxWait" value="" />
<!-- 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 -->
<property name="timeBetweenEvictionRunsMillis" value="" />
<!-- 配置一个连接在池中最小生存的时间,单位是毫秒 -->
<property name="minEvictableIdleTimeMillis" value="" />
<property name="validationQuery" value="${jdbc_2.testSql}" />
<property name="testWhileIdle" value="true" />
<property name="testOnBorrow" value="false" />
<property name="testOnReturn" value="false" />
<!-- 打开PSCache,并且指定每个连接上PSCache的大小(Oracle使用) <property name="poolPreparedStatements"
value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize"
value="" /> -->
<!-- 配置监控统计拦截的filters -->
<property name="filters" value="stat" />
</bean> <bean id="dataBean" class="com.dffk.dfintop.common.util.DBUtils">
<property name="dataSource">
<ref bean="dataSource"/>
</property>
</bean>
<bean id="dataBean_2" class="com.dffk.dfintop.common.util.DBUtils">
<property name="dataSource">
<ref bean="dataSource_2"/>
</property>
</bean> <!-- 创建SqlSessionFactory,同时指定数据源==org.mybatis.spring.SqlSessionFactoryBean== -->
<bean id="sqlSessionFactory" class="com.dffk.dfintop.framework.system.mybatis.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="typeAliasesPackage" value="com.dffk.dfintop" />
<property name="mapperLocations" value="classpath:mapper/${jdbc.type}/**/*.xml" />
<property name="configLocation" value="classpath:mybatis-config.xml" />
</bean>
<!-- 创建SqlSessionFactory,同时指定数据源==org.mybatis.spring.SqlSessionFactoryBean== -->
<bean id="sqlSessionFactory_2" class="com.dffk.dfintop.framework.system.mybatis.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource_2" />
<property name="typeAliasesPackage" value="com.dffk.dfintop" />
<property name="mapperLocations" value="classpath:mapper/${jdbc_2.type}/**/*.xml" />
<property name="configLocation" value="classpath:mybatis-config.xml" />
</bean> <!-- 配置事务 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean> <!-- 配置事务 -->
<bean id="transactionManager_2" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource_2" />
</bean> <!-- 配置 Annotation 驱动,扫描@Transactional注解的类定义事务
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>-->
<tx:annotation-driven transaction-manager="transactionManager" />
<tx:annotation-driven transaction-manager="transactionManager_2" /> <!-- 配置 JSR303 Bean Validator 定义 -->
<bean id="validator" class="org.springframework.validation.beanvalidation.LocalValidatorFactoryBean" /> <!-- scan mappers and let them be autowired -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.dffk.dfintop" />
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
</bean> <!-- scan mappers and let them be autowired -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.dffk.dfintop_2" />
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory_2"></property>
</bean> <!-- swagger config -->
<bean class="com.dffk.dfintop.common.swagger.MySwaggerConfig"/> <!-- 拦截器配置
<mvc:interceptors>
<mvc:interceptor>
<mvc:mapping path="/**" />
<mvc:exclude-mapping path="/act/**"/>
<mvc:exclude-mapping path="/assets/**"/>
<mvc:exclude-mapping path="/bootstrap/**"/>
<mvc:exclude-mapping path="/script/**"/>
<mvc:exclude-mapping path="/static/**"/>
<mvc:exclude-mapping path="/swagger/**"/>
<mvc:exclude-mapping path="/ws/**"/>
<mvc:exclude-mapping path="/api-docs/**"/>
<mvc:exclude-mapping path="/ks/chart/**"/>
<mvc:exclude-mapping path="/upload/**"/>
<mvc:exclude-mapping path="/portal/**"/>
<mvc:exclude-mapping path="/login/**"/>
<mvc:exclude-mapping path="/cms/**"/>
<mvc:exclude-mapping path="/sys/**"/>
<mvc:exclude-mapping path="/"/>
<bean class="com.dffk.dfintop.common.interceptor.AuthorityInterceptor" />
</mvc:interceptor> -->
<!-- <mvc:interceptor>
<mvc:mapping path="/**" />
<mvc:exclude-mapping path="/assets/**"/>
<mvc:exclude-mapping path="/bootstrap/**"/>
<mvc:exclude-mapping path="/script/**"/>
<mvc:exclude-mapping path="/static/**"/>
<mvc:exclude-mapping path="/swagger/**"/>
<mvc:exclude-mapping path="/ws/**"/>
<mvc:exclude-mapping path="/api-docs/**"/>
<mvc:exclude-mapping path="/ks/chart/**"/>
<mvc:exclude-mapping path="/upload/**"/>
<mvc:exclude-mapping path="/portal/**"/>
<mvc:exclude-mapping path="/sys/**"/>
<mvc:exclude-mapping path="/information/**"/>
<mvc:exclude-mapping path="/"/>
<bean class="com.dffk.dfintop.common.interceptor.LogInterceptor" />
</mvc:interceptor>
</mvc:interceptors>-->
</beans>

因为,我们使用了 MapperScannerConfigurer ,dao bean是spring 动态生成的,我们可以不用写dao 实现了。 但是我们需要配置 MapperScannerConfigurer ,指向我们需要使用双数据源的 package, 这个package 最好和之前数据源不同, 以示区别 。

同时, 我们需要配置  transaction-manager ,这里的transaction-manager  是一个注解式的事务管理器。

dao 是可以不用写了。但是, 接口是必须的,我开始的时候是直接复制了原有的dao 接口, 但是发现有问题就是 dao  的bean 的name 和原有的发生冲突。 怎么办呢, 只有改名了, 我就直接加了个2:

/*
* Powered By luokai
* Since 2014 - 2017
*/
package com.dffk.dfintop_2.credit; import com.dffk.dfintop.bussiness.credit.domain.CustomerInfo;
import com.dffk.dfintop.common.exception.CRUDException;
import com.dffk.dfintop.framework.system.domain.SysUser; import java.util.List; /**
* @author luokai
* @version 1.0
* @since 1.0
*/
public interface CustomerInfoMapper2 { /**
* 根据ID查询单条数据
* @param id
* @return
*/
public CustomerInfo findOne(String id); /**
* 查询数据集合
* @param customerInfo
* @return
*/
public List<CustomerInfo> findList(CustomerInfo customerInfo); /**
* 查询数据TREE
* @param sysUser
* @return
* @throws CRUDException
*/
public List<CustomerInfo> findTree(SysUser sysUser); /**
* 查询数据TREE
* @param customerInfo
* @return
* @throws CRUDException
*/
public List<CustomerInfo> findAll(CustomerInfo customerInfo); /**
* 查询数据总数
* @param customerInfo
* @return
*/
public Integer findTotal(CustomerInfo customerInfo); /**
* 数据新增
* @param customerInfo
*/
public void save(CustomerInfo customerInfo); /**
* 数据修改
* @param customerInfo
*/
public void update(CustomerInfo customerInfo); /**
* 数据删除
* @param listId
*/
public void delete(List<String> listId);
}

然后就是使用了, 使用很简单, 通过@Autowired 注解就行了:

@Service
public class XxxService extends BaseService { @Autowired
private CustomerInfoMapper customerInfoMapper; @Autowired
private ContractInfoMapper contractInfoMapper; @Autowired
private ImageInfoMapper imageInfoMapper; @Autowired
private BusinessIntoMapper businessIntoMapper; @Autowired
private com.dffk.dfintop_2.credit.CustomerInfoMapper2 customerInfoMapper2; @Autowired
private com.dffk.dfintop_2.credit.ContractInfoMapper2 contractInfoMapper2; @Autowired
private com.dffk.dfintop_2.credit.ImageInfoMapper2 imageInfoMapper2; @Autowired
private com.dffk.dfintop_2.credit.BusinessIntoMapper2 businessIntoMapper2; ... } // 注,
BaseService 使用了 @Transactional 注解,也就是注解方式启用了事务管理器。
@Transactional(readOnly = false)
public abstract class BaseService { }
 

参考:

http://www.cnblogs.com/zyzcj/p/6653549.html

http://www.cnblogs.com/liujiduo/p/5004691.html

spring+mybatis 配置双数据源的更多相关文章

  1. spring&plus;myBatis 配置多数据源,切换数据源

    注:本文来源于  tianzhiwuqis <spring+myBatis 配置多数据源,切换数据源> 一个项目里一般情况下只会使用到一个数据库,但有的需求是要显示其他数据库的内容,像这样 ...

  2. spring项目配置双数据源读写分离

    我们最早做新项目的时候一直想做数据库的读写分离与主从同步,由于一些原因一直没有去做这个事情,这次我们需要配置双数据源的起因是因为我们做了一个新项目用了另一个数据库,需要把这个数据库的数据显示到原来的后 ...

  3. spring boot 配置双数据源mysql、sqlServer

    背景:原来一直都是使用mysql数据库,在application.properties 中配置数据库信息 spring.datasource.url=jdbc:mysql://xxxx/test sp ...

  4. 如何通过Spring Boot配置动态数据源访问多个数据库

    之前写过一篇博客<Spring+Mybatis+Mysql搭建分布式数据库访问框架>描述如何通过Spring+Mybatis配置动态数据源访问多个数据库.但是之前的方案有一些限制(原博客中 ...

  5. Spring Boot2&period;4双数据源的配置

    相较于单数据源,双数据源配置有时候在数据分库的时候可能更加有利 但是在参考诸多博客以及书籍(汪云飞的实战书)的时候,发现对于spring boot1.X是完全没问题的,一旦切换到spring boot ...

  6. Spring Boot &plus; Mybatis 配置多数据源

    Spring Boot + Mybatis 配置多数据源 Mybatis拦截器,字段名大写转小写 package com.sgcc.tysj.s.common.mybatis; import java ...

  7. Spring&plus;Mybatis配置

    Spring+Mybatis配置 之前做项目的时候用到了spring+mybatis框架,一直想抽空整理一下 Mybatis: mybatis是支持普通 SQL查询,存储过程和高级映射的优秀持久层框架 ...

  8. SpringBoot集成Mybatis配置动态数据源

    很多人在项目里边都会用到多个数据源,下面记录一次SpringBoot集成Mybatis配置多数据源的过程. pom.xml <?xml version="1.0" encod ...

  9. springboot入门系列(四):SpringBoot和Mybatis配置多数据源连接多个数据库

    SpringBoot和Mybatis配置多数据源连接多个数据库 目前业界操作数据库的框架一般是 Mybatis,但在很多业务场景下,我们需要在一个工程里配置多个数据源来实现业务逻辑.在SpringBo ...

随机推荐

  1. Effective C&plus;&plus; -----条款45:运用成员函数模板接受所有兼容类型

    请使用member function templates(成员函数模板)生成”可接受所有兼容类型“的函数. 如果你声明member templates 用于“泛化copy构造”或“泛化assignme ...

  2. 大漠推荐的教程:创建你自己的AngularJS -- 第一部分 Scopes

    创建你自己的AngularJS -- 第一部分 Scopes http://www.html-js.com/article/1863

  3. C&num;学习笔记一

    c#学习笔记一 c#学习笔记一    1 1.    注释    3 1.1.    ///是文档注释,用于类和方法的说明    3 1.2.    #region #endregion可以折叠代码  ...

  4. HDU5301

    题意:给n*m的矩形区域,剔除其中1*1的方块,然后用不同矩形块填充整个矩形区域,求需要的矩形块最大面积的最小值. 思路:先判把矩形矫正,然后特殊处理边值为奇数,且在中心点的情况,最后处理障碍在其他位 ...

  5. 表单验证插件 jquery&period;validata 使用方法

    参考资料:http://www.runoob.com/jquery/jquery-plugin-validate.html 下载地址 jquery.validate插件的文档地址http://docs ...

  6. 上mongodb创建一些吸取的经验教训指数

    想来接触mongodb它已经快一年了,对于其指数已经积累了很多的经验,知识,以这个夜黑风高的优势,放mongodb总结一番吧. 一,索引介绍 mongodb具有两类索引,分别为单键索引和复合索引. 1 ...

  7. Ubuntu 15&period;10 下Tachyon安装

    1 系统环境 Ubuntu 15.10, Java 1.7, Hadoop 2.6.0 HA, Spark-1.4.0 三台机器 spark-1423-0001: Master, Worker spa ...

  8. IVIEW对的table组件超出长度用省略号代替,使用气泡提示。

    render: (h, params) => { return h('div', [ h('Tooltip', { props: { placement: 'top' } }, [ h('spa ...

  9. Synchronized、lock、volatile、ThreadLocal、原子性总结、Condition

    http://blog.csdn.net/sinat_29621543/article/details/78065062

  10. PHP移动互联网开发笔记(6)——MySQL数据库基础回想

    近期看了一些架构方面的资料.可是发现基础知识都不怎么坚固,接下来的一段时间.我会定期总结基础知识. 一.数据类型   1.整型   数据类型 存储空间 说明 取值范围 TINYINT 1字节 很小的整 ...