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