美文网首页互联网科技Spring-Bootjava高级开发群
如何在Hibernate中通过saveAll或EntityMan

如何在Hibernate中通过saveAll或EntityMan

作者: Java高级架构狮 | 来源:发表于2019-01-30 14:59 被阅读4次

    默认情况下,100个插入将导致100个SQL INSERT语句,这很糟糕,因为它导致100次数据库往返。

    批处理机制能够使用分组的机制INSERTs,UPDATEs,并DELETEs,作为一个结果,它显著减少数据库往返次数。实现批量插入的一种方法是使用SimpleJpaRepository#saveAll(Iterable< S> entities)方法。在这里,我们用MySQL做到这一点。

    关键点:

    • 在application.properties中设置spring.jpa.properties.hibernate.jdbc.batch_size
    • 在application.properties中设置spring.jpa.properties.hibernate.generate_statistics(只是为了检查批处理是否正常)
    • 在application.properties,设置JDBC URL中rewriteBatchedStatements=true (特定于MySQL的优化)
    • 在application.properties设置 JDBC URL使用cachePrepStmts=true(启用缓存,如果您决定设置prepStmtCacheSize, 则也很有用prepStmtCacheSqlLimit;等等;如果没有此设置,则禁用缓存)
    • 在application.properties设置 JDBC URL中useServerPrepStmts=true(通过这种方式切换到服务器端预处理语句(可能会显着提升性能))
    • 在实体中,使用指定的生成器,因为MySQL IDENTITY将导致批处理被禁用
    • 在实体中,添加@Version类型的属性Long以避免SELECT在批处理之前额外触发(还防止在多请求事务中丢失更新)。额外的SELECTs是使用merge()而不是使用的效果persist()。在幕后,saveAll()使用save(),在非新实体(具有ID)的情况下将调用merge(),其指示Hibernate触发SELECT语句以确保数据库中没有具有相同标识符的记录。
    • 注意传递给的插入数量saveAll()不要“压倒”持久化上下文。通常情况下,EntityManager应该不时地刷新和清除,但是在saveAll()执行期间,你根本无法做到这一点,所以如果saveAll()有一个包含大量数据的列表,那么所有数据都将达到持久化上下文(第一级缓存)并且在内存中直到到达flush时间。使用相对少量的数据应该没问题。对于大量数据,请查看下一个示例。

    通过MySQL(或其他RDBMS)中的JpaContext/EntityManager批量插入

    使用批处理应该会提高性能,但在flush之前要注意持久化上下文中存储的数据量。在内存中存储大量数据可能会再次导致性能下降。上面一阶非常适合相对少量的数据。

    EntityManager在MySQL(或其他RDBMS)中实现批量插入。这样您就可以轻松控制flush()和clear()持久化上下文(第一级缓存)。这不可能通过Spring Boot,saveAll(Iterable< S>entities)来实现。另一个优点是你可以调用persist()而不是merge(),Spring Boot在saveAll(Iterable< S> entities)和save(S entity)背后使用的方法。

    关键点:

    • 在application.properties,设置spring.jpa.properties.hibernate.jdbc.batch_size
    • 在application.properties,设置spring.jpa.properties.hibernate.generate_statistics(只是为了检查批处理是否正常)
    • 在application.properties设置JDBC URL中rewriteBatchedStatements=true (特定于MySQL的优化)
    • 在application.properties设置 JDBC URL中使用cachePrepStmts=true(启用缓存,如果您决定设置prepStmtCacheSize, 则也很有用 prepStmtCacheSqlLimit;等等;如果没有此设置,则禁用缓存)
    • 在application.properties设置 JDBC URL中useServerPrepStmts=true(通过这种方式切换到服务器端预处理语句(可能会显着提升性能))
    • 在实体中,使用指定的生成器, 因为MySQL IDENTITY将导致批处理被禁用
    • 在DAO中,不时刷新并清除持久性上下文。这样,您就可以避免“压跨”持久化上下文。

    MySQL中的会话级批处理(Hibernate 5.2或更高版本)

    通过MySQL中的Hibernate会话级批处理(Hibernate 5.2或更高版本)批量插入。

    关键点:

    • 在application.properties中设置spring.jpa.properties.hibernate.generate_statistics(只是为了检查批处理是否正常)
    • 在application.properties中设置JDBC URL rewriteBatchedStatements=true(MySQL的优化)
    • 在application.properties中设置JDBC URL cachePrepStmts=true(启用缓存,如果你决定则很有用)设置prepStmtCacheSize,prepStmtCacheSqlLimit等等;没有这个设置,缓存被禁用)
    • 在application.properties中设置JDBC URL useServerPrepStmts=true(这样你切换到服务器端预处理语句(可能会导致显着的性能提升))
    • 如果使用具有级联持久性的父子关系(例如,一对多,多对多)然后考虑spring.jpa.properties.hibernate.order_inserts=true通过排序插入来设置优化批处理
    • 在实体中,使用分配生成器,因为MySQL IDENTITY将导致批处理被禁用
    • Hibernate Session是通过解包来获得的EntityManager#unwrap(Session.class)
    • 批处理大小是通过 DAO 设置Session#setJdbcBatchSize(Integer size)并通过Session#getJdbcBatchSize()
    • 在DAO中,不时刷新并清除持久化上下文。这样就可以避免“压倒”持久化上下文。

    写在最后:

    既然看到这里了,觉得笔者写的还不错的就点个赞,加个关注呗!点关注,不迷路,持续更新!!!

    相关文章

      网友评论

        本文标题:如何在Hibernate中通过saveAll或EntityMan

        本文链接:https://www.haomeiwen.com/subject/fzccsqtx.html