[Spring] アプリケーションの原子性とトランザクションの原子性は異なる（Feat. @Transactional）

@Getter
@NoArgsConstructor(access = AccessLevel.PROTECTED)
@Entity
public class Member {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "member_id")
    private Long id;
    @Column
    private String username;
    @Column(nullable = false)
    private String email;
    @Column
    private String uid;
}

public class FirebaseTokenInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
        // ヘッダー値の抽出
        String token = getAuthorizationToken(request);
        // トークン検証
        FirebaseToken decodedToken = decodeToken(token);
        // 検証済みトークンをHttpServletRequestオブジェクトに保存する
        request.setAttribute("decodedToken", decodedToken);
        return true;
    }
    
    // リクエストからAuthorizationヘッダーの値（idToken）を抽出します。
    private static String getAuthorizationToken(HttpServletRequest request) {
        String header = request.getHeader("Authorization");
        if (header == null || !header.startsWith("Bearer ")) {
            throw new IllegalArgumentException("No Token or Invalid Token.");
        }
        return header.split(" ")[1];
    }
    // Firebaseサーバーにトークンを送って検証します。
    private static FirebaseToken decodeToken(String token) {
        FirebaseToken decodedToken;
        try{
            // idTokenを検証する
            decodedToken = FirebaseAuth.getInstance().verifyIdToken(token);
        } catch (FirebaseAuthException e) {
            throw new IllegalArgumentException("Invalid Token.");
        }
        return decodedToken; // 検証済みトークンの結果を返す
    }
}

@RequiredArgsConstructor
public class LoginMemberArgResolver implements HandlerMethodArgumentResolver {
    private final MemberRepository memberRepository;
    // @Loginアノテーションがあれば値を注入する
    @Override
    public boolean supportsParameter(MethodParameter parameter) {
        boolean hasLoginAnnotation = parameter.hasParameterAnnotation(Login.class);
        boolean hasMemberType = Member.class.isAssignableFrom(parameter.getParameterType());
        return hasLoginAnnotation && hasMemberType;
    }
    @Override
    public Object resolveArgument(MethodParameter parameter, ModelAndViewContainer mavContainer, NativeWebRequest webRequest, WebDataBinderFactory binderFactory) throws Exception {
      HttpServletRequest request = (HttpServletRequest) webRequest.getNativeRequest();
      
      // requestオブジェクトからdecodedTokenを取得
      FirebaseToken decodedToken = (FirebaseToken) request.getAttribute("decodedToken");
      
      // AuthServiceを呼び出す
      return authService.joinAndLogin(decodedToken); 
    }
}

@RequiredArgsConstructor
@Service
public class AuthService {
    private final MemberRepository memberRepository;
    public Member joinAndLogin(FirebaseToken decodedToken) throws InterruptedException {
        String uid = decodedToken.getUid();
        // uidでメンバーを照会し、DBに登録されていないuidであれば、
        // 新しいメンバーを作成して自動会員登録されます。
        return memberRepository.findByUid(uid)
                .orElseGet(() -> memberRepository.save(Member.builder()
                        .username(decodedToken.getName())
                        .email(decodedToken.getEmail())
                        .uid(uid)
                        .build()));
    }
}

// Controller
// パラメーターに@Loginアノテーションがあるので
// HandlerMethodArgumentResolverを使用してMemberを初期化する。
@PostMapping("/post/new")
public Post createPost(@RequestBody Post post, @Login Member member) {
 ...
}

@RequiredArgsConstructor
@Service
public class AuthService {
    private final MemberRepository memberRepository;
    public Member joinAndLogin(FirebaseToken decodedToken) throws InterruptedException {
        String uid = decodedToken.getUid();
        // memberRepositoryでuidでメンバーを照会し、DBに登録されていないuidであれば、
        // 新しいメンバーを作成して自動会員登録されます。
        return memberRepository.findByUid(uid)
                .orElseGet(() -> memberRepository.save(Member.builder()
                        .username(decodedToken.getName())
                        .email(decodedToken.getEmail())
                        .uid(uid).build()));
    }
}

@RequiredArgsConstructor
@Service
public class AuthService {
    private final MemberRepository memberRepository;
     
    // @Transactionalを追加！
    @Transactional
    public Member joinAndLogin(FirebaseToken decodedToken) throws InterruptedException {
        String uid = decodedToken.getUid();
        // uidでメンバーを照会し、DBに登録されていないuidであれば、
        // 新しいメンバーを作成して自動会員登録されます。
        return memberRepository.findByUid(uid)
                .orElseGet(() -> memberRepository.save(Member.builder()
                        .username(decodedToken.getName())
                        .email(decodedToken.getEmail())
                        .uid(uid).build()));
    }
}

@RequiredArgsConstructor
@Service
public class AuthService {
    private final MemberRepository memberRepository;
    
    // synchronizedを適用
    @Transactional
    public synchronized Member joinAndLogin(FirebaseToken decodedToken) throws InterruptedException {
        String uid = decodedToken.getUid();
        // uidでメンバーを照会し、DBに登録されていないuidであれば、
        // 新しいメンバーを作成して自動会員登録されます。
        Optional<Member> memberOptional = memberRepository.findByUid(uid);
        if (memberOptional.isPresent()) {
            log.info("既存の会員です。");
            return memberOptional.get();
        }
        log.info("新しい会員です。");
        Member member = Member.builder()
                .username(decodedToken.getName())
                .email(decodedToken.getEmail())
                .uid(uid).build();
        memberRepository.save(member);
        return member;
    }
}

SELECT * FROM MEMBER WHERE uid="ASDW12SD3" FOR UPDATE; -- 書き込みロック
SELECT * FROM MEMBER WHERE uid="ASDW12SD3" FOR SHARE;  -- 読み込みロック

@RequiredArgsConstructor
@Service
public class AuthService {
    private final MemberRepository memberRepository;
    // synchronizedを適用
    public synchronized Member joinAndLogin(FirebaseToken decodedToken) throws InterruptedException {
        String uid = decodedToken.getUid();
        // uidでメンバーを照会し、DBに登録されていないuidであれば、
        // 新しいメンバーを作成して自動会員登録されます。
        Optional<Member> memberOptional = memberRepository.findByUid(uid);
        if (memberOptional.isPresent()) {
            log.info("既存の会員です。");
            return memberOptional.get();
        }
        log.info("新しい会員です。");
        Member member = Member.builder()
                .username(decodedToken.getName())
                .email(decodedToken.getEmail())
                .uid(uid).build();
        memberRepository.save(member);
        return member;
    }
}

// build.gradleに追加
implementation "org.springframework.retry:spring-retry"

// FirebaseApplication.java
@EnableRetry // ここを追加
@SpringBootApplication
public class FirebaseApplication {}

// AuthService.java
@RequiredArgsConstructor
@Service
public class AuthService {
    private final MemberRepository memberRepository;
    // ここも追加！
    @Retryable(
            retryFor = {DataIntegrityViolationException.class},
            backoff = @Backoff(delay = 1000)
    )    
    @Transactional
    public Member joinAndLogin(FirebaseToken decodedToken) throws InterruptedException {
        String uid = decodedToken.getUid();
        // uidでメンバーを照会し、DBに登録されていないuidであれば、
        // 新しいメンバーを作成して自動会員登録されます。
        Optional<Member> memberOptional = memberRepository.findByUid(uid);
        if (memberOptional.isPresent()) {
            log.info("既存の会員です。");
            return memberOptional.get();
        }
        log.info("新しい会員です。");
        Member member = Member.builder()
                .username(decodedToken.getName())
                .email(decodedToken.getEmail())
                .uid(uid).build();
        memberRepository.save(member);
        return member;
    }
}