实体管理器获取或创建

Question

我如何确定对象是否已经存在而不是再次创建。

@Component
public class ProductServiceImpl implements ProductService
{
    @PersistenceContext
    private EntityManager em;

    public Product getOrCreateProduct(String productName, String peoductDescr)
    {
        Product product =(new Product (productName, peoductDescr));
        em.merge(product);
        return product;
    }
}

我是这样做的，但它仍然会继续创建新的数据库条目，而不是返回新的条目。

Answer 1

虽然 John 的答案在大多数情况下都有效，但存在多线程问题，如果两个线程同时调用 getOrCreateProduct，这可能会导致一次调用失败。如果没有，两个线程都可能会尝试查找现有产品并输入NoResultException 块。然后两者都将创建一个新产品并尝试合并它。在transaction.commit() 上，只有一个线程会成功，另一个线程将进入PersistenceException 块。

这可以通过选择使用双重检查锁定来同步您的方法（对性能有影响）来处理，或者由于您已经在使用 spring，您可以使用 spring 的 @Retryable 功能。

以下是不同方式的示例。所有方法都将是线程安全的并且可以工作。但是在性能方面getOrCreateProductWithSynchronization 将是最差的，因为它会同步每个调用。从性能的角度来看，getOrCreateProductWithDoubleCheckedLocking 和 getOrCreateProductWithRetryable 应该几乎相同。也就是说，您必须决定是使用双重检查锁定引入的额外代码复杂性还是使用纯弹簧 @Retryable 功能。

@Transactional(propagation = Propagation.REQUIRES_NEW)
public synchronized Product getOrCreateProductWithSynchronization(final String productName, final String productDescr) {

  Product product = findProduct(productName);
  if (product != null) {
    return product;
  }

  product = new Product(productName, productDescr);
  em.persist(product);

  return product;
}


@Transactional(propagation = Propagation.REQUIRES_NEW)
public Product getOrCreateProductWithDoubleCheckedLocking(final String productName, final String productDescr) {

  Product product = findProduct(productName);
  if (product != null) {
    return product;
  }

  synchronized (this) {
    product = findProduct(productName);
    if (product != null) {
      return product;
    }

    product = new Product(productName, productDescr);
    em.persist(product);
  }

  return product;
}


@Retryable(include = DataIntegrityViolationException.class, maxAttempts = 2)
@Transactional(propagation = Propagation.REQUIRES_NEW)
public Product getOrCreateProductWithRetryable(final String productName, final String productDescr) {

  Product product = findProduct(productName);
  if (product != null) {
    return product;
  }

  product = new Product(productName, productDescr);
  em.persist(product);
  return product;
}


private Product findProduct(final String productName) {
  // try to find an existing product by name or return null
}

更新： 还有一点需要注意。使用synchronized 的实现只有在您只有一个服务实例时才能正常工作。也就是说，在分布式设置中，如果在您的服务的两个或更多实例上并行调用这些方法，这些方法仍然可能会失败。 @Retryable 解决方案也将正确处理此问题，因此应该是首选解决方案。

Answer 2

由于如果产品名称、产品描述或两者一起是Product 实体的主键，您的方法应该有效，因此我得出结论认为 PK 是其他东西——可能是代理键，因为这就是 JPA被工具默认使用。如果要使用产品名称来决定是创建新的持久实体还是使用现有实体，则需要对产品名称执行搜索。像这样的东西，例如：

    public Product getOrCreateProduct(String productName, String productDescr) {
        Product product;

        try {
            TypedQuery<Product> productForName = em.createQuery(
                    "select p from Product p where p.name = ?1", Product.class);
            EntityTransaction transaction;

            productForName.setParameter(1, productName);

            /*
             * The query and any persist() operation required should be
             * performed in the same transaction.  You might, however, want
             * to be a little more accommodating than this of any transaction
             * that is already in progress.
             */
            transaction = em.getTransaction();
            transaction.begin();
            try {
                product = productForName.getSingleResult();
            } catch (NoResultException nre) {
                product = new Product(productName, productDescr);
                em.persist(product);
            }
            transaction.commit();
        } catch (PersistenceException pe) {
            // ... handle error ...
        }

        return product;
    }

请注意，如果该特定实现返回一个“托管”实体，那么它会返回一个。这可能是也可能不是您想要的。如果您想要一个分离的，那么您当然可以在返回之前手动分离它（但在这种情况下，如果它是新的，请不要忘记先冲洗它）。

您可能还希望通过对产品名称设置唯一性约束来支持这一点。