如何Hibernate批处理插入与实时数据？是否使用@Transactional？

Question

我试图执行批处理插入与数据，目前正在插入到DB每个事务一个语句。事务代码语句看起来类似于下面。目前，对来自外部提要的每个引用都调用addHolding（）方法，每个引用更新大约每秒发生150次。

public class HoldingServiceImpl {

    @Autowired
    private HoldingDAO holdingDao;

    @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
    public void addHolding(Quote quote) {
        Holding holding = transformQuote(quote);
        holdingDao.addHolding(holding);
    }

}

DAO正在从HibernateSessionFactory获取当前会话，并在对象上调用save。

public class HoldingDAOImpl {

    @Autowired
    private SessionFactory sessionFactory;

    public void addHolding(Holding holding) {
        sessionFactory.getCurrentSession().save(holding);
    }

}

我已经看了Hibernate批处理留档，但是从文档中不清楚在这种情况下我将如何组织批处理插入的代码，因为我手头没有完整的数据列表，而是在等待它流式传输。

仅仅在属性文件中设置Hibernate批处理属性（例如，Hibernate.jdbc.batch_size=20）“神奇地”批量插入这些属性吗？或者说，我需要在同步列表中捕获每个报价更新，然后在达到批量大小限制时插入列表加载和清除列表？

此外，实现批处理的全部目的是查看性能是否有所提高。如果在这种情况下有更好的方法来处理插入，请告诉我。

Answer 1

设置属性hibernate。jdbc。batch_size=20表示Hibernate在20之后刷新对象。在您的情况下，hibernate会自动调用sessionfactory。保存20条记录后刷新（）。

当你调用会话工厂时。save（），insert命令仅对内存中的hibernate缓存触发。只有在调用Flush之后，hibernate才会将这些更改与数据库同步。因此，设置hibernate批大小就足以执行批插入。根据需要微调批量大小。

还要确保您的交易得到正确处理。如果提交事务，也会强制Hibernate刷新会话。