`
zhuchengzzcc
  • 浏览: 442911 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

Spring+Mybatis 多数据源配置

 
阅读更多

     项目目录结构如下：



 

 

      spring配置文件

<?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>

 

 

      配置文件内容：

#数据库连接池设置
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类代码：

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 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 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 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]

  • 大小: 24 KB
分享到：
| 设置eclipse不同的workspace共享配置 ( ...
评论
6 楼 yelong0201 2015-11-13  
应该只适用于不同数据源的表结构也不同的情况，如果是多个数据源表结构相同就不行了
5 楼 zhangliguoaccp 2015-10-29  
您好，我也用到同样的功能了，但是我的
15:14:20,838 WARN  [ConfigurationClassEnhancer]
@Bean method SpringIocMappingConfig.mappperConfigurer is non-static and returns an object assignable to Spring's BeanFactoryPostProcessor interface. This will result in a failure to process annotations such as @Autowired, @Resource and @PostConstruct within the method's declaring @Configuration class. Add the 'static' modifier to this method to avoid these container lifecycle issues; see @Bean Javadoc for complete details

15:14:20,856 WARN  [ConfigurationClassEnhancer]
@Bean method SpringIocMappingConfig2.mappperConfigurerAgreement is non-static and returns an object assignable to Spring's BeanFactoryPostProcessor interface. This will result in a failure to process annotations such as @Autowired, @Resource and @PostConstruct within the method's declaring @Configuration class. Add the 'static' modifier to this method to avoid these container lifecycle issues; see @Bean Javadoc for complete details

启动服务器，就停在这了，我QQ602525391 希望能与你取得联系
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修改两个数据库的数据，事务怎么控制？
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    Spring+MyBatis多数据源配置实现

    总之，Spring+MyBatis多数据源配置是大型项目中常见的需求，它通过`AbstractRoutingDataSource`实现了动态数据源选择，结合MyBatis的Mapper接口和注解，可以方便地在多个数据库之间切换，从而满足复杂的数据库访问...

    SSM（Spring+SpringMVC+MyBatis）多数据源配置框架

    在多数据源配置中，Spring能够帮助管理不同的数据源，通过配置bean来切换和控制数据源的使用。 **SpringMVC** 是Spring框架的一部分，专为Web开发设计。它简化了模型-视图-控制器（Model-View-Controller，MVC）的...

    Springboot+Mybatis+Druid多数据源配置

    在多数据源场景下，我们可以通过Spring Boot的@ConfigurationProperties特性来配置不同的数据源。每个数据源都需要定义一套包括URL、用户名、密码和驱动类名等属性。例如： ```java @Configuration @...

    Springboot+mybatis+druid多数据源配置（oracle+mybatis）

    总结，Spring Boot结合Mybatis和Druid实现多数据源配置的过程包括：配置数据源、配置Mybatis、创建数据源切换器、以及针对不同数据库的测试。这一过程涉及了Spring Boot的自动配置、依赖注入、配置属性绑定等多个...

    springmvc + spring + mybatis + maven整合配置文件

    然后配置Spring的applicationContext.xml，包括Bean定义、AOP配置、数据源、事务管理器等。接着配置Spring MVC的servlet-context.xml，设置DispatcherServlet、视图解析器、拦截器等。最后，配置MyBatis的mybatis-...

    SpringMvc+Spring+Mybatis+Maven+注解方式=整合

    - MyBatis的配置文件（mybatis-config.xml）中，设置数据源和SqlSessionFactory，以便MyBatis与数据库交互。 通过以上步骤，我们可以构建一个松耦合、可测试的系统，每个组件都发挥着它应有的作用，而注解方式的...

    《spring+mybatis 企业应用实战》源码、类库全资料

    1. **配置文件**：包括Spring的bean配置文件（如`applicationContext.xml`）和MyBatis的配置文件（如`mybatis-config.xml`），它们定义了数据源、事务管理器、SqlSessionFactory以及Mapper接口的扫描路径。...

    struts2+spring+mybatis框架

    3. **配置MyBatis**：编写MyBatis的配置文件，包括数据源、SqlSessionFactory，并为每个Mapper接口定义XML映射文件。 4. **整合Spring和Struts2**：使用Spring的Struts2插件，使Spring管理的Bean可以直接在Struts2 ...

    Spring+SpringMVC+Mybatis多数据源

    总结来说，"Spring+SpringMVC+Mybatis多数据源"的整合涉及了Spring的数据源管理、SpringMVC的请求路由、Mybatis的数据源配置以及事务管理。具体实现时，可以根据项目需求选择合适的方式进行数据源切换，以达到优化...

    spring+hibernate和spring+myBatis实现连接多个数据库，同时操作的项目

    在多数据源环境中，MyBatis的配置文件需要包含多个数据源的信息，每次操作数据库时，可以通过SqlSessionFactoryBuilder创建指定数据源的SqlSessionFactory，然后通过SqlSession来执行SQL。 项目的...

    springboot+druid+mybatis多数据源动态切换案例

    5. **MyBatis配置**：在多数据源环境下，MyBatis的配置需要针对每个数据源分别设置SqlSessionFactory，并在Mapper接口上通过@MapperScan注解指定对应的SqlSessionFactory。 6. **事务管理**：在多数据源情况下，...

    springboot+mybatis双数据源配置及事务处理

    Spring Boot通过`@EnableAutoConfiguration`注解自动配置了大量常见服务，包括数据源和MyBatis的配置。然而，当涉及到多个数据源时，我们需要手动进行一些配置。 1. **配置双数据源** - 首先，为每个数据源创建一...

    spring+spring mvc+mybatis框架整合实现超市货物管理系统

    对于MyBatis，我们需要创建`mybatis-config.xml`配置文件，配置数据源、事务管理器以及映射文件的位置。 数据库方面，本系统使用了MySQL，通过MyBatis的SqlSessionFactory和SqlSession对象，我们可以执行SQL语句。`...

    SpringBoot+gradle+mybatis多数据源动态配置

    本项目结合了SpringBoot、Gradle和MyBatis，旨在实现多数据源的动态配置，这对于处理多个数据库或者分库分表的场景尤其有用。以下是对这个项目的详细解析： **SpringBoot** SpringBoot是由Pivotal团队提供的全新...

    struts+spring+mybatis源代码例子

    标题中的"struts+spring+mybatis源代码例子"意味着这是一个实际的项目示例，包含了这三个框架的集成使用，可以帮助开发者理解和学习如何在实际项目中整合这些技术。通过分析和研究这个源代码，开发者可以深入理解...

    spring+springmvc+mybatis

    在实际项目中，开发者通常会创建一个配置文件（如：`springmvc_mybatis1208`可能包含的`spring-config.xml`），在其中配置Spring和MyBatis的相关设置，包括数据源、事务管理器、SqlSessionFactory等。同时，还需要...

    SpringMVC+Spring+MyBatis jar包和配置文件

    4. 配置MyBatis：编写mybatis-config.xml，包含数据源、事务管理器、环境等信息。 5. 配置Mapper：创建Mapper接口和对应的XML文件，定义SQL语句。 6. 配置Spring与MyBatis的集成：使用MyBatis-Spring的...

    SSM框架-详细整合教程(Spring+SpringMVC+MyBatis).pdf

    - `spring-mybatis.xml`中配置数据源、事务管理器、MyBatis的SqlSessionFactory以及Mapper扫描器。 - `spring-mvc.xml`中配置DispatcherServlet、视图解析器、拦截器等。 6. **资源文件** - 配置数据库连接的`...

Magicbox
Global site tag (gtag.js) - Google Analytics