设为首页 - 加入收藏 ASP站长网(Aspzz.Cn)- 科技、建站、经验、云计算、5G、大数据,站长网!
热搜: 创业者 数据 手机
当前位置: 首页 > 运营中心 > 建站资源 > 优化 > 正文

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

发布时间:2019-10-18 15:34 所属栏目:21 来源:SnailClimb
导读:更新操作也要通过 save()方法来实现,比如: Personperson=newPerson(SnailClimb,23); PersonsavedPerson=personRepository.save(person); //更新person对象的姓名 savedPerson.setName(UpdatedName); personReposi

更新操作也要通过 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.  
  4. @Async 
  5. 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.  
  8.     /** 
  9.      * 保存person到数据库 
  10.      */ 
  11.     @Before 
  12.     public void setUp() { 
  13.         assertNotNull(personRepository); 
  14.         Person person = new Person("SnailClimb", 23); 
  15.         Person savedPerson = personRepository.saveAndFlush(person);// 更新 person 对象的姓名 
  16.         savedPerson.setName("UpdatedName"); 
  17.         personRepository.save(savedPerson); 
  18.  
  19.         id = savedPerson.getId(); 
  20.     } 
  21.  
  22.     /** 
  23.      * 使用 JPA 自带的方法查找 person 
  24.      */ 
  25.     @Test 
  26.     public void should_get_person() { 
  27.         Optional<Person> personOptional = personRepository.findById(id); 
  28.         assertTrue(personOptional.isPresent()); 
  29.         assertEquals("SnailClimb", personOptional.get().getName()); 
  30.         assertEquals(Integer.valueOf(23), personOptional.get().getAge()); 
  31.  
  32.         List<Person> personList = personRepository.findByAgeGreaterThan(18); 
  33.         assertEquals(1, personList.size()); 
  34.         // 清空数据库 
  35.         personRepository.deleteAll(); 
  36.     } 
  37.  
  38.     /** 
  39.      * 自定义 query sql 查询语句查找 person 
  40.      */ 
  41.  
  42.     @Test 
  43.     public void should_get_person_use_custom_query() { 
  44.         // 查找所有字段 
  45.         Optional<Person> personOptional = personRepository.findByNameCustomeQuery("SnailClimb"); 
  46.         assertTrue(personOptional.isPresent()); 
  47.         assertEquals(Integer.valueOf(23), personOptional.get().getAge()); 
  48.         // 查找部分字段 
  49.         String personName = personRepository.findPersonNameById(id); 
  50.         assertEquals("SnailClimb", personName); 
  51.         System.out.println(id); 
  52.         // 更新 
  53.         personRepository.updatePersonNameById("UpdatedName", id); 
  54.         Optional<Person> updatedName = personRepository.findByNameCustomeQuery("UpdatedName"); 
  55.         assertTrue(updatedName.isPresent()); 
  56.         // 清空数据库 
  57.         personRepository.deleteAll(); 
  58.     } 
  59.  

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

6. 总结

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

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

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

创建异步的方法。

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

基本分页功能实现

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

二 JPA 连表查询和分页

(编辑:ASP站长网)

网友评论
推荐文章
    热点阅读