插入后选择Hibernate

Posted 2021-04-13

我在将新行插入mysql数据库时遇到问题。我正在使用Spring Boot和Spring Boot Data JPA。

由于MySQL不支持序列，我决定尝试创建自己的序列生成器表。这基本上就是我所做的。

1. 我创建了一个使用自动增量字段的sequences表（用作我的表的id）。
2. 创建了一个函数sequences_nextvalue()，它插入到sequences表中并返回新的自动递增id。
3. 然后我在每个表上创建触发器，在插入之前触发，并用调用sequences_nextvalue()的结果替换id字段。

所以这在插入新行时工作正常。我在所有桌子上都获得了独特的ID。我遇到的问题是我的JPA实体。

@Entity
@Inheritance(strategy=InheritanceType.TABLE_PER_CLASS)
public abstract class AbstractBaseClass {
  @Id
  private Integer id = -1;
  ...
}

@Entity
public class ConcreteClass1 extends AbstractBaseClass {
  ...
}


@Entity
public class ConcreteClass2 extends AbstractBaseClass {
  ...
}

我希望能够从抽象基类中进行查询，因此我将@Id列放在该类中，并将@Entity与InheritanceType.TABLE_PER_CLASS一起使用。我还将id初始化为-1，因为需要id来从我的spring crud存储库调用save()。

在调用我的Spring数据save()的CrudRepository函数之后，id的-1正确地被MySQL触发器替换，但save()返回的结果实体不会返回新的id，而是保留-1。查看SQL日志后，插入后不会调用select语句来获取新id，而是返回原始实体。

当你不使用qazxsw poi时，是否可以强制Hibernate在插入后重新选择实体以获取新的id？

任何帮助是极大的赞赏。

答案

只是想提供这个问题的最新消息。这是我的解决方案。

我没有创建MySQL @GeneratedValue来替换TRIGGER上的id，而是创建了一个Hibernate INSERT，它执行IdentifierGenerator来获取并返回一个新的id。

我的抽象基类现在看起来像这样。

CallableStatement

我的发电机看起来像这样。

@Entity
@Inheritance(strategy=InheritanceType.TABLE_PER_CLASS)
public abstract class AbstractBaseClass {

  @Id
  @GenericGenerator(name="MyIdGenerator", strategy="com.sample.model.CustomIdGenerator" )
    @GeneratedValue(generator="MyIdGenerator" )
  private Integer id;
  ...

}

---

仅供参考

public class CustomIdGenerator implements IdentifierGenerator { private Logger log = LoggerFactory.getLogger(CustomIdGenerator.class); private static final String QUERY = "{? = call sequence_nextvalue()}"; @Override public Serializable generate(SessionImplementor session, Object object) throws HibernateException { Integer id = null; try { Connection connection = session.connection(); CallableStatement statement = connection.prepareCall(QUERY); statement.registerOutParameter(1, java.sql.Types.INTEGER); statement.execute(); id = statement.getInt(1); } catch(SQLException e) { log.error("Error getting id", e); throw new HibernateException(e); } return id; } } 表。

sequences

CREATE TABLE sequences ( id INT AUTO_INCREMENT PRIMARY KEY, thread_id INT NOT NULL, created DATETIME DEFAULT CURRENT_TIMESTAMP ) ^; 功能

sequence_nextvalue