想直接看結(jié)論的可以拉到文末總結(jié)。

背景

我們公司的系統(tǒng)中有一個(gè)業(yè)務(wù)場(chǎng)景，需要第三方的賬戶(hù)數(shù)據(jù)同步到我們系統(tǒng)。
同步賬號(hào)的同時(shí)，會(huì)將所有同步數(shù)據(jù)和是否成功記錄到一張同步日志表中，方便排查問(wèn)題和記錄。
好了，話(huà)不多說(shuō)，我們直接上代碼。

歡迎關(guān)注個(gè)人公眾號(hào)【好好學(xué)技術(shù)】交流學(xué)習(xí)

目前的代碼

下面是一段偽代碼

java復(fù)制代碼@Data @Build public class Test() { ?private boolean success = true; } ? @Transaction public void sync() { ?Test test = Test.builder().build(); ?try{ ??xxxxx ?}catch(Exception e) { ?? log.error("xxxx",e) ?? test.setSuccess(false); ?? throw new ThirdAccountException("同步賬號(hào)錯(cuò)誤：" + e.getMessage()); ?} finally { ?? testMapper.insert(test); ?} ?}

大家能看出來(lái)這段代碼有什么問(wèn)題嗎？??

talk is cheap, show me the code

直接實(shí)戰(zhàn)演示

數(shù)據(jù)庫(kù)新建 賬戶(hù)數(shù)據(jù)同步記錄表

sql復(fù)制代碼CREATE TABLE `account_log` ( ??`id` bigint NOT NULL, ??`data` varchar(255) ?DEFAULT NULL COMMENT '第三方數(shù)據(jù)', ??`success` tinyint(1) DEFAULT NULL COMMENT '是否成功0否1是', ??`error_msg` varchar(255) DEFAULT NULL COMMENT '錯(cuò)誤信息', ??PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

第三方賬戶(hù)數(shù)據(jù)實(shí)體

java復(fù)制代碼package com.fandf.demo.transaction; ? ? import cn.hutool.json.JSONUtil; ? import io.swagger.annotations.ApiModel; ? import lombok.AllArgsConstructor; ? import lombok.Data; ? ? /** ? * @author fandongfeng ? * @date 2023/6/17 14:45 ? */ ? @Data ? @AllArgsConstructor(staticName = "of") ? @ApiModel("第三方數(shù)據(jù)實(shí)體") ? public class ThirdAccount { ? ? ?? ?private String id; ? ?? ?private String data; ? ? ?? ?public AccountLog toAccountLog() { ? ?? ? ? ?return AccountLog.builder().data(JSONUtil.toJsonStr(this)).build(); ? ?? ?} ? ? }

本地賬戶(hù)同步記錄實(shí)體

java復(fù)制代碼package com.fandf.demo.transaction; ? ? import com.baomidou.mybatisplus.annotation.IdType; ? import com.baomidou.mybatisplus.annotation.TableId; ? import com.baomidou.mybatisplus.annotation.TableName; ? import com.baomidou.mybatisplus.extension.activerecord.Model; ? import io.swagger.annotations.ApiModelProperty; ? import lombok.Builder; ? import lombok.Data; ? import lombok.EqualsAndHashCode; ? ? /** ? * @author fandongfeng ? * @date 2023/6/17 14:43 ? */ ? @EqualsAndHashCode(callSuper = true) ? @TableName("account_log") ? @Data ? @Builder ? public class AccountLog extends Model<AccountLog> { ? ? ?? ?private static final long serialVersionUID = 5648238459610595434L; ? ? ? ?@TableId(type = IdType.ASSIGN_ID) ? ?? ?private Long id; ? ? ? ?@ApiModelProperty("第三方原始數(shù)據(jù)") ? ?? ?private String data; ? ? ? ?@ApiModelProperty("是否成功: 0否1是") ? ?? ?private boolean success = true; ? ? ? ?@ApiModelProperty("錯(cuò)誤數(shù)據(jù)") ? ?? ?private String errorMsg; ? ? }

本地賬戶(hù)同步記錄實(shí)體mapper

java復(fù)制代碼package com.fandf.demo.transaction; ? ? import com.baomidou.mybatisplus.core.mapper.BaseMapper; ? import org.springframework.stereotype.Repository; ? ? /** ? * @author fandongfeng ? * @date 2023/6/17 14:50 ? */ ? @Repository ? public interface AccountLogMapper extends BaseMapper<AccountLog> { ? }

同步賬戶(hù)處理的邏輯

java復(fù)制代碼package com.fandf.demo.transaction; ? ? import org.springframework.stereotype.Service; ? ? import javax.annotation.Resource; ? ? /** ? * @author fandongfeng ? * @date 2023/6/17 14:42 ? */ ? @Service ? public class TestTransaction { ? ? ?? ?@Resource ? ?? ?AccountLogMapper accountLogMapper; ? ? ?? ?@Transactional(rollbackFor = Exception.class) ?? ?public void syncAccount(ThirdAccount account) { ? ?? ? ? ?AccountLog accountLog = account.toAccountLog(); ? ?? ? ? ?try { ? ?? ? ? ? ? ?//模擬id為2 則拋出異常 ? ?? ? ? ? ? ?if ("2".equals(account.getId())) { ? ?? ? ? ? ? ? ? ?throw new Exception("模擬拋出異常"); ? ?? ? ? ? ? ?} ? ?? ? ? ?} catch (Exception e) { ? ?? ? ? ? ? ?accountLog.setSuccess(false); ? ?? ? ? ? ? ?accountLog.setErrorMsg(e.getMessage()); ? ?? ? ? ? ? ?throw new IllegalArgumentException("同步第三方賬號(hào)錯(cuò)誤：" + e.getMessage()); ?? ? ? ?} finally { ? ?? ? ? ? ? ?accountLogMapper.insert(accountLog); ? ?? ? ? ?} ? ?? ?} ? ? ? }

單元測(cè)試

插入成功案例

java復(fù)制代碼package com.fandf.demo.transaction; ? ? import org.junit.jupiter.api.Test; ? import org.springframework.boot.test.context.SpringBootTest; ? ? import javax.annotation.Resource; ? ? import static org.junit.jupiter.api.Assertions.*; ? ? @SpringBootTest ? class TestTransactionTest { ? ?? ?@Resource ? ?? ?TestTransaction testTransaction; ? ? ?? ?@Test ? ?? ?void syncAccount() { ? ?? ? ? ?testTransaction.syncAccount(ThirdAccount.of("1", "成功數(shù)據(jù)")); ? ?? ?} ? }

查看數(shù)據(jù)庫(kù)

是插入了，但是成功的success應(yīng)該為1啊，為什么插入了0。

AccountLog.java

java復(fù)制代碼 ? ?@ApiModelProperty("是否成功: 0否1是") ? ?? ?private boolean success = true; ?

第三方轉(zhuǎn)為AccountLog實(shí)體的方法

java復(fù)制代碼 ? ?public AccountLog toAccountLog() { ? ?? ? ? ?return AccountLog.builder().data(JSONUtil.toJsonStr(this)).build(); ? ?? ?} ?

我們來(lái)看看編譯后的AccountLog.class源碼中的AccountLogBuilder部分 success并未賦初始值

java復(fù)制代碼public static class AccountLogBuilder { ? ?? ?private Long id; ? ?? ?private String data; ? ?? ?private boolean success; ? ?? ?private String errorMsg; ? ? ? ?AccountLogBuilder() { ? ?? ?} ? ? ? ?public AccountLogBuilder id(Long id) { ? ?? ? ? ?this.id = id; ? ?? ? ? ?return this; ? ?? ?} ? ? ? ?public AccountLogBuilder data(String data) { ? ?? ? ? ?this.data = data; ? ?? ? ? ?return this; ? ?? ?} ? ? ? ?public AccountLogBuilder success(boolean success) { ? ?? ? ? ?this.success = success; ? ?? ? ? ?return this; ? ?? ?} ? ? ? ?public AccountLogBuilder errorMsg(String errorMsg) { ? ?? ? ? ?this.errorMsg = errorMsg; ? ?? ? ? ?return this; ? ?? ?} ? ? ? ?public AccountLog build() { ? ?? ? ? ?return new AccountLog(this.id, this.data, this.success, this.errorMsg); ? ?? ?} ? ? ? ?public String toString() { ? ?? ? ? ?return "AccountLog.AccountLogBuilder(id=" + this.id + ", data=" + this.data + ", success=" + this.success + ", errorMsg=" + this.errorMsg + ")"; ? ?? ?} ? }

我們看到Builder()方法返回了
AccountLogBuilder() {
}
對(duì)象。
指定data

java復(fù)制代碼public AccountLogBuilder data(String data) { ? ?? ?this.data = data; ? ?? ?return this; ? }

執(zhí)行build()方法

java復(fù)制代碼public AccountLog build() { ? ?? ?return new AccountLog(this.id, this.data, this.success, this.errorMsg); ? }

success并未賦初始值，所以success=false, 存到數(shù)據(jù)庫(kù)就是0了。

那么怎么解決呢？

• 1.字段加上注解@Builder.Default

java復(fù)制代碼@Builder.Default ? private boolean success = true;

我們?cè)賮?lái)測(cè)試下

java復(fù)制代碼@Test ? void syncAccount() { ? ?? ?testTransaction.syncAccount(ThirdAccount.of("1", "加上@Builder.Default成功數(shù)據(jù)")); ? }

查看數(shù)據(jù)庫(kù)

插入成功。

• 2.手動(dòng)賦值

java復(fù)制代碼 ? ?public AccountLog toAccountLog() { ? ?? ? ? ?return AccountLog.builder().success(true).data(JSONUtil.toJsonStr(this)).build(); ? ?? ?} ?

插入失敗案例

java復(fù)制代碼@Test ? void syncAccount() { ? ?? ?testTransaction.syncAccount(ThirdAccount.of("2", "測(cè)試失敗數(shù)據(jù)")); ? }

查看數(shù)據(jù)庫(kù)

錯(cuò)誤數(shù)據(jù)并沒(méi)有插入進(jìn)來(lái)。

這是因?yàn)閏atch里面拋出了異常，finally里面提交的事務(wù)也回滾了，我們?nèi)サ魋yncAccount(ThirdAccount account)方法上面的@Transactional注解。
再執(zhí)行一次單元測(cè)試

java復(fù)制代碼@Test ? void syncAccount() { ? ?? ?testTransaction.syncAccount(ThirdAccount.of("2", "去掉@Transactional注解測(cè)試失敗數(shù)據(jù)")); ? }

查看數(shù)據(jù)庫(kù)

總結(jié)

• 1.Build并不是對(duì)屬性賦予默認(rèn)值，如果想指定默認(rèn)值可以在字段上使用@Builder.Default注解。

• 2.如果方法上加了@Transaction注解，catch里面拋出了異常,finally里面的事務(wù)會(huì)回滾。

當(dāng)然我們?cè)谑褂聾Transaction注解的時(shí)候也需要注意事務(wù)的粒度，不能圖省事直接在入口加一個(gè)Transaction注解。