Spring Framework와 JPA 활용

 

package me.chaeyoung.jpa.channel;

import jakarta.persistence.EntityManager;
import jakarta.persistence.PersistenceContext;
import org.springframework.stereotype.Repository;

@Repository
public class ChannelRepository {

    @PersistenceContext
    EntityManager entityManager;
    // persistenceContext 를 주입받아서 EntityManager 를 사용한다.
    
    public Channel insertChannel(Channel channel){
        entityManager.persist(channel);
        return channel;
    }
    
    public Channel selectChannel(Long id) {
        return entityManager.find(Channel.class,id);
    }

}

 

1. RawJPA는 Repository에서 @PersistenceContext를 주입받아서 EntityManger를 사용한다.

 

2. .persist()를 통해 영속성 상태로 만들어준다.

 

3. .find()를 통해 조회한다.

 

 

테스트 코드

package me.chaeyoung.jpa.channel;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.annotation.Rollback;
import org.springframework.transaction.annotation.Transactional;

import static org.junit.jupiter.api.Assertions.*;

@SpringBootTest
@Transactional
@Rollback(value=false)
class ChannelRepositoryTest {

    @Autowired
    private ChannelRepository channelRepository;

    @Test
    void insertSelectGroupTest(){

        // given
        var newChannel = Channel.builder().name("new-group").build();
        // type 은 null 로 들어갈 것임.

        // when
        var savedChannel = channelRepository.insertChannel(newChannel);

        // then
        var foundChannel = channelRepository.selectChannel(savedChannel.getId());
        // DB 에 select 쿼리문을 날리지 않고 영속성 컨텍스트 내에서 가져옴.
        assert foundChannel.getId().equals(savedChannel.getId());
    }

}

 

 

 

Channel.class 코드보기

package me.chaeyoung.jpa.channel;

import jakarta.persistence.*;
import lombok.AccessLevel;
import lombok.Builder;
import lombok.Getter;
import lombok.NoArgsConstructor;
import me.chaeyoung.jpa.thread.Thread;

import java.util.LinkedHashSet;
import java.util.Set;

// lombok
@Getter
@NoArgsConstructor(access = AccessLevel.PROTECTED)

// JPA
@Entity
public class Channel {

    /**
     * 컬럼 - 연관관계 컬럼을 제외한 컬럼을 정의합니다.
     */
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name="id", nullable= false)
    private Long id;

    private String name;

    @Enumerated(EnumType.STRING)
    private Type type;

    public enum Type {
        PUBLIC, PRIVATE
    }

    /**
     * 생성자 - 약속된 형태로만 생성가능하도록 합니다.
     */
    @Builder
    public Channel(String name, Type type){
        this.name = name;
        this.type = type;
    }

    /**
     * 연관관계 - Foreign Key 값을 따로 컬럼으로 정의하지 않고 연관 관계로 정의합니다.
     */
    @OneToMany(mappedBy="channel")
    private Set<Thread> threadList = new LinkedHashSet <>();
    // Set 은 List 와는 다르게 저장된 값이 순서가 없어 중복 미허용.
    // LinkedHashSet 은 순서 보장



    /**
     * 연관관계 편의 메소드 - 반대쪽에는 연관관계 편의 메소드가 없도록 주의합니다.
     */


    /**
     * 서비스 메소드 - 외부에서 엔티티를 수정할 메소드를 정의합니다. (단일 책임을 가지도록 주의합니다.)
     */

}

 

@NoArgsConstructor(access = AccessLevel.PROTECTED)

-> 기본 생성자 lombok활용하여 생성