标签：set sele username ons method nsa 大小 异常 otn
摘要: 本文结合《Spring源码深度解析》来分析Spring 5.0.6版本的源代码。若有描述错误之处，欢迎指正。
一、创建数据表结构
二、创建对应数据表的PO
三、创建表与实体间的映射
四、创建数据操作接口
五、创建数据操作接口实现类
六 、创建Spring配置文件
七、测试
Spring声明式事务让我们从复杂的事务处理中得到解脱，使我们再也不需要去处理获得连接、关闭连接、事务提交和回滚等操作，再也不需要在与事务相关的方法中处理大置的 try...catch...finally代码。Spring中事务的使用虽然已经相对简单得多，但是，还是有很多的使用及配置规则，有兴趣的读者可以自己查阅相关资料进行深入研究，这里只列举出最常用的使用方法。
同样，我们还是以最简单的示例来进行直观地介绍。
CREATE TABLE `user` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `username` varchar(20) DEFAULT NULL COMMENT ‘用户名‘, `password` varchar(50) DEFAULT NULL COMMENT ‘密码‘, `sex` tinyint(1) DEFAULT NULL COMMENT ‘用户性别, 1: 男; 2: 女‘, `age` int(2) DEFAULT NULL COMMENT ‘用户年龄‘, `status` int(1) DEFAULT NULL COMMENT ‘用户状态, 1: 有效; 0: 无效‘, `create_tm` timestamp NULL DEFAULT NULL COMMENT ‘创建时间‘, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=33 DEFAULT CHARSET=utf8;
public class User { private Long id; private String username; private String password; private Integer sex; private Integer age; private Integer status; private Date createTm; // 省略set/get方法 }
public interface UserMapper { int insert(User record); User selectByPrimaryKey(Long id); }
public interface UserService { boolean register(UserDTO userDTO); }
@Service("userService")
public class UserServiceImpl implements UserService {
@Autowired
private UserMapper userMapper;
@Override
@Transactional(propagation = Propagation.REQUIRED)
public boolean register(UserDTO userDTO) {
if (!ObjectUtils.allNotNull(userDTO)) {
return false;
}
User user = new User();
try {
BeanUtils.copyProperties(userDTO, user);
user.setStatus(1);
user.setCreateTm(new Date());
}catch (BeansException e) {
return false;
}
boolean ret = userMapper.insert(user) == 1;
// 事务测试，加上这句代码则数据不会保存到数据库中
throw new RuntimeException("insert error");
return ret;
}
}
<?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:tx="http://www.springframework.org/schema/tx" 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"> <!-- 配置数据源 --> <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close" lazy-init="true"> <property name="driverClassName" value="${jdbc.driverClassName}"/> <property name="url" value="${jdbc.url}"/> <property name="username" value="${jdbc.username}"/> <property name="password" value="${jdbc.password}"/> <!-- 配置连接池初始化大小、最小、最大 --> <property name="initialSize" value="${jdbc.initialSize}"/> <property name="minIdle" value="${jdbc.minIdle}"/> <property name="maxActive" value="${jdbc.maxActive}"/> <!-- 配置获取连接等待超时的时间，单位是毫秒 --> <property name="maxWait" value="${jdbc.maxWait}"/> <!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 --> <property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}"/> <!-- 配置一个连接在池中最小生存的时间，单位是毫秒 --> <property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}"/> <property name="validationQuery" value="select 1"/> <property name="testWhileIdle" value="${jdbc.testWhileIdle}"/> <property name="testOnBorrow" value="${jdbc.testOnBorrow}"/> <property name="testOnReturn" value="${jdbc.testOnReturn}"/> <!-- 打开PSCache，并且指定每个连接上PSCache的大小 --> <property name="poolPreparedStatements" value="${jdbc.poolPreparedStatements}"/> <property name="maxPoolPreparedStatementPerConnectionSize" value="${jdbc.maxPoolPreparedStatementPerConnectionSize}"/> <!-- 统计sql filter --> <property name="proxyFilters"> <list> <bean class="com.alibaba.druid.filter.stat.StatFilter"> <property name="mergeSql" value="true"/> <property name="slowSqlMillis" value="${jdbc.slowSqlMillis}"/> <property name="logSlowSql" value="true"/> </bean> </list> </property> </bean> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <tx:annotation-driven/> </beans>
public static void main(String[] args) { ApplicationContext context = new ClassPathXmlApplicationContext("spring/application.xml"); UserService userService = (UserService) context.getBean("userService"); UserDTO userDTO = new UserDTO(); userDTO.setUsername("张三"); userDTO.setAge(20); userDTO.setSex(1); // 保存一条记录 userService.register(userDTO); }
上面的测试示例中，UserServicelmpl类对接口UserService中的register函数的实现最后加入了一句抛出异常的代码：throw new RuntimeException("insert error")。当注掉这段代码执行测试类，那 么会看到数据被成功的保存到了数据库中，但是如果加入这段代码时再次运行测试类，发现此处的操作并不会将数据保存到数据库中。
注意：默认情况下Spring中的事务处理只对RuntimeException方法进行回滚，所以，如果此处将RuntimeException替换成普通的Exception不会产生回滚效果。
标签：set sele username ons method nsa 大小 异常 otn
原文地址：https://www.cnblogs.com/warehouse/p/9452352.html
