[Elasticsearch] Java API - JPA 연동 조회 방법

Spring Data Jpa에서는 Custom Repository를 JpaRepository 상속 클래스에서 사용할 수 있도록 기능을 지원합니다.

 

 

실제로 소스를 사용하면,

 

0. 모델 생성

@Data
@Entity
@Table(name = "ACADEMY")
public class Academy {
 
    @Id
    @Column(name = "BASE_INFO_SEQ")
    @ApiModelProperty(value = "seq")
    private Long baseInfoSeq;
    @ApiModelProperty(value = "직업")
    private String job;
 
    // baseInfo 관련 컬럼
    @Transient
    @ApiModelProperty(value = "영문명")
    private String name;
    @Transient
    @ApiModelProperty(value = "한글명")
    private String nameKr;
    @Transient
    @ApiModelProperty(value = "풀네임")
    private String fullName;
    @Transient
    @ApiModelProperty(value = "생년월일")
    private String birthDate;
    @Transient
    @ApiModelProperty(value = "성별")
    private String gender;
}

 

1. jpa 관련 인터페이스 생성

1 2 3 4 5 6

@Repository public interface AcademyRepositoryExtra {     Page<Academy> findAllByQueryParams(Optional<QueryParams> queryParams) throws ParseException;     List<Academy> findAllListByQueryParams(Optional<QueryParams> queryParams) throws ParseException;     List<Academy> findByBaseInfoSeq(int seq) throws ParseException; } Colored by Color Scripter

cs

 

2. JpaRepository를 상속받은 인터페이스 생성

 ※ 여기에는 단순한 조회(or 쿼리문) 관련 소스를 호출하기도 함

@Repository
public interface AcademyRepository extends JpaRepository<Academy, Long>, AcademyRepositoryExtra {
}

 

3. Jpa 관련 소스 생성

public class AcademyRepositoryImpl extends QuerydslRepositorySupport implements AcademyRepositoryExtra {
 
    public AcademyRepositoryImpl() {
        super(Academy.class);
    }
 
    @PersistenceContext
    private EntityManager em;
 
    @Override
    public Page<Academy> findAllByQueryParams(Optional<QueryParams> queryParams) {
        Pageable pageable = queryParams.isPresent() ? queryParams.get().getPageable() : Pageable.unpaged();
 
        JPQLQuery query = getQuery(queryParams);
 
        long totalCount = query.fetchCount();
 
        final List<Academy> Academy = getQuerydsl().applyPagination(pageable, query).fetch();
        return new PageImpl(Academy, pageable, totalCount);
    }
 
    @Override
    public List<Academy> findAllListByQueryParams(Optional<QueryParams> queryParams) throws ParseException {
 
        JPQLQuery query = getQuery(queryParams);
 
        return query.fetch();
    }
 
    public JPQLQuery getQuery(Optional<QueryParams> queryParams) {
 
        QBaseInfo qBaseInfo = QBaseInfo.baseInfo;
        QAcademy qAcademy = QAcademy.academy;
        JPAQueryFactory queryFactory = new JPAQueryFactory(em);
        JPQLQuery query = queryFactory
                .select(Projections.fields(Academy.class, qBaseInfo.seq, qAcademy.baseInfoSeq, qBaseInfo.name, qBaseInfo.nameKr,
                        qBaseInfo.name.concat(" (").concat(qBaseInfo.nameKr).concat(")").as("fullName"), qBaseInfo.birthDate, qBaseInfo.gender,
                       qAcademy.job
                        )
                ).from(qBaseInfo)
                .rightJoin(qAcademy)
                .on(qBaseInfo.seq.eq(qAcademy.baseInfoSeq))
                .orderBy(qBaseInfo.regDate.desc()); // 등록일 역순으로 정렬
 
        // Name filter
        if (queryParams.isPresent() && queryParams.get().getName().isPresent() &&
                !isEmpty(queryParams.get().getName().get())) {
            // contains '단어'는 like '%단어%'와 같다
            query.where(qBaseInfo.name.upper().contains(queryParams.get().getName().get().toUpperCase(Locale.ROOT))
                    .or(qBaseInfo.nameKr.contains(queryParams.get().getName().get())));
        }
 
        // From/To birthDate filter
        if (queryParams.isPresent() && queryParams.get().getBirthDateFrom().isPresent() &&
                !isEmpty(queryParams.get().getBirthDateFrom().get())) {
            if (!queryParams.get().getBirthDateTo().isPresent()) {
                query.where(qBaseInfo.birthDate.eq(queryParams.get().getBirthDateFrom().get()));
            } else {
                query.where(qBaseInfo.birthDate.between(queryParams.get().getBirthDateFrom().get(),
                        queryParams.get().getBirthDateTo().get()));
            }
        }
        
        return query;
    }
 
    @Override
    public List<Academy> findByBaseInfoSeq(int seq) {
        QBaseInfo qBaseInfo = QBaseInfo.baseInfo;
        QAcademy qAcademy = QAcademy.academy;
 
        JPAQueryFactory queryFactory = new JPAQueryFactory(em);
        JPQLQuery query = queryFactory
                .select(Projections.fields(Academy.class, qBaseInfo.seq, qAcademy.baseInfoSeq, qBaseInfo.name, qBaseInfo.nameKr,
                        qBaseInfo.name.concat(" (").concat(qBaseInfo.nameKr).concat(")").as("fullName"), qBaseInfo.birthDate, qBaseInfo.gender,
                       qAcademy.job
                        )
                ).from(qBaseInfo)
                .rightJoin(qAcademy)
                .on(qBaseInfo.seq.eq(qAcademy.baseInfoSeq))
                .orderBy(qBaseInfo.regDate.desc()); // 등록일 역순으로 정렬
 
        // Seq filter
        query.where(qAcademy.baseInfoSeq.eq(Long.valueOf(seq)));
 
        return query.fetch();
    }
}

 

4. 조회 호출

    /**
     * 아카데미 목록 조회
     */
    public Page<Academy> listAcademy(Optional<QueryParams> queryParams) throws ParseException {
        return AcademyRepository.findAllByQueryParams(queryParams);
    }

 

5. 페이징

    boolean pageable = true;
 
    public Pageable getPageable() {
        if (pageable) {
            final int currentPage = page.orElse(1);
            final int pageSize = size.orElse(10);
 
            return PageRequest.of(currentPage - 1, pageSize);
        } else {
            return Pageable.unpaged();
        }
    }

 

 

참고 : https://jojoldu.tistory.com/372