郑州网站建设小程序,和龙市建设局网站,电子商务网站有哪些?,中国最大的广告公司排名列表目录 Spring JDBC 和 事务控制主要内容Spring 整合 JDBC 环境构建项目添加依赖坐标添加 jdbc 配置文件编写 spring 配置文件配置数据源C3P0 数据源配置DBCP 数据源配置 模板类配置Spring JDBC 测试 #xff08;入门#xff09;创建指定数据库创建数据表使用 JUnit 测试JUnit … 目录 Spring JDBC 和 事务控制主要内容Spring 整合 JDBC 环境构建项目添加依赖坐标添加 jdbc 配置文件编写 spring 配置文件配置数据源C3P0 数据源配置DBCP 数据源配置 模板类配置Spring JDBC 测试 入门创建指定数据库创建数据表使用 JUnit 测试JUnit 测试优化JUnit单元测试-传统单元测试方式优化JUnit单元测试-Spring Test 模块添加依赖代码中加入注解 优化JUnit单元测试-Spring Test 模块-通用封装 持久层dao层- 账户模块 - 操作定义实体类dao层中账户接口及方法定义定义接口类定义接口实现类 账户记录添加实现添加账户记录添加记录返回主键批量添加账户记录 账户记录查询实现查询用户的账户总记录数查询指定账户记录详情多条件查询用户账户记录 账户记录更新实现更新账户记录批量更新账户记录 账户记录删除实现删除账户记录批量删除账户记录 Spring 事务控制转账场景模拟实现接口方法定义实现对应接口转账方法业务层实现需加入事务控制 Spring 事务核心接口JDBC 事务Hibernate 事务Java 持久化 API 事务JPAJava 原生 API 事务 Spring 事务控制配置XML 配置导入命名空间依赖添加命名空间 声明式事务属性介绍name属性readonly属性(true|false)timeoutrollback-for属性propagation属性isolation属性 注解配置配置事务管理器加入配置注解扫描方法上加入事务注解 Spring JDBC 和 事务控制主要内容 Spring 整合 JDBC 环境
Spring 框架除了提供 IOC 与 AOP 核心功能外同样提供了基于JDBC 的数据访问功能使得访问持久层数据更加方便。想要使用 Spring JDBC 环境需要将JDBC整合到Spring中。
构建项目添加依赖坐标
构建项目普通的java项目即可
!-- 添加相关的依赖坐标 --
!-- spring 依赖--
dependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion6.0.5/version
/dependency
!-- spring jdbc --
dependencygroupIdorg.springframework/groupIdartifactIdspring-jdbc/artifactIdversion6.0.5/version
/dependency
!-- 用mysql数据库就需要 mysql 驱动包 --
dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.19/version
/dependency
!-- c3p0 连接池
初识为什么要用连接池
对于一个简单的数据库引用如果对数据库的访问不是很频繁这种情况可以简单的在需要访问数据库时创建一个链接用完关闭它这样做不会有太明显的性能上的开销。但是对于复杂的数据库引用情况就截然不同了频繁的建立、关闭连接会极大的减低系统的性能这是对于连接的使用造成系统性能的瓶颈。连接池的作用
连接池的作用是为了提高性能避免重复多次的打开数据库连接而造成性能的下降和系统资源的浪费连接池是将已经创建好的连接保存在池中当有请求来时直接使用已经创建好的连接对数据库进行访问。这样省略了创建和销毁的过程。这样以提高系统的性能。
--
dependencygroupIdcom.mchange/groupIdartifactIdc3p0/artifactIdversion0.9.5.5/version
/dependency添加 jdbc 配置文件
在src/main/resources目录下新建db.properties配置文件并设置对应的配置信息
放在配置文件的目的后续修改的时候直接到配置文件中修改即可。
# 驱动名
jdbc.drivercom.mysql.cj.jdbc.Driver
# 数据库连接
jdbc.urljdbc:mysql://127.0.0.1:3306/(数据库名称)?useSSLfalseuseUnicodetruecharacterEncodingUTF-8serverTimezoneAsia/ShanghaiallowPublicKeyRetrievaltrue
# 数据库用户名称
jdbc.user(数据库账号)
# 数据库用户密码
jdbc.password(数据库密码)以下为可选配置
# 指定连接池的初始化连接数。取值应在minPoolSize 与 maxPoolSize 之间.Default:3个可以自己设置为20个
initialPoolSize20
# 指定连接池中保留的最大连接数. Default:15个可以自己设置为100个
maxPoolSize100
# 指定连接池中保留的最小连接数
minPoolSize10
# 最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。 Default:0秒可以自己设置为60秒
maxIdleTime60
# 当连接池中的连接耗尽的时候c3p0一次同时获取的连接数. Default:3个可以自己设置为5个
acquireIncrement5
# JDBC的标准,用以控制数据源内加载的PreparedStatements数量。
maxStatements5
# 每60秒检查所有连接池中的空闲连接因为它本身是有回收机制的Default:0可以自己设置为60
idleConnectionTestPeriod60编写 spring 配置文件
编写spring配置文件applicationcontext.xml
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxsi:schemaLocationhttp://www.springframework.org/schema/beanshttps://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsd!--加载db.properties属性文件用来读取db.properties中的数据--context:property-placeholder locationdb.properties/context:property-placeholder/beans配置数据源
由于建立数据库连接是一个非常耗时耗资源的行为所以通过连接池预先同数据库建立一些连接放在内存中应用程序需要建立数据库连接时直接到连接池中申请一个就行用完后再放回去。
C3P0 与 DBCP 二选一即可
DBCP(DataBase connection pool)数据库连接池。是 apache 上的一个 java 连接池项目也是 tomcat 使用的连接池组件。单独使用dbcp需要2个包commons-dbcp.jarcommons-pool.jar dbcp没有自动回收空闲连接的功能。
C3P0是一个开源的JDBC连接池它实现了数据源支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有HibernateSpring等c3p0有自动回收空闲连接功能。
我们一般使用的是C3P0。
C3P0 数据源配置
在applicationContext.xml文件中加入如下配置
!-- 配置 c3p0 数据源 --
bean iddataSource classcom.mchange.v2.c3p0.ComboPooledDataSource!-- property标签的value属性对应的是jdbc.properties中的值 --property namedriverClass value${jdbc.driver}/propertyproperty namejdbcUrl value${jdbc.url}/propertyproperty nameuser value${jdbc.user}/propertyproperty namepassword value${jdbc.password}/property
/beanC3P0 其他额外配置对应的值在jdbc.properties文件中指定
!-- 指定连接池中保留的最大连接数。 Default:15--
property namemaxPoolSize value${maxPoolSize}/
!-- 指定连接池中保留的最小连接数。--
property nameminPoolSize value${minPoolSize}/
!-- 指定连接池的初始化连接数。取值应在minPoolSize 与 maxPoolSize 之间.Default:3--
property nameinitialPoolSize value${initialPoolSize}/
!-- 最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。 Default:0--
property namemaxIdleTime value${maxIdleTime}/
!-- 当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。 Default:3--
property nameacquireIncrement value${acquireIncrement}/
!-- JDBC的标准,用以控制数据源内加载的PreparedStatements数量。
但由于预缓存的statements属于单个connection而不是整个连接池所以设置这个参数需要考虑到多方面的因数。如果maxStatements与maxStatementsPerConnection均为0则缓存被关闭。Default:0--
property namemaxStatements value${maxStatements}/
!-- 每60秒检查所有连接池中的空闲连接。Default:0 --
property nameidleConnectionTestPeriod value${idleConnectionTestPeriod}/DBCP 数据源配置
在applicationContext.xml文件中加入如下配置
!-- 配置dbcp数据源--
bean idmyDataSource classorg.apache.commons.dbcp2.BasicDataSourceproperty namedriverClassName value${jdbc.driver} /property nameurl value${jdbc.url}/property nameusername value${jdbc.user}/property namepassword value${jdbc.password}/!-- 连接池启动时的初始值 -- property nameinitialSize value1/ !-- 最大空闲值.当经过一个高峰时间后连接池可以将已经用不到的连接慢慢释放一部分一直减少到maxIdle为止 -- property namemaxIdle value2/ !-- 最小空闲值.当空闲的连接数少于阀值时连接池就会预申请一些连接以避免洪峰来时再申请而造成的性能开销 -- property nameminIdle value1/
/bean模板类配置
创建JDBC的模板我们会通过模板进行JDBC相关的操作。
Spring把 JDBC 中重复的操作建立成了一个模板类org.springframework.jdbc.core.JdbcTemplate 。
!-- 配置JdbcTemplate模板实例并注入一个dataSource数据源--
bean idjdbcTemplate classorg.springframework.jdbc.core.JdbcTemplateproperty namedataSource refdataSource/property
/beanSpring JDBC 测试 入门
创建指定数据库
选择连接右键选择新建数据库设置数据库的名称和编码格式 创建数据表
创建账户表tb_account: 创建表以后表中加入数据
使用 JUnit 测试
进行 junit 测试解析applicationContext.xml获取 jdbcTemplate bean
如果使用junit需要将junit依赖加入到pom.xml中
dependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion4.13.2/versionscopetest/scope!--只能在test目录下进行单元测试在main-java目录下就无法使用--
/dependency
JUnit 测试
在test/java目录下新建com.msb.test包构建测试类和方法
package com.msb.test;import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;/*** Author: zhaoss*/
public class SpringJdbcTest01 {Testpublic void testQueryCount() {// 获取spring上下文环境ApplicationContext ctx new ClassPathXmlApplicationContext(applicationContext.xml);// 得到模板类 JdbcTemplate对象JdbcTemplate jdbcTemplate (JdbcTemplate) ctx.getBean(jdbcTemplate);// 通过模板进行CRUD操作// 定义sql语句:案例查询总计有多少个账户String sql select count(1) from tb_account;// 执行查询操作无参数Integer total jdbcTemplate.queryForObject(sql, Integer.class);System.out.println(总记录数: total);}Testpublic void testQueryCountByUserId() {// 获取spring上下文环境ApplicationContext ctx new ClassPathXmlApplicationContext(applicationContext.xml);// 得到模板类 JdbcTemplate对象JdbcTemplate jdbcTemplate (JdbcTemplate) ctx.getBean(jdbcTemplate);// 通过模板进行CRUD操作// 定义sql语句:案例查询指定用户有多少个账户String sql select count(1) from tb_account where user_id ?;// 执行查询操作有参数第一个参数Integer total jdbcTemplate.queryForObject(sql, Integer.class, 1);System.out.println(总记录数: total);}
}
JdbcTemplate模板如何使用呢可以通过官网查看 优化JUnit单元测试-传统单元测试方式
在上面入门测试案例中可以看到testQueryCount()方法和testQueryCountByUserId()方法有很多重复的东西那么重复的东西能否做到简单的封装呢基于单元测试的特性可以使用 Before注解在执行单元测试方法之前可以执行的代码
package com.msb.test;import org.junit.Before;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;/*** Author: zhaoss*/
public class SpringJdbcTest01 {private JdbcTemplate jdbcTemplate;Beforepublic void init() {// 获取spring上下文环境ApplicationContext ctx new ClassPathXmlApplicationContext(applicationContext.xml);// 得到模板类 JdbcTemplate对象jdbcTemplate (JdbcTemplate) ctx.getBean(jdbcTemplate);}Testpublic void testQueryCount() {// 通过模板进行CRUD操作// 定义sql语句:案例查询总计有多少个账户String sql select count(1) from tb_account;// 执行查询操作无参数Integer total jdbcTemplate.queryForObject(sql, Integer.class);System.out.println(总记录数: total);}Testpublic void testQueryCountByUserId() {// 通过模板进行CRUD操作// 定义sql语句:案例查询指定用户有多少个账户String sql select count(1) from tb_account where user_id ?;// 执行查询操作有参数第一个参数Integer total jdbcTemplate.queryForObject(sql, Integer.class, 1);System.out.println(总记录数: total);}
}
优化JUnit单元测试-Spring Test 模块
Spring可以让单元测试用起来更加简单Spring提供了Spring Test 模块该模块整合了一些常见的单元测试工具例如Junit。
整合后可以在测试类中直接使用Spring容器中的内容相当于把测试类也放入到Spring容器中测试类里面可以直接使用注解注入一些bean对象。
同时也可以通过ContextConfigration注解指定配置文件路径让测试方法在启动的时候直接加载配置文件。
添加依赖
spring-context核心依赖无论使用哪个模块都必须导入的。这个我们已经添加过了
需要导入junit依赖的现在使用的就是Spring Test模块整合的junit。这个我们已经添加过了
spring-test 表示spring test模块的依赖导入后才能有ContextConfiguration这些注解 这个需要现在添加
dependencygroupIdorg.springframework/groupIdartifactIdspring-test/artifactIdversion6.0.5/versionscopetest/scope
/dependency
代码中加入注解
package com.msb.test;import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;/*** Author: zhaoss*/
// 使用Spring整合Junit4的类启动当前测试类 这个注解必须要用4.12以上版本的junit
// RunWith、ContextConfiguration这些注解不用扫描RunWith就会自动去构建测试类对象
RunWith(SpringJUnit4ClassRunner.class)
// 启动时加载的配置文件里面要包含classpath
ContextConfiguration(locations classpath:applicationContext.xml)
public class SpringJdbcTest02 {// 将容器中的jdbcTemplate注入进来Autowiredprivate JdbcTemplate jdbcTemplate;Testpublic void testQueryCount() {// 通过模板进行CRUD操作// 定义sql语句:案例查询总计有多少个账户String sql select count(1) from tb_account;// 执行查询操作无参数Integer total jdbcTemplate.queryForObject(sql, Integer.class);System.out.println(总记录数: total);}Testpublic void testQueryCountByUserId() {// 通过模板进行CRUD操作// 定义sql语句:案例查询指定用户有多少个账户String sql select count(1) from tb_account where user_id ?;// 执行查询操作有参数第一个参数Integer total jdbcTemplate.queryForObject(sql, Integer.class, 1);System.out.println(总记录数: total);}
}
PS上面的注解生效并没有在applicationContext.xml中配置扫描因为Spring整合Junit4的类会帮我们处理无需我们考虑扫描问题。
优化JUnit单元测试-Spring Test 模块-通用封装
如果有n多个测试类每次都要写RunWith和ContextConfiguration注释如果配置文件修改那么每个文件中的classpath都要修改很麻烦所以我们可以再次提取 定义一个父类设置通用的配置信息 /*** Author: zhaoss*/
// 使用Spring整合Junit4的类启动当前测试类 这个注解必须要用4.12以上版本的junit
// RunWith、ContextConfiguration这些注解不用扫描RunWith就会自动去构建测试类对象
RunWith(SpringJUnit4ClassRunner.class)
// 启动时加载的配置文件里面要包含classpath
ContextConfiguration(locations classpath:applicationContext.xml)
public class BaseTest {}继承通用的测试类 public class SpringJdbcTest03 extends BaseTest {// 将容器中的jdbcTemplate注入进来Autowiredprivate JdbcTemplate jdbcTemplate;Testpublic void testQueryCount() {// 通过模板进行CRUD操作// 定义sql语句:案例查询总计有多少个账户String sql select count(1) from tb_account;// 执行查询操作无参数Integer total jdbcTemplate.queryForObject(sql, Integer.class);System.out.println(总记录数: total);}Testpublic void testQueryCountByUserId() {// 通过模板进行CRUD操作// 定义sql语句:案例查询指定用户有多少个账户String sql select count(1) from tb_account where user_id ?;// 执行查询操作有参数第一个参数Integer total jdbcTemplate.queryForObject(sql, Integer.class, 1);System.out.println(总记录数: total);}
}持久层dao层- 账户模块 - 操作
当完成 Spring Jdbc 环境集成后这里使用spring jdbc 完成账户单表tb_account的crud 操作。但是实际开发中还是使用框架来操作比如Mybatis。
定义实体类
创建com.msb.pojo包定义Account.java
package com.msb.entity;import java.util.Date;/*** 用户账户类*/
public class Account {private Integer accountId; // 账户ID主键private String accountName; // 账户名称private String accountType; // 账户类型private Double money; // 账户金额private String remark; // 账户备注private Integer userId; // 用户ID账户所属用户private Date createTime; // 创建时间private Date updateTime; // 修改时间public Account() {}// 构造器中不需要加账户ID利用主键自增即可、创建时间、修改时间这个时间通过sql操作即可public Account(String accountName, String accountType, Double money,String remark, Integer userId) {this.accountName accountName;this.accountType accountType;this.money money;this.remark remark;this.userId userId;}Overridepublic String toString() {return Account{ accountId accountId , accountName accountName \ , accountType accountType \ , money money , remark remark \ , userId userId , createTime createTime , updateTime updateTime };}public Integer getAccountId() {return accountId;}public void setAccountId(Integer accountId) {this.accountId accountId;}public String getAccountName() {return accountName;}public void setAccountName(String accountName) {this.accountName accountName;}public String getAccountType() {return accountType;}public void setAccountType(String accountType) {this.accountType accountType;}public Double getMoney() {return money;}public void setMoney(Double money) {this.money money;}public String getRemark() {return remark;}public void setRemark(String remark) {this.remark remark;}public Integer getUserId() {return userId;}public void setUserId(Integer userId) {this.userId userId;}public Date getCreateTime() {return createTime;}public void setCreateTime(Date createTime) {this.createTime createTime;}public Date getUpdateTime() {return updateTime;}public void setUpdateTime(Date updateTime) {this.updateTime updateTime;}
}dao层中账户接口及方法定义
定义接口类
AccountDao.java
package com.msb.dao;
import com.msb.pojo.Account;
import java.util.List;/*** Author: zhaoss* 用户模块 接口定义* 1. 添加账户* 添加账户记录返回受影响的行数* 添加账户记录返回记录的主键* 批量添加账户记录返回受影响的行数* 2. 查询账户* 查询指定用户的账户总记录数返回该记录数* 通过账户主键id查询指定账户的记录详情返回账户信息* 多条件查询指定用户的账户列表返回账户集合* 3. 更新账户* 更新账户记录返回受影响的行数* 批量更新账户记录返回受影响的行数* 4. 删除账户* 删除账户记录返回受影响的行数* 批量删除账户记录返回受影响的行数*/
public interface AccountDao {// 添加操作添加账户记录返回受影响的行数int addAccount(Account account);// 添加操作添加账户记录返回记录的主键int addAccountReturnKey(Account account);// 添加操作批量添加账户记录返回受影响的行数int addAccountBatch(ListAccount accounts);// 查询操作查询指定用户的账户总记录数返回账户总记录数int queryAccountCount(Integer userId);// 查询操作通过账户的主键id查询对应的账户的信息Account queryAccountById(Integer accountId);/**查询操作多条件查询指定用户的账户列表返回账户集合param userId 指定的账户的idparam accountName 账户名称 利用模糊查询param createTime 创建时间 查询大于当前时间*/ListAccount queryAccountByParams(Integer userId,String accountName,String createTime);// 更新操作更新账户记录返回受影响的行数int updateAccountById(Account account);// 更新操作批量更新账户记录返回受影响的行数int updateAccountBatch(ListAccount accounts);// 删除操作根据主键id删除对应的账户返回受影响的行数int deleteAccountById(Integer accountId);// 删除操作批量删除-根据主键id删除对应的账户返回受影响的行数int deleteAccountBatch(Integer[] accountIds);}
定义接口实现类
package com.msb.dao.impl;import com.msb.dao.AccountDao;
import com.msb.pojo.Account;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;import java.util.List;/*** Author: zhaoss* AccountDaoImpl对象的构建我们交给ioc容器去管理,加入Repository注解*/
Repository
public class AccountDaoImpl implements AccountDao {// 注入JdbcTemplate模板对象AutowiredJdbcTemplate jt;Overridepublic int addAccount(Account account) {return 0;}Overridepublic int addAccountReturnKey(Account account) {return 0;}Overridepublic int addAccountBatch(ListAccount accounts) {return 0;}Overridepublic int queryAccountCount(Integer userId) {return 0;}Overridepublic Account queryAccountById(Integer accountId) {return null;}Overridepublic ListAccount queryAccountByParams(Integer userId, String accountName, String createTime) {return null;}Overridepublic int updateAccountById(Account account) {return 0;}Overridepublic int updateAccountBatch(ListAccount accounts) {return 0;}Overridepublic int deleteAccountById(Integer accountId) {return 0;}Overridepublic int deleteAccountBatch(Integer[] accountIds) {return 0;}
}
如果想要Repository注解和 Autowired注解起作用必须要在applicationContext.xml中进行扫描加入配置
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxsi:schemaLocationhttp://www.springframework.org/schema/beanshttps://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdcontext:property-placeholder locationdb.properties/context:property-placeholderbean iddataSource classcom.mchange.v2.c3p0.ComboPooledDataSourceproperty namedriverClass value${jdbc.driver}/propertyproperty namejdbcUrl value${jdbc.url}/propertyproperty nameuser value${jdbc.user}/propertyproperty namepassword value${jdbc.password}/property/beanbean idjdbcTemplate classorg.springframework.jdbc.core.JdbcTemplateproperty namedataSource refdataSource/property/bean!--扫描注解--context:component-scan base-packagecom.msb.dao/context:component-scan
/beans账户记录添加实现
在企业项目开发时对于记录的添加可能涉及到多种添加方式比如添加单条记录批量添加多条记录等情况。这里对于账户记录添加方式分为三种方式添加单条记录返回受影响行数、添加单条记录返回主键、批量添加多条记录。
添加账户记录
AccountDaoImpl.java中重写方法
/*** 添加单条记录返回受影响的行数* param account* return*/
Override
public int addAccount(Account account) {String sql insert into tb_account(account_name,account_type,money,remark, user_id,create_time,update_time) values (?,?,?,?,?,now(),now());Object[] objs {account.getAccountName(),account.getAccountType(),account.getMoney(),account.getRemark(),account.getUserId()};return jdbcTemplate.update(sql,objs);
} 测试方法
package com.msb.test;import com.msb.dao.AccountDao;
import com.msb.pojo.Account;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;/*** Author: zhaoss*/
public class TestSpringJDBCAddTest extends BaseTest{// 注入持久层对象dao层对象AutowiredAccountDao accountDao;Testpublic void testAddAccount(){// 准备你要添加的数据Account account new Account(账号3,工商银行,400.0,奖金,1);// 调用AccountDaoImpl对象的addAccount方法传入上面要添加的数据accountint row accountDao.addAccount(account);System.out.println(添加账户受影响的行数为 row);}
}
参照 添加记录返回主键
Overridepublic int addAccountReturnKey(Account account) {// 添加操作添加账户记录返回记录的主键// 定义sql:String sql insert into tb_account (account_name,account_type,money,remark,create_time,update_time,user_id) values (?,?,?,?,now(),now(),?);// 利用模板调用方法返回主键// 定义KeyHolder对象获取记录的主键值KeyHolder keyHolder new GeneratedKeyHolder();// 利用模板调用方法:/*jt.update(new PreparedStatementCreator() {Overridepublic PreparedStatement createPreparedStatement(Connection con) throws SQLException {// 预编译sql语句并设置返回主键PreparedStatement ps con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);// 设置参数ps.setString(1,account.getAccountName());ps.setString(2,account.getAccountType());ps.setDouble(3,account.getMoney());ps.setString(4,account.getRemark());ps.setInt(5,account.getUserId());return ps;}}, keyHolder);*/// 利用lambda表达式的写法jt.update(con - {// 预编译sql语句并设置返回主键PreparedStatement ps con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);// 设置参数ps.setString(1,account.getAccountName());ps.setString(2,account.getAccountType());ps.setDouble(3,account.getMoney());ps.setString(4,account.getRemark());ps.setInt(5,account.getUserId());return ps;}, keyHolder);// 通过keyHolder对象来获取主键int key keyHolder.getKey().intValue();return key;}测试方法
/*** 添加账户记录返回主键*/Testpublic void testAddAccount2(){// 准备你要添加的数据Account account new Account(账号4,招商银行,1400.0,兼职费用,2);// 调用AccountDaoImpl对象的addAccount方法传入上面要添加的数据accountint key accountDao.addAccountReturnKey(account);System.out.println(对应的主键为 key);}参照 批量添加账户记录
/*** 添加多条记录返回受影响的行数* param accounts* return*/
Override
public int addAccountBatch(ListAccount accounts) {// 添加操作批量添加账户记录返回受影响的行数// 定义sql:String sql insert into tb_account (account_name,account_type,money,remark,create_time,update_time,user_id) values (?,?,?,?,now(),now(),?);// 通过模板进行批量增加操作int[] nums jt.batchUpdate(sql, new BatchPreparedStatementSetter() {Overridepublic void setValues(PreparedStatement ps, int i) throws SQLException {// 必须获取每一条记录给每一条记录赋值Account account accounts.get(i);// 给参数设置值ps.setString(1,account.getAccountName());ps.setString(2,account.getAccountType());ps.setDouble(3,account.getMoney());ps.setString(4,account.getRemark());ps.setInt(5,account.getUserId());}Overridepublic int getBatchSize() {// 可以得到一共操作多少条记录return accounts.size();}});// 获取影响几行记录return nums.length;
}测试方法
/*** 批量添加数据返回受影响的行数*/
Test
public void testAddAccountBatch() {// 准备你要添加的数据Account account1 new Account(账号8,招商银行,13450.0,兼职费用,3);Account account2 new Account(账号9,工商银行,1670.0,奖金,3);Account account3 new Account(账号10,建设银行,7400.0,工资,3);// 上面的三个账户添加到集合中以便以后传入批量添加的方法中ListAccount accouts new ArrayList();accouts.add(account1);accouts.add(account2);accouts.add(account3);// 调用AccountDaoImpl对象的addAccountBatch方法传入上面要添加的数据accoutsint row accountDao.addAccountBatch(accouts);System.out.println(添加账户受影响的行数为 row);
}参考 账户记录查询实现
账户记录查询这里提供了三种查询方式查询指定用户所有账户记录数查询单条账户记录详情多条件查询指定用户账户记录。
查询用户的账户总记录数
/*** 查询指定用户的账户总记录数返回记录数* param userId* return*/
Override
public int queryAccountCount(Integer userId) {String sql select count(1) from tb_account where user_id ?;int count jdbcTemplate.queryForObject(sql,Integer.class,userId);return count;
}测试方法
/*** 查询用户的账户总记录数返回总记录数*/
Test
public void testQueryAccountCount(){// 查询ID为1的用户的账户总记录数int total accountDao.queryAccountCount(1);System.out.println(总记录数 total);
}参考 查询指定账户记录详情
/*** 查询某个账户记录详情返回账户对象* param accountId* return*/
Overridepublic Account queryAccountById(Integer accountId) {// 查询操作通过账户的主键id查询对应的账户的信息// 定义sqlString sql select * from tb_account where account_id ?;// 利用模板调用方法操作/*Account account jt.queryForObject(sql, new RowMapperAccount() {Overridepublic Account mapRow(ResultSet rs, int rowNum) throws SQLException {// 创建一个Account对象接收数据库中查询的数据Account a new Account();a.setAccountId(accountId);a.setAccountName(rs.getString(account_name));a.setAccountType(rs.getString(account_type));a.setMoney(rs.getDouble(money));a.setRemark(rs.getString(remark));a.setCreateTime(rs.getDate(create_time));a.setUpdateTime(rs.getDate(update_time));a.setUserId(rs.getInt(user_id));return a;}}, accountId);*/// 利用lambda表达式简化Account account jt.queryForObject(sql, (ResultSet rs, int rowNum) - {// 创建一个Account对象接收数据库中查询的数据Account a new Account();a.setAccountId(accountId);a.setAccountName(rs.getString(account_name));a.setAccountType(rs.getString(account_type));a.setMoney(rs.getDouble(money));a.setRemark(rs.getString(remark));a.setCreateTime(rs.getDate(create_time));a.setUpdateTime(rs.getDate(update_time));a.setUserId(rs.getInt(user_id));return a;}, accountId);return account;}测试方法
/*** 查询指定账户的记录详情返回账户对象*/
Testpublic void testquery02(){// 调用accountDao中的queryAccountById查询操作通过账户的主键id查询对应的账户的信息Account account accountDao.queryAccountById(10);System.out.println(该用户的账户信息为 account.toString());}参考 多条件查询用户账户记录
/**查询操作多条件查询指定用户的账户列表返回账户集合param userId 指定的账户的用户idparam accountName 账户名称 利用模糊查询param createTime 创建时间 查询大于当前时间*/Overridepublic ListAccount queryAccountByParams(Integer userId, String accountName, String createTime) {// 定义sql :String sql select * from tb_account where user_id ?;// 定义参数列表案例我们不用那么多参数只用userId先测试,参数列表可以先不定义。// 如果案例中有多个参数那么就需要定义数组然后传入可变参数位置---直接定义数组方案不可取因为数组长度不能改变// 将数组改为集合// Object[] params {userId};List params new ArrayList();params.add(userId);// 根据参数是否为空将sql进行拼接if(accountName ! null !.equals(accountName)){// 模糊查询 注意and前面一定要加空格否则报错sql and account_name like concat(%,?,%);params.add(accountName);}if(createTime ! null !.equals(createTime)){sql and create_time ?;params.add(createTime);}// 将集合转为数组Object[] objects params.toArray();// 使用模板ListAccount accountList jt.query(sql, (ResultSet rs, int rowNum) - {// 创建一个Account对象接收数据库中查询的数据// 查询出来的每个数据利用一个Account对象做接收然后query方法内部会将对象放入List集合中返回Account a new Account();a.setAccountId(rs.getInt(account_id));a.setAccountName(rs.getString(account_name));a.setAccountType(rs.getString(account_type));a.setMoney(rs.getDouble(money));a.setRemark(rs.getString(remark));a.setCreateTime(rs.getDate(create_time));a.setUpdateTime(rs.getDate(update_time));a.setUserId(rs.getInt(user_id));return a;}, objects);return accountList;}测试方法
Testpublic void testquery03(){// 调用accountDao中的queryAccountByParamsListAccount accountList accountDao.queryAccountByParams(1,null,null);/*System.out.println(accountList.toString());System.out.println(accountList.size());*/ListAccount accountList2 accountDao.queryAccountByParams(1,1,null);/*System.out.println(accountList2.toString());System.out.println(accountList2.size());*/ListAccount accountList3 accountDao.queryAccountByParams(1,null,2023-3-20);System.out.println(accountList3.toString());System.out.println(accountList3.size());}参考如果有参数就传入参数。 账户记录更新实现
更新账户记录
/*** 更新指定账户记录返回受影响的行数* param account* return*/
Override
public int updateAccountById(Account account) {String sql update tb_account set account_name ?, account_type ?, money ? ,remark ?,user_id ? ,update_time now() where account_id ? ;Object[] objs {account.getAccountName(),account.getAccountType(),account.getMoney(), account.getRemark(),account.getUserId(),account.getAccountId()};return jdbcTemplate.update(sql,objs);
}测试方法
/*** 更新指定账户记录返回受影响的行数*/
Test
public void testUpdateAccount(){// 准备要修改的数据Account account new Account(张三1,建设银行1,500.0,零花钱加倍,1);account.setAccountId(1);int row accountDao.updateAccountById(account);System.out.println(修改账户返回受影响的行数 row);
}参考 批量更新账户记录
/*** 批量新账户记录返回受影响的行数* param accounts* return*/
Override
public int updateAccountBatch(ListAccount accounts) {// 更新操作批量更新账户记录返回受影响的行数// 定义sql:String sql update tb_account set account_name ?,account_type ?,money ?,remark ?, update_time now(),user_id ? where account_id ?;// 通过模板进行批量更新操作int[] nums jt.batchUpdate(sql, new BatchPreparedStatementSetter() {Overridepublic void setValues(PreparedStatement ps, int i) throws SQLException {// 必须获取每一条记录给每一条记录赋值Account account accounts.get(i);// 给参数设置值ps.setString(1,account.getAccountName());ps.setString(2,account.getAccountType());ps.setDouble(3,account.getMoney());ps.setString(4,account.getRemark());ps.setInt(5,account.getUserId());ps.setInt(6,account.getAccountId());}Overridepublic int getBatchSize() {// 可以得到一共操作多少条记录return accounts.size();}});// 获取影响几行记录return nums.length;
}测试方法
/*** 批量更新账户记录返回受影响的行数*/
Test
public void testupdate02(){// 调用accountDao中的updateAccountBatch// 封装Account对象Account ac1 new Account(账户66,农业银行,220.0,奖金,1);ac1.setAccountId(9);Account ac2 new Account(账户77,农业银行,240.0,奖金,1);ac2.setAccountId(10);Account ac3 new Account(账户88,农业银行,290.0,奖金,1);ac3.setAccountId(11);// 上面的数据要放入List集合中List list new ArrayList();list.add(ac1);list.add(ac2);list.add(ac3);int row accountDao.updateAccountBatch(list);System.out.println(更新操作影响行数为 row);}参考 账户记录删除实现
删除账户记录
/*** 删除账户记录返回受影响的行数* param accountId* return*/
Override
public Integer deleteAccoutById(Integer accountId) {String sql delete from tb_account where account_id ? ;Object[] objs {accountId};return jdbcTemplate.update(sql,objs);
}测试方法
/*** 删除账户记录返回受影响的行数*/
Test
public void testDeleteAccount(){// 删除ID为1的账户记录int row accountDao.deleteAccoutById(1);System.out.println(删除账户记录返回受影响的行数 row);
}批量删除账户记录 /*** 批量删除账户记录返回受影响的行数* param ids* return*/
Override
public int deleteAccountBatch(Integer[] ids) {String sql delete from tb_account where account_id ?;int row jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {Overridepublic void setValues(PreparedStatement ps, int i) throws SQLException {ps.setInt(1,ids[i]);}Overridepublic int getBatchSize() {return ids.length;}}).length;return row;
}测试方法
/*** 批量删除账户记录返回受影响的行数*/
Test
public void testDeleteAccountBatch(){// 删除多个id的账户记录Integer[] ids new Integer[]{2,3};int rows accountDao.deleteAccountBatch(ids);System.out.println(批量删除账户记录返回受影响的行数 rows);
}Spring 事务控制
通过转账操作案例来引入事务管理。
转账场景模拟实现
项目搭建与SpringJDBC中一致这里不重复赘述。
接口方法定义
dao层定义接口 对于转账涉及到双方账户以及对应转账金额所以有入账和出账两个方法。
package com.msb.dao;/*** Author: zhaoss*/
public interface AccountDao {/*** 收入* param tarAid 收入金额的账户ID* param money 收入金额* return*/public abstract int inAccount(Integer accountId,Double money);/*** 支出* param outAid 支出金额的账户ID* param money 支出金额* return*/public abstract int outAccount(Integer accountId,Double money);
}
实现对应接口
package com.msb.dao.impl;import com.msb.dao.AccountDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;/*** Author: zhaoss*/
Repository
public class AccountDaoImpl implements AccountDao {// 注入JdbcTemplate模板对象AutowiredJdbcTemplate jt;Overridepublic int inAccount(Integer accountId, Double money) {// 定义sql:String sql update tb_account set money money ? where account_id ?;// 参数Object[] params {money,accountId};// 使用模板int i jt.update(sql, params);return i;}Overridepublic int outAccount(Integer accountId, Double money) {// 定义sql:String sql update tb_account set money money - ? where account_id ?;// 参数Object[] params {money,accountId};// 使用模板int i jt.update(sql, params);return i;}
}
转账方法业务层实现
service层中实现
package com.msb.service;import com.msb.dao.AccountDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** Author: zhaoss*/
Service
public class AccountService {Autowiredprivate AccountDao ad;// 定义业务方法转账操作返回值为int类型在方法内部可以定义一个状态码成功返回1失败返回0public int updateAccount(Integer outid,Integer inid,Double money){// 定义状态码成功1失败0,初始化状态下 code是0int code 0;// 账户Aid为6给账户Bid为10转100 // 账户A支出100int outRow ad.outAccount(outid, money);// 账户B收入100int inRow ad.inAccount(inid, money);// 如果收入和支出两个操作都执行成功的话表示转账成功if (outRow 1 inRow 1){code 1;// 转账成功}// 状态码作为方法的返回值return code;}
}
需加入事务控制
我们在上述的代码中人为制造错误使账户A支出成功但是账户B收入失败
package com.msb.service;import com.msb.dao.AccountDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** Author: zhaoss*/
Service
public class AccountService {Autowiredprivate AccountDao ad;// 定义业务方法转账操作返回值为int类型在方法内部可以定义一个状态码成功返回1失败返回0public int updateAccount(Integer outid,Integer inid,Double money){// 定义状态码成功1失败0,初始化状态下 code是0int code 0;// 账户Aid为6给账户Bid为10转100 // 账户A支出100int outRow ad.outAccount(outid, money);// 加入异常代码int a 1 / 0;// 账户B收入100int inRow ad.inAccount(inid, money);// 如果收入和支出两个操作都执行成功的话表示转账成功if (outRow 1 inRow 1){code 1;// 转账成功}// 状态码作为方法的返回值return code;}
}
再次执行测试类发现程序报错账户A损失100但是账户B并没有加100元操作。
出现上述现象的原因
默认MySQL的事务是自动提交的也就是说当执行一条DML语句MySQL会立即隐式提交事务也就是说在执行账户A的转账操作的时候事务提交然后出现异常转账B的操作没有执行
PS事务是一组操作的集合它是一个不可分割的工作单位事务会把所有的操作作为一个整体一起向系统提交或撤销操作请求即这些操作要么同时成功要么同时失效。
解决
将转账操作放入同一事务中进行处理。
**方式1**编程式事务。事务代码由程序员自己书写
截取以前代码 仔细思考代码会发现在程序运行中无法保证 service 层业务代码不发生异常如果通过 jdbc 的方式处理事务此时需要手动方式控制事务这样的话凡是涉及到事务控制的业务方法均需要开发人员手动来进行事务处理无法满足生产的需要。
在业务层加、在dao层加都不合适即便加进去了凡是涉及到事务控制的方法都需要处理太麻烦了所以需要方式2
**方式2**声明式事务。事务代码由框架负责程序员进行声明和简单配置即可。
Spring就提供了事务的处理方式将所需内容全部封装程序员只需要简单的配置即可。封装在哪里呢如下 怎么去理解呢 Spring 事务核心接口
Spring 并不直接管理事务而是提供了多种事务管理器他们将事务管理的职责委托给 Hibernate 或者 JTA 等持久化机制所提供的相关平台框架的事务来实现。
Spring 事务管理器的接口是org.springframework.transaction.PlatformTransactionManager通过这个接口Spring 为各个平台如 JDBC、Hibernate 等都提供了对应的事务管理器但是具体的实现就是各个平台自己的事情了。此接口的内容如下
public interface PlatformTransactionManager(){ // 由 TransactionDefinition 得到 TransactionStatus 对象 TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException; // 提交 void commit(TransactionStatus status) throws TransactionException; // 回滚 void rollback(TransactionStatus status) throws TransactionException;
} 从这里可知具体的具体的事务管理机制对 Spring 来说是透明的它并不关心那些那些是对应各个平台需要关心的所以 Spring 事务管理的一个优点就是为不同的事务 API 提供一致的编程模型如 JTA、JDBC、Hibernate、JPA。下面分别介绍各个平台框架实现事务管理的机制。
JDBC 事务
如果应用程序中直接使用 JDBC 来进行持久化此时使用 DataSourceTransactionManager 来处理事务边界。为了使用DataSourceTransactionManager需要使用如下的 XML 将其装配到应用程序的上下文定义中
bean idtransactionManager
classorg.springframework.jdbc.datasource.DataSourceTransactionManagerproperty namedataSource refdataSource /
/bean 实际上DataSourceTransactionManager 是通过调用 java.sql.Connection 来管理事务而后者是通过 DataSource 获取到的。通过调用连接的 commit() 方法来提交事务同样事务失败则通过调用 rollback() 方法进行回滚。
Hibernate 事务
如果应用程序的持久化是通过 Hibernate 实现的那么你需要使用 HibernateTransactionManager。对于 Hibernate3需要在 Spring 上下文定义中添加如下的声明
bean idtransactionManager
classorg.springframework.orm.hibernate3.HibernateTransactionManagerproperty namesessionFactory refsessionFactory /
/bean sessionFactory 属性需要装配一个 Hibernate 的 session 工厂HibernateTransactionManager 的实现细节是它将事务管理的职责委托给 org.hibernate.Transaction 对象而后者是从 Hibernate Session 中获取到的。当事务成功完成时HibernateTransactionManager 将会调用 Transaction 对象的 commit() 方法反之将会调用 rollback() 方法。
Java 持久化 API 事务JPA
Hibernate 多年来一直是 Java 持久化标准但是现在 Java 持久化 API 作为真正的 Java 持久化标准进入大家的视野。如果你计划使用 JPA 的话那你需要使用 Spring 的 JpaTransactionManager 来处理事务。你需要在 Spring 中这样配置 JpaTransactionManager
bean idtransactionManager
classorg.springframework.orm.jpa.JpaTransactionManagerproperty namesessionFactory refsessionFactory /
/bean JpaTransactionManager 只需要装配一个 JPA 实体管理工厂javax.persistence.EntityManagerFactory 接口的任意实现。 JpaTransactionManager 将与由工厂所产生的 JPA EntityManager 合作来构建事务。
Java 原生 API 事务
如果应用程序没有使用以上所述的事务管理或者是跨越了多个事务管理源比如两个或者是多个不同的数据源此时需要使用 JtaTransactionManager
bean idtransactionManager
classorg.springframework.transaction.jta.JtaTransactionManagerproperty nametransactionManagerName valuejava:/TransactionManager /
/bean JtaTransactionManager 将事务管理的责任委托给 javax.transaction.UserTransaction 和javax.transaction.TransactionManager 对象其中事务成功完成通过 UserTransaction.commit() 方法提交事务失败通过 UserTransaction.rollback() 方法回滚。
Spring 事务控制配置
通过 jdbc 持久化事务对于事务配置实现由两种方式即Xml 配置注解配置。
XML 配置
导入命名空间依赖
dependencygroupIdorg.aspectj/groupIdartifactIdaspectjweaver/artifactIdversion1.9.9.1/version!--scoperuntime/scope--
/dependency添加命名空间
在spring.xml配置文件的添加事务tx和aop的命名空间
事务
xmlns:txhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsdAOP
xmlns:aophttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd配置如下
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:aophttp://www.springframework.org/schema/aopxmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://www.springframework.org/schema/beanshttps://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/aophttps://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttps://www.springframework.org/schema/tx/spring-tx.xsdcontext:property-placeholder locationdb.properties/context:property-placeholderbean iddataSource classcom.mchange.v2.c3p0.ComboPooledDataSourceproperty namedriverClass value${jdbc.driver}/propertyproperty namejdbcUrl value${jdbc.url}/propertyproperty nameuser value${jdbc.user}/propertyproperty namepassword value${jdbc.password}/property/beanbean idjdbcTemplate classorg.springframework.jdbc.core.JdbcTemplateproperty namedataSource refdataSource/property/beancontext:component-scan base-packagecom.msb.dao,com.msb.service/context:component-scan!--配置声明式事务--!--配置事务管理器封装事务固定套路代码的类--bean idtransactionManager classorg.springframework.jdbc.datasource.DataSourceTransactionManager!--注入数据源原因因为调用封装的方法需要用Connection需要靠数据源获取--property namedataSource refdataSource/property/bean!--配置事务通知 transaction-manager属性表示这个事务通知是哪个事务管理器管理的--tx:advice idt transaction-managertransactionManager!--具体给哪个方法加入通知呢把方法写在这updateAccount是一个事务单元注意该方法出现异常就会触发异常通知实现事务回滚所以在该方法内部决不能加入try-catch对异常处理--tx:attributestx:method nameupdateAccount//tx:attributes/tx:advice!--配置事务切面--aop:config!--设置哪个方法需要被声明式事务管理通过切点定义需要声明式事务管理的方法但是这里表达式的范围写大一些不能定位到具体方法需要配合上面事务通知一起才会生效--aop:pointcut idpt expressionexecution(* com.msb.service.*.*(..))/!--advice-ref指向上面的通知id--aop:advisor advice-reft pointcut-refpt/aop:advisor/aop:config
/beans备注默认 spring 事务只在发生未被捕获的 runtimeexcetpion 时才回滚。
spring aop 异常捕获原理
被拦截的方法需显式抛出异常并不能经任何处理这样aop 代理才能捕获到方法的异常才能进行回滚默认情况下 aop 只捕获 runtimeexception 的异常但可以通过配置来捕获特定的异常并回滚换句话说在 service 的方法中不使用 try catch 或者在 catch 中最后加上 throw new RunTimeexcetpion()这样程序异常时才能被 aop 捕获进而回滚.
声明式事务属性介绍
tx:method标签有下面属性的配置
name属性
配置哪些方法需要有事务控制支持*通配符
tx:advice idt transaction-managertransactionManagertx:attributes!-- 表示所有以update开头的方法需要进行事务管理 --tx:method nameupdate*/!-- 表示所有方法需要进行事务管理--!-- tx:method name*/--/tx:attributes
/tx:advicereadonly属性(true|false)
是否是只读事务.如果为true,告诉数据库此事务为只读事务.底层支持查询的代码逻辑不走提交事务和回滚事务的代码,会对性能有一定提升,所以只要是查询的方法,建议设置readonly“true”.如果为false(默认值),事务需要提交的事务.建议新增,删除,修改不设置readonly属性或设置readonly“false”.
tx:advice idt transaction-managertransactionManagertx:attributes!-- 所有select开头的方法执行查询逻辑 --tx:method nameselect* read-onlytrue/tx:method/tx:attributes
/tx:advicetimeout
超过时间事务提交失败
tx:advice idt transaction-managertransactionManagertx:attributestx:method nameselect* timeout5/tx:method/tx:attributes
/tx:advicerollback-for属性
异常类型全限定路径,表示出现什么类型的异常进行数据回滚。
tx:advice idt transaction-managertransactionManagertx:attributes!-- 定义只要方法出现了ArithmeticException类型异常及子类型异常都需要进行回滚 --tx:method nameselect* rollback-forjava.lang.ArithmeticException/tx:method/tx:attributes
/tx:advice 与之对应的属性no-rollback-for 出现什么类型的异常不回滚与rollback-for属性配置一个即可
propagation属性
事务传播行为, 包括 REQUIRED,SUPPORTS,MANDATORY,NEVER REQUIRES_NEW,NOT_SUPPORTED,NESTED
我们一般使用 **REQUIRED:**默认值。如果有事务就用如果没有事务则新增事务。
tx:advice idt transaction-managertransactionManagertx:attributestx:method nameselect* propagationREQUIRED/tx:method/tx:attributes
/tx:adviceisolation属性
该属性控制事务的隔离级别默认值DEFAULT表示用数据库的隔离级别MySQL8默认的事务隔离级别REPEATABLE_READ
注解配置
之前在利用xml配置声明式事务的时候其实就是完成了一件事给方法加入事务那么这么简单的操作用了那么复杂的xml没必要所以可以通过注解来简化配置。
配置事务管理器
在applicationContext.xml中注释掉配置事务通知、配置事务切面的配置
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:aophttp://www.springframework.org/schema/aopxmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://www.springframework.org/schema/beanshttps://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/aophttps://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttps://www.springframework.org/schema/tx/spring-tx.xsdcontext:property-placeholder locationdb.properties/context:property-placeholderbean iddataSource classcom.mchange.v2.c3p0.ComboPooledDataSourceproperty namedriverClass value${jdbc.driver}/propertyproperty namejdbcUrl value${jdbc.url}/propertyproperty nameuser value${jdbc.user}/propertyproperty namepassword value${jdbc.password}/property/beanbean idjdbcTemplate classorg.springframework.jdbc.core.JdbcTemplateproperty namedataSource refdataSource/property/beancontext:component-scan base-packagecom.msb.dao,com.msb.service/context:component-scan!--配置声明式事务--!--配置事务管理器--bean idtransactionManager classorg.springframework.jdbc.datasource.DataSourceTransactionManagerproperty namedataSource refdataSource/property/bean!--配置事务通知--!--tx:advice idt transaction-managertransactionManagertx:attributestx:method nameupdate* timeout5 no-rollback-forjava.lang.ArithmeticException propagationREQUIRED isolationDEFAULT//tx:attributes/tx:advice--!--配置事务切面--!--aop:configaop:pointcut idpt expressionexecution(* com.msb.service.*.*(..))/aop:advisor advice-reft pointcut-refpt/aop:advisor/aop:config--
/beans加入配置注解扫描
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:aophttp://www.springframework.org/schema/aopxmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://www.springframework.org/schema/beanshttps://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/aophttps://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttps://www.springframework.org/schema/tx/spring-tx.xsdcontext:property-placeholder locationdb.properties/context:property-placeholderbean iddataSource classcom.mchange.v2.c3p0.ComboPooledDataSourceproperty namedriverClass value${jdbc.driver}/propertyproperty namejdbcUrl value${jdbc.url}/propertyproperty nameuser value${jdbc.user}/propertyproperty namepassword value${jdbc.password}/property/beanbean idjdbcTemplate classorg.springframework.jdbc.core.JdbcTemplateproperty namedataSource refdataSource/property/beancontext:component-scan base-packagecom.msb.dao,com.msb.service/context:component-scan!--配置声明式事务--!--配置事务管理器--bean idtransactionManager classorg.springframework.jdbc.datasource.DataSourceTransactionManagerproperty namedataSource refdataSource/property/bean!--配置事务通知--!--tx:advice idt transaction-managertransactionManagertx:attributestx:method nameupdate* timeout5 no-rollback-forjava.lang.ArithmeticException propagationREQUIRED isolationDEFAULT//tx:attributes/tx:advice--!--配置事务切面--!--aop:configaop:pointcut idpt expressionexecution(* com.msb.service.*.*(..))/aop:advisor advice-reft pointcut-refpt/aop:advisor/aop:config--!--加入配置注解扫描--tx:annotation-driven /
/beans
方法上加入事务注解
Service 方法上在需要添加事务的方法上加入事务注解如需配置属性在参数位置设置即可 Transactional(propagationPropagation.REQUIRED)public int updateAccount(Integer outid,Integer inid,Double money){// 定义状态码成功1失败0,初始化状态下 code是0int code 0;// 账户Aid为6给账户Bid为10转100 // 账户A支出100int outRow ad.outAccount(outid, money);// 制造异常//int a 1 / 0;// 账户B收入100int inRow ad.inAccount(inid, money);// 如果收入和支出两个操作都执行成功的话表示转账成功if (outRow 1 inRow 1){code 1;// 转账成功}// 状态码作为方法的返回值return code;}PS如果很多方法都需要事务处理那么可以直接将这个注解放在类上代表这个类的所有方法都被事务管控。
y
bean idjdbcTemplate classorg.springframework.jdbc.core.JdbcTemplateproperty namedataSource refdataSource/property
/beancontext:component-scan base-packagecom.msb.dao,com.msb.service/context:component-scan!--配置声明式事务--
!--配置事务管理器--
bean idtransactionManager classorg.springframework.jdbc.datasource.DataSourceTransactionManagerproperty namedataSource refdataSource/property
/bean
!--配置事务通知--
!--tx:advice idt transaction-managertransactionManagertx:attributestx:method nameupdate* timeout5 no-rollback-forjava.lang.ArithmeticException propagationREQUIRED isolationDEFAULT//tx:attributes
/tx:advice--!--配置事务切面--
!--aop:configaop:pointcut idpt expressionexecution(* com.msb.service.*.*(..))/aop:advisor advice-reft pointcut-refpt/aop:advisor
/aop:config--!--加入配置注解扫描--
tx:annotation-driven /##### 方法上加入事务注解Service 方法上在需要添加事务的方法上加入事务注解如需配置属性在参数位置设置即可javaTransactional(propagationPropagation.REQUIRED)public int updateAccount(Integer outid,Integer inid,Double money){// 定义状态码成功1失败0,初始化状态下 code是0int code 0;// 账户Aid为6给账户Bid为10转100 // 账户A支出100int outRow ad.outAccount(outid, money);// 制造异常//int a 1 / 0;// 账户B收入100int inRow ad.inAccount(inid, money);// 如果收入和支出两个操作都执行成功的话表示转账成功if (outRow 1 inRow 1){code 1;// 转账成功}// 状态码作为方法的返回值return code;}PS如果很多方法都需要事务处理那么可以直接将这个注解放在类上代表这个类的所有方法都被事务管控。
