使用JPA+JTA的无状态web服务:如何提交被管理实体的更改

Question

我有以下简单的web服务声明为@Stateless EJB运行在GlassFish 3.1.2.2与EclipseLink 2.4.1使用JTA DataSource连接到MySQL数据库:

@POST
@Consumes(MediaType.APPLICATION_JSON)
public Response update(TimeRow e) throws Exception {
    if ((e.getKey() == null) || !e.getKey().keyValid()) {
        return Response.status(400).build();
    }
    TimeRow existing = em.find(TimeRow.class, e.getKey());
    if (existing == null) {
        em.persist(e);
    } else {
        existing.setValues(e.getValues());
        em.flush();
    }
    return Response.status(204).build();
}

TimeRow的实体类:

@Entity
@NamedQueries({
    @NamedQuery(name="TimeRow.findAllByUser",
         query="SELECT t FROM TimeRow t WHERE t.table.userId = :uid")
})
public class TimeRow implements Serializable {
    @EmbeddedId
    private TimeRowPK key;
    @MapsId("userId")
    @JoinColumn(name = "USERID", referencedColumnName = "userId")
    @ManyToOne
    private UserTable table;
    @Column(name="ROWVALUES")
    private List<Double> values;
    public TimeRow() {
        this.key = new TimeRowPK();
        this.values = new ArrayList<Double>(20);
        extendValuesTo20();
    }
    public TimeRow(String uid, Date date) {
        this.key = new TimeRowPK(date, uid);
        this.table = new UserTable(uid);
        this.values = new ArrayList<Double>(20);
        extendValuesTo20();
    }
    public List<Double> getValues() {
        return values;
    }
    public void setValues(List<Double> values) {
        this.values = values;
        extendValuesTo20();
    }
    private void extendValuesTo20() {
        if (this.values.size() < 20) {
             for (int i = this.values.size(); i < 20; i++) {
                  this.values.add(0.0);
             }
        }
    }
}

@EmbeddableId TimeRowPK:

@Embeddable
public class TimeRowPK implements Serializable {
    public TimeRowPK() { }
    public TimeRowPK(Date date, String userId) {
        this.date = date;
        this.userId = userId;
    }
    @Column(name="DAY")
    private Date date;
    @Column(name = "USERID")
    private String userId;
    public boolean keyValid() {
        return ((date != null) && ((userId != null) && !userId.isEmpty()));
    }
}

persistence.xml(不含<persistence>标签):

<persistence-unit name="test" transaction-type="JTA">
    <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
    <jta-data-source>jdbc/test</jta-data-source>
    <class>com.test.TimeRow</class>
    <class>com.test.TimeRowPK</class>
    <class>...</class>
    <properties>
        <property name="eclipselink.ddl-generation" value="create-tables" />
        <property name="eclipselink.ddl-generation.output-mode" value="database" />
    </properties>
</persistence-unit>

Webservice声明:

@Path("row")
@Stateless
public class TimeRowWebService {
    @PersistenceContext(unitName = "test")
    private EntityManager em;
    ...
}

问题是，如果实体存在，则更改仅存储在PersistenceContext中，但不会提交到数据库。这意味着我可以通过更改检索正确的数据，但是如果重新启动应用服务器，更改就会消失。AS日志中没有错误。

所以我想我必须做一些bean级别的手动事务处理来完成这项工作。我到底需要添加什么才能使它工作?

Answer 1

在努力以@EmbeddedId方式获得此工作后，我试图通过使用生成的@Id来实现它，并在之后为两个关键字段添加唯一的约束。

实体

public class TimeRow implements Serializable {
    @Id
    @GeneratedValue
    private long id;
    @JoinColumn(name = "USERID", referencedColumnName = "USERID")
    @ManyToOne(optional = false)
    private UserTable table;
    @Basic(optional = false)
    @Column(name = "DAY")
    @Temporal(TemporalType.DATE)
    private Date date;
    @Lob
    @Column(name="ROWVALUES")
    private List<Double> values;
    ...
}

此外，我已经将DB引擎从MyISAM更改为InnoDB，以获得更好的外键支持。为此，我在[mysqld]部分下将default-storage-engine = innodb添加到/etc/mysql/my.cnf。

在用DDL生成DB结构之后，我为USERID和DAY添加了一个唯一的约束:

alter table TIMEROW add unique index(USERID,DAY);

现在它工作了，数据被正确修改:)非常感谢每个对这个问题做出贡献的人!

Answer 2

也许问题就在这里:

public void setValues(List<Double> values) {
    this.values = values;
    extendValuesTo20();
}

尝试使用容器的列表，如:

public void setValues(List<Double> values) {
    this.values.clear();
    this.values.addAll(values);
    extendValuesTo20();
}

而且，这是JPA的一个非常奇怪的用法。我从来没有见过没有@ElementCollection