一、使用spring 事务注解@Transactional
1.数据库表
users.sql
DROP TABLE IF EXISTS `users`;
CREATE TABLE `users` (
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键id',
`userName` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '用户名',
`passWord` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '密码',
`user_sex` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
`nick_name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 28 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
2.pom依赖
pom.xml
<dependencies>
<!-- spring boot 项目-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!-- 使用springboot mybatis -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.1</version>
</dependency>
<!-- druid连接池 -->
<!--<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.21</version>
</dependency>-->
<!-- 使用alibaba的spring boot druid数据库连接池 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.10</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
3.spring boot配置文件
application.properties
mybatis.type-aliases-package=com.ljj.entity
mybatis.mapper-locations=classpath:mapping/*.xml
#################### spring boot druid配置 ################################
spring.datasource.druid.url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
spring.datasource.druid.username=root
spring.datasource.druid.password=root
spring.datasource.druid.driver-class-name=com.mysql.cj.jdbc.Driver
# 初始化大小,最小,最大
spring.datasource.druid.initial-size=5
spring.datasource.druid.min-idle=5
spring.redis.jedis.pool.max-idle=100
spring.datasource.druid.max-active=200
# 配置获取连接等待超时的时间
spring.datasource.druid.max-wait=5000
# 每次使用连接时进行校验,会影响系统性能。默认为false
spring.datasource.druid.test-on-borrow=false
spring.datasource.druid.test-on-return=false
# 验证使用的SQL语句
spring.datasource.druid.validation-query=SELECT 1
# 指明连接是否被空闲连接回收器(如果有)进行检验.如果检测失败,则连接将被从池中去除
spring.datasource.druid.test-while-idle=true
# 每30秒运行一次空闲连接回收器(默认-1)
spring.datasource.druid.time-between-eviction-runs-millis=30000
# 池中的连接空闲30分钟后被回收(默认30分钟)
spring.datasource.druid.min-evictable-idle-time-millis=1800000
# 在每次空闲连接回收器线程(如果有)运行时检查的连接数量(设置为和maxIdle一样)
# 不再使用,一个DruidDataSource只支持一个EvictionRun
# spring.datasource.druid.num-tests-per-eviction-run=100
# 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
spring.datasource.druid.filters=stat,wall,log4j
spring.datasource.druid.filter.stat.log-slow-sql=true
################################################################################
4.实体类
User.java
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@EqualsAndHashCode
public class User {
private long id;
private String userName;
private String passWord;
private String userSex;
private String nickName;
public User(String userName, String passWord, String userSex, String nickName) {
this.userName = userName;
this.passWord = passWord;
this.userSex = userSex;
this.nickName = nickName;
}
}
5.dao层
UserDao.java
@Repository
@MapperScan(basePackages = "com.ljj.dao")
public interface UserDao {
List<User> getAll();
User getOne(Long id);
void insert(User user);
void update(User user);
void delete(Long id);
}
6.mapping映射
resources/mapping/UserMapper.xml
<?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.ljj.dao.UserDao" >
<resultMap id="BaseResultMap" type="com.ljj.entity.User" >
<id column="id" property="id" jdbcType="BIGINT" />
<result column="userName" property="userName" jdbcType="VARCHAR" />
<result column="passWord" property="passWord" jdbcType="VARCHAR" />
<result column="user_sex" property="userSex" jdbcType="VARCHAR"/>
<result column="nick_name" property="nickName" jdbcType="VARCHAR" />
</resultMap>
<sql id="Base_Column_List" >
id, userName, passWord, user_sex, nick_name
</sql>
<select id="getAll" resultMap="BaseResultMap" >
SELECT
<include refid="Base_Column_List" />
FROM users
</select>
<select id="getOne" parameterType="java.lang.Long" resultMap="BaseResultMap" >
SELECT
<include refid="Base_Column_List" />
FROM users
WHERE id = #{id}
</select>
<insert id="insert" parameterType="com.ljj.entity.User" >
INSERT INTO
users
(userName,passWord,user_sex)
VALUES
(#{userName}, #{passWord}, #{userSex})
</insert>
<update id="update" parameterType="com.ljj.entity.User" >
UPDATE
users
SET
<if test="userName != null">userName = #{userName},</if>
<if test="passWord != null">passWord = #{passWord},</if>
nick_name = #{nickName}
WHERE
id = #{id}
</update>
<delete id="delete" parameterType="java.lang.Long" >
DELETE FROM
users
WHERE
id =#{id}
</delete>
</mapper>
7.service层
UserService.java
@Service
@Transactional
//@Transactional(rollbackFor = Exception.class)
@Slf4j
public class UserService {
@Autowired
private UserDao userDao;
public void test() throws Exception {
List<User> user = userDao.getAll();
log.info("----------------> user: {}", user);
User user1 = new User("eee", "eee", "eee", "angular");
userDao.insert(user1);
List<User> user2 = userDao.getAll();
log.info("----------------> user: {}", user2);
throw new RuntimeException("抛出一个运行期异常");
}
}
@Transactional默认只是拦截RuntimeException,如果需要拦截Exception,则要加上rollbackFor参数
8.测试
@RunWith(SpringRunner.class)
@SpringBootTest
public class TransactionApplicationTests {
@Autowired
private UserService userService;
@Test
public void test() {
try {
userService.test();
} catch (Exception e) {
e.printStackTrace();
}
}
}