AttributeConverter 在 EclipseLink 中不工作，在 Hibernate 中工作正常答案

【问题标题】：AttributeConverter not working in EclipseLink, works fine in HibernateAttributeConverter 在 EclipseLink 中不工作，在 Hibernate 中工作正常
【发布时间】：2021-08-03 23:33:25
【问题描述】：

我想尝试一个带有转换器的简单测试用例。不幸的是，它不适用于 payara 5。它适用于 Wildfly 20.0.1。数据库是 H2。

pom.xml

<project
    xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
        http://maven.apache.org/xsd/maven-4.0.0.xsd"
>
    <modelVersion>4.0.0</modelVersion>
    <groupId>fjp</groupId>
    <artifactId>converter</artifactId>
     <version>1.0</version>
    <packaging>war</packaging>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <maven.compiler.source>11</maven.compiler.source>
        <maven.compiler.target>11</maven.compiler.target>
        <failOnMissingWebXml>false</failOnMissingWebXml>
    </properties>

    <dependencies>
        <dependency>
            <groupId>jakarta.platform</groupId>
            <artifactId>jakarta.jakartaee-api</artifactId>
            <version>8.0.0</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>
</project>

persistence.xml

    <?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.2"
    xmlns="http://xmlns.jcp.org/xml/ns/persistence"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence
        http://xmlns.jcp.org/xml/ns/persistence/persistence_2_2.xsd"
>
    <persistence-unit name="primary" transaction-type="JTA">
        <!--jta-data-source>java:/TestDS</jta-data-source-->
        <jta-data-source>jdbc/TestDS</jta-data-source>
        <class>fjp.converter.entity.Employee</class>
        <class>fjp.converter.entity.converter.StatusConverter</class>
        <exclude-unlisted-classes>true</exclude-unlisted-classes>
        <properties>
            <property name="javax.persistence.schema-generation.database.action" value="drop-and-create" />
            <property name="eclipselink.logging.level.sql" value="FINE"/>
            <property name="eclipselink.logging.parameters" value="true"/>
             <property name="hibernate.show_sql" value="true"/>
        </properties>
    </persistence-unit>
</persistence>

道：

package fjp.converter.dao;    
import java.util.List;   
import fjp.converter.entity.Employee;

public interface EmployeeDAO {
    public Employee find(long i);
    public void create(Employee e);
    public void delete(Employee e);
    public void delete(long i);
    public List<Employee> findByStatus(Employee.Status status);
}

DAOImpl

package fjp.converter.dao;    
import java.util.List;    
import javax.ejb.Stateless;
import javax.persistence.PersistenceContext;
import javax.persistence.EntityManager;
import fjp.converter.entity.Employee;

@Stateless
public class EmployeeDAOImpl implements EmployeeDAO {
    @PersistenceContext
    private EntityManager em;

    public Employee find(long i) {
        return em.find(Employee.class, i);
    }
    @Override
    public void create(Employee e) {
        em.persist(e);
    }
    @Override
    public void delete(long i) {
        var e = this.find(i);
        if(e != null) em.remove(e);
    }
    @Override
    public void delete(Employee e) {
        if(e == null) return;
        delete(e.getId());
    }

    @Override
    public List<Employee> findByStatus(Employee.Status status) {
        return em.createNamedQuery("Employee.findByStatus", Employee.class)
            .setParameter("status", status)
            .getResultList();
    }
}

实体：

package fjp.converter.entity;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.AttributeConverter;
import javax.persistence.Convert;
import javax.persistence.NamedQuery;  
import java.io.Serializable;

@NamedQuery(name="Employee.findByStatus", query="select e from Employee e where e.status=:status")
@Entity
public class Employee implements Serializable{

    public enum Status {
        SENIOR("SENIOR"),
        JUNIOR("JUNIOR");
        private String code;
        private Status(String s) {
            this.code = s;
        }
        public String getCode() {
            return this.code;
        }
    }

    @Id
    private long id;
    @Convert(converter = fjp.converter.entity.converter.StatusConverter.class)
    private Status status;

    public long getId() {
        return id;
    }
    public void setId(long id) {
        this.id = id;
    }
    public Status getStatus() {
        return this.status;
    }
    public void setStatus(Status s) {
        this.status = s;
    }

    @Override
    public String toString() {
        return String.format("id=%d, status=%s", id, status == null ? null : status.getCode());
    }
}

转换器：

package fjp.converter.entity.converter;    
import javax.persistence.Converter;
import javax.persistence.AttributeConverter;    
import fjp.converter.entity.Employee.Status;

@Converter
public class StatusConverter implements AttributeConverter<Status, String> {
    @Override
    public String convertToDatabaseColumn(Status e) {
        return e == null ? null : e.getCode();
    }
    @Override
    public Status convertToEntityAttribute(String s) {
        if(s == null) return null;
        switch(s) {
            case "SENIOR": return Status.SENIOR;
            case "JUNIOR": return Status.JUNIOR;
            default: return null;
        }
    }
}

小服务程序

package fjp.converter.servlet;    
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServlet;    
import fjp.converter.dao.EmployeeDAO;
import fjp.converter.entity.Employee;
import fjp.converter.entity.Employee.Status;
import javax.inject.Inject;

@WebServlet("/test")
public class Test extends HttpServlet {
    @Inject
    private EmployeeDAO dao;

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) {
        Employee e = new Employee();
        long id = 1;
        dao.delete(id);
        e.setId(id);
        e.setStatus(Status.SENIOR);
        dao.create(e);

        id = 2;
        dao.delete(id);
        e.setId(id);
        e.setStatus(Status.JUNIOR);
        dao.create(e);

        Status status = Status.SENIOR;
        var list = dao.findByStatus(status);
        for(var o : list) {
            System.out.println(o);
            if(o.getStatus() != status) {
                System.out.println("ERROR !!!!!");
            }
        }
        status = Status.JUNIOR;
        list = dao.findByStatus(status);
        for(var o : list) {
            System.out.println(o);
            if(o.getStatus() != status) {
                System.out.println("ERROR !!!!!");
            }
        }
    }
}

第一次询问 servlet 时会收到错误消息：

[2021-05-13T19:08:07.512+0200] [Payara 5.2021.3] [PRÉCIS] [] [org.eclipse.persistence.session./file:/home/frederic/payara5/glassfish/domains/domain1/applications/converter-1.0/WEB-INF/classes/_primary.sql] [tid: _ThreadID=76 _ThreadName=http-thread-pool::http-listener-1(5)] [timeMillis: 1620925687512] [levelValue: 500] [[
  SELECT ID, STATUS FROM EMPLOYEE WHERE (STATUS = ?)
    bind => [SENIOR]]]

[2021-05-13T19:08:07.514+0200] [Payara 5.2021.3] [INFOS] [] [] [tid: _ThreadID=76 _ThreadName=http-thread-pool::http-listener-1(5)] [timeMillis: 1620925687514] [levelValue: 800] [[
  id=2, status=JUNIOR]]

[2021-05-13T19:08:07.514+0200] [Payara 5.2021.3] [INFOS] [] [] [tid: _ThreadID=76 _ThreadName=http-thread-pool::http-listener-1(5)] [timeMillis: 1620925687514] [levelValue: 800] [[
  ERROR !!!!!]]

如果你刷新页面：它会爆炸！

    Local Exception Stack: 
Exception [EclipseLink-4002] (Eclipse Persistence Services - 2.7.7.payara-p3): org.eclipse.persistence.exceptions.DatabaseException
Internal Exception: org.h2.jdbc.JdbcSQLException: Violation dindex unique ou clé primaire: {0}
Unique index or primary key violation: {0}; SQL statement:
INSERT INTO EMPLOYEE (ID, STATUS) VALUES (?, ?) [23505-197]

【问题讨论】：

不清楚您真正看到的是什么 - 为什么您认为这是转换器的问题？发出查询时数据库中的数据是什么？尝试将 EclipseLink 日志记录到 ALL 并完全显示它发出的所有 SQL 以及在部署和处理持久性单元时可能遇到的警告和问题。重试时 pk 违规的问题表明这未正确连接到事务中，因此在尝试插入时未执行和提交删除语句。
查询都正确。

标签： jpa eclipselink converters

【解决方案1】：

问题是您在以 JPA 规范不允许的方式调用persist 之后编辑对象。这里发生的是您首先创建 Employee e 并设置其 ID 和状态（1，SENIOR），然后在此实例上调用 persist。

然后您更改 e (2, JUNIOR) 上的 id 和状态值，并再次在同一个实例上调用 persist。实例 E 虽然已经被持久化，所以它被忽略了。当您查询状态 SENIOR 时，EclipseLink 将查询并找到匹配的行 (1, SENIOR)，但是当它去缓存查看是否已经有数据时，它会找到您的 'e' 实例等只是返回。您的应用程序记录了一个错误，因为您已将 e 的状态更改为 JUNIOR。

为了证明正在发生的事情 - 尝试列出数据库中的内容。

解决方案只是创建第二个 Employee 实例来表示 (2,JUNIOR) 数据。

JPA 提供程序的一些不同之处在于 EclipseLink 默认会维护 1 级和 2 级缓存。这会干扰这种情况，因为您正在以 JPA 规范中不允许的方式修改对象，并且 EclipseLink 记住数据的时间比没有缓存的时间长。您不能在 JPA 中修改主键。

【讨论】：

你是对的。如果我创建一个新员工而不是重用它，它就可以工作。但是，我的 servlet 中的 Employee 是分离的，我应该能够重用它，如果我愿意，可以更改它的 id。我尝试添加基于 id 的 equals 方法，但如果我重用 Employee，该错误仍然存在。对我来说不可接受的是要求一个状态（比如 JUNIOR）却没有得到它！这是一个 AssertionError。
它没有分离，这就是重点。不要在 EclipseLink 中使用从一个持久性到另一个持久性的管理实体，因为它具有允许它更有效地跟踪更改和缓存差异的钩子，这将导致类似的行为。正确的做法是使用不同的实例来表示不同的实例数据。您正在获取代表数据库中行的实例，您刚刚损坏了它，因此您看到的数据不再是数据库中的数据了。

【解决方案2】：

如果我添加到 persistence.xml 就可以了：

<shared-cache-mode>ENABLE_SELECTIVE</shared-cache-mode>

因此您可以重复使用 Employe，但要注意二级缓存。

【讨论】：