1. 极牛网首页
  2. 架构设计

一文搞懂如何在Spring Boot中正确使用JPA

JPA 这部分内容上手很容易,但是涉及到的东西还是挺多的,网上大部分关于 JPA 的资料都不是特别齐全,大部分用的版本也是比较落后的。另外,我下面讲到了的内容也不可能涵盖所有 JPA 相关内容,我只是把自己觉得比较重要的知识点总结在了下面。很多地方我自己也是参考着官方文档写的,官方文档非常详细了,非常推荐阅读一下。这篇文章可以帮助对 JPA 不了解或者不太熟悉的人来在实际项目中正确使用 JPA。

一文搞懂如何在Spring Boot中正确使用JPA

另外,我发现网上关于连表查询这一块并没有太多比较有参考价值的博客,所以对这部分也做了详细的总结,以供大家学习参考。

项目代码基于 Spring Boot 最新的 2.1.9.RELEASE 版本构建(截止到这篇文章写完),另外,新建项目的过程就不多说了。

一 JPA 基础:常见操作

1.相关依赖

我们需要下面这些依赖支持我们完成这部分内容的学习:

  1. <dependencies>
  2.         <dependency>
  3.             <groupId>org.springframework.boot</groupId>
  4.             <artifactId>spring-boot-starter-web</artifactId>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>org.springframework.boot</groupId>
  8.             <artifactId>spring-boot-starter-data-jpa</artifactId>
  9.         </dependency>
  10.         <dependency>
  11.             <groupId>mysql</groupId>
  12.             <artifactId>mysql-connector-java</artifactId>
  13.             <scope>runtime</scope>
  14.         </dependency>
  15.         <dependency>
  16.             <groupId>org.projectlombok</groupId>
  17.             <artifactId>lombok</artifactId>
  18.             <optional>true</optional>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-test</artifactId>
  23.             <scope>test</scope>
  24.         </dependency>
  25.     </dependencies>

2.配置数据库连接信息和JPA配置

下面的配置中需要单独说一下 spring.jpa.hibernate.ddl-auto=create这个配置选项。

这个属性常用的选项有四种:

  1. create:每次重新启动项目都会重新创新表结构,会导致数据丢失
  2. create-drop:每次启动项目创建表结构,关闭项目删除表结构
  3. update:每次启动项目会更新表结构
  4. validate:验证表结构,不对数据库进行任何更改

但是,一定要不要在生产环境使用 ddl 自动生成表结构,一般推荐手写 SQL 语句配合 Flyway 来做这些事情。

  1. spring.datasource.url=jdbc:mysql://localhost:3306/springboot_jpa?useSSL=false&serverTimezone=CTT
  2. spring.datasource.username=root
  3. spring.datasource.password=123456
  4. # 打印出 sql 语句
  5. spring.jpa.show-sql=true
  6. spring.jpa.hibernate.ddl-auto=create
  7. spring.jpa.openinview=false
  8. # 创建的表的 ENGINE 为 InnoDB
  9. spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL55Dialect

3.实体类

我们为这个类添加了 @Entity 注解代表它是数据库持久化类,还配置了主键 id。

  1. import lombok.Data;
  2. import lombok.NoArgsConstructor;
  3. import javax.persistence.Column;
  4. import javax.persistence.Entity;
  5. import javax.persistence.GeneratedValue;
  6. import javax.persistence.GenerationType;
  7. import javax.persistence.Id;
  8. @Entity
  9. @Data
  10. @NoArgsConstructor
  11. public class Person {
  12.     @Id
  13.     @GeneratedValue(strategy = GenerationType.IDENTITY)
  14.     private Long id;
  15.     @Column(unique = true)
  16.     private String name;
  17.     private Integer age;
  18.     public Person(String nameInteger age) {
  19.         this.name = name;
  20.         this.age = age;
  21.     }
  22. }

如何检验你是否正确完成了上面 3 步?很简单,运行项目,查看数据如果发现控制台打印出创建表的 sql 语句,并且数据库中表真的被创建出来的话,说明你成功完成前面 3 步。

控制台打印出来的 sql 语句类似下面这样:

  1. drop table if exists person
  2. CREATE TABLE person (
  3.   id bigint(20) NOT NULL AUTO_INCREMENT,
  4.   age int(11) DEFAULT NULL,
  5.   name varchar(255) DEFAULT NULL
  6.    PRIMARY KEY (id)
  7. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  8. alter table person add constraint UK_p0wr4vfyr2lyifm8avi67mqw5 unique (name)

4.创建操作数据库的 Repository 接口

  1. @Repository
  2. public interface PersonRepository extends JpaRepository<Person, Long> {
  3. }

首先这个接口加了 @Repository 注解,代表它和数据库操作有关。另外,它继承了 JpaRepository接口,而JpaRepository长这样:

  1. @NoRepositoryBean
  2. public interface JpaRepository<T, ID> extends PagingAndSortingRepository<T, ID>, QueryByExampleExecutor<T> {
  3.     List<T> findAll();
  4.     List<T> findAll(Sort var1);
  5.     List<T> findAllById(Iterable<ID> var1);
  6.     <S extends T> List<S> saveAll(Iterable<S> var1);
  7.     void flush();
  8.     <S extends T> S saveAndFlush(S var1);
  9.     void deleteInBatch(Iterable<T> var1);
  10.     void deleteAllInBatch();
  11.     T getOne(ID var1);
  12.     <S extends T> List<S> findAll(Example<S> var1);
  13.     <S extends T> List<S> findAll(Example<S> var1, Sort var2);
  14. }

这表明我们只要继承了JpaRepository 就具有了 JPA 为我们提供好的增删改查、分页查询以及根据条件查询等方法。

4.1 JPA 自带方法实战

1) 增删改查

1.保存用户到数据库

  1. Person person = new Person(“SnailClimb”, 23);
  2.    personRepository.save(person);

save()方法对应 sql 语句就是:insert into person (age, name) values (23,”snailclimb”)

2.根据 id 查找用户

  1. Optional<Person> personOptional = personRepository.findById(id);

findById()方法对应 sql 语句就是:select * from person p where p.id = id

3.根据 id 删除用户

  1. personRepository.deleteById(id);

deleteById()方法对应 sql 语句就是:delete from person where id=id

4.更新用户

更新操作也要通过 save()方法来实现,比如:

  1. Person person = new Person(“SnailClimb”, 23);
  2.     Person savedPerson = personRepository.save(person);
  3.     // 更新 person 对象的姓名
  4.     savedPerson.setName(“UpdatedName”);
  5.     personRepository.save(savedPerson);

在这里 save()方法相当于 sql 语句:update person set name=”UpdatedName” where id=id

2) 带条件的查询

下面这些方法是我们根据 JPA 提供的语法自定义的,你需要将下面这些方法写到 PersonRepository 中。

假如我们想要根据 Name 来查找 Person ,你可以这样:

  1. Optional<Person> findByName(String name);

如果你想要找到年龄大于某个值的人,你可以这样:

  1. List<Person> findByAgeGreaterThan(int age);

4.2 自定义 SQL 语句实战

很多时候我们自定义 sql 语句会非常有用。

根据 name 来查找 Person:

  1. @Query(“select p from Person p where p.name = :name”)
  2.     Optional<Person> findByNameCustomeQuery(@Param(“name”) String name);

Person 部分属性查询,避免 select *操作:

  1. @Query(“select p.name from Person p where p.id = :id”)
  2.     String findPersonNameById(@Param(“id”) Long id);

根据 id 更新Person name:

  1. @Modifying
  2.     @Transactional
  3.     @Query(“update Person p set p.name = ?1 where p.id = ?2”)
  4.     void updatePersonNameById(String name, Long id);

4.3 创建异步方法

如果我们需要创建异步方法的话,也比较方便。

异步方法在调用时立即返回,然后会被提交给TaskExecutor执行。当然你也可以选择得出结果后才返回给客户端。如果对 Spring Boot 异步编程感兴趣的话可以看这篇文章:《新手也能看懂的 SpringBoot 异步编程指南》 。

  1. @Async
  2. Future<User> findByName(String name);
  3. @Async
  4. CompletableFuture<User> findByName(String name);

5.测试类和源代码地址

测试类:

  1. @SpringBootTest
  2. @RunWith(SpringRunner.class)
  3. public class PersonRepositoryTest {
  4.     @Autowired
  5.     private PersonRepository personRepository;
  6.     private Long id;
  7.     @Before
  8.     public void setUp() {
  9.         assertNotNull(personRepository);
  10.         Person person = new Person(“SnailClimb”, 23);
  11.         Person savedPerson = personRepository.saveAndFlush(person);// 更新 person 对象的姓名
  12.         savedPerson.setName(“UpdatedName”);
  13.         personRepository.save(savedPerson);
  14.         id = savedPerson.getId();
  15.     }
  16.     @Test
  17.     public void should_get_person() {
  18.         Optional<Person> personOptional = personRepository.findById(id);
  19.         assertTrue(personOptional.isPresent());
  20.         assertEquals(“SnailClimb”, personOptional.get().getName());
  21.         assertEquals(Integer.valueOf(23), personOptional.get().getAge());
  22.         List<Person> personList = personRepository.findByAgeGreaterThan(18);
  23.         assertEquals(1, personList.size());
  24.         // 清空数据库
  25.         personRepository.deleteAll();
  26.     }
  27.     @Test
  28.     public void should_get_person_use_custom_query() {
  29.         // 查找所有字段
  30.         Optional<Person> personOptional = personRepository.findByNameCustomeQuery(“SnailClimb”);
  31.         assertTrue(personOptional.isPresent());
  32.         assertEquals(Integer.valueOf(23), personOptional.get().getAge());
  33.         // 查找部分字段
  34.         String personName = personRepository.findPersonNameById(id);
  35.         assertEquals(“SnailClimb”, personName);
  36.         System.out.println(id);
  37.         // 更新
  38.         personRepository.updatePersonNameById(“UpdatedName”, id);
  39.         Optional<Person> updatedName = personRepository.findByNameCustomeQuery(“UpdatedName”);
  40.         assertTrue(updatedName.isPresent());
  41.         // 清空数据库
  42.         personRepository.deleteAll();
  43.     }
  44. }

源代码地址:https://github.com/Snailclimb/springboot-guide/tree/master/source-code/basis/jpa-demo

6. 总结

本文主要介绍了 JPA 的基本用法:

使用 JPA 自带的方法进行增删改查以及条件查询。

自定义 SQL 语句进行查询或者更新数据库。

创建异步的方法。

在下一篇关于 JPA 的文章中我会介绍到非常重要的两个知识点:

基本分页功能实现

多表联合查询以及多表联合查询下的分页功能实现。

二 JPA 连表查询和分页

对于连表查询,在 JPA 中还是非常常见的,由于 JPA 可以在 respository 层自定义 SQL 语句,所以通过自定义 SQL 语句的方式实现连表还是挺简单。这篇文章是在上一篇入门 JPA的文章的基础上写的,不了解 JPA 的可以先看上一篇文章。

在上一节的基础上我们新建了两个实体类,如下:

1.相关实体类创建

  1. Company.java
  2. @Entity
  3. @Data
  4. @NoArgsConstructor
  5. public class Company {
  6.     @Id
  7.     @GeneratedValue(strategy = GenerationType.IDENTITY)
  8.     private Long id;
  9.     @Column(unique = true)
  10.     private String companyName;
  11.     private String description;
  12.     public Company(String name, String description) {
  13.         this.companyName = name;
  14.         this.description = description;
  15.     }
  16. }
  17. School.java
  18. @Entity
  19. @Data
  20. @NoArgsConstructor
  21. @AllArgsConstructor
  22. public class School {
  23.     @Id
  24.     @GeneratedValue(strategy = GenerationType.IDENTITY)
  25.     private Long id;
  26.     @Column(unique = true)
  27.     private String name;
  28.     private String description;
  29. }

2.自定义 SQL语句实现连表查询

假如我们当前要通过 person 表的 id 来查询 Person 的话,我们知道 Person 的信息一共分布在Company、School、Person这三张表中,所以,我们如果要把 Person 的信息都查询出来的话是需要进行连表查询的。

首先我们需要创建一个包含我们需要的 Person 信息的 DTO 对象,我们简单第将其命名为 UserDTO,用于保存和传输我们想要的信息。

  1. @Data
  2. @NoArgsConstructor
  3. @Builder(toBuilder = true)
  4. @AllArgsConstructor
  5. public class UserDTO {
  6.     private String name;
  7.     private int age;
  8.     private String companyName;
  9.     private String schoolName;
  10. }

下面我们就来写一个方法查询出 Person 的基本信息。

  1.   @Query(value = “select new github.snailclimb.jpademo.model.dto.UserDTO(p.name,p.age,c.companyName,s.name) “ +
  2.           “from Person p left join Company c on  p.companyId=c.id “ +
  3.           “left join School s on p.schoolId=s.id “ +
  4.           “where p.id=:personId”)
  5.   Optional<UserDTO> getUserInformation(@Param(“personId”) Long personId);

可以看出上面的 sql 语句和我们平时写的没啥区别,差别比较大的就是里面有一个 new 对象的操作。

3.自定义 SQL 语句连表查询并实现分页操作

假如我们要查询当前所有的人员信息并实现分页的话,你可以按照下面这种方式来做。可以看到,为了实现分页,我们在@Query注解中还添加了 countQuery 属性。

  1. @Query(value = “select new github.snailclimb.jpademo.model.dto.UserDTO(p.name,p.age,c.companyName,s.name) “ +
  2.         “from Person p left join Company c on  p.companyId=c.id “ +
  3.         “left join School s on p.schoolId=s.id “,
  4.         countQuery = “select count(p.id) “ +
  5.                 “from Person p left join Company c on  p.companyId=c.id “ +
  6.                 “left join School s on p.schoolId=s.id “)
  7. Page<UserDTO> getUserInformationList(Pageable pageable);

实际使用:

  1. //分页选项
  2. PageRequest pageRequest = PageRequest.of(0, 3, Sort.Direction.DESC“age”);
  3. Page<UserDTO> userInformationList = personRepository.getUserInformationList(pageRequest);
  4. //查询结果总数
  5. System.out.println(userInformationList.getTotalElements());// 6
  6. //按照当前分页大小,总页数
  7. System.out.println(userInformationList.getTotalPages());// 2
  8. System.out.println(userInformationList.getContent());

4.加餐:自定以SQL语句的其他用法

下面我只介绍两种比较常用的:

IN 查询

BETWEEN 查询

当然,还有很多用法需要大家自己去实践了。

4.1 IN 查询

在 sql 语句中加入我们需要筛选出符合几个条件中的一个的情况下,可以使用 IN 查询,对应到 JPA 中也非常简单。比如下面的方法就实现了,根据名字过滤需要的人员信息。

  1. @Query(value = “select new github.snailclimb.jpademo.model.dto.UserDTO(p.name,p.age,c.companyName,s.name) “ +
  2.         “from Person p left join Company c on  p.companyId=c.id “ +
  3.         “left join School s on p.schoolId=s.id “ +
  4.         “where p.name IN :peopleList”)
  5. List<UserDTO> filterUserInfo(List peopleList);

实际使用:

List personList=new ArrayList<>(Arrays.asList(“person1″,”person2”));List userDTOS = personRepository.filterUserInfo(personList);

4.2 BETWEEN 查询

查询满足某个范围的值。比如下面的方法就实现查询满足某个年龄范围的人员的信息。

  1. @Query(value = “select new github.snailclimb.jpademo.model.dto.UserDTO(p.name,p.age,c.companyName,s.name) “ +
  2.             “from Person p left join Company c on  p.companyId=c.id “ +
  3.             “left join School s on p.schoolId=s.id “ +
  4.             “where p.age between :small and :big”)
  5.     List<UserDTO> filterUserInfoByAge(int small,int big);

实际使用:

List userDTOS = personRepository.filterUserInfoByAge(19,20);

5.测试类和源代码地址

  1. @SpringBootTest
  2. @RunWith(SpringRunner.class)
  3. public class PersonRepositoryTest2 {
  4.     @Autowired
  5.     private PersonRepository personRepository;
  6.     @Sql(scripts = {“classpath:/init.sql”})
  7.     @Test
  8.     public void find_person_age_older_than_18() {
  9.         List<Person> personList = personRepository.findByAgeGreaterThan(18);
  10.         assertEquals(1, personList.size());
  11.     }
  12.     @Sql(scripts = {“classpath:/init.sql”})
  13.     @Test
  14.     public void should_get_user_info() {
  15.         Optional<UserDTO> userInformation = personRepository.getUserInformation(1L);
  16.         System.out.println(userInformation.get().toString());
  17.     }
  18.     @Sql(scripts = {“classpath:/init.sql”})
  19.     @Test
  20.     public void should_get_user_info_list() {
  21.         PageRequest pageRequest = PageRequest.of(0, 3, Sort.Direction.DESC“age”);
  22.         Page<UserDTO> userInformationList = personRepository.getUserInformationList(pageRequest);
  23.         //查询结果总数
  24.         System.out.println(userInformationList.getTotalElements());// 6
  25.         //按照当前分页大小,总页数
  26.         System.out.println(userInformationList.getTotalPages());// 2
  27.         System.out.println(userInformationList.getContent());
  28.     }
  29.     @Sql(scripts = {“classpath:/init.sql”})
  30.     @Test
  31.     public void should_filter_user_info() {
  32.         List<String> personList=new ArrayList<>(Arrays.asList(“person1”,“person2”));
  33.         List<UserDTO> userDTOS = personRepository.filterUserInfo(personList);
  34.         System.out.println(userDTOS);
  35.     }
  36.     @Sql(scripts = {“classpath:/init.sql”})
  37.     @Test
  38.     public void should_filter_user_info_by_age() {
  39.         List<UserDTO> userDTOS = personRepository.filterUserInfoByAge(19,20);
  40.         System.out.println(userDTOS);
  41.     }
  42. }

六 总结

本节我们主要学习了下面几个知识点:

自定义 SQL 语句实现连表查询;

自定义 SQL 语句连表查询并实现分页操作;

条件查询:IN 查询,BETWEEN查询。

我们这一节是把 SQl 语句连表查询的逻辑放在 Dao 层直接写的,这样写的好处是比较方便,也比较简单明了。但是可能会不太好维护,很多时候我们会选择将这些逻辑放到 Service 层去做,这样也是可以实现的,后面章我就会介绍到如何将这些写在 Dao 层的逻辑转移到 Service 层去。

极牛网精选文章《一文搞懂如何在Spring Boot中正确使用JPA》文中所述为作者独立观点,不代表极牛网立场。如若转载请注明出处:https://jikenb.com/8559.html

发表评论

登录后才能评论