Hibernate+JDBC实现批量插入、更新及删除的方法详解

本文将介绍如何使用Hibernate+JDBC实现批量插入、更新及删除数据的方法。

数据库连接

首先，我们需要在Hibernate的配置文件中配置数据库连接信息，以便在后续操作中使用：

<property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
<property name="hibernate.connection.url">jdbc:mysql://localhost:3306/test?useUnicode=true&amp;characterEncoding=UTF8&amp;zeroDateTimeBehavior=convertToNull</property>
<property name="hibernate.connection.username">root</property>
<property name="hibernate.connection.password">root</property>
<property name="hibernate.show_sql">true</property>
<property name="hibernate.hbm2ddl.auto">update</property>

实体类定义

接下来，我们需要定义要操作的实体类，并通过Hibernate映射到数据库表中，以便完成数据的增删改查操作。

以用户实体类为例，定义如下：

@Entity
@Table(name = "t_user")
public class User implements Serializable {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(name = "name")
    private String name;

    @Column(name = "age")
    private Integer age;

    // getter and setter
}

批量插入数据

要批量插入数据，我们可以通过JDBC批量处理机制实现。

假设有如下要插入的用户列表：

List<User> userList = new ArrayList<>();
userList.add(new User("Jack", 23));
userList.add(new User("Lucy", 21));
userList.add(new User("Tom", 25));

我们可以使用如下代码实现批量插入：

Session session = HibernateUtil.getSessionFactory().getCurrentSession();
int batchSize = 1000;
int i = 0;
for (User user : userList) {
    session.save(user);
    i++;
    if (i % batchSize == 0) {
        session.flush();
        session.clear();
    }
}

这里每插入一条数据后，都调用flush()和clear()方法将数据写入数据库，以避免内存溢出。

批量更新数据

要批量更新数据，我们可以使用Hibernate的batch方式实现。

假设现在要把用户列表中所有年龄小于22岁的用户的年龄改为22岁：

List<User> userList = new ArrayList<>();
userList.add(new User("Jack", 23));
userList.add(new User("Lucy", 21));
userList.add(new User("Tom", 25));

我们可以使用如下代码实现批量更新：

Session session = HibernateUtil.getSessionFactory().getCurrentSession();
session.beginTransaction();
int batchSize = 1000;
int i = 0;
for (User user : userList) {
    Query query = session.createQuery("update User set age = 22 where name = :name and age < 22")
            .setString("name", user.getName());
    query.executeUpdate();
    i++;
    if (i % batchSize == 0) {
        session.flush();
        session.clear();
    }
}
session.getTransaction().commit();

这里我们使用Query对象执行了一条update语句，将年龄小于22岁的用户的年龄批量改为22岁。同样，每更新一条数据后，都调用flush()和clear()方法将数据写入数据库，以避免内存溢出。

批量删除数据

要批量删除数据，我们可以使用Hibernate的batch方式实现。

假设现在要删除用户列表中所有年龄大于24岁的用户：

List<User> userList = new ArrayList<>();
userList.add(new User("Jack", 23));
userList.add(new User("Lucy", 21));
userList.add(new User("Tom", 25));

我们可以使用如下代码实现批量删除：

Session session = HibernateUtil.getSessionFactory().getCurrentSession();
session.beginTransaction();
int batchSize = 1000;
int i = 0;
for (User user : userList) {
    Query query = session.createQuery("delete from User where name = :name and age > 24")
            .setString("name", user.getName());
    query.executeUpdate();
    i++;
    if (i % batchSize == 0) {
        session.flush();
        session.clear();
    }
}
session.getTransaction().commit();

这里我们使用Query对象执行了一条delete语句，将年龄大于24岁的用户批量删除。同样，每删除一条数据后，都调用flush()和clear()方法将数据写入数据库，以避免内存溢出。

至此，我们已经通过Hibernate+JDBC实现了批量插入、更新及删除数据的方法。