`

Spring 学习系列 -- Spring + Mybatis 从零开始配置多数据源访问

 
阅读更多

目的：

    项目中以前有整合mybatis + spring操作数据库，但是以前都是单数据库，现需要实现mybatis访问多数据源，依旧使用spring调用mybatis。

    通过注解的方式整合 spring + mybatis 多数据源，同时使两者能够执行事务操作

    网上虽然也有类似的文章，但是或多或少有些问题。先将我的解决方法记录下来，以供参考。

 

步骤

 

  • 导入相关的包


 

 

  • 有2个数据库，分别是spring1 和 spring2
spring1 有表：teacher和数据
CREATE TABLE `teacher` (
  `iTeacherId` int(11) NOT NULL AUTO_INCREMENT,
  `sName` varchar(32) DEFAULT NULL,
  PRIMARY KEY (`iTeacherId`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

INSERT INTO `teacher` VALUES (1, 'teacher1');
INSERT INTO `teacher` VALUES (2, 'teacher2');
 

spring2有表：

 

CREATE TABLE `student` (
  `iStudentId` int(11) NOT NULL AUTO_INCREMENT,
  `sName` varchar(32) DEFAULT NULL,
  `iClass` int(11) DEFAULT NULL COMMENT '班级',
  PRIMARY KEY (`iStudentId`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;
INSERT INTO `student` VALUES (1, 'student1', 1);
INSERT INTO `student` VALUES (2, 'student2', 2);
INSERT INTO `student` VALUES (3, 'student3', 2);
  •  功能：同时查询spring1.teacher和spring2.student 且支持事务操作

建立工程如下：


 


 各个包说明：
  • com.my.teacher.pojo，com.my.student.pojo：和表结构一一对应的pojo类
Teacher类：
public class Teacher {
	private Integer iTeacherId;
	private String sName;
        ....
}
 Student类：
public class Student {
	private Integer iStudentId;
	private String sName;
	private Integer iClass;
        ...
}
 
  • com.my.student.mapper，com.my.teacher.mapper：mybatis的Mapper类，每个mapper都必须有一个同名的mapper.xml
StudentMapper类和对应的mapper.xml
public interface StudentMapper {
	List<Student> querys(Map<String,Object> map);
}
 <?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.my.student.mapper.StudentMapper" >
  <!-- resultMap  -->
  <resultMap id="ResultMap" type="Student" >
    <id column="iStudentId" property="iStudentId" jdbcType="INTEGER" />
    <result column="sName" property="sName" jdbcType="VARCHAR" />
    <result column="iClass" property="iClass" jdbcType="INTEGER" />
  </resultMap>
 
  <!-- querys  -->
  <select id="querys" resultMap="ResultMap" parameterType="map" >
    select * from student
  </select>
 
</mapper>
 
TeacherMapper类和对应的mapper.xml
public interface TeacherMapper {
	List<Teacher> querys(Map<String,Object> map);
}
 <?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.my.teacher.mapper.TeacherMapper" >
  <!-- resultMap  -->
  <resultMap id="ResultMap" type="Teacher" >
    <id column="iTeacherId" property="iTeacherId" jdbcType="INTEGER" />
    <result column="sName" property="sName" jdbcType="VARCHAR" />
  </resultMap>
 
  <!-- querys  -->
  <select id="querys" resultMap="ResultMap" parameterType="map" >
    select * from teacher
  </select>
 
</mapper>
 

  • com.my.student.dao，com.my.student.dao.imp：调用mapper，逐个获取student、teacher记录
public interface Dao {
	public void printAll();
	public void printStudent();
	public void printTeacher();
}
 

@Component
@Transactional
public class DaoImp implements Dao {
	@Resource private StudentMapper studentMapper;
	@Resource private TeacherMapper teacherMapper;
	
	
	@Override
	public void printAll() {
		// TODO Auto-generated method stub
		List<Student> l = this.studentMapper.querys(new HashMap<String,Object>());
		for(Student o : l){
			System.out.println(o);
		}
		
		List<Teacher> l2 = this.teacherMapper.querys(new HashMap<String,Object>());
		for(Teacher o : l2){
			System.out.println(o);
		}
	}
	
	@Override
	public void printStudent() {
		// TODO Auto-generated method stub
		List<Student> l = this.studentMapper.querys(new HashMap<String,Object>());
		for(Student o : l){
			System.out.println(o);
		}
	}
	
	@Override
	public void printTeacher() {
 
		
		List<Teacher> l2 = this.teacherMapper.querys(new HashMap<String,Object>());
		for(Teacher o : l2){
			System.out.println(o);
		}
	}

}
 
  • com.my.student.dao.imp.test：测试dao类，代码略
  • resource：配置类，这里是重点介绍部分
main.properties：属性配置文件，把一些易变的属性配置到这个文件中，比配置到spring的配置文件中，要易于维护。
# ALL database are same
main.db.sIp=127.0.0.1
main.db.sPort=3306
main.db.sUsername=mysql
main.db.sPassword=password
mybatis_student.xml：spring2的mybatis配置xml
<configuration>   
    <settings>   
        <!-- changes from the defaults for testing -->   
        <setting name="cacheEnabled" value="false" />   
        <setting name="useGeneratedKeys" value="true" />   
        <setting name="defaultExecutorType" value="REUSE" /> 
    </settings>    
  
    <typeAliases>
        <!-- 类重命名 -->
		<typeAlias type="com.my.student.pojo.Student" alias="Student"/>
    </typeAliases>
     
</configuration>
 
 mybatis_teacher.xml：spring1的mybatis配置xml 和 mybatis_student相似
<configuration>   
    <settings>   
        <!-- changes from the defaults for testing -->   
        <setting name="cacheEnabled" value="false" />   
        <setting name="useGeneratedKeys" value="true" />   
        <setting name="defaultExecutorType" value="REUSE" /> 
    </settings>    
  
    <typeAliases>
		<!-- 类重命名 -->
		<typeAlias type="com.my.teacher.pojo.Teacher" alias="Teacher"/>
    </typeAliases>
     
</configuration>
 
spring_student.xml：spring2的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: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/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">

  <!-- 开启注释扫描   --> 
  <context:annotation-config />
  <!-- 包扫描 -->
  <context:component-scan base-package="
  		com.my.student.dao
  	"/>
 
  <!-- 加载外部属性配置文件 -->
  <context:property-placeholder location="classpath:resource/main.properties" />
 
  <!-- 多个数据源的 DataSource名称不能相等 -->
  <bean id="studentDataSource" destroy-method="close"
    class="org.apache.commons.dbcp.BasicDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://${main.db.sIp}:${main.db.sPort}/spring2" />  
    <property name="username" value="${main.db.sUsername}" />
    <property name="password" value="${main.db.sPassword}" />
    <property name="initialSize" value="20"/>  
    <property name="maxActive" value="200"/>  
    <property name="maxIdle" value="30"/>  
    <property name="maxWait" value="1000"/>  

	<property name="testOnBorrow" value="true"/>  
    <property name="testWhileIdle" value="true"/>  
    <property name="testOnReturn" value="true"/> 
    <property name="minEvictableIdleTimeMillis" value="300000" />  
    <property name="timeBetweenEvictionRunsMillis" value="120000" /> 
    <property name="validationQuery" value="select 1 from dual" />   
  </bean>
 	

   <!-- 多个数据源的SqlSessionFactory名称不能相等 -->  
  <bean id="studentSqlSessionFactory" name="studentSqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="studentDataSource" />
    <!-- 加载mybatis配置类 -->
    <property name="configLocation" value="resource/mybatis_student.xml" />
  </bean>
  <!-- ScanMapperFiles: mapper类要扫描的包；扫描mapper类 ，也不能同名 -->
  <bean name="studentMapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
     <!-- mapper类所在的包  -->
    <property name="basePackage" value="com.my.student.mapper"/> 
    <property name="sqlSessionFactoryBeanName" value="studentSqlSessionFactory"/> 
  </bean>



  <!-- ================================事务相关控制=================================================    -->
  <!-- 开启通过注解实现事务，设置事务的名称 . 事务管理对象的名称也要不一样。系统默认事务管理对象名称为transactionManager -->
  <tx:annotation-driven transaction-manager="studentTransactionManager"/>
  <bean name="studentTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">     
          <property name="dataSource" ref="studentDataSource"></property>
    </bean>     
 
</beans>
 
spring_teacher.xml：spring1的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: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/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">

 
  <!-- 多个数据源的 DataSource名称不能相等 -->
  <bean id="teacherDataSource" destroy-method="close"
    class="org.apache.commons.dbcp.BasicDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://${main.db.sIp}:${main.db.sPort}/spring1" />  
    <property name="username" value="${main.db.sUsername}" />
    <property name="password" value="${main.db.sPassword}" />
    <property name="initialSize" value="20"/>  
    <property name="maxActive" value="200"/>  
    <property name="maxIdle" value="30"/>  
    <property name="maxWait" value="1000"/>  

	<property name="testOnBorrow" value="true"/>  
    <property name="testWhileIdle" value="true"/>  
    <property name="testOnReturn" value="true"/> 
    <property name="minEvictableIdleTimeMillis" value="300000" />  
    <property name="timeBetweenEvictionRunsMillis" value="120000" /> 
    <property name="validationQuery" value="select 1 from dual" />   
  </bean>
 	

  <!-- 多个数据源的SqlSessionFactory名称不能相等 -->  
  <bean id="teacherSessionFactory"  name="teacherSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="teacherDataSource" />
    <!-- 加载mybatis的配置文件 -->
    <property name="configLocation" value="resource/mybatis_teacher.xml" />
  </bean>
  <!-- ScanMapperFiles 扫描mapper类 ，也不能同名-->
  <bean  name="teacherMapperScannerConfigurer"   class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <!-- mapper类所在的包  -->
    <property name="basePackage" value="com.my.teacher.mapper"/>  
    <property name="sqlSessionFactoryBeanName" value="teacherSessionFactory"/> 
  </bean>

  <!-- ================================事务相关控制=================================================    -->
  <!-- 开启通过注解实现事务，设置事务的名称 . 事务管理对象的名称也要不一样。系统默认事务管理对象名称为transactionManager -->
  <tx:annotation-driven  transaction-manager="teachaerTransactionManager" />
  
  <bean name="teachaerTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">     
      <property name="dataSource" ref="teacherDataSource"></property>
  </bean>     
</beans>
 

重点说明：

 

  • mybatis + spring 中，多数据库源的配置和单数据源配置和相似，最大的不同时，2个数据源的配置的名称不能相等。如上面配置spring配置xml中 DataSource、SqlSessionFactoryBean、MapperScannerConfigurer、DataSourceTransactionManager等在2个spring配置名称中都不相等。尤其是事务管理类DataSourceTransactionManager，必须通过以下方式开启并进行命名：<tx:annotation-driven transaction-manager="teachaerTransactionManager" />
     

 

 

   同时部分只演示了同时操作2个数据库，事务操作通过更新操作才能够更好演示出来，其实以上已经实现事务了，这里就省略步骤了。

   以上内容源代码见附近

 

 

参考文献：

 

  • 大小: 51.6 KB
  • 大小: 20.5 KB
分享到：
| Apache 开源软件学习
评论
2 楼 xj56ai 2016-07-18  
能不能 提供一下 包
1 楼 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 希望能与你取得联系
发表评论

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

相关推荐

    （Spring整合）Spring+SpringMVC+MyBatis.zip

    在整合Spring、SpringMVC和MyBatis时，通常会通过Spring的DataSource、TransactionManager和SqlSessionFactoryBean来配置数据源、事务管理和SQL会话工厂。Spring的声明式事务管理可以确保在处理数据库操作时的事务...

    本科毕设-课设-基于SpringMVC+MyBatis开发学生管理系统.zip

    【描述】中提到，该系统的所有源码都经过测试，可以直接运行，这表明项目已经具备了一定的完整性和可用性，对于初学者来说，这是一个很好的实践平台，可以深入理解Web应用的开发流程，而无需从零开始编码。...

    spring+springMVC+Mybatis+maven框架

    以上就是关于"spring+springMVC+Mybatis+maven框架"整合的知识点，这个整合包提供了完整的SSM项目结构，开发者可以直接使用，避免了从零开始搭建环境的繁琐步骤。通过这个项目，你可以学习到如何有效地组织和管理...

    spring+springmvc+mybatis+maven整合demo

    本整合Demo旨在提供一个完整的开发环境，使得开发者可以快速地搭建项目并进行开发工作，无需从零开始配置各种依赖。 Spring作为一个全面的轻量级框架，它提供了依赖注入（DI）和面向切面编程（AOP）等核心特性，...

    spring+mybatis。非常简单

    "压缩包内有mysql转储的sql文件" 表明提供了一个预先创建好的数据库结构，用户可以通过导入这个SQL文件在MySQL数据库中建立相应的表，无需从零开始。"改变一下数据源就可以使用" 提示我们，开发者已经考虑到了可配置...

    Spring+SpringMVC+MyBatis的JAR包

    - **快速启动**：这个整合包提供了一键式的SSM配置，开发者无需从零开始设置，只需将其导入项目，按照指定方式配置数据库连接等信息，就能快速启动一个具备完整SSM功能的应用。 - **注意事项**：尽管使用预配置的...

    Spring+Springmvc+Mybatis整合好的模板

    开发者只需要导入到IDEA，就可以直接开始编写业务代码，无需从零开始搭建环境。 5. **项目结构**：通常，一个整合了SSM的项目会包含以下目录和文件： - `src/main/java`：存放源代码，包括实体类（Entity）、服务...

    Macbook中使用IDEA开发Spring+SpringMVC+Mybatis+Tomcat+MySQL项目新手必看

    以下是一份详细的步骤指南，帮助你从零开始构建这样的项目。 1. **环境配置**： - **Java环境**：首先确保安装了Java JDK，并设置好`JAVA_HOME`环境变量。 - **IDEA**：下载并安装IntelliJ IDEA社区版或专业版，...

    springmvc+spring+mybatis+Maven+mysql环境搭建，附源码

    通过本教程的学习，读者可以了解如何从零开始搭建一个完整的项目结构，包括数据库设计、项目构建、框架配置等各个环节。 #### 二、环境准备与配置 ##### 1. 数据库设计与创建 在搭建开发环境之前，首先需要创建...

    从零搭建一个 Spring Boot 开发环境！Spring Boot+Mybatis+Swagger2 环境搭建.docx

    在本文中，我们将详细介绍如何从零开始搭建一个基于Spring Boot的开发环境，其中包括Spring Boot、Mybatis和Swagger2的集成。首先，让我们了解为何选择Spring Boot。 **为什么使用Spring Boot** Spring Boot是...

    SpringBoot+Mybatis+MySQL 学习练习项目源码+数据库+说明文档

    项目中附带的创建教程地址，应该是一个详细的步骤指南，教你如何从零开始搭建并运行这个项目，包括安装IDEA、导入项目、配置数据库连接、运行项目等步骤，对于初学者来说是非常有价值的资源。 总的来说，这个项目...

    Spinrg+SpirngMvc+Mybatis+Maven整合项目，打开即用

    这个整合项目提供了一种快速启动开发的方案，使得开发者无需从零开始搭建环境，只需进行必要的配置调整就能投入使用。 Spring是一个全面的后端开发框架，它提供了依赖注入（DI）和面向切面编程（AOP）等功能，有助...

    springmvc+mybatis+maven登陆、增删改查、分页实例-初学者必选（含数据库）

    这个项目包含了完整的登录功能、数据的增删改查以及分页显示，同时还提供了数据库的SQL脚本，使得用户可以直接运行项目而无需从零开始搭建环境。 1. **SpringMVC**：SpringMVC是Spring框架的一部分，它是一个轻量级...

    java_Spring+Mybatis_Demo

    这个压缩包包含了一个完整的项目结构，使得开发者无需从零开始设置框架，可以直接进入编码阶段，极大地提高了开发效率。 1. **Spring框架**：Spring是一个开源的Java平台，它简化了Java企业级应用的开发。Spring...

    JavaWeb开发之Spring+SpringMVC+MyBatis+SpringSecurity+EhCache+JCaptcha 完整Web基础框架

    因此，自己动手实践，从零开始构建这样一个框架，不仅能深入理解每个组件的工作原理，还能掌握它们之间的协同工作方式，对提升开发技能大有裨益。尽管如此，完整的源代码并不总是必要的，因为学习过程中，更重要的是...

    Myecilpse上配置好的SSM（spring+springMVC+Mybatis）项目结构，方便直接使用

    在MyEclipse中，导入这个预配置的SSM项目后，可以直接进行业务逻辑开发，无需从零开始配置环境。通常，项目结构会包含以下模块： 1. `src/main/java`：存放所有的Java源代码，包括Service、Controller、DAO、Model...

    Struts2+Spring4+MyBatis3 最新包集成发布就可运行

    这个集成包的特点在于已经完成了基本的配置，并且对配置文件进行了详细的注释，这对于初学者来说是非常友好的，他们可以直接运行项目，了解各个框架之间的协作，而无需从零开始配置。开发者可以通过阅读这些注释，...

    spring-springMVC-mybatis框架基本代码代码

    这个基础框架的目的是提供一个快速开发的起点，开发者可以在此基础上添加自己的业务逻辑和功能，而无需从零开始配置整个框架。通过理解和掌握SSM框架的运作机制，开发者可以更高效地开发和维护Java Web应用。

    Spring+SpringMVC+MyBatis可运行工程源码

    这个压缩包包含了一个完整的、可运行的工程源码，允许开发者直接在IDEA（IntelliJ IDEA）中导入并运行，无需从零开始配置。 **Spring框架**： Spring是一个开源的应用框架，核心特性是依赖注入（Dependency ...

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