0%

hibernate批量操作

hibernate批量操作

有以下四种方式来进行批量操作

  • 通过session

  • 通过HQL

  • 通过statelessSession

  • 通过JDBCAPI 使用该方式效率最高,速度最快

通过session

通过session批量操作时:session的save()及update()方法会把处理的对象存放在自己的缓存中,如果使用session来处理大量持久化对象,需要及时从缓存中清空已经处理完毕且不会再访问的对象(处理完一批对象后,立即调用flush()方法刷新缓存,然后调用clear()方法清空缓存)

注意

  • 在hibernate配置文件中设置JDBC单次批量的数目,应保证每次向数据库发送的批量SQL语句数目与batch_size属性一致

  • 如果主键由数据库自增生成的话,无法使用批量操作

通过HQL

不能进行批量插入,更新只能操作一条sql语句(比如说将某个值批量改为某个数)

通过StatelessSession

  • StatelessSession没有缓存,使用该类来加载、保存、更新后的对象处于游离状态
  • 调用save()、update()、delete()方法时会立即执行SQL语句
  • StatelessSession不会对所加载的对象自动进行脏检查。需要进行显式的save()/update()
  • StatelessSession不会对关联的对象进行任何级联操作
  • 通过同一个StatelessSession加载相同OID的对象,会得到两个具有不同内存地址的对象
  • StatelessSession可以被Interceptor拦截器拦截到,但是会被hibernate事件处理系统忽略

通过JDBCAPI

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
// 没有返回值
session.doWork(new Work() {
@Override
public void execute(Connection connection) throws SQLException {

try(PreparedStatement statement = connection.prepareStatement("insert into jr_customer_schedule (customer_schedule_details_id,time,cpm) values (?,?,?)")){
for (JrCustomerSchedule jrCustomerSchedule : jrCustomerSchedules) {
statement.setLong(1, jrCustomerSchedule.getCustomer_schedule_details_id());
statement.setLong(2, jrCustomerSchedule.getTime());
statement.setInt(3, jrCustomerSchedule.getCpm());
statement.addBatch();
}
statement.executeBatch();
statement.clearBatch();
}
}
});


// 有返回值
session.doReturningWork(
connection -> {
// 返回自增id
PreparedStatement statement = connection.prepareStatement("insert into ad_plan_schedule (ad_plan_id,location_package,start_time,end_time) values (?,?,?,?)",
Statement.RETURN_GENERATED_KEYS);
List<Long> ids = new ArrayList<>();
for (AdPlanSchedule adPlanSchedule : adPlanSchedules) {
statement.setLong(1, adPlanSchedule.getAd_plan_id());
statement.setLong(2, adPlanSchedule.getLocation_package());
statement.setLong(3, adPlanSchedule.getStart_time());
statement.setLong(4, adPlanSchedule.getEnd_time());
statement.addBatch();
}
statement.executeBatch();
ResultSet rs = statement.getGeneratedKeys();
while (rs.next()) {
ids.add(rs.getLong(1));
}
statement.clearBatch();
return ids;
}

);

欢迎关注我的其它发布渠道