Go to Qiita Advent Calendar 2024 Top
LoginSignup
2
6

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?

More than 5 years have passed since last update.

@rubytomato@github(渡邉 真)

JPQLのクエリ結果をHibernate ResultTransformerを使ってPOJOへマッピングする

Last updated at Posted at 2017-09-07

概要

JPAで実装した検索処理のクエリ結果をエンティティクラスではなく非エンティティクラス(POJO)へマッピングしたい場合、HibernateのResultTransformerを使用すると簡単に実装することができます。
このことは、参考に挙げているページ([The best way to map a projection query to a DTO (Data Transfer Object) with JPA and Hibernate] (https://vladmihalcea.com/2017/08/29/the-best-way-to-map-a-projection-query-to-a-dto-with-jpa-and-hibernate/amp/))で知りました。この記事はそのページを参考に実際にコードを書いて動作を確認した記録になります。とくに目新しいことは書いていないので、詳細をお知りになりたい場合は参考ページをご確認ください。

環境

  • Windows10 Professional
  • Java 1.8.0_144
  • Spring Boot 1.5.6
    • Spring Data JPA 1.11.6
    • Hibernate 5.0.1 Final
  • MySQL 5.6.25

参考

サンプルコード

検索処理

実装のポイント

No ポイント
(1) エンティティマネージャが生成するQueryのインスタンスを、unwrapメソッドで指定する型になるようにします
(2) aliasToBeanメソッドで指定するクラスへカラムのエイリアス名を使ってマッピングします
(3) カラムにAS "エイリアス名"というようにエイリアスを付けます。カラム名とエイリアス名が同じ場合でも省略はできません 
package com.example.domain.dao;

import com.example.domain.dto.ItemDto;
import com.example.domain.entity.Category;
import org.hibernate.Query;
import org.hibernate.transform.Transformers;
import org.hibernate.type.BooleanType;
import org.hibernate.type.LocalDateTimeType;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import java.time.LocalDateTime;
import java.util.List;

@Component
public class ItemDao {

    @PersistenceContext
    private EntityManager entityManager;

    // 実装ポイント (3)
    private static final String ITEM_STOCK_QUERY =
        "SELECT item.id AS itemId, " +
               " item.name AS itemName, " +
               " item.price AS price, " +
               " item.salesFrom AS salesFrom, " +
               " item.salesTo AS salesTo, " +
               " item.standardType AS standardType, " +
               " item.category.name as categoryName, " +
               " stocks.stock AS stock " +
          "FROM com.example.domain.entity.Item AS item " +
   "INNER JOIN item.itemStocks AS stocks " +
         "WHERE item.category = :category " +
           "AND item.delFlag = :delFlag " +
           "AND item.salesFrom <= :currentDate " +
           "AND item.salesTo >= :currentDate " +
           "AND stocks.stock > 0 " +
           "AND stocks.delFlag = :delFlag "
            ;

    @Transactional
    public List<ItemDto> findItemStock(final Category category, final LocalDateTime current) {

        Query query = entityManager.createQuery(ITEM_STOCK_QUERY)
                // 実装ポイント (1)
                .unwrap(org.hibernate.Query.class)
                // 実装ポイント (2)
                .setResultTransformer(Transformers.aliasToBean(ItemDto.class))
                .setParameter("category", category)
                .setParameter("delFlag", Boolean.FALSE, BooleanType.INSTANCE)
                .setParameter("currentDate", current, LocalDateTimeType.INSTANCE)
                .setComment("item stock list");

        System.out.println(query.getClass().getCanonicalName());
        // → org.hibernate.internal.QueryImpl

        //noinspection unchecked
        return query.list();
    }

}

留意点

Hiberanateの実装に依存するコードになります。例えば検索結果を返すメソッドは下記のように異なります。

Hibernate

org.hibernate.Query.list

JPA

javax.persistence.Query.getResultList

補足. 実際に実行されるSQL

select
    item0_.id as col_0_0_,
    item0_.name as col_1_0_,
    item0_.price as col_2_0_,
    item0_.sales_from as col_3_0_,
    item0_.sales_to as col_4_0_,
    item0_.standard_type as col_5_0_,
    category2_.name as col_6_0_,
    itemstocks1_.stock as col_7_0_ 
from
    item item0_ 
inner join
    item_stock itemstocks1_ 
        on item0_.id=itemstocks1_.item_id,
    category category2_ 
where
    item0_.category_id=category2_.id 
    and item0_.category_id=? 
    and item0_.del_flag=? 
    and item0_.sales_from<=? 
    and item0_.sales_to>=? 
    and itemstocks1_.stock>0 
    and itemstocks1_.del_flag=?

検索結果をマッピングするPOJO(DTO)クラス

ItemDto
package com.example.domain.dto;

import com.example.domain.StandardType;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.time.LocalDateTime;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ItemDto implements Serializable {

    private static final long serialVersionUID = 7803523681004958221L;

    // アイテムID
    private Long itemId;
    // アイテム名
    private String itemName;
    // 価格
    private Integer price;
    // 販売開始日
    private LocalDateTime salesFrom;
    // 販売終了日
    private LocalDateTime salesTo;
    // 規格
    private StandardType standardType;
    // 在庫数
    private Integer stock;

    // カテゴリ名
    private String categoryName;
}

テーブル定義

サンプルコードで使用するテーブルです。

categoryテーブル

アイテムが属するカテゴリデータを持つテーブル

category
CREATE TABLE category (
  id INT NOT NULL AUTO_INCREMENT             COMMENT 'カテゴリID',
  name VARCHAR(60) NOT NULL                  COMMENT 'カテゴリ名',
  del_flag TINYINT(1) NOT NULL DEFAULT 0     COMMENT '1:論理削除',
  create_at DATETIME NOT NULL DEFAULT NOW(),
  update_at DATETIME NOT NULL DEFAULT NOW(),
  PRIMARY KEY (id)
)
ENGINE = INNODB
DEFAULT CHARSET = UTF8
COMMENT = 'カテゴリマスター';

itemテーブル

アイテムデータを持つテーブル

item
CREATE TABLE item (
  id INT NOT NULL AUTO_INCREMENT             COMMENT 'アイテムID',
  name VARCHAR(90) NOT NULL                  COMMENT 'アイテム名',
  price INT NOT NULL                         COMMENT '価格',
  sales_from DATE NOT NULL                   COMMENT '販売開始日',
  sales_to DATE NOT NULL                     COMMENT '販売終了日',
  standard_type INT NOT NULL                 COMMENT '規格タイプ',
  category_id INT NOT NULL                   COMMENT 'カテゴリID',
  del_flag TINYINT(1) NOT NULL DEFAULT 0     COMMENT '1:論理削除',
  create_at DATETIME NOT NULL DEFAULT NOW(),
  update_at DATETIME NOT NULL DEFAULT NOW(),
  PRIMARY KEY (id)
)
ENGINE = INNODB
DEFAULT CHARSET = UTF8
COMMENT = 'アイテムマスター';

item_stockテーブル

アイテムの在庫を持つテーブル、アイテムに対して複数件存在する。

item_stock
CREATE TABLE item_stock (
  id INT NOT NULL AUTO_INCREMENT             COMMENT 'アイテム在庫ID',
  stock INT NOT NULL DEFAULT 0               COMMENT '在庫数',
  item_id INT NOT NULL                       COMMENT 'アイテムID',
  del_flag TINYINT(1) NOT NULL DEFAULT 0     COMMENT '1:論理削除',
  create_at DATETIME NOT NULL DEFAULT NOW(),
  update_at DATETIME NOT NULL DEFAULT NOW(),
  PRIMARY KEY (id)
)
ENGINE = INNODB
DEFAULT CHARSET = UTF8
COMMENT = 'アイテム在庫テーブル';

エンティティクラス

Categoryエンティティ

Category
package com.example.domain.entity;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.*;
import java.io.Serializable;
import java.time.LocalDateTime;

@Entity
@Table(name="category")
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class Category implements Serializable {

    private static final long serialVersionUID = -69562357755603227L;

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    @Column(name="name", nullable = false)
    private String name;
    @Column(name="del_flag", nullable = false)
    private Boolean delFlag;
    @Column(name="create_at", nullable = false)
    private LocalDateTime createAt;
    @Column(name="update_at", nullable = false)
    private LocalDateTime updateAt;
}

Itemエンティティ

Item
package com.example.domain.entity;

import com.example.domain.StandardType;
import lombok.*;

import javax.persistence.*;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.List;

@Entity
@Table(name="item")
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ToString(exclude = {"itemStocks"})
@EqualsAndHashCode(exclude = {"itemStocks"})
public class Item implements Serializable {

    private static final long serialVersionUID = -3153084093423004609L;

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    @Column(name="name", nullable = false)
    private String name;
    @Column(name="price", nullable = false)
    private Integer price;
    @Column(name="sales_from", nullable = false)
    private LocalDateTime salesFrom;
    @Column(name="sales_to", nullable = false)
    private LocalDateTime salesTo;
    @Enumerated(EnumType.ORDINAL)
    @Column(name="standard_type", nullable = false)
    private StandardType standardType;
    @JoinColumn(name = "category_id", nullable = false)
    @ManyToOne
    private Category category;
    @Column(name="del_flag", nullable = false)
    private Boolean delFlag;
    @Column(name="create_at", nullable = false)
    private LocalDateTime createAt;
    @Column(name="update_at", nullable = false)
    private LocalDateTime updateAt;

    @OneToMany(mappedBy = "item", cascade = CascadeType.ALL)
    private List<ItemStock> itemStocks;
}

StandardType

アイテムの規格タイプを定義するenumです。

StandardType
package com.example.domain;

public enum StandardType {
    UNKNOWN,
    A, B, C, D, E, F, G, H, I, J;
}

ItemStockエンティティ

ItemStock
package com.example.domain.entity;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.*;
import java.io.Serializable;
import java.time.LocalDateTime;

@Entity
@Table(name="item_stock")
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ItemStock implements Serializable {

    private static final long serialVersionUID = -7012583289204822258L;

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    @Column(name="stock", nullable = false)
    private Integer stock;
    @JoinColumn(name = "item_id", nullable = false)
    @ManyToOne
    private Item item;
    @Column(name="del_flag", nullable = false)
    private Boolean delFlag;
    @Column(name="create_at", nullable = false)
    private LocalDateTime createAt;
    @Column(name="update_at", nullable = false)
    private LocalDateTime updateAt;
}
2
6
0

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
Sign upLogin
2
6

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?