java - エンティティ Bean への挿入時に @Id が自動的に設定されない

Question

私はかなり単純なEJBアプリケーションを持っています.

1 つのエンティティ Bean:

import java.io.Serializable;
import java.util.Date;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

@Entity
public class Employee implements Serializable {

private static final long serialVersionUID = -8450766960140252704L;

@Id
@GeneratedValue(strategy=GenerationType.IDENTITY)
@Column(name="employee_number", nullable=false)
private int employeeNumber;
private String firstname;
private String inital;
private String lastname;
private int age;
private Date birthday;
private String street;
@Column(name="house_number")
private String houseNumber;
private String postalcode;
private String city;
private String department;
@Column(name="sallery_group")
private String salleryGroup;

public int getEmployeeNumber() {
    return employeeNumber;
}
public void setEmployeeNumber(int employeeNumber) {
    this.employeeNumber = employeeNumber;
}
public String getFirstname() {
    return firstname;
}
public void setFirstname(String firstname) {
    this.firstname = firstname;
}
public String getInital() {
    return inital;
}
public void setInital(String inital) {
    this.inital = inital;
}
public String getLastname() {
    return lastname;
}
public void setLastname(String lastname) {
    this.lastname = lastname;
}
public int getAge() {
    return age;
}
public void setAge(int age) {
    this.age = age;
}
public Date getBirthday() {
    return birthday;
}
public void setBirthday(Date birthday) {
    this.birthday = birthday;
}
public String getStreet() {
    return street;
}
public void setStreet(String street) {
    this.street = street;
}
public String getHouseNumber() {
    return houseNumber;
}
public void setHouseNumber(String houseNumber) {
    this.houseNumber = houseNumber;
}
public String getPostalcode() {
    return postalcode;
}
public void setPostalcode(String postalcode) {
    this.postalcode = postalcode;
}
public String getCity() {
    return city;
}
public void setCity(String city) {
    this.city = city;
}
public String getDepartment() {
    return department;
}
public void setDepartment(String department) {
    this.department = department;
}
public String getSalleryGroup() {
    return salleryGroup;
}
public void setSalleryGroup(String salleryGroup) {
    this.salleryGroup = salleryGroup;
}

@Override
public String toString() {

    StringBuffer sb = new StringBuffer();

    sb.append("Employee Number: " + this.getEmployeeNumber() + "\n");
    sb.append("Firstname: " + this.getFirstname() + "\n");
    sb.append("Inital: " + this.getInital() + "\n");
    sb.append("Lastname: " + this.getLastname() + "\n");
    sb.append("Age: " + this.getAge() + "\n");
    sb.append("Birthday: " + this.getBirthday() + "\n");
    sb.append("Street: " + this.getStreet() + "\n");
    sb.append("House Number: " + this.getHouseNumber() + "\n");
    sb.append("Postalcode: " + this.getPostalcode() + "\n");
    sb.append("City: " + this.getCity() + "\n");
    sb.append("Department: " + this.getDepartment() + "\n");
    sb.append("Sallery Group: " + this.getSalleryGroup() + "\n");

    return sb.toString();
}

@Override
public boolean equals(Object obj) {

    if(obj == null || this.getClass() != obj.getClass())
    {
        return false;
    }
    else if (obj == this)
    {
        return true;
    }
    else
    {
        Employee employee = (Employee)obj;
        return (
               ((this.getFirstname() == null && employee.getFirstname() == null) || (this.getFirstname().equals(employee.getFirstname()))) &&
               ((this.getInital() == null && employee.getInital() == null) || (this.getInital().equals(employee.getInital()))) &&
               ((this.getLastname() == null && employee.getLastname() == null) || (this.getLastname().equals(employee.getLastname()))) &&
               this.getAge() == employee.getAge() &&
               ((this.getBirthday() == null && employee.getBirthday() == null) || (this.getBirthday().equals(employee.getBirthday()))) &&
               ((this.getStreet() == null && employee.getStreet() == null) || (this.getStreet().equals(employee.getStreet()))) &&
               ((this.getHouseNumber() == null && employee.getHouseNumber() == null) || (this.getHouseNumber().equals(employee.getHouseNumber()))) &&
               ((this.getPostalcode() == null && employee.getPostalcode() == null) || (this.getPostalcode().equals(employee.getPostalcode()))) &&
               ((this.getCity() == null && employee.getCity() == null) || (this.getCity().equals(employee.getCity()))) &&
               ((this.getDepartment() == null && employee.getDepartment() == null) || (this.getDepartment().equals(employee.getDepartment()))) &&
               ((this.getSalleryGroup() == null && employee.getSalleryGroup() == null) || (this.getSalleryGroup().equals(employee.getSalleryGroup()))));

    }
}

}

1 つのセッション Bean

import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;

@Stateless
public class EmployeeManagementBean implements EmployeeManagement {

@PersistenceContext(unitName="EmployeePersistenceUnit")
private EntityManager entityManager;

@Override
public Employee create() {
    return new Employee();  
}

@Override
public void store(Employee employee) {
    entityManager.persist(employee);
}

@Override
public Employee findEmployeeWithNumber(int employeeNumber) {
    return entityManager.find(Employee.class, employeeNumber);
}

}

私のクライアントでは、セッション Bean で create() を呼び出すだけで、私の場合は employeeNumber である id フィールドを除くすべてのプロパティを設定します。その後、store() を呼び出して、オブジェクトをセッション Bean に渡します。その後、オブジェクトはデータベースに適切に格納され、主キーは mysql データベースによって自動的に生成されます。

問題

私の問題は、生成された ID がオブジェクトに返されないことです。したがって、store() を呼び出した後、entityManager.persist() を呼び出した後、getEmployeeNumber() の呼び出しは常に 0 を返します。Web で読んだ多くのことによると、@Id フィールドには、データベースによって生成された ID が自動的に入力されるはずです。うまくいけば、誰かが私を助けてくれます。entityManager.flush() は問題を解決しません。

詳細

JBoss 7.1.0 と MySQL 5.6 を使用しています。MySQL JDBC Driver は、デプロイメントフォルダーに配置されます。

persistence.xml

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0" xmlns="http://java.sun.com/xml/ns/persistence"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence 
http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">

<persistence-unit name="EmployeePersistenceUnit" transaction-type="JTA">
    <provider>org.hibernate.ejb.HibernatePersistence</provider>
    <jta-data-source>java:jboss/datasources/MySQLEmployeeManagementDS</jta-data-source>
</persistence-unit>

スタンドアロン.xml

<datasource jndi-name="java:jboss/datasources/MySQLEmployeeManagementDS" pool-name="MySQLEmployeeManagementDS" enabled="true" jta="true" use-java-context="true" use-ccm="true">
                <connection-url>
                    jdbc:mysql://localhost:3306/employee_management
                </connection-url>
                <driver>
                    mysql-connector-java-5.1.25.jar
                </driver>
                <pool>
                    <min-pool-size>
                        10
                    </min-pool-size>
                    <max-pool-size>
                        100
                    </max-pool-size>
                    <prefill>
                        true
                    </prefill>
                    <use-strict-min>
                        false
                    </use-strict-min>
                    <flush-strategy>
                        FailingConnectionOnly
                    </flush-strategy>
                </pool>
                <security>
                    <user-name>
                        root
                    </user-name>
                    <password>
                        test
                    </password>
                </security>
            </datasource>
            <drivers>
                <driver name="mysql-connector-java-5.1.25.jar" module="com.mysql">
                    <xa-datasource-class>
                        com.mysql.jdbc.jdbc2.optional.MysqlXADataSource
                    </xa-datasource-class>
                </driver>
            </drivers>

テーブル

CREATE TABLE `employee` (
`employee_number` int(11) NOT NULL AUTO_INCREMENT,
`firstname` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
`inital` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
`lastname` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
`age` int(11) DEFAULT NULL,
`birthday` datetime DEFAULT NULL,
`street` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
`house_number` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
`postalcode` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
`city` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
`department` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
`sallery_group` varchar(128) COLLATE utf8_unicode_ci DEFAULT NULL,
PRIMARY KEY (`employee_number`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8

score 1 · Accepted Answer

あなたが観察した行動は正しいと思います。GenerationType.IDENTITY または GenerationType.SEQUENCE 戦略を使用する場合、行が挿入される前に id 値は不明です。

エンティティを永続化した直後にその値が必要な場合は、EntityManager.flush() を呼び出してデータベースとの同期を強制し、オブジェクトを取得する必要があります。その時点で ID が設定されます。

find メソッドではなく、HQL クエリを使用することもできます。

Query q = em.createQuery("select e from Employee where e.id = :id");
q.setId(employeeNumber);
return q.getSingleResult()

リモートインターフェースで EJB を使用すると、別の問題が発生する可能性があります。以下の流れを想定

クライアント側で EmployeeManagementBean.create() を呼び出すと、クライアント側で Employee オブジェクトが取得されます。これを e1 と呼びましょう。
クライアント側で EmployeeManagementBean.store(e1) を呼び出します
クライアント側で e1.getEmployeeNumber() を呼び出すと、0 が返されます

問題は以下です。EmployeeManagementBean.store(e1) を呼び出すと、e1 オブジェクトのコピーが EJB メソッドに渡されます。オブジェクトはサーバー側で変更されますが、クライアント側の元のオブジェクトは変更されません。これは、リモート EJB の呼び出し中に、引数が元のオブジェクトのシリアル化されたコピーとしてサーバーに渡されるためです。

そのため、サーバー側でのリモート変更 (ID の変更など) は、クライアント側では表示されません。

これを克服するために、次のように保存方法を変更できます。

public Employee store(Employee employee) {
    entityManager.persist(employee);
    entityManager.flush();
    return employee; //employee should have id set to the DB value
}

java - エンティティ Bean への挿入時に @Id が自動的に設定されない

1 に答える 1

Related

Reference