本文是关于Hibernate如何实现批处理的。我觉得边肖很实用,就和大家分享一下作为参考。让我们跟着边肖看一看。
事实上,Hibernate批处理在性能方面并不理想,而且会浪费大量内存。就其机制而言,Hibernate首先找出符合条件的数据,放入内存,然后进行操作。其实表现很不理想。在笔者的实际使用中,下面第三个优化方案的数据是:10万条数据插入数据库,主流台式机的配置需要30分钟左右,呵呵,晕。
总而言之,有三种方法可以解决性能问题:
1.绕过Hibernate API,直接通过JDBC API来做。该方法具有良好的性能。也是最快的。
2.使用存储过程。
3.我们还是用Hibernate API进行常规的批处理,也可以改,改就改。当我们发现一定数量时,我们可以及时完成这些数据的运算。
Delete,session . flush();session . exclude(XX对象集);这样也可以节省一点性能损失。这个“一定量”要根据实际情况定量参考。一般30-60左右,但效果还是不理想。
1.绕过Hibernate API,直接通过JDBC API来做。这种方法性能更好,速度最快。(示例是更新操作)
transactiontx=session . BeginIntrasaction();
//注意使用了hibernate事务边界。
connection conn=session . connection();
preparedstatementsmt=conn . preparedstatement
(' updatecustomersracsetc . sarlary=c . sarlary 1 where c . sarlary1000 ');
stmt . excepteupdate();
tx.commit();
//注意使用了hibernate事务边界。
在这个小程序中,直接调用JDBC的API来访问数据库,非常高效。避免Hibernate查询并在操作前将其加载到内存中导致的性能问题。
2.使用存储过程。但是,不建议使用这种方法,因为它易于种植,并且便于部署程序。(示例是更新操作)
如果底层数据库(如Oracle)支持存储过程,也可以通过存储过程执行批量更新。存储过程直接在数据库中运行,速度更快。甲骨文中的数字
根据该库,可以定义一个名为batchUpdateCustomer()的存储过程,代码如下:
creatorreplaceprojectiebatchupdatecustomer(p _ ageinnumber)
asbeginpdatecustomersetageage=AGE 1p _ AGE所在的位置;
结束;
上面的存储过程有一个参数p_age,它表示客户的年龄。应用程序可以通过以下方式调用存储过程:
tx=session . BeginIntrasaction();connection con=session . connection();stringprocedure=' { callbatchUpdateCustomer(?)}';callablestatementcstt=con . prepare call(过程);csmt . setint(1,0);//将age参数设置为0 csmt . execute update();tx.commit();从上面的程序可以看出,应用程序必须绕过Hibernate API,直接通过JDBC API调用存储过程。
感谢阅读!我希望这篇关于“Hibernate如何实现批处理”的文章能在这里分享。
内容来源网络,如有侵权,联系删除,本文地址:https://www.230890.com/zhan/136811.html