Kohei Nozaki's blog 

Entity Graphを使ってみる


Posted on Sunday Jan 26, 2014 at 04:05PM in Technology


JPA2.1の新機能Entity Graphを使ってみます。SELECT文を実行するときにどこまで階層を掘り下げて拾ってくるかを指定することができるようになり、むだにManaged状態のときにsize()を呼び出したりしなくてよくなる仕組みのようです。

環境

  • Hibernate 4.3.0.Final
  • WildFly8.0.0.CR1
  • Oracle JDK7u51
  • postgresql-9.3-1100.jdbc41.jar
  • PostgreSQL 9.2.4

使い方

  1. エンティティの階層を表すEntity Graphを作ります。JPQLのような名前付きの静的なものとして作っておく他に、動的にコードから作ることも可能。Canonical MetaModelも使えるようです。
  2. Query#setHint()メソッドを使ってEntity Graphを渡してやってからクエリを実行します。ヒント名には2つあり、どちらを使うかで以下のように動作が変わります
    • javax.persistence.fetchgraph: Entity Graphに含まれるフィールドのみロードされる。含まれないフィールドはロードされない。Entity Graphに含まれないフィールドは全てLAZY扱いになる
    • javax.persistence.loadgraph: Entity Graphに含まれるフィールドはLAZYであってもロードされる。含まれないフィールドはそれぞれのフィールドの設定による

前提条件

NativeQueryで関連持ちエンティティをSELECTしてみるで使った資源を使います。エンティティはこれです

試してみる

javax.persistence.fetchgraph

Entity Graphを作る

Employeeクラスにこんなアノテーションを付けます

@NamedEntityGraph(
        name = "onlyFirstNameAndLastName",
        attributeNodes = {
                @NamedAttributeNode("firstName"),
                @NamedAttributeNode("lastName")})

orm.xmlにクエリを定義

    <named-query name="findEmployees">
        <query><![CDATA[
            SELECT
                e
            FROM
                Employee e
        ]]></query>
    </named-query>

テストメソッド

    @Test
    @Transactional
    @UsingDataSet({"datasets/relativeSelect/dept.yml", "datasets/relativeSelect/employees.yml"})
    public void select() throws Exception {
        EntityGraph<?> entityGraph = em.getEntityGraph("onlyFirstNameAndLastName");
        dumpEmployeeList(em.createNamedQuery("findEmployees", Employee.class)
            .setHint("javax.persistence.fetchgraph", entityGraph)
            .getResultList());
    }

    protected void dumpEmployeeList(List<Employee> employees){
        for(Employee emp : employees){
            System.out.printf("        emp: id=%d, firstName=%s, lastName=%s\n", emp.getId(), emp.getFirstName(), emp.getLastName());               
        }
    }

テストメソッドを実行

javax.persistence.fetchgraphを指定して、Entity GraphではfirstNameとlastNameのみ指定しているので、deptはロードされないと思っていたら…

17:27:12,991 INFO  [stdout] (pool-2-thread-34) Hibernate: select employee0_.id as id1_1_, employee0_.dept_id as dept_id4_1_, employee0_.firstName as firstNam2_1_, employee0_.lastName as lastName3_1_ from Employee employee0_
17:27:12,993 INFO  [stdout] (pool-2-thread-34) Hibernate: select dept0_.id as id1_0_0_, dept0_.deptName as deptName2_0_0_ from Dept dept0_ where dept0_.id=?
17:27:12,994 INFO  [stdout] (pool-2-thread-34) Hibernate: select dept0_.id as id1_0_0_, dept0_.deptName as deptName2_0_0_ from Dept dept0_ where dept0_.id=?
17:27:12,995 INFO  [stdout] (pool-2-thread-34)         emp: id=-1, firstName=Taro, lastName=Yamada
17:27:12,996 INFO  [stdout] (pool-2-thread-34)         emp: id=-2, firstName=Jiro, lastName=Suzuki
17:27:12,996 INFO  [stdout] (pool-2-thread-34)         emp: id=-3, firstName=Saburo, lastName=Tanaka

何故か普通に取ってきてますね。どうも無視されているような気が…。[2]にはエンティティグラフについても言及されているようなのだが未実装という事だろうか。あるいは、この機能はあくまでヒントであって実際にどうなるかはJPAプロバイダの実装によるとかそういう事なのか。

[1]を書いた人のサンプルを見るとEclipseLinkを使っているようなのでEclipseLinkなら期待通りの動作をするかもしれない。

[4]に起票されているが、どうもJPA仕様では強制されてないからバグではないと認識されているようだ。ううむ。

javax.persistence.loadgraph

Entity Graphを作る

Deptクラスにこんなアノテーションを付けます

@NamedEntityGraph(
name = "loadEmployees",
attributeNodes = {
        @NamedAttributeNode("employees")}
)

orm.xmlにクエリを定義

    <named-query name="findDeptsDistinct">
        <query><![CDATA[
            SELECT DISTINCT
                d
            FROM
                Dept AS d
        ]]></query>
    </named-query>

テストメソッド

    @Test
    @Transactional
    @UsingDataSet({"datasets/relativeSelect/dept.yml", "datasets/relativeSelect/employees.yml"})
    public void select() throws Exception {
        EntityGraph<?> entityGraph = em.getEntityGraph("loadEmployees");
        dumpDeptList(em.createNamedQuery("findDeptsDistinct", Dept.class)
            .setHint("javax.persistence.loadgraph", entityGraph)
            .getResultList());
    }

    protected void dumpEmployeeList(List<Employee> employees){
        for(Employee emp : employees){
            System.out.printf("        emp: id=%d, firstName=%s, lastName=%s\n", emp.getId(), emp.getFirstName(), emp.getLastName());               
        }
    }

    protected void dumpDeptList(List<Dept> list){
        for(Dept dept : list){
            System.out.printf("dept: id=%d, deptName=%s\n", dept.getId(), dept.getDeptName());
            dumpEmployeeList(dept.getEmployees());
        }
    }

テストメソッドを実行

21:03:35,540 INFO  [stdout] (pool-2-thread-4) Hibernate: select distinct dept0_.id as id1_0_0_, employees1_.id as id1_1_1_, dept0_.deptName as deptName2_0_0_, employees1_.dept_id as dept_id4_1_1_, employees1_.firstName as firstNam2_1_1_, employees1_.lastName as lastName3_1_1_, employees1_.dept_id as dept_id4_0_0__, employees1_.id as id1_1_0__ from Dept dept0_ left outer join Employee employees1_ on dept0_.id=employees1_.dept_id
21:03:35,544 INFO  [stdout] (pool-2-thread-4) dept: id=-1, deptName=Sales
21:03:35,545 INFO  [stdout] (pool-2-thread-4)         emp: id=-2, firstName=Jiro, lastName=Suzuki
21:03:35,545 INFO  [stdout] (pool-2-thread-4)         emp: id=-1, firstName=Taro, lastName=Yamada
21:03:35,545 INFO  [stdout] (pool-2-thread-4) dept: id=-2, deptName=Legal
21:03:35,545 INFO  [stdout] (pool-2-thread-4)         emp: id=-3, firstName=Saburo, lastName=Tanaka

めでたくSELECT文が一回になりました。こっちは大丈夫そう。

その他

Entity Graphをorm.xmlで定義しようとすると例外が起きてしまい動作しません。「named-attribute-node.value is mandatory in XML overriding.」と言われます。書き方が悪いのか、あるいは他の原因があるのかは不明。またそのうち調べる。

参考文献

  1. Forward Everyday: JPA 2.1: Entity Graph
  2. ORMツール Hibernare 4.3がリリース,JPA 2.1仕様を実装
  3. FETCH JOIN is still a JOIN « Piotr Nowicki's Homepage
  4. [HHH-8776] Ability for JPA entity-graphs to handle non-lazy attributes as lazy - Hibernate JIRA


NativeQueryで複数のエンティティを同時にSELECTしつつconstructor-resultを使ってみる


Posted on Sunday Jan 26, 2014 at 03:18PM in Technology


NativeQueryでconstructor-resultを使ってSELECTしてみるの続きです。2つのエンティティ分のデータを取得するSELECT文から、エンティティ2つに加えて、DTOクラスのオブジェクト1つをconstructor-resultを使って取得してみます。だからなんだって感じもしますが。

環境

  • Hibernate 4.3.0.Final
  • WildFly8.0.0.CR1
  • Oracle JDK7u51
  • postgresql-9.3-1100.jdbc41.jar
  • PostgreSQL 9.2.4

何をするか

エンティティと関連の構造は前回と同じです。

今回は以下をSELECT一回で取ってきます

  • Employeeエンティティ
  • Deptエンティティ
  • deptName, firstName, lastNameをフィールドにもつDTO

準備

配置図

図中で選択されている資源を作成または編集します。

  • orm.xmlにNamedNativeQuery “findVarious” とResultSetMapping “variousResult” を追加します
  • テストクラスVariousResultSelectTestを作ります
  • DTOクラスEmployeeProfileを作ります
  • テストデータは前回のを流用します

EmployeeProfile.java

package org.arquillian.example;

public class EmployeeProfile {

    private String deptName;
    private String firstName;
    private String lastName;

    public EmployeeProfile(String deptName, String firstName, String lastName) {
        super();
        this.deptName = deptName;
        this.firstName = firstName;
        this.lastName = lastName;
    }

    @Override
    public String toString() {
        return "EmployeeProfile [deptName=" + deptName + ", firstName=" + firstName + ", lastName=" + lastName + "]";
    }

}

orm.xml

<?xml version="1.0" encoding="UTF-8"?>
<entity-mappings version="2.1"
    xmlns="http://xmlns.jcp.org/xml/ns/persistence/orm" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence/orm http://xmlns.jcp.org/xml/ns/persistence/orm_2_1.xsd">

    <named-native-query name="findVarious" result-set-mapping="variousResult">
        <query><![CDATA[
            SELECT
                emp.id,
                emp.firstName,
                emp.lastName,
                emp.dept_id,
                dep.deptName
            FROM
                Employee AS emp,
                Dept AS dep
            WHERE
                emp.dept_id = dep.id
        ]]></query>
    </named-native-query>

    <sql-result-set-mapping name="variousResult">
        <entity-result entity-class="org.arquillian.example.Employee"/>
        <entity-result entity-class="org.arquillian.example.Dept">
            <field-result name="id" column="dept_id"/>
            <field-result name="deptName" column="deptName"/>
        </entity-result>
        <constructor-result target-class="org.arquillian.example.EmployeeProfile">
            <column name="deptName" class="java.lang.String" />
            <column name="firstName" class="java.lang.String" />
            <column name="lastName" class="java.lang.String" />
        </constructor-result>
    </sql-result-set-mapping>   

</entity-mappings>

VariousResultSelectTest.java

package org.arquillian.example;

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;

import org.jboss.arquillian.container.test.api.Deployment;
import org.jboss.arquillian.junit.Arquillian;
import org.jboss.arquillian.persistence.UsingDataSet;
import org.jboss.shrinkwrap.api.Archive;
import org.jboss.shrinkwrap.api.ShrinkWrap;
import org.jboss.shrinkwrap.api.asset.EmptyAsset;
import org.jboss.shrinkwrap.api.spec.WebArchive;
import org.junit.Test;
import org.junit.runner.RunWith;

@RunWith(Arquillian.class)
public class VariousSelectTest {
    @Deployment
    public static Archive<?> createDeployment() {
        Archive<?> a = ShrinkWrap.create(WebArchive.class, "test.war")
            .addPackage(Employee.class.getPackage())
            .addAsResource("test-persistence.xml", "META-INF/persistence.xml")
            .addAsResource("META-INF/orm.xml", "META-INF/orm.xml")
            .addAsWebInfResource(EmptyAsset.INSTANCE, "beans.xml")
            .addAsWebInfResource("jbossas-ds.xml");
        return a;
    }

    @PersistenceContext
    EntityManager em;

    @Test
    @Transactional
    @UsingDataSet({"datasets/relativeSelect/dept.yml", "datasets/relativeSelect/employees.yml"})
    public void select() throws Exception {
        dumpEntityList(em.createNamedQuery("findVarious").getResultList());
    }

    protected void dumpEntityList(List<?> list){
        for(Object o : list){
            Object[] array = (Object[])o;
            Employee employee = (Employee) array[0];
            Dept dept = (Dept) array[1];
            EmployeeProfile employeeProfile = (EmployeeProfile) array[2];
            System.out.println("");
            System.out.println("---------------------------------");
            System.out.printf("id=%d, firstName=%s, lastName=%s, dept_id=%s, deptName=%s, employee=%s, dept=%s\n",
                    employee.getId(), employee.getFirstName(), employee.getLastName(),
                    dept.getId(), dept.getDeptName(),
                    em.contains(employee), em.contains(dept));
            System.out.println(employeeProfile);
            System.out.println("---------------------------------");
        }
    }
}

実行結果

15:15:55,405 INFO  [stdout] (pool-2-thread-20) Hibernate: SELECT emp.id, emp.firstName, emp.lastName, emp.dept_id, dep.deptName FROM Employee AS emp, Dept AS dep WHERE emp.dept_id = dep.id
15:15:55,409 INFO  [stdout] (pool-2-thread-20) 
15:15:55,409 INFO  [stdout] (pool-2-thread-20) ---------------------------------
15:15:55,409 INFO  [stdout] (pool-2-thread-20) id=-1, firstName=Taro, lastName=Yamada, dept_id=-1, deptName=Sales, employee=true, dept=true
15:15:55,409 INFO  [stdout] (pool-2-thread-20) EmployeeProfile [deptName=Sales, firstName=Taro, lastName=Yamada]
15:15:55,410 INFO  [stdout] (pool-2-thread-20) ---------------------------------
15:15:55,410 INFO  [stdout] (pool-2-thread-20) 
15:15:55,410 INFO  [stdout] (pool-2-thread-20) ---------------------------------
15:15:55,410 INFO  [stdout] (pool-2-thread-20) id=-2, firstName=Jiro, lastName=Suzuki, dept_id=-1, deptName=Sales, employee=true, dept=true
15:15:55,410 INFO  [stdout] (pool-2-thread-20) EmployeeProfile [deptName=Sales, firstName=Jiro, lastName=Suzuki]
15:15:55,410 INFO  [stdout] (pool-2-thread-20) ---------------------------------
15:15:55,410 INFO  [stdout] (pool-2-thread-20) 
15:15:55,410 INFO  [stdout] (pool-2-thread-20) ---------------------------------
15:15:55,411 INFO  [stdout] (pool-2-thread-20) id=-3, firstName=Saburo, lastName=Tanaka, dept_id=-2, deptName=Legal, employee=true, dept=true
15:15:55,411 INFO  [stdout] (pool-2-thread-20) EmployeeProfile [deptName=Legal, firstName=Saburo, lastName=Tanaka]
15:15:55,411 INFO  [stdout] (pool-2-thread-20) ---------------------------------

あんまり意味ないかもしれませんが柔軟に出来ているなぁと。

備考

今回使ったsql-result-set-mappingに、さらに以下を追加してもXML的には不正ではないのですが、

<column-result name="deptName"/>

動かそうとすると何故か以下のような例外が出て動きません。まああまり困ることもなさそうですが。

15:26:45,836 SEVERE [org.jboss.arquillian.protocol.jmx.JMXTestRunner] (pool-2-thread-21) Failed: org.arquillian.example.VariousSelectTest.select: javax.persistence.PersistenceException: org.hibernate.loader.custom.NonUniqueDiscoveredSqlAliasException: Encountered a duplicated sql alias [deptName] during auto-discovery of a native-sql query

参考文献

  1. JavaEE 7 JPA 2.1の新機能 ネイティブクエリの改善 - しんさんの出張所 はてな編


NativeQueryでconstructor-resultを使ってSELECTしてみる


Posted on Sunday Jan 26, 2014 at 02:35PM in Technology


NativeQueryで複数のエンティティを1度にSELECTしてみるの続きです。JPA2.1のNativeQueryの新機能constructor-resultを使ってSELECTしてみます。

constructor-resultはJPQLのNEW句のようなものです。エンティティを拾ってくるクエリでなく、レポート的なのを出すクエリの場合とかに使うとキャストが要らなくなるので便利っぽいです。

環境

  • Hibernate 4.3.0.Final
  • WildFly8.0.0.CR1
  • Oracle JDK7u51
  • postgresql-9.3-1100.jdbc41.jar
  • PostgreSQL 9.2.4

何をするか

エンティティと関連の構造は前回と同じです。

今回はDeptエンティティのdeptNameと、EmployeeのカウントをSELECTしてみます。

準備

配置図

図中で選択されている資源を作成または編集します。

  • orm.xmlにNamedNativeQuery “findDeptNameAndEmployeeCount” とResultSetMapping “deptNameAndEmployeeCountResult” を追加します
  • テストクラスConstructorResultSelectTestを作ります
  • DTOクラスDeptNameAndEmployeeCountを作ります
  • テストデータは前回のを流用します

DeptNameAndEmployeeCount.java

package org.arquillian.example;

public class DeptNameAndEmployeeCount {

    private String deptName;
    private Number employeeCount;

    public DeptNameAndEmployeeCount(String deptName, Number employeeCount) {
        super();
        this.deptName = deptName;
        this.employeeCount = employeeCount;
    }

    @Override
    public String toString() {
        return "DeptNameAndEmployeeCount [deptName=" + deptName + ", employeeCount=" + employeeCount + "]";
    }
}

orm.xml

<?xml version="1.0" encoding="UTF-8"?>
<entity-mappings version="2.1"
    xmlns="http://xmlns.jcp.org/xml/ns/persistence/orm" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence/orm http://xmlns.jcp.org/xml/ns/persistence/orm_2_1.xsd">

    <named-native-query name="findDeptNameAndEmployeeCount" result-set-mapping="deptNameAndEmployeeCountResult">
        <query><![CDATA[
            SELECT
                dep.deptName,
                COUNT(dep.deptName) AS employeeCount
            FROM
                Dept AS dep,
                Employee AS emp
            WHERE
                dep.id = emp.dept_id
            GROUP BY
                dep.deptName
        ]]></query>
    </named-native-query>

    <sql-result-set-mapping name="deptNameAndEmployeeCountResult">
        <constructor-result target-class="org.arquillian.example.DeptNameAndEmployeeCount">
            <column name="deptName" class="java.lang.String" />
            <column name="employeeCount" class="java.lang.Number" />
        </constructor-result>
    </sql-result-set-mapping>   

</entity-mappings>
  • column要素のclass属性は省略可みたい(少なくともHibernate4.3.1では動いた)
  • ただcolumn要素自体は省略不可っぽい

ConstructorResultSelectTest.java

package org.arquillian.example;

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;

import org.jboss.arquillian.container.test.api.Deployment;
import org.jboss.arquillian.junit.Arquillian;
import org.jboss.arquillian.persistence.UsingDataSet;
import org.jboss.shrinkwrap.api.Archive;
import org.jboss.shrinkwrap.api.ShrinkWrap;
import org.jboss.shrinkwrap.api.asset.EmptyAsset;
import org.jboss.shrinkwrap.api.spec.WebArchive;
import org.junit.Test;
import org.junit.runner.RunWith;

@RunWith(Arquillian.class)
public class ConstructorResultSelectTest {
    @Deployment
    public static Archive<?> createDeployment() {
        Archive<?> a = ShrinkWrap.create(WebArchive.class, "test.war")
            .addPackage(Employee.class.getPackage())
            .addAsResource("test-persistence.xml", "META-INF/persistence.xml")
            .addAsResource("META-INF/orm.xml", "META-INF/orm.xml")
            .addAsWebInfResource(EmptyAsset.INSTANCE, "beans.xml")
            .addAsWebInfResource("jbossas-ds.xml");
        return a;
    }

    @PersistenceContext
    EntityManager em;

    @Test
    @Transactional
    @UsingDataSet({"datasets/relativeSelect/dept.yml", "datasets/relativeSelect/employees.yml"})
    public void select() throws Exception {
        dumpEntityList(em.createNamedQuery("findDeptNameAndEmployeeCount").getResultList());
    }

    protected void dumpEntityList(List<?> list){
        for(Object o : list){
            System.out.println(o);
        }
    }
}

実行結果

14:42:45,278 INFO  [stdout] (pool-2-thread-17) Hibernate: SELECT dep.deptName, COUNT(dep.deptName) AS employeeCount FROM Dept AS dep, Employee AS emp WHERE dep.id = emp.dept_id GROUP BY dep.deptName
14:42:45,281 INFO  [stdout] (pool-2-thread-17) DeptNameAndEmployeeCount [deptName=Legal, employeeCount=1]
14:42:45,282 INFO  [stdout] (pool-2-thread-17) DeptNameAndEmployeeCount [deptName=Sales, employeeCount=2]

キャストが要らないのがいいですね。

続き

NativeQueryで複数のエンティティを同時にSELECTしつつconstructor-resultを使ってみる

参考文献

  1. JavaEE 7 JPA 2.1の新機能 ネイティブクエリの改善 - しんさんの出張所 はてな編


NativeQueryで複数のエンティティを1度にSELECTしてみる


Posted on Sunday Jan 26, 2014 at 01:51PM in Technology


NativeQueryでエンティティとスカラ値を同時にSELECTしてみるの続きです。今回は2つのエンティティを1回のSELECT文で取得してみます。

環境

  • Hibernate 4.3.0.Final
  • WildFly8.0.0.CR1
  • Oracle JDK7u51
  • postgresql-9.3-1100.jdbc41.jar
  • PostgreSQL 9.2.4

何をするか

エンティティと関連の構造は前回と同じです。

今回はEmployeeエンティティとDeptエンティティを同時にSELECTしてみます。

準備

配置図

図中で選択されている資源を作成または編集します。

  • orm.xmlにNamedNativeQuery “findEmployeeWithDeptAtOnce” とResultSetMapping “employeeWithDeptResult” を追加します
  • MultiEntitySelectTestを作ります
  • テストデータは前回のを流用します

orm.xml

<?xml version="1.0" encoding="UTF-8"?>
<entity-mappings version="2.1"
    xmlns="http://xmlns.jcp.org/xml/ns/persistence/orm" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence/orm http://xmlns.jcp.org/xml/ns/persistence/orm_2_1.xsd">

    <named-native-query name="findEmployeeWithDeptAtOnce" result-set-mapping="employeeWithDeptResult">
        <query><![CDATA[
            SELECT
                emp.id,
                emp.firstName,
                emp.lastName,
                emp.dept_id,
                dep.deptName
            FROM
                Employee AS emp,
                Dept AS dep
            WHERE
                emp.dept_id = dep.id
        ]]></query>
    </named-native-query>

    <sql-result-set-mapping name="employeeWithDeptResult">
        <entity-result entity-class="org.arquillian.example.Employee"/>
        <entity-result entity-class="org.arquillian.example.Dept">
            <field-result name="id" column="dept_id"/>
            <field-result name="deptName" column="deptName"/>
        </entity-result>
    </sql-result-set-mapping>   

</entity-mappings>

ResultSetMappingのfield-result要素で、Deptエンティティのidフィールドの値はクエリ中のdept_idだよ、と教えてやります

MultiEntitySelectTest.java

package org.arquillian.example;

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;

import org.jboss.arquillian.container.test.api.Deployment;
import org.jboss.arquillian.junit.Arquillian;
import org.jboss.arquillian.persistence.UsingDataSet;
import org.jboss.shrinkwrap.api.Archive;
import org.jboss.shrinkwrap.api.ShrinkWrap;
import org.jboss.shrinkwrap.api.asset.EmptyAsset;
import org.jboss.shrinkwrap.api.spec.WebArchive;
import org.junit.Test;
import org.junit.runner.RunWith;

@RunWith(Arquillian.class)
public class MultiEntitySelectTest {
    @Deployment
    public static Archive<?> createDeployment() {
        Archive<?> a = ShrinkWrap.create(WebArchive.class, "test.war")
            .addPackage(Employee.class.getPackage())
            .addAsResource("test-persistence.xml", "META-INF/persistence.xml")
            .addAsResource("META-INF/orm.xml", "META-INF/orm.xml")
            .addAsWebInfResource(EmptyAsset.INSTANCE, "beans.xml")
            .addAsWebInfResource("jbossas-ds.xml");
        return a;
    }

    @PersistenceContext
    EntityManager em;

    @Test
    @Transactional
    @UsingDataSet({"datasets/relativeSelect/dept.yml", "datasets/relativeSelect/employees.yml"})
    public void select() throws Exception {
        dumpEntityList(em.createNamedQuery("findEmployeeWithDeptAtOnce").getResultList());
    }

    protected void dumpEntityList(List<?> list){
        for(Object o : list){
            Object[] array = (Object[])o;
            Employee employee = (Employee) array[0];
            Dept dept = (Dept) array[1];
            System.out.println("");
            System.out.printf("id=%d, firstName=%s, lastName=%s, dept_id=%s, deptName=%s, employee=%s, dept=%s\n",
                    employee.getId(), employee.getFirstName(), employee.getLastName(),
                    dept.getId(), dept.getDeptName(),
                    em.contains(employee), em.contains(dept));
            System.out.println("---------------------------------");
            System.out.println("checking relation references");
            System.out.println(dept.getEmployees());
            System.out.println(employee.getDept());
            System.out.println("---------------------------------");
        }
    }
}

実行結果

4,688 INFO  [stdout] (pool-2-thread-15) Hibernate: SELECT emp.id, emp.firstName, emp.lastName, emp.dept_id, dep.deptName FROM Employee AS emp, Dept AS dep WHERE emp.dept_id = dep.id
14:11:54,691 INFO  [stdout] (pool-2-thread-15) 
14:11:54,692 INFO  [stdout] (pool-2-thread-15) id=-1, firstName=Taro, lastName=Yamada, dept_id=-1, deptName=Sales, employee=true, dept=true
14:11:54,692 INFO  [stdout] (pool-2-thread-15) ---------------------------------
14:11:54,692 INFO  [stdout] (pool-2-thread-15) checking relation references
14:11:54,693 INFO  [stdout] (pool-2-thread-15) [Employee [id=-1, firstName=Taro, lastName=Yamada, dept=Dept [id=-1, deptName=Sales, employees=2]], Employee [id=-2, firstName=Jiro, lastName=Suzuki, dept=Dept [id=-1, deptName=Sales, employees=2]]]
14:11:54,693 INFO  [stdout] (pool-2-thread-15) Dept [id=-1, deptName=Sales, employees=2]
14:11:54,693 INFO  [stdout] (pool-2-thread-15) ---------------------------------
14:11:54,693 INFO  [stdout] (pool-2-thread-15) 
14:11:54,693 INFO  [stdout] (pool-2-thread-15) id=-2, firstName=Jiro, lastName=Suzuki, dept_id=-1, deptName=Sales, employee=true, dept=true
14:11:54,694 INFO  [stdout] (pool-2-thread-15) ---------------------------------
14:11:54,694 INFO  [stdout] (pool-2-thread-15) checking relation references
14:11:54,694 INFO  [stdout] (pool-2-thread-15) [Employee [id=-1, firstName=Taro, lastName=Yamada, dept=Dept [id=-1, deptName=Sales, employees=2]], Employee [id=-2, firstName=Jiro, lastName=Suzuki, dept=Dept [id=-1, deptName=Sales, employees=2]]]
14:11:54,694 INFO  [stdout] (pool-2-thread-15) Dept [id=-1, deptName=Sales, employees=2]
14:11:54,694 INFO  [stdout] (pool-2-thread-15) ---------------------------------
14:11:54,694 INFO  [stdout] (pool-2-thread-15) 
14:11:54,694 INFO  [stdout] (pool-2-thread-15) id=-3, firstName=Saburo, lastName=Tanaka, dept_id=-2, deptName=Legal, employee=true, dept=true
14:11:54,695 INFO  [stdout] (pool-2-thread-15) ---------------------------------
14:11:54,695 INFO  [stdout] (pool-2-thread-15) checking relation references
14:11:54,695 INFO  [stdout] (pool-2-thread-15) [Employee [id=-3, firstName=Saburo, lastName=Tanaka, dept=Dept [id=-2, deptName=Legal, employees=1]]]
14:11:54,696 INFO  [stdout] (pool-2-thread-15) Dept [id=-2, deptName=Legal, employees=1]
14:11:54,696 INFO  [stdout] (pool-2-thread-15) ---------------------------------

SELECT文が1回になったので状況によってはクエリを軽くするのに寄与するかもしれません。また、こういう取り方をしてもお互いの参照はちゃんと設定されていて、実際にアクセスしてもよけいなクエリを実行する事もないようです。賢い。

と思ったのだがorg.hibernate.SQLのログレベルを上げて見ると、別途SELECT文が実行されている気配。persistence.xmlにhibernate.show_sqlを設定しただけでは全てのSQLは出ないという事なのか、あるいは見落としたのか…。PostgreSQL側にSQLをログ出力させる設定を加えて見てみるとこんなのが出ている。

Feb  2 11:35:46 kyle-no-MacBook.local postgres[1120]: [877-1] 2014-02-02 11:35:46 JST LOG:  execute <unnamed>: SELECT emp.id, emp.firstName, emp.lastName, emp.dept_id, dep.deptName FROM Employee AS emp,
 Dept AS dep WHERE emp.dept_id = dep.id
Feb  2 11:35:46 kyle-no-MacBook.local postgres[1120]: [878-1] 2014-02-02 11:35:46 JST LOG:  execute <unnamed>: select employees0_.dept_id as dept_id4_0_0_, employees0_.id as id1_1_0_, employees0_.id as 
id1_1_1_, employees0_.dept_id as dept_id4_1_1_, employees0_.firstName as firstNam2_1_1_, employees0_.lastName as lastName3_1_1_ from Employee employees0_ where employees0_.dept_id=$1
Feb  2 11:35:46 kyle-no-MacBook.local postgres[1120]: [878-2] 2014-02-02 11:35:46 JST DETAIL:  parameters: $1 = '-1'
Feb  2 11:35:46 kyle-no-MacBook.local postgres[1120]: [879-1] 2014-02-02 11:35:46 JST LOG:  execute <unnamed>: select employees0_.dept_id as dept_id4_0_0_, employees0_.id as id1_1_0_, employees0_.id as 
id1_1_1_, employees0_.dept_id as dept_id4_1_1_, employees0_.firstName as firstNam2_1_1_, employees0_.lastName as lastName3_1_1_ from Employee employees0_ where employees0_.dept_id=$1
Feb  2 11:35:46 kyle-no-MacBook.local postgres[1120]: [879-2] 2014-02-02 11:35:46 JST DETAIL:  parameters: $1 = '-2'

続き

NativeQueryでconstructor-resultを使ってSELECTしてみる

参考文献

  1. Pro JPA 2


NativeQueryでエンティティとスカラ値を同時にSELECTしてみる


Posted on Sunday Jan 26, 2014 at 01:06PM in Technology


NativeQueryで関連持ちエンティティをSELECTしてみるの続きです。今回はエンティティとCOUNT関数の結果を同時にSELECTしてみます。

環境

  • Hibernate 4.3.0.Final
  • WildFly8.0.0.CR1
  • Oracle JDK7u51
  • postgresql-9.3-1100.jdbc41.jar
  • PostgreSQL 9.2.4

何をするか

エンティティと関連の構造は前回と同じです。

今回は部署エンティティと一緒に社員数のカウントを取ってみます。

準備

配置図

図中で選択されている資源を作成または編集します。

  • orm.xmlにNamedNativeQuery “findDeptWithCount” とResultSetMapping “deptWithCountResult” を追加します
  • EntityWithScalarSelectTestを作ります
  • テストデータは前回のを流用します

資源

orm.xml

<?xml version="1.0" encoding="UTF-8"?>
<entity-mappings version="2.1"
    xmlns="http://xmlns.jcp.org/xml/ns/persistence/orm" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence/orm http://xmlns.jcp.org/xml/ns/persistence/orm_2_1.xsd">

    <named-native-query name="findEmployee" result-set-mapping="employeeResult">
        <query><![CDATA[
            SELECT
                emp.id,
                emp.firstName,
                emp.lastName
            FROM
                Employee AS emp
        ]]></query>
    </named-native-query>

    <named-native-query name="findEmployeeWithDept" result-set-mapping="employeeResult">
        <query><![CDATA[
            SELECT
                emp.id,
                emp.firstName,
                emp.lastName,
                emp.dept_id
            FROM
                Employee AS emp
        ]]></query>
    </named-native-query>

    <named-native-query name="findDeptWithCount" result-set-mapping="deptWithCountResult">
        <query><![CDATA[
            SELECT
                dep.id,
                dep.deptName,
                COUNT(dep.id) AS employeeCount
            FROM
                Dept AS dep,
                Employee AS emp
            WHERE
                dep.id = emp.dept_id
            GROUP BY
                dep.id
        ]]></query>
    </named-native-query>

    <sql-result-set-mapping name="employeeResult">
        <entity-result entity-class="org.arquillian.example.Employee"/>
    </sql-result-set-mapping>       

    <sql-result-set-mapping name="deptWithCountResult">
        <entity-result entity-class="org.arquillian.example.Dept"/>
        <column-result name="employeeCount"/>
    </sql-result-set-mapping>       
</entity-mappings>

EntityWithScalarSelectTest.java

この環境だとCOUNT()の結果はBigIntegerになるようですが、別の環境ではLongだったりいろいろかもしれません

package org.arquillian.example;

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;

import org.jboss.arquillian.container.test.api.Deployment;
import org.jboss.arquillian.junit.Arquillian;
import org.jboss.arquillian.persistence.UsingDataSet;
import org.jboss.shrinkwrap.api.Archive;
import org.jboss.shrinkwrap.api.ShrinkWrap;
import org.jboss.shrinkwrap.api.asset.EmptyAsset;
import org.jboss.shrinkwrap.api.spec.WebArchive;
import org.junit.Test;
import org.junit.runner.RunWith;

@RunWith(Arquillian.class)
public class EntityWithScalarSelectTest {
    @Deployment
    public static Archive<?> createDeployment() {
        Archive<?> a = ShrinkWrap.create(WebArchive.class, "test.war")
            .addPackage(Employee.class.getPackage())
            .addAsResource("test-persistence.xml", "META-INF/persistence.xml")
            .addAsResource("META-INF/orm.xml", "META-INF/orm.xml")
            .addAsWebInfResource(EmptyAsset.INSTANCE, "beans.xml")
            .addAsWebInfResource("jbossas-ds.xml");
        return a;
    }

    @PersistenceContext
    EntityManager em;

    @Test
    @Transactional
    @UsingDataSet({"datasets/relativeSelect/dept.yml", "datasets/relativeSelect/employees.yml"})
    public void select() throws Exception {
        dumpEntityList(em.createNamedQuery("findDeptWithCount").getResultList());
    }

    protected void dumpEntityList(List<?> list){
        for(Object o : list){
            Object[] array = (Object[])o;
            Dept dept = (Dept) array[0];
            Number employees = (Number) array[1];
            System.out.printf("id=%d, deptName=%s, employees=%s, contains=%s\n",
                    dept.getId(), dept.getDeptName(), employees, em.contains(dept));
        }
    }
}

実行結果

13:05:40,545 INFO  [stdout] (pool-2-thread-9) Hibernate: SELECT dep.id, dep.deptName, COUNT(dep.id) AS employeeCount FROM Dept AS dep, Employee AS emp WHERE dep.id = emp.dept_id GROUP BY dep.id
13:05:40,548 INFO  [stdout] (pool-2-thread-9) id=-1, deptName=Sales, employees=2, contains=true
13:05:40,548 INFO  [stdout] (pool-2-thread-9) id=-2, deptName=Legal, employees=1, contains=true

この取り方でもちゃんとmanagedで返ってきているのがすごい。

続き

NativeQueryで複数のエンティティを1度にSELECTしてみる

参考文献

  1. Pro JPA 2