您的位置:首页 > 编程语言 > Java开发

Spring+Mybatis 多数据源配置

2015-06-10 14:43 330 查看
项目目录结构如下:



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>

配置文件内容:

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

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 {

}

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");

}

}

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);

}

}

客户端测试类如下:

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)

}

}

输出结果:

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)
下载次数: 670

查看图片附件

分享到:




Session超时 Ajax请求页面的跳转 | 设置eclipse不同的workspace共享配置
( ...

2013-03-14 11:26

浏览 14330

评论(4)

收藏

分类:编程语言

相关推荐


评论


4 楼 江_南 2015-05-21 引用













3 楼 pizi18 2013-11-19 引用
你好,我也想请教一下,如果每一个service是独立的事务,那要想在一个service里面完成对2个数据库的操作该如何做

2 楼 zhuchengzzcc 2013-03-22 引用

asgab 写道

同一个service修改两个数据库的数据,事务怎么控制?

不是,每一个service是独立的事务,请注意看

@Transactional(value = "insurance", rollbackFor = Exception.class)

@Transactional(value = "isap", rollbackFor = Exception.class)

注解式的事务声明,

对应的insurance代表Oracle, isap代表Mysql

1 楼 asgab 2013-03-21 引用
同一个service修改两个数据库的数据,事务怎么控制?
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: