如果主键是由数据库生成的，如何使用 em.merge() 插入或更新 jpa 实体？

Question

我有一个像这样的 JPA 实体：

@Entity
@Table(name = "category")
public class Category implements Serializable {
    private static final long serialVersionUID = 1L;

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Basic(optional = false)
    @Column(name = "id")
    private Integer id;

    @Basic(optional = false)
    @Column(name = "name")
    private String name;

    @OneToMany(cascade = CascadeType.ALL, mappedBy = "category")
    private Collection<ItemCategory> itemCategoryCollection;

    //...
}

使用 Mysql 作为底层数据库。 “name”被设计为唯一的键。使用 Hibernate 作为 JPA 提供程序。

使用合并方法的问题是，因为 pk 是由 db 生成的，所以如果记录已经存在（名称已经存在），那么 Hibernate 将尝试将其插入到 db 中，我将得到一个唯一的键约束冲突异常，并且不执行更新 。有没有人有一个好的做法来处理这个问题？谢谢你！

PS：我的解决方法是这样的：

public void save(Category entity) {

    Category existingEntity = this.find(entity.getName());
    if (existingEntity == null) {
       em.persist(entity);
       //code to commit ...
    } else {
        entity.setId(existingEntity.getId());
        em.merge(entity);
        //code to commit ...
    }
}

public Category find(String categoryName) {
    try {
        return (Category) getEm().createNamedQuery("Category.findByName").
                setParameter("name", categoryName).getSingleResult();
    } catch (NoResultException e) {
        return null;

    }
}

Answer 1

如果主键是由数据库生成的，如何使用 em.merge() 插入或更新 jpa 实体？

无论您是否使用生成的标识符，IMO 都无关紧要。这里的问题是，您想要在 PK 之外的某个唯一键上实现“upsert”，而 JPA 并没有真正提供对此的支持（merge 依赖于数据库身份）。

所以你有 AFAIK 2 个选择。

首先执行 INSERT 并实现一些重试机制，以防由于违反唯一约束而失败，然后查找并更新现有记录（使用新的实体管理器）。

或者，首先执行 SELECT，然后根据 SELECT 的结果插入或更新（这就是您所做的）。这可以工作，但不能 100% 保证，因为两个并发线程之间可能存在竞争条件（它们可能找不到给定类别名称的记录并尝试并行插入；最慢的线程将失败）。如果这不太可能，这可能是一个可接受的解决方案。

更新：如果您不介意使用 MySQL 专有功能，可能还有第三个奖励选项，请参阅 12.2.5.3。 INSERT ... ON DUPLICATE KEY UPDATE 语法。但从未使用 JPA 进行过测试。

Answer 2

我之前没有看到过这一点，所以我只是想添加一个可能的解决方案来避免进行多个查询。 版本控制。

通常用作在乐观锁定场景中检查正在更新的记录是否已过时的简单方法，还可以使用 @Version 注释的列来检查记录是否是持久的（存在于数据库中）。

这一切听起来可能很复杂，但事实并非如此。它归结为记录上的一个额外列，其值在每次更新时都会发生变化。我们在数据库中定义一个额外的列版本，如下所示：

CREATE TABLE example
(
  id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
  version INT,   -- <== It really is that simple!
  value VARCHAR(255)
);

并用 @Version 标记 Java 类中的相应字段，如下所示：

@Entity
public class Example {
    @Id 
    @GeneratedValue
    private Integer id;

    @Version  // <-- that's the trick!
    private Integer version;

    @Column(length=255)
    private String value;
}

@Version 注释将使 JPA 通过包含该列来使用乐观锁定的列作为任何更新语句中的条件，如下所示：

UPDATE example 
SET value = 'Hello, World!' 
WHERE id = 23
AND version = 2  -- <-- if version has changed, update won't happen

（JPA 自动执行此操作，无需您自己编写）

然后，它检查一条记录是否已更新（按预期）（在这种情况下）该对象已过时）。

我们必须确保没有人可以设置版本字段，否则会弄乱乐观锁定，但如果需要，我们可以在 version 上创建一个 getter。我们还可以在方法 isPercient 中使用版本字段，该方法将检查记录是否已经在数据库中，而无需进行查询：

@Entity
public class Example {
    // ...
    /** Indicates whether this entity is present in the database. */
    public boolean isPersistent() {
        return version != null;
    }
}

最后，我们可以在 insertOrUpdate 中使用此方法方法：

public insertOrUpdate(Example example) {
    if (example.isPersistent()) {
        // record is already present in the db
        // update it here
    }
    else {
        // record is not present in the db
        // insert it here
    }
}