集成Hibernate


使用JdbcTemplate的时候,我们用得最多的方法就是List<T> query(String, RowMapper, Object...)。这个RowMapper的作用就是把ResultSet的一行记录映射为Java Bean。

这种把关系数据库的表记录映射为Java对象的过程就是ORM:Object-Relational Mapping。ORM既可以把记录转换成Java对象,也可以把Java对象转换为行记录。

使用JdbcTemplate配合RowMapper可以看作是最原始的ORM。如果要实现更自动化的ORM,可以选择成熟的ORM框架,例如Hibernate

我们来看看如何在Spring中集成Hibernate。

Hibernate作为ORM框架,它可以替代JdbcTemplate,但Hibernate仍然需要JDBC驱动,所以,我们需要引入JDBC驱动、连接池,以及Hibernate本身。在Maven中,我们加入以下依赖项:

  • org.springframework:spring-context:6.0.0
  • org.springframework:spring-orm:6.0.0
  • jakarta.annotation:jakarta.annotation-api:2.1.1
  • jakarta.persistence:jakarta.persistence-api:3.1.0
  • org.hibernate:hibernate-core:6.1.4.Final
  • com.zaxxer:HikariCP:5.0.1
  • org.hsqldb:hsqldb:2.7.1

AppConfig中,我们仍然需要创建DataSource、引入JDBC配置文件,以及启用声明式事务:

  1. @Configuration
  2. @ComponentScan
  3. @EnableTransactionManagement
  4. @PropertySource("jdbc.properties")
  5. public class AppConfig {
  6. @Bean
  7. DataSource createDataSource() {
  8. ...
  9. }
  10. }

为了启用Hibernate,我们需要创建一个LocalSessionFactoryBean

  1. public class AppConfig {
  2. @Bean
  3. LocalSessionFactoryBean createSessionFactory(@Autowired DataSource dataSource) {
  4. var props = new Properties();
  5. props.setProperty("hibernate.hbm2ddl.auto", "update"); // 生产环境不要使用
  6. props.setProperty("hibernate.dialect", "org.hibernate.dialect.HSQLDialect");
  7. props.setProperty("hibernate.show_sql", "true");
  8. var sessionFactoryBean = new LocalSessionFactoryBean();
  9. sessionFactoryBean.setDataSource(dataSource);
  10. // 扫描指定的package获取所有entity class:
  11. sessionFactoryBean.setPackagesToScan("com.itranswarp.learnjava.entity");
  12. sessionFactoryBean.setHibernateProperties(props);
  13. return sessionFactoryBean;
  14. }
  15. }

注意我们在定制Bean中讲到过FactoryBeanLocalSessionFactoryBean是一个FactoryBean,它会再自动创建一个SessionFactory,在Hibernate中,Session是封装了一个JDBC Connection的实例,而SessionFactory是封装了JDBC DataSource的实例,即SessionFactory持有连接池,每次需要操作数据库的时候,SessionFactory创建一个新的Session,相当于从连接池获取到一个新的ConnectionSessionFactory就是Hibernate提供的最核心的一个对象,但LocalSessionFactoryBean是Spring提供的为了让我们方便创建SessionFactory的类。

注意到上面创建LocalSessionFactoryBean的代码,首先用Properties持有Hibernate初始化SessionFactory时用到的所有设置,常用的设置请参考Hibernate文档,这里我们只定义了3个设置:

  • hibernate.hbm2ddl.auto=update:表示自动创建数据库的表结构,注意不要在生产环境中启用;
  • hibernate.dialect=org.hibernate.dialect.HSQLDialect:指示Hibernate使用的数据库是HSQLDB。Hibernate使用一种HQL的查询语句,它和SQL类似,但真正在“翻译”成SQL时,会根据设定的数据库“方言”来生成针对数据库优化的SQL;
  • hibernate.show_sql=true:让Hibernate打印执行的SQL,这对于调试非常有用,我们可以方便地看到Hibernate生成的SQL语句是否符合我们的预期。

除了设置DataSourceProperties之外,注意到setPackagesToScan()我们传入了一个package名称,它指示Hibernate扫描这个包下面的所有Java类,自动找出能映射为数据库表记录的JavaBean。后面我们会仔细讨论如何编写符合Hibernate要求的JavaBean。

紧接着,我们还需要创建HibernateTransactionManager

  1. public class AppConfig {
  2. @Bean
  3. PlatformTransactionManager createTxManager(@Autowired SessionFactory sessionFactory) {
  4. return new HibernateTransactionManager(sessionFactory);
  5. }
  6. }

HibernateTransactionManager是配合Hibernate使用声明式事务所必须的。到此为止,所有的配置都定义完毕,我们来看看如何将数据库表结构映射为Java对象。

考察如下的数据库表:

  1. CREATE TABLE user
  2. id BIGINT NOT NULL AUTO_INCREMENT,
  3. email VARCHAR(100) NOT NULL,
  4. password VARCHAR(100) NOT NULL,
  5. name VARCHAR(100) NOT NULL,
  6. createdAt BIGINT NOT NULL,
  7. PRIMARY KEY (`id`),
  8. UNIQUE KEY `email` (`email`)
  9. );

其中,id是自增主键,emailpasswordnameVARCHAR类型,email带唯一索引以确保唯一性,createdAt存储整型类型的时间戳。用JavaBean表示如下:

  1. public class User {
  2. private Long id;
  3. private String email;
  4. private String password;
  5. private String name;
  6. private Long createdAt;
  7. // getters and setters
  8. ...
  9. }

这种映射关系十分易懂,但我们需要添加一些注解来告诉Hibernate如何把User类映射到表记录:

  1. @Entity
  2. public class User {
  3. @Id
  4. @GeneratedValue(strategy = GenerationType.IDENTITY)
  5. @Column(nullable = false, updatable = false)
  6. public Long getId() { ... }
  7. @Column(nullable = false, unique = true, length = 100)
  8. public String getEmail() { ... }
  9. @Column(nullable = false, length = 100)
  10. public String getPassword() { ... }
  11. @Column(nullable = false, length = 100)
  12. public String getName() { ... }
  13. @Column(nullable = false, updatable = false)
  14. public Long getCreatedAt() { ... }
  15. }

如果一个JavaBean被用于映射,我们就标记一个@Entity。默认情况下,映射的表名是user,如果实际的表名不同,例如实际表名是users,可以追加一个@Table(name="users")表示:

  1. @Entity
  2. @Table(name="users)
  3. public class User {
  4. ...
  5. }

每个属性到数据库列的映射用@Column()标识,nullable指示列是否允许为NULLupdatable指示该列是否允许被用在UPDATE语句,length指示String类型的列的长度(如果没有指定,默认是255)。

对于主键,还需要用@Id标识,自增主键再追加一个@GeneratedValue,以便Hibernate能读取到自增主键的值。

细心的童鞋可能还注意到,主键id定义的类型不是long,而是Long。这是因为Hibernate如果检测到主键为null,就不会在INSERT语句中指定主键的值,而是返回由数据库生成的自增值,否则,Hibernate认为我们的程序指定了主键的值,会在INSERT语句中直接列出。long型字段总是具有默认值0,因此,每次插入的主键值总是0,导致除第一次外后续插入都将失败。

createdAt虽然是整型,但我们并没有使用long,而是Long,这是因为使用基本类型会导致findByExample查询会添加意外的条件,这里只需牢记,作为映射使用的JavaBean,所有属性都使用包装类型而不是基本类型。

使用Hibernate时,不要使用基本类型的属性,总是使用包装类型,如Long或Integer。

类似的,我们再定义一个Book类:

  1. @Entity
  2. public class Book {
  3. @Id
  4. @GeneratedValue(strategy = GenerationType.IDENTITY)
  5. @Column(nullable = false, updatable = false)
  6. public Long getId() { ... }
  7. @Column(nullable = false, length = 100)
  8. public String getTitle() { ... }
  9. @Column(nullable = false, updatable = false)
  10. public Long getCreatedAt() { ... }
  11. }

如果仔细观察UserBook,会发现它们定义的idcreatedAt属性是一样的,这在数据库表结构的设计中很常见:对于每个表,通常我们会统一使用一种主键生成机制,并添加createdAt表示创建时间,updatedAt表示修改时间等通用字段。

不必在UserBook中重复定义这些通用字段,我们可以把它们提到一个抽象类中:

  1. @MappedSuperclass
  2. public abstract class AbstractEntity {
  3. private Long id;
  4. private Long createdAt;
  5. @Id
  6. @GeneratedValue(strategy = GenerationType.IDENTITY)
  7. @Column(nullable = false, updatable = false)
  8. public Long getId() { ... }
  9. @Column(nullable = false, updatable = false)
  10. public Long getCreatedAt() { ... }
  11. @Transient
  12. public ZonedDateTime getCreatedDateTime() {
  13. return Instant.ofEpochMilli(this.createdAt).atZone(ZoneId.systemDefault());
  14. }
  15. @PrePersist
  16. public void preInsert() {
  17. setCreatedAt(System.currentTimeMillis());
  18. }
  19. }

对于AbstractEntity来说,我们要标注一个@MappedSuperclass表示它用于继承。此外,注意到我们定义了一个@Transient方法,它返回一个“虚拟”的属性。因为getCreatedDateTime()是计算得出的属性,而不是从数据库表读出的值,因此必须要标注@Transient,否则Hibernate会尝试从数据库读取名为createdDateTime这个不存在的字段从而出错。

再注意到@PrePersist标识的方法,它表示在我们将一个JavaBean持久化到数据库之前(即执行INSERT语句),Hibernate会先执行该方法,这样我们就可以自动设置好createdAt属性。

有了AbstractEntity,我们就可以大幅简化UserBook

  1. @Entity
  2. public class User extends AbstractEntity {
  3. @Column(nullable = false, unique = true, length = 100)
  4. public String getEmail() { ... }
  5. @Column(nullable = false, length = 100)
  6. public String getPassword() { ... }
  7. @Column(nullable = false, length = 100)
  8. public String getName() { ... }
  9. }

注意到使用的所有注解均来自jakarta.persistence,它是JPA规范的一部分。这里我们只介绍使用注解的方式配置Hibernate映射关系,不再介绍传统的比较繁琐的XML配置。通过Spring集成Hibernate时,也不再需要hibernate.cfg.xml配置文件,用一句话总结:

使用Spring集成Hibernate,配合JPA注解,无需任何额外的XML配置。

类似UserBook这样的用于ORM的Java Bean,我们通常称之为Entity Bean。

最后,我们来看看如果对user表进行增删改查。因为使用了Hibernate,因此,我们要做的,实际上是对User这个JavaBean进行“增删改查”。我们编写一个UserService,注入SessionFactory

  1. @Component
  2. @Transactional
  3. public class UserService {
  4. @Autowired
  5. SessionFactory sessionFactory;
  6. }

Insert操作

要持久化一个User实例,我们只需调用persist()方法。以register()方法为例,代码如下:

  1. public User register(String email, String password, String name) {
  2. // 创建一个User对象:
  3. User user = new User();
  4. // 设置好各个属性:
  5. user.setEmail(email);
  6. user.setPassword(password);
  7. user.setName(name);
  8. // 不要设置id,因为使用了自增主键
  9. // 保存到数据库:
  10. sessionFactory.getCurrentSession().persist(user);
  11. // 现在已经自动获得了id:
  12. System.out.println(user.getId());
  13. return user;
  14. }

Delete操作

删除一个User相当于从表中删除对应的记录。注意Hibernate总是用id来删除记录,因此,要正确设置Userid属性才能正常删除记录:

  1. public boolean deleteUser(Long id) {
  2. User user = sessionFactory.getCurrentSession().byId(User.class).load(id);
  3. if (user != null) {
  4. sessionFactory.getCurrentSession().remove(user);
  5. return true;
  6. }
  7. return false;
  8. }

通过主键删除记录时,一个常见的用法是先根据主键加载该记录,再删除。注意到当记录不存在时,load()返回null

Update操作

更新记录相当于先更新User的指定属性,然后调用merge()方法:

  1. public void updateUser(Long id, String name) {
  2. User user = sessionFactory.getCurrentSession().byId(User.class).load(id);
  3. user.setName(name);
  4. sessionFactory.getCurrentSession().merge(user);
  5. }

前面我们在定义User时,对有的属性标注了@Column(updatable=false)。Hibernate在更新记录时,它只会把@Column(updatable=true)的属性加入到UPDATE语句中,这样可以提供一层额外的安全性,即如果不小心修改了UseremailcreatedAt等属性,执行update()时并不会更新对应的数据库列。但也必须牢记:这个功能是Hibernate提供的,如果绕过Hibernate直接通过JDBC执行UPDATE语句仍然可以更新数据库的任意列的值。

最后,我们编写的大部分方法都是各种各样的查询。根据id查询我们可以直接调用load(),如果要使用条件查询,例如,假设我们想执行以下查询:

  1. SELECT * FROM user WHERE email = ? AND password = ?

我们来看看可以使用什么查询。

使用HQL查询

一种常用的查询是直接编写Hibernate内置的HQL查询:

  1. List<User> list = sessionFactory.getCurrentSession()
  2. .createQuery("from User u where u.email = ?1 and u.password = ?2", User.class)
  3. .setParameter(1, email).setParameter(2, password)
  4. .list();

和SQL相比,HQL使用类名和属性名,由Hibernate自动转换为实际的表名和列名。详细的HQL语法可以参考Hibernate文档

除了可以直接传入HQL字符串外,Hibernate还可以使用一种NamedQuery,它给查询起个名字,然后保存在注解中。使用NamedQuery时,我们要先在User类标注:

  1. @NamedQueries(
  2. @NamedQuery(
  3. // 查询名称:
  4. name = "login",
  5. // 查询语句:
  6. query = "SELECT u FROM User u WHERE u.email = :e AND u.password = :pwd"
  7. )
  8. )
  9. @Entity
  10. public class User extends AbstractEntity {
  11. ...
  12. }

注意到引入的NamedQueryjakarta.persistence.NamedQuery,它和直接传入HQL有点不同的是,占位符使用:e:pwd

使用NamedQuery只需要引入查询名和参数:

  1. public User login(String email, String password) {
  2. List<User> list = sessionFactory.getCurrentSession()
  3. .createNamedQuery("login", User.class) // 创建NamedQuery
  4. .setParameter("e", email) // 绑定e参数
  5. .setParameter("pwd", password) // 绑定pwd参数
  6. .list();
  7. return list.isEmpty() ? null : list.get(0);
  8. }

直接写HQL和使用NamedQuery各有优劣。前者可以在代码中直观地看到查询语句,后者可以在User类统一管理所有相关查询。

练习

集成Hibernate - 图1下载练习:集成Hibernate (推荐使用IDE练习插件快速下载)

小结

在Spring中集成Hibernate需要配置的Bean如下:

  • DataSource;
  • LocalSessionFactory;
  • HibernateTransactionManager。

推荐使用Annotation配置所有的Entity Bean。

读后有收获可以支付宝请作者喝咖啡:

集成Hibernate - 图2