一、使用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();
}
}
}
9.github
GitHub
![Java String.format方法的簡單使用[圖]](data:image/gif;base64,R0lGODlhAQABAIAAAP///wAAACwAAAAAAQABAAACAkQBADs=)