java - Hibernate合并产生新行而不是更新

Question

我正在使用Hibernate-EntityManager version 4.3.5。我有多个表使用带有生成值的ID。

插入和这样的工作很好，但是当我尝试合并Hibernate不更新旧行并创建新的。

内容相同，但id正在递增。

合并前：

合并后：

我试图用一个自定义的ID生成器来检查ID已存在。有了这个新的策略，我得到以下错误：

Caused by: java.sql.SQLException: Field 'product_id' doesn't have a default value 
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1094) 
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4226) 
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4158) 
at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2615) 

编辑：

我发现@GeneratedValues不会将IDS中的局部变量。这意味着您可以在合并时覆盖现有的。虽然，这并没有解决我的问题。

这里是我使用的代码：

@Entity(name = "calculation_storage") 
@Proxy(lazy = false) 
public class CalculationStorage { 

@Id 
private Date created; 

@OneToMany(mappedBy = "storage", fetch = FetchType.EAGER, cascade = CascadeType.ALL) 
private List<Product> products; 

public CalculationStorage(Date created) { 
    this.created = created; 
    this.products = new LinkedList<Product>() { 
     @Override 
     public boolean add(Product product) { 
      product.setStorage(CalculationStorage.this); 
      return super.add(product); 
     } 
    }; 
} 

public CalculationStorage(Date created, List<Product> products) { 
    this.created = created; 
    this.products = products; 
} 

public CalculationStorage() { 
} 

public Date getCreated() { 
    return created; 
} 

public void setCreated(Date created) { 
    this.created = created; 
} 

/** 
* Durch das aufrufen get add Methode wird der benoetigte Fremdschluesseleintrag gesetzt 
* 
* @return Alle Produkte die registriert sind 
*/ 
public List<Product> getProducts() { 
    return products; 
} 

public void setProducts(List<Product> entities) { 
    this.products = entities; 
} 

PRODUKT：

@Entity(name = "product") 
public class Product implements Serializable { 

@Id 
@Column(name = "product_id") 
//@GeneratedValue 
@GeneratedValue(strategy=GenerationType.IDENTITY, generator="IdOrGenerated") 
@GenericGenerator(name="IdOrGenerated", 
     strategy="at.iktopia.firmenverwaltung.abendabrechnung.control.hibernate.ProductIdGenerator" 
) 
private int id; 

private double costs; 

private String name; 

private ProductType type; 

@OneToMany(mappedBy = "product", fetch = FetchType.EAGER, cascade = CascadeType.ALL) 
private List<CalculatorEntity> entities; 

@ManyToOne 
@JoinColumn(name = "product_fk", nullable = false) 
private CalculationStorage storage; 

public Product(String name, ProductType type, double costs) { 
    this.name = name; 
    this.type = type; 
    this.costs = costs; 
    this.entities = new LinkedList<>(); 
} 

/** 
* JPA - Konstruktor 
*/ 
public Product() { 
} 

public int getId() { 
    return id; 
} 

public void setId(int id) { 
    this.id = id; 
} 

public String getName() { 
    return name; 
} 

public void setName(String name) { 
    this.name = name; 
} 

public ProductType getType() { 
    return type; 
} 

public void setType(ProductType type) { 
    this.type = type; 
} 

public List<CalculatorEntity> getEntities() { 
    return entities; 
} 

public void setEntities(List<CalculatorEntity> entities) { 
    this.entities = entities; 
} 

public double getCosts() { 
    return costs; 
} 

public void setCosts(double costs) { 
    this.costs = costs; 
} 

public CalculationStorage getStorage() { 
    return storage; 
} 

public void setStorage(CalculationStorage calculationStorage) { 
    this.storage = calculationStorage; 
} 
} 

发电机：

public class ProductIdGenerator extends IdentityGenerator { 
@Override 
public Serializable generate(SessionImplementor session, Object obj) throws HibernateException { 
    if (obj == null) throw new HibernateException(new NullPointerException()); 

    if ((((Product) obj).getId()) == 0) return super.generate(session, obj); 

    else return ((Product) obj).getId(); 
} 
} 

被称为合并对象的更新方法：

public class CalculationManager implements Manager<CalculationStorage, Date, CalculationStorageList> { 

/** 
* @see Manager#save(Object) 
*/ 
@Override 
public void save(CalculationStorage calculationStorage) { 
    Validate.notNull(calculationStorage); 

    EntityManager em = PersistenceManager.getInstance().getEntityManager(); 
    EntityTransaction transaction = em.getTransaction(); 

    transaction.begin(); 

    try { 
     em.persist(calculationStorage); 
     transaction.commit(); 
    } catch (Exception e) { 
     ErrorHandler.handleException(e, JPA_PERSIST_ERROR_MESSAGE); 
     if (transaction.isActive()) 
      transaction.rollback(); 
    } 

    em.close(); 
} 

/** 
* @see Manager#update(Object) 
*/ 
@Override 
public void update(CalculationStorage calculations) { 
    Validate.notNull(calculations); 

    EntityManager em = PersistenceManager.getInstance().getEntityManager(); 
    EntityTransaction transaction = em.getTransaction(); 

    transaction.begin(); 

    try { 
     CalculationStorage c = em.getReference(CalculationStorage.class, calculations.getCreated()); 
     c.setProducts(calculations.getProducts()); 

     em.merge(c); 

     transaction.commit(); 
    } catch (EntityNotFoundException e) { 
     if (transaction.isActive()) 
      transaction.rollback(); 
     save(calculations); 
    } catch (Exception e) { 
     ErrorHandler.handleException(e, JPA_PERSIST_ERROR_MESSAGE); 
     if (transaction.isActive()) 
      transaction.rollback(); 
    } 

    em.close(); 
} 

/** 
* @see Manager#getAll() 
*/ 
@Override 
public CalculationStorageList getAll() { 
    EntityManager em = PersistenceManager.getInstance().getEntityManager(); 

    List<CalculationStorage> calculations; 

    try { 
     calculations = em.createQuery("SELECT c FROM calculation_storage c").getResultList(); 
    } catch (Exception e) { 
     ErrorHandler.handleException(e, JPA_LOAD_ERROR_MESSAGE); 
     return null; 
    } 

    em.close(); 

    return new CalculationStorageList(calculations); 
} 

/** 
* @see Manager#remove(Object) 
*/ 
@Override 
public void remove(Date primaryKey) { 
    Validate.notNull(primaryKey); 

    EntityManager em = PersistenceManager.getInstance().getEntityManager(); 
    EntityTransaction transaction = em.getTransaction(); 

    transaction.begin(); 

    try { 
     em.remove(em.getReference(CalculationStorage.class, primaryKey)); 
     transaction.commit(); 
    } catch (Exception e) { 
     ErrorHandler.handleException(e, JPA_PERSIST_ERROR_MESSAGE); 
     if (transaction.isActive()) 
      transaction.rollback(); 
    } 

    em.close(); 
} 

/** 
* @see Manager#get(Object) 
*/ 
@Override 
public CalculationStorage get(Date primaryKey) { 
    Validate.notNull(primaryKey); 

    EntityManager em = PersistenceManager.getInstance().getEntityManager(); 

    try { 
     CalculationStorage storage = em.getReference(CalculationStorage.class, primaryKey); 
     em.close(); 
     return storage; 
    } catch (Exception e) { 
     ErrorHandler.handleException(e, JPA_LOAD_ERROR_MESSAGE); 
     return null; 
    } 
} 
} 

我无能为力可能会导致此问题。

Answer 1

只是试图看到这一点：http://www.programmingforfuture.com/2011/02/hibernate-merge-may-insert-new-record.html

它可以帮助你。

Answer 2

好的，我找到了解决方案。由于很多Kulbhushan辛格谁使我了解这一点：

我用我的代码@GeneratedValue：

@Id 
@Column(name = "product_id") 
@GeneratedValue 
private int id; 

什么我不知道的是，使用@GeneratedValue当只有数据库条目得到ID。本地对象将具有与以前相同的ID。 （默认为0）。在我而言这将意味着product_id在数据库中1，2，3，...在我的对象是0

当我试图更新我的目标，我做了以下内容：

CalculationStorage dbReference = em.getReference(CalculationStorage.class, calculations.getCreated()); 
dbReference.setProducts(localStorageObject.getProducts()); 

我基本上将数据库中生成的ID设置回0，因为我的本地对象中ID仍然为0。

由于我将Id设置回0，数据库生成新的ID。

编辑：显然，如果你重新启动你的应用程序，本地ID值将再次为0。所以当你需要的时候，尝试从数据库中提取数据，并在完成后让垃圾收集器拥有它。