Springboot 系列（十）使用 Spring data jpa 访问数据库 (2)

Springboot Data JPA 是 ORM 的完整实现，实体类和数据表关系一一对应，因此实体类也就是数据表结构。spring.jpa.hibernate.ddl-auto=update 会在 JPA 运行时自动在数据表中创建被 @Entity 注解的实体数据表。如果表已经存在，则不会创建。

4.1. 数据实体类 import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; import org.springframework.format.annotation.DateTimeFormat; import javax.persistence.*; import javax.validation.constraints.NotNull; import java.util.Date; /** * <p> * * @Entity JPA实体 * @Data GET SET TOSTRING * @NoArgsConstructor 无参构造 * @AllArgsConstructor 全参构造 * @Author niujinpeng * @Date 2018/12/19 17:13 */ @Data @NoArgsConstructor @AllArgsConstructor @Entity @Table(name = "user") public class User { /** * 用户ID * * @Id 主键 * @GeneratedValue 自增主键 */ @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Integer id; /** * 用户名 */ @Column(name = "username", length = 32, nullable = false) @NotNull(message = "用户名不能为空") private String username; /** * 密码 */ @Column(name = "password", length = 32, nullable = false) @NotNull(message = "密码不能为空") private String password; /** * 年龄 */ @Column(name = "age", length = 3) private Integer age; /** * 生日 */ @DateTimeFormat(pattern = "yyyy-MM-dd hh:mm:ss") private Date birthday; /** * 技能 */ private String skills; } 4.2. JPA 操作接口

JPA 操作接口只需要继承 JpaRepository 就可以了，JpaRepository 里封装了常用的增删改查分页等方法，可以直接使用，如果需要自定义查询方式，可以通过构造方法名的方式增加。下面增加了一个根据 username 和 password 查询 User 信息的方法。

package net.codingme.boot.domain.repository; import net.codingme.boot.domain.User; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.stereotype.Repository; /** * <p> * * @Author niujinpeng * @Date 2019/1/1114:26 */ @Repository public interface UserRepository extends JpaRepository<User, Integer> { /** * 一个自定义方法，根据 username 和 password 查询 User 信息 */ User findByUsernameAndPassword(String username, String password); }

到这里，Jpa 的功能已经可以测试使用了，关于 Service 层和 Controller 就不在这里贴了，直接编写 Springboot 单元测试进行 Jpa 测试。

5. Spring data jpa 测试

使用 Springboot 的单元测试方法可以方便的测试 Springboot 项目，对 Springboot 单元测试不了解的可以直接参照的说明，当然，也可以直接看下面的示例代码。
下面编写四个测试方法分别测试根据 Id 查询、分页查询、更新数据、根据 username 和 password 查询四个功能。

package net.codingme.boot.domain.repository; import net.codingme.boot.domain.User; import org.junit.Assert; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageRequest; import org.springframework.test.context.junit4.SpringRunner; import java.util.List; import java.util.Optional; /** * 单元测试 */ @RunWith(SpringRunner.class) @SpringBootTest public class UserRepositoryTest { @Autowired private UserRepository userRepository; /** * id查询 */ @Test public void findByIdUserTest() { Optional<User> userOptional = userRepository.findById(1); User user = userOptional.orElseGet(null); System.out.println(user); Assert.assertNotNull(user); } /** * 分页查询 */ @Test public void findByPageTest() { PageRequest pageRequest = PageRequest.of(0, 2); Page<User> userPage = userRepository.findAll(pageRequest); List<User> userList = userPage.getContent(); userList.forEach((user) -> System.out.println(user)); Assert.assertNotNull(userList); } /** * 更新 */ @Test public void updateUserTest() { Optional<User> userOptional = userRepository.findById(1); User user = userOptional.orElseThrow(() -> new RuntimeException("用户信息没有取到")); System.out.println(user.getAge()); ; user.setAge(user.getAge() + 1); User updateResult = userRepository.save(user); Assert.assertNotNull(updateResult); } /** * 根据 Username 和 Password 查询 */ @Test public void findByUsernameAndPasswordTest() { User user = userRepository.findByUsernameAndPassword("Darcy", "123"); System.out.println(user); Assert.assertNotNull(user); } }

首先看到四个方法全部运行通过。

分页查询查出数据库中的两条数据。

Hibernate: select user0_.id as id1_0_, user0_.age as age2_0_, user0_.birthday as birthday3_0_, user0_.password as password4_0_, user0_.skills as skills5_0_, user0_.username as username6_0_ from user user0_ limit ? Hibernate: select count(user0_.id) as col_0_0_ from user user0_ User(id=1, username=Darcy, password=123, age=18, birthday=2019-01-12 21:02:30.0, skills=Go) User(id=3, username=Chris, password=456, age=23, birthday=2019-01-01 00:11:22.0, skills=Java)