赞
踩
Spring整合MyBatis是指将Spring框架和MyBatis持久化框架结合起来使用,实现数据访问层和业务逻辑层的整合。Spring是一个轻量级的Java开发框架,提供了面向切面编程(AOP)、依赖注入(DI)等功能,可以简化企业级应用程序的开发。而MyBatis是一种持久化框架,通过将数据库操作与Java对象的映射进行配置,实现了数据库操作的简化。
本文中将使用到整合提供的事务管理机制,可以统一管理数据库操作的事务,确保数据的一致性和完整性。
项目案例主要的流程为:通过service层调用dao层,然后通过dao层调用mybatis进行数据库,最后使用Demo测试类。
事务管理模块:通过模拟两个账号的转账功能,实现事务管理的功能。
项目核心的部分包含:1)项目相关依赖 2)mybatis核心配置文件 3)spring核心配置文件 4)service层内容 5)mapper层内容 6)Demo测试类内容
具体内容如下:
1. pom.xml 依赖
- <dependencies>
- <!--spring基础依赖-->
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-context</artifactId>
- <version>5.3.20</version>
- </dependency>
- <!--spring连接jdbc-->
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-jdbc</artifactId>
- <version>5.3.20</version>
- </dependency>
- <!--aop面向切面编程框架-->
- <dependency>
- <groupId>org.aspectj</groupId>
- <artifactId>aspectjweaver</artifactId>
- <version>1.9.7</version>
- </dependency>
- <!--spring事务管理-->
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-tx</artifactId>
- <version>5.3.20</version>
- </dependency>
- <!--mybatis依赖-->
- <dependency>
- <groupId>org.mybatis</groupId>
- <artifactId>mybatis</artifactId>
- <version>3.5.4</version>
- </dependency>
- <!--mybatis与spring整合-->
- <dependency>
- <groupId>org.mybatis</groupId>
- <artifactId>mybatis-spring</artifactId>
- <version>1.3.2</version>
- </dependency>
- <!--mysql数据库依赖-->
- <dependency>
- <groupId>mysql</groupId>
- <artifactId>mysql-connector-java</artifactId>
- <version>8.0.29</version>
- </dependency>
- <!--dbcp连接池-->
- <dependency>
- <groupId>org.apache.commons</groupId>
- <artifactId>commons-dbcp2</artifactId>
- <version>2.11.0</version>
- </dependency>
- <!--lombok依赖-->
- <dependency>
- <groupId>org.projectlombok</groupId>
- <artifactId>lombok</artifactId>
- <version>1.18.30</version>
- </dependency>
- </dependencies>
2. mybatis核心配置文件:mybatis-config.xml
- <?xml version="1.0" encoding="UTF-8" ?>
- <!DOCTYPE configuration
- PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
- "http://mybatis.org/dtd/mybatis-3-config.dtd">
- <configuration>
- <typeAliases>
- <package name="com.laoma.pojo"/>
- </typeAliases>
- <mappers>
- <mapper resource="mapper/AccountMapper.xml"/>
- </mappers>
- </configuration>
3. spring核心配置文件:applicationContext.xml
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:tx="http://www.springframework.org/schema/tx"
- xmlns:aop="http://www.springframework.org/schema/aop"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans.xsd
- http://www.springframework.org/schema/tx
- http://www.springframework.org/schema/tx/spring-tx.xsd
- http://www.springframework.org/schema/aop
- http://www.springframework.org/schema/aop/spring-aop.xsd">
-
- <!--数据源的配置-->
- <bean id="dataSource" class="org.apache.commons.dbcp2.BasicDataSource">
- <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
- <property name="url" value="jdbc:mysql://localhost:3306/student_db"/>
- <property name="username" value="root"/>
- <property name="password" value="12345678"/>
- </bean>
- <!--sqlSessionFactory-->
- <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
- <!--加载mybatis核心配置文件-->
- <property name="configLocation" value="mybatis-config.xml"/>
- <!--数据源的配置-->
- <property name="dataSource" ref="dataSource"/>
- </bean>
- <!--Mapper接口的代理-->
- <bean id="accountMapper" class="org.mybatis.spring.mapper.MapperFactoryBean">
- <!--指定需要代理的接口-->
- <property name="mapperInterface" value="com.laoma.mapper.AccountMapper"/>
- <!--sqlSession工厂-->
- <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
- </bean>
- <!--Service注册-->
- <bean id="accountService" class="com.laoma.service.impl.AccountServiceImpl">
- <property name="accountMapper" ref="accountMapper"/>
- </bean>
-
-
- <!--事务管理数据源的配置-->
- <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
- <property name="dataSource" ref="dataSource"/>
- </bean>
- <!--配置事务-->
- <tx:advice id="txAdvice" transaction-manager="transactionManager">
- <!--配置事务的属性
- 1. name: 指定的哪些方式进行事务管理(这些方式指的事service中的方法)
- 1.1 * 表示所有的方法都需要进行事务管理
- 1.2 save* 表示save开头的方式需要进行事务管理
- 2. propagation: 传播级别
- 2.1 REQUIRED 如果当前没有事务,就新建一个事务,如果已经存在一个事务中,就加入到这个事务中。这是最常见的选择。
- 3. isolation: 隔离级别
- -->
- <tx:attributes>
- <tx:method name="*" propagation="REQUIRED" isolation="DEFAULT"/>
- </tx:attributes>
- </tx:advice>
-
- <!--使用AOP编程进行事务的配置-->
- <aop:config>
- <aop:advisor advice-ref="txAdvice" pointcut="execution(* com.laoma.service.impl.*.*(..))"/>
- </aop:config>
-
- </beans>
4.pojo 层:Account
- @Data
- public class Account {
- private int id;
- private String name;
- private int money;
- }
5. Service 层:AccountService
- public interface AccountService {
- public int pay(int sourceId, int dstId,int money);
- }
6. Service层:AccountServiceImpl
- public class AccountServiceImpl implements AccountService {
- private AccountMapper accountMapper;
-
- public void setAccountMapper(AccountMapper accountMapper) {
- this.accountMapper = accountMapper;
- }
-
- @Override
- public int pay(int sourceId, int dstId, int money) {
- //-:转出 sourceId
- accountMapper.transferOut(sourceId,money);
- //-转账中错先异常(模拟停电现象)
- //int res = 10/0;
- //-:转入 dstId
- accountMapper.transferIn(dstId,money);
- return 0;
- }
- }
7. 持久层:AccountMapper
- public interface AccountMapper {
- //-转出
- public int transferOut(@Param("id") int sourceId,@Param("money") int money);
- //-转入
- public int transferIn(@Param("id") int dstId,@Param("money") int money);
- }
8. Mapper映射文件:AccountMapper
- <?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.laoma.mapper.AccountMapper">
- <update id="transferOut">
- update t_account set money=money-${money} where id=${id}
- </update>
- <update id="transferIn">
- update t_account set money=money+${money} where id=${id}
- </update>
- </mapper>
9. 测试类:Demo
- public class Demo {
- public static void main(String[] args) {
- ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
- AccountService accountService = (AccountService) context.getBean("accountService");
- accountService.pay(1,2,100);
- }
- }
10. 补充:数据库中:account 表设计
11. 补充:如果去掉 mybatis核心配置文件:mybatis-config.xml,也是可以的,将mybatis核心配置文件中的内容,写到spring核心配置文件中的SqlSessionFactoryBean的定义中,如下:
- <!--sqlSessionFactory-->
- <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
- <!--pojo中实体类别名设置-->
- <property name="typeAliasesPackage" value="com.laoma.pojo"/>
- <!--mapper映射文件配置-->
- <property name="mapperLocations" value="mapper/*.xml"/>
- <!--数据源的配置-->
- <property name="dataSource" ref="dataSource"/>
- </bean>
到此,整个操作整理完毕!
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。