MyBatis 어노테이션 매퍼로 쿼리 연동

// 매퍼: 반환 타입 void, 마지막 파라미터로 ResultHandler
@Select("SELECT id, member_id, product_id, qty, amount, status, ordered_at FROM orders ORDER BY id")
@Options(fetchSize = 1000)                                        // 드라이버가 1000행씩 가져오게 (JDBC 레슨 변형 2 의 fetchSize)
void streamAll(ResultHandler<Order> handler);

// 호출
try (SqlSession s = factory.openSession();
     BufferedWriter bw = Files.newBufferedWriter(Path.of("data/orders.csv"))) {
    long[] n = {0};
    s.getMapper(OrderMapper.class).streamAll(ctx -> {               // ResultContext<Order>
        Order o = ctx.getResultObject();
        try { bw.write(o.id() + "," + o.memberId() + "," + o.amount().toPlainString()); bw.newLine(); }
        catch (IOException e) { throw new UncheckedIOException(e); }
        if (++n[0] % 100_000 == 0) System.out.println(n[0] + "행...");
    });
    System.out.println("내보내기 " + n[0] + "행");
}
// 출력(예): 100000행... 200000행... 내보내기 253행   (예제 데이터는 253건)

// ❌ 예제 5: @One → 주문 N건이면 SQL N+1 번
// ✅ JOIN 으로 한 번에 가져와 중첩 프로퍼티 "member.name" 에 직접 매핑
@Select("""
    SELECT o.id, o.qty, o.amount,
           m.id AS m_id, m.name AS m_name, m.grade AS m_grade, m.active_yn AS m_active_yn
    FROM orders o JOIN member m ON m.id = o.member_id
    ORDER BY o.id
    """)
@Results({
    @Result(property = "id", column = "id", id = true),
    @Result(property = "qty", column = "qty"),
    @Result(property = "amount", column = "amount"),
    @Result(property = "member.id", column = "m_id"),              // 점 표기로 중첩 객체 프로퍼티. member 가 null 이면 MyBatis 가 생성
    @Result(property = "member.name", column = "m_name"),
    @Result(property = "member.grade", column = "m_grade"),
    @Result(property = "member.active", column = "m_active_yn")
})
List<Order.WithMember> findAllWithMemberJoin();
// 로그: Preparing: SELECT o.id, ... JOIN member ...   ← 딱 1번

<!-- MemberMapper.xml : namespace = 인터페이스 FQN, id = 메서드명 -->
<mapper namespace="MemberMapper">
  <resultMap id="memberMap" type="Member">                          <!-- @Results(id="memberMap") -->
    <id property="id" column="id"/>
    <result property="active" column="active_yn"/>
  </resultMap>

  <select id="findById" resultMap="memberMap">                      <!-- @Select + @ResultMap -->
    SELECT * FROM member WHERE id = #{id}
  </select>

  <insert id="insert" useGeneratedKeys="true" keyProperty="id">     <!-- @Insert + @Options -->
    INSERT INTO member(name, email, grade, joined_at, balance, active_yn)
    VALUES (#{name}, #{email}, #{grade}, #{joinedAt}, #{balance}, #{active})
  </insert>

  <select id="searchScript" resultMap="memberMap">                  <!-- <script> 내용 그대로. 이스케이프 불필요 -->
    SELECT * FROM member
    <where>
      <if test="name != null">AND name LIKE '%' || #{name} || '%'</if>
      <if test="from != null">AND joined_at >= #{from}</if>
    </where>
    ORDER BY id
  </select>
</mapper>

conf.addMapper(MemberMapper.class);                                  // 인터페이스 등록 시 같은 경로의 MemberMapper.xml 을 자동으로 찾아 함께 읽는다

// application.yml
// mybatis.configuration.map-underscore-to-camel-case: true
// mybatis.type-handlers-package: shop.mybatis.handler

@MapperScan("shop.mapper")                  // conf.addMappers("shop.mapper") 에 해당. 매퍼 프록시를 빈으로 등록
@SpringBootApplication
public class App {}

@Service
public class OrderService {
    private final OrderMapper orders;       // 주입되는 것은 SqlSessionTemplate 을 감싼 프록시. 스레드 안전
    public OrderService(OrderMapper orders) { this.orders = orders; }

    @Transactional                          // 메서드 진입 시 세션(커넥션) 확보, 정상 종료 commit, RuntimeException 이면 rollback
    public long placeOrder(long memberId, long productId, int qty, String payMethod) {
        BigDecimal price = orders.lockPrice(productId);
        if (orders.decreaseStock(productId, qty) == 0) throw new OutOfStockException("재고 부족");
        Map<String, Object> order = new HashMap<>(Map.of("memberId", memberId, "productId", productId, "qty", qty, "amount", price.multiply(BigDecimal.valueOf(qty)), "status", "PAID"));
        orders.insertOrder(order);
        long orderId = ((Number) order.get("id")).longValue();
        orders.insertPayment(orderId, order.get("amount"), payMethod);
        return orderId;                     // try-with-resources, commit(), close() 가 전부 사라졌다
    }
}