当前位置：首页 > news >正文

Spring：多数据源配置多个事务管理器DEMO

news 来源：原创 2025/6/26 9:46:05

Spring配置文件：

配置2个事务管理器：txManager和txManager2

<?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:context="http://www.springframework.org/schema/context"xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd">  <context:component-scan base-package="xyz.jangle.service">  <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>  <context:exclude-filter type="annotation" expression="org.springframework.web.bind.annotation.ControllerAdvice"/>  </context:component-scan>  <!-- 配置数据源, 整合其他框架, 事务等. -->  <!-- 1. 数据源 : DriverManagerDataSource -->  <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">  <!-- tomcat连接池需要添加对应的jar包。 -->
<!--     <bean id="dataSource" class="org.apache.tomcat.jdbc.pool.DataSource"> -->
<!--         <property name="driverClassName" value="com.mysql.jdbc.Driver" />   --><property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />  <property name="url" value="jdbc:mysql://127.0.0.1:3306/jangle_test?characterEncoding=UTF8" />  <property name="username" value="root" />  <property name="password" value="111111" /> </bean>  <bean id="dataSource2" class="org.springframework.jdbc.datasource.DriverManagerDataSource">  <!-- tomcat连接池需要添加对应的jar包。 -->
<!--     <bean id="dataSource" class="org.apache.tomcat.jdbc.pool.DataSource"> -->
<!--         <property name="driverClassName" value="com.mysql.jdbc.Driver" />   --><property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />  <property name="url" value="jdbc:mysql://127.0.0.1:3306/jangle_test1?characterEncoding=UTF8" />  <property name="username" value="root" />  <property name="password" value="111111" /> </bean>  <!--  2. mybatis的SqlSession的工厂: SqlSessionFactoryBean dataSource:引用数据源  MyBatis定义数据源,同意加载配置  -->  <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">  <property name="dataSource" ref="dataSource"></property>  <property name="configLocation" value="classpath:mybatis-config.xml" />   <!-- 此处定义mapper映射文件，以通配符的形式定义整个包底下的所有mapper文件。 --><property name="mapperLocations" value="classpath:xyz/jangle/mapper/*.xml" /></bean><bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">  <property name="dataSource" ref="dataSource2"></property>  <property name="configLocation" value="classpath:mybatis-config.xml" />   <!-- 此处定义mapper映射文件，以通配符的形式定义整个包底下的所有mapper文件。 --><property name="mapperLocations" value="classpath:xyz/jangle/mapper2/*.xml" /></bean><!--  3. mybatis自动扫描加载Sql映射文件/接口 : MapperScannerConfigurer sqlSessionFactory  basePackage:指定sql映射文件/接口所在的包（自动扫描）   (主要是接口，映射文件如果不在同一个包中，则在mybatis-config.xml等配置文件中配置)  -->  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">  <property name="basePackage" value="xyz.jangle.dao"></property>  <property name="sqlSessionFactory" ref="sqlSessionFactory"></property>  </bean>  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">  <property name="basePackage" value="xyz.jangle.dao2"></property>  <property name="sqlSessionFactory" ref="sqlSessionFactory2"></property>  </bean><!-- 4. 事务管理 : DataSourceTransactionManager dataSource:引用上面定义的数据源 -->  <bean id="txManager"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">  <property name="dataSource" ref="dataSource"></property>  </bean>  <bean id="txManager2"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">  <property name="dataSource" ref="dataSource2"></property>  </bean>  <!-- 5. 使用声明式事务  transaction-manager：引用上面定义的事务管理器  -->  <tx:annotation-driven transaction-manager="txManager" />  <!-- spring-mvc 附件功能需要配置的bean。  --><bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver"><property name="maxUploadSize" value="50000000" /><!-- 单位b 最大附件50M --></bean></beans>

使用：

@Transactional(transactionManager="txManager2") 默认第一个事务管理器，第2个手动引用。

    @Override@Transactionalpublic Map<String, Object> insertOrUpdate(Demo record) {Map<String, Object> map = new HashMap<String, Object>();if(record.getId() == null) {demoMapper.insert(record);}else {demoMapper.updateByPrimaryKey(record);}
//		System.out.println(1/0);map.put("model", record);map.put("code", JConstant.SUCCESS_CODE);map.put("message", JConstant.SUCCESS_MESSAGE);return map;}

    @Override@Transactional(transactionManager="txManager2")public Map<String, Object> insertOrUpdate(Demo record) {Map<String, Object> map = new HashMap<String, Object>();if(record.getId() == null) {demoMapper2.insert(record);}else {demoMapper2.updateByPrimaryKey(record);}
//		System.out.println(1/0);	// 测试事务map.put("model", record);map.put("code", JConstant.SUCCESS_CODE);map.put("message", JConstant.SUCCESS_MESSAGE);return map;}

Mybatis：多数据源配置-CSDN博客