벌크 연산 — 수만 건을 한 번에 수정하면 어떤 문제가 생길까

// 일반적인 방식 — N번의 UPDATE 쿼리
List<Member> members = memberRepository.findByAge(20);
for (Member member : members) {
    member.setGrade("GOLD");  // 변경 감지(Dirty Checking)
}
// → 회원 수만큼 UPDATE 쿼리 실행

// 벌크 연산 — 1번의 UPDATE 쿼리
@Modifying
@Query("UPDATE Member m SET m.grade = 'GOLD' WHERE m.age = :age")
int bulkUpdateGrade(@Param("age") int age);
// → 단 1번의 UPDATE 쿼리로 처리

@Test
void bulkUpdateTest() {
    // 1. 회원 저장 (영속성 컨텍스트에 age=20으로 캐시됨)
    Member member = memberRepository.save(new Member("심정훈", 20));

    // 2. 벌크 연산으로 나이 +1 (DB에는 age=21로 변경됨)
    memberRepository.bulkAgePlus(20);

    // 3. 영속성 컨텍스트에서 조회 → age=20 (오래된 데이터!)
    Member found = memberRepository.findById(member.getId()).get();
    System.out.println(found.getAge()); // 20 (기대값: 21)
}

@Modifying(clearAutomatically = true, flushAutomatically = true)
@Query("UPDATE Member m SET m.age = m.age + 1 WHERE m.age >= :age")
int bulkAgePlus(@Param("age") int age);

@Transactional
public void bulkUpdate() {
    // 1. flush — 아직 DB에 반영되지 않은 변경사항 적용
    em.flush();

    // 2. 벌크 연산 실행
    int count = em.createQuery("UPDATE Member m SET m.age = m.age + 1")
        .executeUpdate();

    // 3. clear — 영속성 컨텍스트 초기화
    em.clear();

    // 4. 이후 조회는 DB에서 최신 데이터를 가져옴
    List<Member> members = em.createQuery("SELECT m FROM Member m", Member.class)
        .getResultList();
}

@Modifying(clearAutomatically = true)
@Query("DELETE FROM Member m WHERE m.lastLoginDate < :date")
int deleteInactiveMembers(@Param("date") LocalDateTime date);

@Repository
@RequiredArgsConstructor
public class MemberBulkRepository {

    private final JdbcTemplate jdbcTemplate;

    public void bulkInsert(List<Member> members) {
        String sql = "INSERT INTO member (name, age, team_id) VALUES (?, ?, ?)";
        jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement ps, int i) throws SQLException {
                ps.setString(1, members.get(i).getName());
                ps.setInt(2, members.get(i).getAge());
                ps.setLong(3, members.get(i).getTeam().getId());
            }
            @Override
            public int getBatchSize() { return members.size(); }
        });
    }
}

@Transactional
public void mixedOperation() {
    // JPA로 엔티티 저장 (영속성 컨텍스트에만 존재, 아직 DB에 없을 수 있음)
    Member member = new Member("심정훈", 25);
    memberRepository.save(member);

    // JdbcTemplate으로 직접 쿼리 실행 시 JPA의 flush가 필요
    em.flush(); // JPA 변경사항을 DB에 반영

    // 이제 JdbcTemplate으로 안전하게 조회/수정 가능
    jdbcTemplate.update("UPDATE member SET age = age + 1 WHERE name = ?", "심정훈");

    em.clear(); // 영속성 컨텍스트 초기화
}

// 이렇게 하면 InvalidDataAccessApiUsageException 발생
@Query("UPDATE Member m SET m.age = m.age + 1")
int bulkUpdate(); // @Modifying 누락!