當前位置：
首頁 >
前端技术
> javascript
>内容正文
javascript
Spring+Mybatis 多数据源配置
生活随笔
收集整理的這篇文章主要介紹了
Spring+Mybatis 多数据源配置
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
2013-03-14? 項目目錄結構如下： spring配置文件 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:tx="http://www.springframework.org/schema/tx" xmlns:jdbc="http://www.springframework.org/schema/jdbc" ? xmlns:context="http://www.springframework.org/schema/context" ? xsi:schemaLocation=" ?? http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd ?? http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ?? http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.0.xsd ?? http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd ?? http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"> ? <bean ? class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> ? <property name="locations"> ? <value>classpath:init-config.properties</value> ? </property> ? </bean> ? <!-- enable component scanning (beware that this does not enable mapper scanning!) --> ? <context:component-scan base-package="org.zhuc.mybatis" /> ? <!-- enable autowire --> ? <context:annotation-config /> ? <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" ? init-method="init" destroy-method="close"> ? <!-- 基本屬性 url、user、password --> ? <property name="url" value="${dataSource.url}" /> ? <property name="username" value="${dataSource.username}" /> ? <property name="password" value="${dataSource.password}" /> ? <property name="connectionProperties" value="${dataSource.driver}"></property> ? <!-- 配置初始化大小、最小、最大 --> ? <property name="initialSize" value="1" /> ? <property name="minIdle" value="1" /> ? <property name="maxActive" value="20" /> ? <!-- 配置獲取連接等待超時的時間 --> ? <property name="maxWait" value="60000" /> ? <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 --> ? <property name="timeBetweenEvictionRunsMillis" value="60000" /> ? <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 --> ? <property name="minEvictableIdleTimeMillis" value="300000" /> ? <property name="validationQuery" value="SELECT 'x'" /> ? <property name="testWhileIdle" value="true" /> ? <property name="testOnBorrow" value="false" /> ? <property name="testOnReturn" value="false" /> ? <!-- 打開PSCache，并且指定每個連接上PSCache的大小 --> ? <property name="poolPreparedStatements" value="true" /> ? <property name="maxPoolPreparedStatementPerConnectionSize" ? value="20" /> ? <!-- 配置監控統計攔截的filters --> ? <property name="filters" value="stat" /> ? </bean> ? <!-- define the SqlSessionFactory --> ? <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> ? <property name="dataSource" ref="dataSource" /> ? <property name="typeAliasesPackage" value="org.zhuc.mybatis.domain" /> ? </bean> ? <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> ? <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/> ? <property name="basePackage" value="org.zhuc.mybatis.mapper" /> ? </bean> ? <!-- transaction manager, use JtaTransactionManager for global tx --> ? <bean id="transactionManager" ? class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> ? <property name="dataSource" ref="dataSource" /> ? <qualifier value="isap" /> ? </bean> ? <!-- 全注解方式 ? 需加上@Transactional --> ? <tx:annotation-driven transaction-manager="transactionManager" /> ? <!-- 事務控制的業務方法配 --> ? <!-- ? ?? <tx:advice id="txAdvice" transaction-manager="transactionManager"> ? <tx:attributes> ? <tx:method name="get*" read-only="true" /> ? <tx:method name="page*" read-only="true" /> ? <tx:method name="list*" read-only="true" /> ? <tx:method name="*" /> ? </tx:attributes> ? </tx:advice> ? --> ? <!-- 事務控制攔截 --> ? <!-- ? ?? <aop:config proxy-target-class="true"> ? <aop:advisor pointcut="execution(* org.zhuc..*.service..*Service.*(..))" ? advice-ref="txAdvice" /> ? </aop:config> ? --> ? <!-- =================================================================== --> ? <!-- 數據源2 --> ? <bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource" ? init-method="init" destroy-method="close"> ? <!-- 基本屬性 url、user、password --> ? <property name="url" value="${dataSource2.url}" /> ? <property name="username" value="${dataSource2.username}" /> ? <property name="password" value="${dataSource2.password}" /> ? <property name="connectionProperties" value="${dataSource2.driver}"></property> ? <!-- 配置初始化大小、最小、最大 --> ? <property name="initialSize" value="1" /> ? <property name="minIdle" value="1" /> ? <property name="maxActive" value="20" /> ? <!-- 配置獲取連接等待超時的時間 --> ? <property name="maxWait" value="60000" /> ? <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 --> ? <property name="timeBetweenEvictionRunsMillis" value="60000" /> ? <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 --> ? <property name="minEvictableIdleTimeMillis" value="300000" /> ? <property name="validationQuery" value="SELECT 'x'" /> ? <property name="testWhileIdle" value="true" /> ? <property name="testOnBorrow" value="false" /> ? <property name="testOnReturn" value="false" /> ? <!-- 打開PSCache，并且指定每個連接上PSCache的大小 --> ? <property name="poolPreparedStatements" value="true" /> ? <property name="maxPoolPreparedStatementPerConnectionSize" ? value="20" /> ? <!-- 配置監控統計攔截的filters --> ? <property name="filters" value="stat" /> ? </bean> ? <bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean"> ? <property name="dataSource" ref="dataSource2" /> ? <property name="typeAliasesPackage" value="org.zhuc.mybatis.domain2" /> ? </bean> ? <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> ? <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory2"/> ? <property name="basePackage" value="org.zhuc.mybatis.mapper2" /> ? </bean> ? <bean id="transactionManager2" ? class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> ? <property name="dataSource" ref="dataSource2" /> ? <qualifier value="insurance" /> ? </bean> ? <!-- 全注解方式 --> ? <tx:annotation-driven transaction-manager="transactionManager2" /> ? </beans> ? <?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:tx="http://www.springframework.org/schema/tx" xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation=" http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <value>classpath:init-config.properties</value> </property> </bean> <!-- enable component scanning (beware that this does not enable mapper scanning!) --> <context:component-scan base-package="org.zhuc.mybatis" /> <!-- enable autowire --> <context:annotation-config /> <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <!-- 基本屬性 url、user、password --> <property name="url" value="${dataSource.url}" /> <property name="username" value="${dataSource.username}" /> <property name="password" value="${dataSource.password}" /> <property name="connectionProperties" value="${dataSource.driver}"></property> <!-- 配置初始化大小、最小、最大 --> <property name="initialSize" value="1" /> <property name="minIdle" value="1" /> <property name="maxActive" value="20" /> <!-- 配置獲取連接等待超時的時間 --> <property name="maxWait" value="60000" /> <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 --> <property name="timeBetweenEvictionRunsMillis" value="60000" /> <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 --> <property name="minEvictableIdleTimeMillis" value="300000" /> <property name="validationQuery" value="SELECT 'x'" /> <property name="testWhileIdle" value="true" /> <property name="testOnBorrow" value="false" /> <property name="testOnReturn" value="false" /> <!-- 打開PSCache，并且指定每個連接上PSCache的大小 --> <property name="poolPreparedStatements" value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize" value="20" /> <!-- 配置監控統計攔截的filters --> <property name="filters" value="stat" /> </bean> <!-- define the SqlSessionFactory --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dataSource" /> <property name="typeAliasesPackage" value="org.zhuc.mybatis.domain" /> </bean> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/> <property name="basePackage" value="org.zhuc.mybatis.mapper" /> </bean> <!-- transaction manager, use JtaTransactionManager for global tx --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource" /> <qualifier value="isap" /> </bean> <!-- 全注解方式 ? 需加上@Transactional --> <tx:annotation-driven transaction-manager="transactionManager" /> <!-- 事務控制的業務方法配 --> <!-- ? <tx:advice id="txAdvice" transaction-manager="transactionManager"> <tx:attributes> <tx:method name="get*" read-only="true" /> <tx:method name="page*" read-only="true" /> <tx:method name="list*" read-only="true" /> <tx:method name="*" /> </tx:attributes> </tx:advice> --> <!-- 事務控制攔截 --> <!-- ? <aop:config proxy-target-class="true"> <aop:advisor pointcut="execution(* org.zhuc..*.service..*Service.*(..))" advice-ref="txAdvice" /> </aop:config> --> <!-- =================================================================== --> <!-- 數據源2 --> <bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <!-- 基本屬性 url、user、password --> <property name="url" value="${dataSource2.url}" /> <property name="username" value="${dataSource2.username}" /> <property name="password" value="${dataSource2.password}" /> <property name="connectionProperties" value="${dataSource2.driver}"></property> <!-- 配置初始化大小、最小、最大 --> <property name="initialSize" value="1" /> <property name="minIdle" value="1" /> <property name="maxActive" value="20" /> <!-- 配置獲取連接等待超時的時間 --> <property name="maxWait" value="60000" /> <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 --> <property name="timeBetweenEvictionRunsMillis" value="60000" /> <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 --> <property name="minEvictableIdleTimeMillis" value="300000" /> <property name="validationQuery" value="SELECT 'x'" /> <property name="testWhileIdle" value="true" /> <property name="testOnBorrow" value="false" /> <property name="testOnReturn" value="false" /> <!-- 打開PSCache，并且指定每個連接上PSCache的大小 --> <property name="poolPreparedStatements" value="true" /> <property name="maxPoolPreparedStatementPerConnectionSize" value="20" /> <!-- 配置監控統計攔截的filters --> <property name="filters" value="stat" /> </bean> <bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dataSource2" /> <property name="typeAliasesPackage" value="org.zhuc.mybatis.domain2" /> </bean> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory2"/> <property name="basePackage" value="org.zhuc.mybatis.mapper2" /> </bean> <bean id="transactionManager2" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource2" /> <qualifier value="insurance" /> </bean> <!-- 全注解方式 --> <tx:annotation-driven transaction-manager="transactionManager2" /> </beans> 配置文件內容： Java代碼? #數據庫連接池設置 ?? dataSource.driver=com.mysql.jdbc.Driver ?? dataSource.url=jdbc:mysql://localhost:3306/dwz ?? dataSource.username=root ?? dataSource.password=root ?? dataSource2.driver=oracle.jdbc.driver.OracleDriver ?? dataSource2.url=jdbc:oracle:thin:@192.168.10.43:1521:test ?? dataSource2.username=test ?? dataSource2.password=test ? #數據庫連接池設置 dataSource.driver=com.mysql.jdbc.Driver dataSource.url=jdbc:mysql://localhost:3306/dwz dataSource.username=root dataSource.password=root dataSource2.driver=oracle.jdbc.driver.OracleDriver dataSource2.url=jdbc:oracle:thin:@192.168.10.43:1521:test dataSource2.username=test dataSource2.password=test Service類代碼： Java代碼? package org.zhuc.mybatis.service; ?? import org.springframework.transaction.annotation.Transactional; ?? /** ? * 基礎mysql Service抽象類 ? * 使用isap數據源及回滾 ? * @author zhuc ? * @create 2013-3-11 下午4:27:33 ? */ ? @Transactional(value = "isap", rollbackFor = Exception.class) ?? public abstract class BaseMySqlService { ?? } ? package org.zhuc.mybatis.service; import org.springframework.transaction.annotation.Transactional; /** * 基礎mysql Service抽象類 * 使用isap數據源及回滾 * @author zhuc * @create 2013-3-11 下午4:27:33 */ @Transactional(value = "isap", rollbackFor = Exception.class) public abstract class BaseMySqlService { } Java代碼? package org.zhuc.mybatis.service; ?? import java.util.List; ?? import org.springframework.beans.factory.annotation.Autowired; ?? import org.springframework.stereotype.Service; ?? import org.zhuc.mybatis.domain.User; ?? import org.zhuc.mybatis.mapper.UserMapper; ?? /** ? * @author zhuc ? * @create 2013-3-11 下午1:19:03 ? */ ? @Service("userService") ?? //@Transactional(value = "isap", rollbackFor = Exception.class) ?? public class UserService extends BaseMySqlService { ?? @Autowired ? private UserMapper userMapper; ?? /** ? * @param id ? * @return ? */ ? public User get(Integer id) { ?? return userMapper.get(id); ?? } ?? /** ? * @param id ? * @return ? */ ? public User get2(Integer id) { ?? return userMapper.get2(id); ?? } ?? /** ? * @return ? */ ? public List<User> findAll() { ?? return userMapper.findAll(); ?? } ?? /** ? * @param user ? * @throws Exception ?? */ ? public void insert(User user) throws Exception { ?? userMapper.insert(user); ?? throw new Exception("testException"); ?? } ?? } ? package org.zhuc.mybatis.service; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.zhuc.mybatis.domain.User; import org.zhuc.mybatis.mapper.UserMapper; /** * @author zhuc * @create 2013-3-11 下午1:19:03 */ @Service("userService") //@Transactional(value = "isap", rollbackFor = Exception.class) public class UserService extends BaseMySqlService { @Autowired private UserMapper userMapper; /** * @param id * @return */ public User get(Integer id) { return userMapper.get(id); } /** * @param id * @return */ public User get2(Integer id) { return userMapper.get2(id); } /** * @return */ public List<User> findAll() { return userMapper.findAll(); } /** * @param user * @throws Exception? */ public void insert(User user) throws Exception { userMapper.insert(user); throw new Exception("testException"); } } Java代碼? package org.zhuc.mybatis.service; ?? import org.springframework.beans.factory.annotation.Autowired; ?? import org.springframework.stereotype.Service; ?? import org.springframework.transaction.annotation.Transactional; ?? import org.zhuc.mybatis.domain2.Flow; ?? import org.zhuc.mybatis.mapper2.FlowMapper; ?? /** ? * @author zhuc ? * @create 2013-3-11 下午1:19:03 ? */ ? @Service("flowService") ?? @Transactional(value = "insurance", rollbackFor = Exception.class) ?? public class FlowService { ?? @Autowired ? private FlowMapper flowMapper; ?? /** ? * @param id ? * @return ? */ ? public Flow get(String id) { ?? return flowMapper.get(id); ?? } ?? } ? package org.zhuc.mybatis.service; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.zhuc.mybatis.domain2.Flow; import org.zhuc.mybatis.mapper2.FlowMapper; /** * @author zhuc * @create 2013-3-11 下午1:19:03 */ @Service("flowService") @Transactional(value = "insurance", rollbackFor = Exception.class) public class FlowService { @Autowired private FlowMapper flowMapper; /** * @param id * @return */ public Flow get(String id) { return flowMapper.get(id); } } 客戶端測試類如下： Java代碼? package spring; ?? import org.springframework.context.ApplicationContext; ?? import org.springframework.context.support.ClassPathXmlApplicationContext; ?? import org.zhuc.mybatis.service.FlowService; ?? import org.zhuc.mybatis.service.UserService; ?? /** ? * @author zhuc ? * @create 2013-3-11 下午1:47:03 ? */ ? public class MultiTest { ?? /** ? * @param args ? * @throws Exception ?? */ ? public static void main(String[] args) throws Exception { ?? ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml"); ?? UserService userService = (UserService) ac.getBean("userService"); ?? System.out.println(userService.get(1)); ?? System.out.println(userService.get2(1)); ?? FlowService flowService = (FlowService) ac.getBean("flowService"); ?? System.out.println(flowService.get("94003d29-a7b0-42f0-839c-fa609b209ff1")); ?? // ? ? ?User user = new User(); ?? // ? ? ?user.setId(100); ?? // ? ? ?user.setUserName("admin100"); ?? // ? ? ?user.setPassword("password100"); ?? // ? ? ?user.setTrueName("小李4"); ?? // ? ? ?user.setCreateTime(new Date()); ?? // ?? // ? ? ?userService.insert(user); ? //受事務管理,拋出Exception時將回滾 ?(rollbackFor) ?? } ?? } ? package spring; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.zhuc.mybatis.service.FlowService; import org.zhuc.mybatis.service.UserService; /** * @author zhuc * @create 2013-3-11 下午1:47:03 */ public class MultiTest { /** * @param args * @throws Exception? */ public static void main(String[] args) throws Exception { ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml"); UserService userService = (UserService) ac.getBean("userService"); System.out.println(userService.get(1)); System.out.println(userService.get2(1)); FlowService flowService = (FlowService) ac.getBean("flowService"); System.out.println(flowService.get("94003d29-a7b0-42f0-839c-fa609b209ff1")); //User user = new User(); //user.setId(100); //user.setUserName("admin100"); //user.setPassword("password100"); //user.setTrueName("小李4"); //user.setCreateTime(new Date()); // //userService.insert(user);//受事務管理,拋出Exception時將回滾 ?(rollbackFor) } } 輸出結果： 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper.UserMapper.get - ooo Using Connection [com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl@f6d64c5] 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper.UserMapper.get - ==> ?Preparing: SELECT * from T_USER where id = ?? 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper.UserMapper.get - ==> Parameters: 1(Integer) User [id=1, userName=userName0, password=password0, roleId=3, trueName=姓名0, createTime=Mon Mar 04 14:17:31 CST 2013, modifyTime=Mon Mar 04 14:17:31 CST 2013] 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper.UserMapper.get2 - ooo Using Connection [com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl@f6d64c5] 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper.UserMapper.get2 - ==> ?Preparing: SELECT * from T_USER where id = ?? 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper.UserMapper.get2 - ==> Parameters: 1(Integer) User [id=1, userName=userName0, password=password0, roleId=3, trueName=姓名0, createTime=Mon Mar 04 14:17:31 CST 2013, modifyTime=Mon Mar 04 14:17:31 CST 2013] 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper2.FlowMapper.get - ooo Using Connection [com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl@11742dfe] 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper2.FlowMapper.get - ==> ?Preparing: SELECT * from T_FLOW where FLOW_ID = ?? 2013-03-14 11:21:19 [main] DEBUG org.zhuc.mybatis.mapper2.FlowMapper.get - ==> Parameters: 94003d29-a7b0-42f0-839c-fa609b209ff1(String) Flow [id=94003d29-a7b0-42f0-839c-fa609b209ff1, insuranceId=5a08abc4-463e-436d-b249-9954be487cdd, codeId=14, operatingTime=Mon Jan 21 16:47:12 CST 2013] mybatis-demo.zip (33.7 KB)? 下載次數: 106
總結
以上是生活随笔為你收集整理的Spring+Mybatis 多数据源配置的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 字体大宝库：26款新鲜出炉的高品质免费英
- 下一篇： Fat Jar Eclipse Plug