多數據源配置主要涉及自定義類（DataSource注解類、DataSourceAspect切面類，動態數據源接口實現類、以及數據源字符串線程保存類），pom.xml文件、applicationContext.xml、mybatis相關配置，以及業務代碼(test包)，參考實際開發及網上資料記錄下來。
一、配置文件
1.pom.xml
這里我用的是mac上的eclipse，maven版本是3.6.0，jdk版本是1.8，tomcat9。pom文件配置如下:
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>laboratory</groupId> <artifactId>mvclab</artifactId> <packaging>war</packaging> <version>0.0.1-SNAPSHOT</version> <name>mcv Maven Webapp</name> <url>http://maven.apache.org</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target> <spring.version>5.1.5.RELEASE</spring.version> <mybatis.version>3.2.8</mybatis.version> <mybatis-spring.version>1.2.2</mybatis-spring.version> <spring-jpa-version>1.3.2.RELEASE</spring-jpa-version> </properties> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> <scope>test</scope> </dependency> <!--spring--> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aop</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-beans</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-orm</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>${spring.version}</version> </dependency> <!--日志--> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>1.2.17</version> </dependency> <!--tomcat所需jar包--> <dependency> <groupId>javax.servlet</groupId> <artifactId>jstl</artifactId> <version>1.2</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.24</version> </dependency> <dependency> <groupId>cglib</groupId> <artifactId>cglib</artifactId> <version>2.2.2</version> </dependency> <!--返回object對象所需要的依賴，它在<mvc:annotation-driven>注冊時注入--> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-annotations</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-core</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>org.junit.jupiter</groupId> <artifactId>junit-jupiter-api</artifactId> <version>RELEASE</version> <scope>compile</scope> </dependency> <!-- 補充 --> <!-- https://mvnrepository.com/artifact/aopalliance/aopalliance --> <dependency> <groupId>aopalliance</groupId> <artifactId>aopalliance</artifactId> <version>1.0</version> </dependency> <!-- https://mvnrepository.com/artifact/org.aspectj/aspectjweaver --> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjweaver</artifactId> <version>1.8.13</version> </dependency> <!-- https://mvnrepository.com/artifact/org.aspectj/aspectjrt --> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjrt</artifactId> <version>1.8.9</version> </dependency> <!-- MyBatis --> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>${mybatis.version}</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>${mybatis-spring.version}</version> </dependency> <!-- dbcp數據源 --> <dependency> <groupId>commons-dbcp</groupId> <artifactId>commons-dbcp</artifactId> <version>1.4</version> </dependency> <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api --> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.26</version> </dependency> <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.16.20</version> <scope>provided</scope> </dependency> </dependencies> <build> <finalName>mcv</finalName> </build> </project>
2.applicationContext.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/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 http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd"> <!-- context:設置注解掃描包注解 注: 如果springmvc-servlet中掃描注解沒有排除@Service注解，這里要設置掃描除@Controller之外的其它所有注解 --> <context:component-scan base-package="com.mvc"> <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> <!-- 開啟@Autowired注解掃描 注: 它等價於<bean class="org.springframework.beans.factory.annotation. AutowiredAnnotationBeanPostProcessor "/> 注: 配置了<context:component-scan />，默認包含對@Autowired的配置，因此下面這個配置就不需要了 --> <context:annotation-config/> <!-- 注冊數據源配置文件 --> <context:property-placeholder location="classpath:jdbc.properties" /> <!-- 注冊數據源對象 這里用Spring內置數據源 --> <bean id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName"> <value>${oracle11g.driverClass}</value> </property> <property name="url"> <value>${oracle11g.url}</value> </property> <property name="username"> <value>${oracle11g.username}</value> </property> <property name="password"> <value>${oracle11g.password}</value> </property> <property name="maxActive"> <value>${oracle11g.maxActive}</value> </property> <property name="maxIdle"> <value>${oracle11g.maxIdle}</value> </property> <property name="maxWait"> <value>${oracle11g.maxWait}</value> </property> <property name="defaultAutoCommit"> <value>${oracle11g.defaultAutoCommit}</value> </property> <property name="timeBetweenEvictionRunsMillis"> <value>${oracle11g.timeBetweenEvictionRunsMillis}</value> </property> <property name="minEvictableIdleTimeMillis"> <value>${oracle11g.minEvictableIdleTimeMillis}</value> </property> </bean> <bean id="dataSource2" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName"> <value>${oracle11g-1.driverClass}</value> </property> <property name="url"> <value>${oracle11g-1.url}</value> </property> <property name="username"> <value>${oracle11g-1.username}</value> </property> <property name="password"> <value>${oracle11g-1.password}</value> </property> <property name="maxActive"> <value>${oracle11g-1.maxActive}</value> </property> <property name="maxIdle"> <value>${oracle11g-1.maxIdle}</value> </property> <property name="maxWait"> <value>${oracle11g-1.maxWait}</value> </property> <property name="defaultAutoCommit"> <value>${oracle11g-1.defaultAutoCommit}</value> </property> <property name="timeBetweenEvictionRunsMillis"> <value>${oracle11g-1.timeBetweenEvictionRunsMillis}</value> </property> <property name="minEvictableIdleTimeMillis"> <value>${oracle11g-1.minEvictableIdleTimeMillis}</value> </property> </bean> <!-- 配置動態數據源 --> <bean id="dynamicDataSource" class="com.mvc.dynamicDataSource.DynamicDataSource"> <property name="targetDataSources"> <map key-type="java.lang.String"> <!-- 指定lookupKey和與之對應的數據源 --> <entry key="dataSource1" value-ref="dataSource1" /> <entry key="dataSource2" value-ref="dataSource2" /> </map> </property> <!-- 指定默認的數據源 --> <property name="defaultTargetDataSource" ref="dataSource1" /> </bean> <!-- 配置事務管理對象,注意這里設置的是dataSource1而不是dynamicDataSource--> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource1" /> </bean> <!-- 將所有具有@Transactional注解的Bean自動配置為聲明式事務支持 --> <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/> <!-- MyBatis 數據源和sql- --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dynamicDataSource"/> <property name="mapperLocations" value="classpath:/mappings/**/*.xml"/> <property name="configLocation" value="classpath:/mybatis-config.xml"></property> </bean> <!-- MyBayis 掃描器配置--> <bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/> <property name="basePackage" value="com.mvc.laboratory"/> </bean> <!--接收json數據--> <bean id="jsonHttpMessageConverter" class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter"> <property name="supportedMediaTypes"> <list> <value>application/json;charset=UTF-8</value> </list> </property> </bean> <!-- 配置事務自動代理 --> <aop:aspectj-autoproxy proxy-target-class="true" /> </beans>
3.mybatis-config.xml
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <!-- 全局參數 --> <settings> <!-- 使全局的映射器啟用或禁用緩存。 --> <setting name="cacheEnabled" value="true"/> <!-- 全局啟用或禁用延遲加載。當禁用時，所有關聯對象都會即時加載。 --> <setting name="lazyLoadingEnabled" value="true"/> <!-- 當啟用時，有延遲加載屬性的對象在被調用時將會完全加載任意屬性。否則，每種屬性將會按需要加載。 --> <setting name="aggressiveLazyLoading" value="true"/> <!-- 是否允許單條sql 返回多個數據集 (取決於驅動的兼容性) default:true --> <setting name="multipleResultSetsEnabled" value="true"/> <!-- 是否可以使用列的別名 (取決於驅動的兼容性) default:true --> <setting name="useColumnLabel" value="true"/> <!-- 允許JDBC 生成主鍵。需要驅動器支持。如果設為了true，這個設置將強制使用被生成的主鍵，有一些驅動器不兼容不過仍然可以執行。 default:false --> <setting name="useGeneratedKeys" value="false"/> <!-- 指定 MyBatis 如何自動映射 數據基表的列 NONE：不隱射 PARTIAL:部分 FULL:全部 --> <setting name="autoMappingBehavior" value="PARTIAL"/> <!-- 這是默認的執行類型 （SIMPLE: 簡單； REUSE: 執行器可能重復使用prepared statements語句；BATCH: 執行器可以重復執行語句和批量更新） --> <setting name="defaultExecutorType" value="SIMPLE"/> <!-- 使用駝峰命名法轉換字段。 <setting name="mapUnderscoreToCamelCase" value="true"/> --> <!-- 設置本地緩存范圍 session:就會有數據的共享 statement:語句范圍 (這樣就不會有數據的共享 ) defalut:session --> <setting name="localCacheScope" value="SESSION"/> <!-- 設置但JDBC類型為空時,某些驅動程序 要指定值,default:OTHER，插入空值時不需要指定類型 --> <setting name="jdbcTypeForNull" value="NULL"/> <!-- mybatis打印日志 --> <!-- <setting name="logImpl" value="STDOUT_LOGGING" /> --> <setting name="logImpl" value="NO_LOGGING" /> </settings> <!-- 類型別名 --> <typeAliases> </typeAliases> </configuration>
4.jdbc.properties和log4j.properties
這里我用的是oracle，在mac上用docker起了兩個oracle數據庫鏡像，端口分別映射到本地mac的1521和1522，並且各自建了apple賬號。
# docker ps --> oracle11g
oracle11g.driverClass=oracle.jdbc.driver.OracleDriver
oracle11g.url=jdbc:oracle:thin:@127.0.0.1:1521:helowin
oracle11g.username=apple
oracle11g.password=1234
oracle11g.maxActive=100
oracle11g.maxIdle=40
oracle11g.maxWait=3000
oracle11g.defaultAutoCommit=true
oracle11g.timeBetweenEvictionRunsMillis=3600000
oracle11g.minEvictableIdleTimeMillis=3600000
# docker ps --> oracle11g-1
oracle11g-1.driverClass=oracle.jdbc.driver.OracleDriver
oracle11g-1.url=jdbc:oracle:thin:@127.0.0.1:1522:helowin
oracle11g-1.username=apple
oracle11g-1.password=1234
oracle11g-1.maxActive=100
oracle11g-1.maxIdle=40
oracle11g-1.maxWait=3000
oracle11g-1.defaultAutoCommit=true
oracle11g-1.timeBetweenEvictionRunsMillis=3600000
oracle11g-1.minEvictableIdleTimeMillis=3600000
log4j.rootCategory=info, CONSOLE, DAILY
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%-5p[%F:%M:%L]- %m%n
log4j.appender.DAILY=org.apache.log4j.DailyRollingFileAppender
log4j.appender.DAILY.DatePattern='.'yyyy-MM-dd
log4j.appender.DAILY.ImmediateFlush=true
log4j.appender.DAILY.Append=true
log4j.appender.DAILY.layout=org.apache.log4j.PatternLayout
log4j.appender.DAILY.layout.conversionPattern=[ %-5p]-%-d{yyyyMMdd HHmmss}-[%F:%M:%L]- %m%n
log4j.appender.DAILY.File=../logs/mvc.log
5.springmvc.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:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:mvc="http://www.springframework.org/schema/mvc" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd "> <mvc:annotation-driven> <!-- 解決亂碼 --> <mvc:message-converters register-defaults="true"> <bean class="org.springframework.http.converter.StringHttpMessageConverter"> <constructor-arg value="UTF-8" /> </bean> </mvc:message-converters> </mvc:annotation-driven> <!-- 設置注解掃描目錄 注意，在springmvc-servlet中排除了@Service注解,它等價於在applicationContext.xml中排除@Controller注解 SpringMVC中掃描controller而不是@Service，因為此時service還沒有進行事務處理可能會引起事務失效 --> <context:component-scan base-package="com.mvc" > <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Service" /> </context:component-scan> <!-- 靜態資源訪問控制 --> <mvc:resources mapping="/images/**" location="/images/" /> <mvc:resources mapping="/js/**" location="/js/" /> <mvc:resources mapping="/css/**" location="/css/" /> </beans>
6.web.xml配置
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" id="WebApp_ID" version="3.0" > <display-name>Archetype Created Web Application</display-name> <!-- 注冊ApplicationContext容器 --> <context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:applicationContext.xml</param-value> </context-param> <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> <!--注冊中央調度器--> <servlet> <servlet-name>springmvc</servlet-name> <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> <init-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:springmvc-servlet.xml</param-value> </init-param> <load-on-startup>1</load-on-startup> <async-supported>true</async-supported> </servlet> <servlet-mapping> <servlet-name>springmvc</servlet-name> <url-pattern>/</url-pattern> </servlet-mapping> <welcome-file-list> <welcome-file>index.jsp</welcome-file> <welcome-file>welcome.jsp</welcome-file> </welcome-file-list> <!--解決requesMapping請求參數中的中文亂碼--> <filter> <filter-name>encodingFilter</filter-name> <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class> <init-param> <param-name>encoding</param-name> <param-value>UTF-8</param-value> </init-param> <init-param> <param-name>forceEncoding</param-name> <param-value>true</param-value> </init-param> </filter> <filter-mapping> <filter-name>encodingFilter</filter-name> <url-pattern>/*</url-pattern> </filter-mapping> </web-app>
二、自定義類
1.DataSource
package com.mvc.dynamicDataSource; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; @Target({ ElementType.TYPE,ElementType.METHOD }) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface DataSource { String value() default DataSource.dataSource1; public static String dataSource1 = "dataSource1"; public static String dataSource2 = "dataSource2"; }
2.DataSourceAspect
package com.mvc.dynamicDataSource; import java.lang.reflect.Method; import org.aspectj.lang.JoinPoint; import org.aspectj.lang.annotation.After; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.annotation.Before; import org.aspectj.lang.annotation.Pointcut; import org.aspectj.lang.reflect.MethodSignature; import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; @Component @Aspect @Order(1) public class dataSourceAspect { @Pointcut(value="execution(* com.mvc.laboratory..*.*(..))") private void doPointcut() {}; @Before(value = "doPointcut()") @After(value = "doPointcut()") public void intercept(JoinPoint joinPoint) throws NoSuchMethodException { // 獲取切入點的類反射 Class<?> targetClass = joinPoint.getTarget().getClass(); // 獲取方法參數 MethodSignature signature = (MethodSignature) joinPoint.getSignature(); for (Class<?> clazz:targetClass.getInterfaces()){ dealDataSource(clazz, signature.getMethod()); } // 默認使用目標類的注解，如果沒有則使用其實現的接口注解 dealDataSource(targetClass, signature.getMethod()); } private void dealDataSource(Class<?> clazz, Method method) throws NoSuchMethodException { // 獲取方法參數 Class<?>[] paramTypeArr = method.getParameterTypes(); // 檢查是否為dataSource注解 if (clazz.isAnnotationPresent(DataSource.class)){ // 獲取注解對象 DataSource source = clazz.getAnnotation(DataSource.class); DynamicDataSourceHolder.setDataSource(source.value()); } Method m = clazz.getMethod(method.getName(), paramTypeArr); if (m != null && m.isAnnotationPresent(DataSource.class)) { DataSource source = m.getAnnotation(DataSource.class); DynamicDataSourceHolder.setDataSource(source.value()); } } }
3.DynamicDataSource
package com.mvc.dynamicDataSource; import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource; /** * 通過重寫這個查找數據源標識的方法就可以讓spring切換到指定的數據源 * */ public class DynamicDataSource extends AbstractRoutingDataSource{ @Override protected Object determineCurrentLookupKey() { // 從自定義的位置獲取數據源標識 return DynamicDataSourceHolder.getDataSource(); } }
4.DynamicDataSourceHolder
package com.mvc.dynamicDataSource; /** * 用於持有當前線程中使用的數據源標識 */ public class DynamicDataSourceHolder { // 注意：數據源標識保存在線程變量中，避免多線程操作數據源時互相干擾 private static final ThreadLocal<String> THREAD_DATA_SOURCE = new ThreadLocal<>(); public static String getDataSource() { return THREAD_DATA_SOURCE.get(); } public static void setDataSource(String dataSource) { THREAD_DATA_SOURCE.set(dataSource); } public static void clearDataSource() { THREAD_DATA_SOURCE.remove(); } }
三、業務代碼
1.TestController
package com.mvc.laboratory.test; import java.util.List; import java.util.Map; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; @Controller @RequestMapping(value = "/test") public class TestController { @Resource private TestService testService; /** * @see http://localhost:8080/mvclab/test/testAspectJAround?name=weiweian&age=123 * @param name * @param age * @return */ @RequestMapping(value = "/testAspectJAround") @ResponseBody public List<Map<String, String>> testAspectJArounds(HttpServletRequest request, String name, String age){ List<Map<String, String>> map = testService.testAspectJAround(request, name, age); return map; } /** * @see http://localhost:8080/mvclab/test/testDynamicDataSource * @param request * @return */ @RequestMapping(value = "/testDynamicDataSource") @ResponseBody public List<Map<String, String>> testDynamicDataSource(HttpServletRequest request){ List<Map<String, String>> map = testService.testDynamicDataSource(request); return map; } }
2.TestService
package com.mvc.laboratory.test; import java.util.List; import java.util.Map; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @Service @Transactional(rollbackFor = Exception.class) public class TestService { @Resource private LoggerDao loggerDao; @Resource private TestDao testDao; public List<Map<String, String>> testAspectJAround(HttpServletRequest request, String name, String age) { List<Map<String, String>> map = loggerDao.test(); return map; } public List<Map<String, String>> testDynamicDataSource(HttpServletRequest request) { List<Map<String, String>> map = testDao.dynamicDataSource(); return map; } }
3.LoggerDao
package com.mvc.laboratory.test; import java.util.Date; import java.util.List; import java.util.Map; import org.apache.ibatis.annotations.Param; import com.mvc.dynamicDataSource.DataSource; @DataSource(DataSource.dataSource1) public interface LoggerDao { public List<Map<String, String>> test(); }
4.TestDao
package com.mvc.laboratory.test; import java.util.List; import java.util.Map; import com.mvc.dynamicDataSource.DataSource; @DataSource(DataSource.dataSource2) public interface TestDao { public List<Map<String, String>> dynamicDataSource(); }
5.logger.xml和test.xml
參考applicationcontext.xml中關於mabatis的配置，目錄為resources/mappings/test/logger.xml
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.mvc.laboratory.test.LoggerDao"> <select id="test" resultType="java.util.Map"> select
url,
intfname,
sign,
to_char(begin_time) as begin_time,
to_char(end_time) as end_time,
result
from intf_caller_log </select> </mapper>
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.mvc.laboratory.test.TestDao"> <select id="dynamicDataSource" resultType="java.util.Map"> select * from test </select> </mapper>
6.intf_caller_log和test表
參考LoggerDao的注解，intf_caller_log表位於dataSource1數據源對應的數據庫中，test表位於dataSource2數據源對應的數據庫中，兩個表只是查詢，可自由創建。
四、測試
1.單元測試
在test/mvc路徑下新建測試類，內容如下：
package mvc; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import org.springframework.transaction.annotation.Transactional; import com.mvc.laboratory.test.LoggerDao; import com.mvc.laboratory.test.TestDao; @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration({"classpath:applicationContext.xml"}) @Transactional(rollbackFor = Exception.class) public class DynamicDataSourceTest { @Resource private LoggerDao loggerDao; @Resource private TestDao testDao; @Test public void loggerTest() { List<Map<String, String>> map = loggerDao.test(); for (int i = 0; i < map.size(); i++) { System.out.println(map.get(i)); } } @Test public void dynamicDataSourceTest() { List<Map<String, String>> map = testDao.dynamicDataSource(); for (int i = 0; i < map.size(); i++) { System.out.println(map.get(i)); } } }
分別執行兩個方法（run as junit，可在run configuration中配置要執行的方法及junit版本(這里是4)），打印如下：
...
{INTFNAME=@82c0502, END_TIME=2019-06-26 09:44:04.0, BEGIN_TIME=2019-06-26 09:44:04.0, ID=8C312E309096C199E05011AC02001066, SIGN=1, RESULT={sayHello=hello, my name is weiweian, 123 years old., name=weiweian, age=123}, URL=/mvclab/test/example1}
{INTFNAME=@784a89d9, END_TIME=2019-06-26 10:09:43.0, BEGIN_TIME=2019-06-26 10:09:43.0, ID=8C3189ED0639F220E05011AC0200107C, SIGN=1, RESULT={sayHello=hello, my name is weiweian, 123 years old., name=weiweian, age=123}, URL=/mvclab/test/testAspectJAround}
{INTFNAME=@349f84fe, END_TIME=2019-06-26 10:40:22.0, BEGIN_TIME=2019-06-26 10:40:22.0, ID=8C31F7934D601BCFE05011AC02001092, SIGN=1, RESULT={sayHello=hello, my name is weiweian, 123 years old., name=weiweian, age=123}, URL=/mvclab/test/testAspectJAround}
...
...
{ID=8C31D356D681E364E05011AC03000F08, NAME=Alex, AGE=20}
{ID=8C31D356D682E364E05011AC03000F08, NAME=An, AGE=18}
...
可見，intf_caller_log表中的記錄和test表中的記錄都能正常查詢出來。查詢其它表也應該是相應的數據。
2.發布到tomcat測試
分別訪問controller中的測試路徑，頁面顯示如下：
[
{
"INTFNAME": "@3507200d",
"END_TIME": "26-6月 -19",
"BEGIN_TIME": "26-6月 -19",
"SIGN": "1",
"RESULT": "{sayHello=hello, my name is weiweian, 123 years old., name=weiweian, age=123}",
"URL": "/mvclab/test/testAspectJAround"
},
{
"INTFNAME": "@3507200d",
"END_TIME": "26-6月 -19",
"BEGIN_TIME": "26-6月 -19",
"SIGN": "1",
"RESULT": "{sayHello=hello, my name is weiweian, 123 years old., name=weiweian, age=123}",
"URL": "/mvclab/test/testAspectJAround"
},
...
[
{
"ID": "8C31D356D681E364E05011AC03000F08",
"NAME": "Alex",
"AGE": "20"
},
{
"ID": "8C31D356D682E364E05011AC03000F08",
"NAME": "An",
"AGE": "18"
}
]
五、Hibernate事務管理配置多數據源
只修改pom.xml添加相關jar包，以及application.xml添加Hibernate事務管理，其它和上述一樣不變。
1.pom.xml
添加hibernate相關jar包
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>laboratory</groupId> <artifactId>mvclab</artifactId> <packaging>war</packaging> <version>0.0.1-SNAPSHOT</version> <name>mcv Maven Webapp</name> <url>http://maven.apache.org</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target> <spring.version>5.1.5.RELEASE</spring.version> <mybatis.version>3.2.8</mybatis.version> <mybatis-spring.version>1.2.2</mybatis-spring.version> <spring-jpa-version>1.3.2.RELEASE</spring-jpa-version> </properties> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> <scope>test</scope> </dependency> <!--spring--> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aop</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-beans</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-orm</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>${spring.version}</version> </dependency> <!--日志--> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>1.2.17</version> </dependency> <!--tomcat所需jar包--> <dependency> <groupId>javax.servlet</groupId> <artifactId>jstl</artifactId> <version>1.2</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.24</version> </dependency> <dependency> <groupId>cglib</groupId> <artifactId>cglib</artifactId> <version>2.2.2</version> </dependency> <!-- Spring JPA dependencies --> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-jpa</artifactId> <version>${spring-jpa-version}</version> </dependency> <!-- Hibernate dependencies --> <!-- https://mvnrepository.com/artifact/org.hibernate/hibernate-core --> <dependency> <groupId>org.hibernate</groupId> <artifactId>hibernate-core</artifactId> <version>5.4.2.Final</version> </dependency> <!-- https://mvnrepository.com/artifact/org.hibernate/hibernate-entitymanager --> <dependency> <groupId>org.hibernate</groupId> <artifactId>hibernate-entitymanager</artifactId> <version>5.4.2.Final</version> </dependency> <!-- https://mvnrepository.com/artifact/org.hibernate.javax.persistence/hibernate-jpa-2.0-api --> <dependency> <groupId>org.hibernate.javax.persistence</groupId> <artifactId>hibernate-jpa-2.0-api</artifactId> <version>1.0.1.Final</version> </dependency> <!--返回object對象所需要的依賴，它在<mvc:annotation-driven>注冊時注入--> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-annotations</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-core</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>org.junit.jupiter</groupId> <artifactId>junit-jupiter-api</artifactId> <version>RELEASE</version> <scope>compile</scope> </dependency> <!-- 補充 --> <!-- https://mvnrepository.com/artifact/aopalliance/aopalliance --> <dependency> <groupId>aopalliance</groupId> <artifactId>aopalliance</artifactId> <version>1.0</version> </dependency> <!-- https://mvnrepository.com/artifact/org.aspectj/aspectjweaver --> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjweaver</artifactId> <version>1.8.13</version> </dependency> <!-- https://mvnrepository.com/artifact/org.aspectj/aspectjrt --> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjrt</artifactId> <version>1.8.9</version> </dependency> <!-- MyBatis --> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>${mybatis.version}</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>${mybatis-spring.version}</version> </dependency> <!-- dbcp數據源 --> <dependency> <groupId>commons-dbcp</groupId> <artifactId>commons-dbcp</artifactId> <version>1.4</version> </dependency> <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api --> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.26</version> </dependency> <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.16.20</version> <scope>provided</scope> </dependency> </dependencies> <build> <finalName>mcv</finalName> </build> </project>
2.applicationContext.xml
注釋掉jdbc事務管理，添加hibernate事務管理。
<?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/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 http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd"> <!-- context:設置注解掃描包注解 注: 如果springmvc-servlet中掃描注解沒有排除@Service注解，這里要設置掃描除@Controller之外的其它所有注解 --> <context:component-scan base-package="com.mvc"> <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> <!-- 開啟@Autowired注解掃描 注: 它等價於<bean class="org.springframework.beans.factory.annotation. AutowiredAnnotationBeanPostProcessor "/> 注: 配置了<context:component-scan />，默認包含對@Autowired的配置，因此下面這個配置就不需要了 --> <context:annotation-config/> <!-- 注冊數據源配置文件 --> <context:property-placeholder location="classpath:jdbc.properties" /> <!-- 注冊數據源對象 這里用Spring內置數據源 --> <bean id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName"> <value>${oracle11g.driverClass}</value> </property> <property name="url"> <value>${oracle11g.url}</value> </property> <property name="username"> <value>${oracle11g.username}</value> </property> <property name="password"> <value>${oracle11g.password}</value> </property> <property name="maxActive"> <value>${oracle11g.maxActive}</value> </property> <property name="maxIdle"> <value>${oracle11g.maxIdle}</value> </property> <property name="maxWait"> <value>${oracle11g.maxWait}</value> </property> <property name="defaultAutoCommit"> <value>${oracle11g.defaultAutoCommit}</value> </property> <property name="timeBetweenEvictionRunsMillis"> <value>${oracle11g.timeBetweenEvictionRunsMillis}</value> </property> <property name="minEvictableIdleTimeMillis"> <value>${oracle11g.minEvictableIdleTimeMillis}</value> </property> </bean> <bean id="dataSource2" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName"> <value>${oracle11g-1.driverClass}</value> </property> <property name="url"> <value>${oracle11g-1.url}</value> </property> <property name="username"> <value>${oracle11g-1.username}</value> </property> <property name="password"> <value>${oracle11g-1.password}</value> </property> <property name="maxActive"> <value>${oracle11g-1.maxActive}</value> </property> <property name="maxIdle"> <value>${oracle11g-1.maxIdle}</value> </property> <property name="maxWait"> <value>${oracle11g-1.maxWait}</value> </property> <property name="defaultAutoCommit"> <value>${oracle11g-1.defaultAutoCommit}</value> </property> <property name="timeBetweenEvictionRunsMillis"> <value>${oracle11g-1.timeBetweenEvictionRunsMillis}</value> </property> <property name="minEvictableIdleTimeMillis"> <value>${oracle11g-1.minEvictableIdleTimeMillis}</value> </property> </bean> <!-- 配置動態數據源 --> <bean id="dynamicDataSource" class="com.mvc.dynamicDataSource.DynamicDataSource"> <property name="targetDataSources"> <map key-type="java.lang.String"> <!-- 指定lookupKey和與之對應的數據源 --> <entry key="dataSource1" value-ref="dataSource1" /> <entry key="dataSource2" value-ref="dataSource2" /> </map> </property> <!-- 指定默認的數據源 --> <property name="defaultTargetDataSource" ref="dataSource1" /> </bean> <!-- 配置事務管理對象--> <!-- <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource1" /> </bean> --> <!-- Hibernate JPA vendor adapter --> <bean id="hibernateJpaVendorAdapter" class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"> <property name="databasePlatform" value="org.hibernate.dialect.Oracle10gDialect"/> </bean> <!-- JPA entity manager factory --> <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"> <property name="dataSource" ref="dataSource1"/> <property name="jpaVendorAdapter" ref="hibernateJpaVendorAdapter"/> <property name="packagesToScan" value="com.mvc.laboratory"/> <property name="jpaProperties"> <props> <prop key="hibernate.dialect">org.hibernate.dialect.Oracle10gDialect</prop> <prop key="hibernate.ejb.naming_strategy">org.hibernate.cfg.ImprovedNamingStrategy</prop> <prop key="hibernate.show_sql">false</prop> </props> </property> </bean> <!-- JPA transaction manager --> <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"> <property name="entityManagerFactory" ref="entityManagerFactory"/> </bean> <!-- 將所有具有@Transactional注解的Bean自動配置為聲明式事務支持 --> <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/> <!-- MyBatis 數據源和sql- --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dynamicDataSource"/> <property name="mapperLocations" value="classpath:/mappings/**/*.xml"/> <property name="configLocation" value="classpath:/mybatis-config.xml"></property> </bean> <!-- MyBayis 掃描器配置--> <bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/> <property name="basePackage" value="com.mvc.laboratory"/> </bean> <!--接收json數據--> <bean id="jsonHttpMessageConverter" class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter"> <property name="supportedMediaTypes"> <list> <value>application/json;charset=UTF-8</value> </list> </property> </bean> <!-- 配置事務自動代理 --> <aop:aspectj-autoproxy proxy-target-class="true" /> </beans>
同樣進行單元測試，動態數據源切換可照常使用。