SpringBoot数据持久化之SpringDataJPA!

360影视 欧美动漫 2025-06-02 14:58 1

摘要:项目在运行过程中会产生很多业务数据,一般我们把数据保存起来的这个过程称为数据持久化。数据可以保存在内存、文件和数据库中,最普遍的方式是把数据保存到数据库中。

项目在运行过程中会产生很多业务数据,一般我们把数据保存起来的这个过程称为数据持久化。数据可以保存在内存、文件和数据库中,最普遍的方式是把数据保存到数据库中。

因为经常要把数据保存到数据库中,所以Spring抽象出了一套数据库访问框架——spring Data JPA,它集成了多种数据访问技术,支持JDBC、MyBatis、Hibernate和JPA等数据持久化框架。

在介绍Spring Data JPA之前需要先介绍下JPA(Java PersistenceAPI,Java持久化API),它是Sun公司在JDK 1.5发布后提出的Java持久化规范(JSR 338)。JPA规范定义了一系列的标准接口,让实体类和数据库的表之间建立了一个对应关系,当在代码中将数据保存到数据库中时,可以不写SQL就能操作数据库中的数据表。

JPA的实现思想即ORM(Object Relation Mapping,对象关系映射),用于在关系型数据库和实体对象之间建立一种映射关系。JPA规范是为了简化项目开发中的数据持久化以及整合不同的ORM技术。JPA是在现有的ORM框架基础上发展而来的,具有易于使用和伸缩性强的特点。

Spring Data JPA是基于Spring团队在JPA接口之上添加的一层抽象接口(Repository层的实现)所形成的ORM框架,它极大地降低了持久层开发及ORM框架切换的成本。Spring Data JPA底层是使用Hibernate的JPA技术实现的,它提供了包括增、删、改、查等常用的功能。在使用Spring Data JPA时不需要手写SQL语句,因为框架在底层已经自动生成了操作数据库的SQL,只需要在使用过程中遵守JPA的规范即可。

在接口开发的过程中,一个非常重要的原则就是不信任任何的输入,开发者根本不知道传递的是什么参数,因此需要对入参进行参数的校验,否则极有可能引发系统故障,或者造成业务数据的错误。

传统的if…else校验

以前,开发者经常在Controller中对参数进行if…else判断,如果参数不符合要求,就提示用户参数错误,流程不再进行下去,类似下面的代码:

package com.springboot.demo;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RestController;

@RestController

public class UserController1 {

/**

* 保存新的用户

* @param user

*/

@PostMapping("/save")

public void saveUser(@RequestBody User user) {

if (user.getAge > 120) {

throw new IllegalArgumentException("最大年龄小于120");

}

if (user.getage

throw new IllegalArgumentException("最小年龄大于1");

}

if (user.getUserName == null) {

throw new IllegalArgumentException("用户名不能为空");

} if (user.getUserName.length > 10) {

throw new IllegalArgumentException("用户名长度不能超过10");

}

if(user.getPassword==null){

throw new IllegalArgumentException("密码不能为空");

}

//saveTheUser

}

}

以上代码中对应的User实体类的代码如下:

package com.springboot.demo;

import lombok.Data;

import javax.persistence.Column;

import javax.persistence.Entity;

import javax.persistence.GeneratedValue;

import javax.persistence.Id;

@Entity

@Data

public class User {

@Id

@GeneratedValue

private long id;

@Column(nullable = false, unique = true)

private String userName;

@Column(nullable = false)

private String password;

private int age;

}

Controller中的if代码能够满足参数校验功能的需要,但是代码逻辑非常“丑陋”,没有一点优雅、复用性可言。Spring Boot中是怎么处理的呢?

在Spring Boot项目中,可以使用Spring Boot Validate进行参数的校验,开发人员只需要简单地标记注解就能完成参数的校验。下面演示SpringBoot的参数校验。

(1)在pom.xml中添加校验的依赖如下:

org.springframework.boot

spring-boot-starter-validation

(2)首先新建包com.springboot.demo,再新建一个类UserController2用于参数校验,执行新建用户的保存方法。

package com.springboot.demo;

import org.springframework.web.bind.annotation.*;

import javax.validation.Valid;

@RestController

public class UserController2 {

/**

* 保存新的用户

* @param user

*/

@PostMapping("/save")

public void saveUser(@Valid @RequestBody User user) {

//saveTheUser }

}

(3)在包com.springboot.demo中新建User实体类并在其中配置校验,代码如下:

package com.springboot.demo;

import lombok.Data;

import org.hibernate.validator.constraints.Length;

import javax.persistence.*;

import javax.validation.constraints.Max;

import javax.validation.constraints.Min;

import javax.validation.constraints.NotBlank;

@Entity

@Data

public class User {

@Id

@GeneratedValue

private long id;

@NotBlank

@Length(max = 10, message = "用户名长度不能超过10")

@Column(nullable = false, unique = true)

private String userName;

@NotBlank(message = "密码不能为空")

@Column(nullable = false)

private String password;

@Max(value = 120, message = "最大年龄小于120")

@Min(value = 1, message = "最小年龄大于1")

private int age;

}

(4)在UserController2的方法中给要校验的参数标记上@Valid注解,再使用如@Not- Blank、@Min和@Max注解并且加上提示信息就能完成参数的校验。

(5)为了系统的完整性,在Spring Boot项目中增加系统异常的处理,需要给用户返回统一的结果并在结果中提示入参的具体错误。在包com.springboot.demo中新建ValidateCommonHandler异常处理类,代码如下:

package com.springboot.demo;

import org.springframework.http.*;

import org.springframework.validation.FieldError;

import org.springframework.web.bind.MethodArgumentNotValidException;

import org.springframework.web.context.request.WebRequest;

import org.springframework.web.servlet.mvc.method.annotation.Response

EntityExceptionHandler;

public class ValidateCommonHandler extends

ResponseEntityExceptionHandler {

@Override

protected ResponseEntity handleMethodArgumentNotValid(

MethodArgumentNotValidException ex,

HttpHeaders headers, HttpStatus status,

WebRequest request) {

ResponeVo vo = new ResponeVo;

vo.setCode(500);

for (FieldError fieldError :

ex.getBindingResult.getFieldErrors) {

String defaultMessage = fieldError.getDefaultMessage;

vo.setMessage(defaultMessage);

Object value = fieldError.getRejectedValue;

vo.setData(value);

break;

}

return new ResponseEntity(vo, HttpStatus.OK); }

}

新建一个ValidateCommonHandler类继承自ResponseEntityExceptionHandler接口,并且重写该接口的handleMethodArgumentNotValid方法,ResponseEntityExceptionHandler是统一处理所有经过Valid注解的接口,此处统一返回类ResponeVo的信息,用这个类和前端进行Restful交互,只要出现校验命中的就会执行此方法,并且携带具体的错误信息。

(6)在包com.springboot.demo中新建统一返回实体信息类ResponeVo:

package com.springboot.demo;

import lombok.Data;

@Data

public class ResponeVo {

private int code;

private String message;

private Object data;

}

上述代码中,code返回一个标识码,message字段用于返回校验的信息,data返回具体的数据。

Validate校验常用的注解

Spring Boot Validate的参数校验依赖于注解,可以对不同类型的参数配置相应的注解校验,常用的注解如表3.1所示。

表3.1 Validate注解

前面介绍了Spring Boot Validate的参数校验,现在演示在SpringBoot项目中如何使用Spring Data JPA保存数据,详细步骤如下:

(1)在pom.xml中添加Spring Data JPA依赖和mysql的驱动依赖:

org.springframework.boot

spring-boot-starter-web

spring-boot-starter-test

mysql

mysql-connector-java

spring-boot-starter-data-jpa

org.projectlombok

lombok

(2)在application.properties中添加项目的配置文件,包括MySQL的链接、用户名、密码、驱动类及Spring JPA的配置:

spring.datasource.url=jdbc:mysql://localhost:3306/test?

useUnicode=true&

characterEncoding=utf-8&serverTimezone=UTC&useSSL=true

spring.datasource.username=root

spring.datasource.password=q123456.

spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

spring.jpa.properties.hibernate.hbm2ddl.auto=update

spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5In

n

oDBDialect

spring.jpa.show-sql=true

(3)在包com.springboot.demo中添加User的实体类:

package com.springboot.demo;

import lombok.Data;

import javax.persistence.*;

@Entity

@Data

public class User {

@Id

@GeneratedValue

private long id;

@Column(nullable = false, unique = true)

private String userName;

@Column(nullable = false)

private String password;

private int age;

}

(4)在包com.springboot.demo中添加数据库的操作Dao接口代码如下:

package com.springboot.demo;

import org.springframework.data.jpa.repository.JpaRepository;

public interface UserRepository extends JpaRepository {

//根据名字查询用户

User findByUserName(String userName);

}

(5)在包com.springboot.demo中新增Spring Boot的启动类代码如下:

package com.springboot.demo;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication

public class App {

public static void main(String args) {

SpringApplication.run(App.class,args);

}

}

(6)在包com.springboot.demo中增加使用Spring Data JPA操作数据库的测试类代码如下:

package com.springboot.demo;

import lombok.extern.slf4j.Slf4j;

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;

importorg.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.util.Optional;

@Slf4j

@RunWith(SpringJUnit4ClassRunner.class)

@SpringBootTest(classes = App.class)

public class UserTest {

@Autowired

private UserRepository userRepository;

@Test

public void userTest {

User user = new User;

user.setUserName("myCc");

user.setAge(18);

user.setPassword("123");

//保存用户

userRepository.save(user);

//根据名字查询用户

User item = userRepository.findByUserName("myCc");

System.out.println(item);

Assert.assertNotNull(item);

//ID为1的用户是否存在

Assert.assertEquals(true, userRepository.existsById(1L));

//根据ID查询用户

Optional byId = userRepository.findById(1L);

Assert.assertEquals(true, byId.isPresent);

Assert.assertEquals(true,

userRepository.findById(2L).isPresent);

//删除ID为1的用户

userRepository.deleteById(1L);

//判断ID为1的用户是否存在

Assert.assertEquals(false, userRepository.existsById(1L));

}

}

至此,项目代码的书写工作就完成了,当前整个项目的结构如图3.1所示。

图3.1 项目结构

运行UserTest测试类执行全部的测试用例,完成后使用客户端连接数据库查看user表中的数据,如图3.2所示,程序已经成功地把数据插入数据库中。

图3.2 user表中的数据

Spring Data JPA会根据方法名字自动解析方法名后拼接成SQL语句,然后设置参数,最后再执行SQL语句,完成数据库的操作。

前面的UserRepository接口继承自JpaRepository,该接口中自定义了方法findByUserName。同理,还可以在UserRepository接口中定义以下方法:

Long deleteById(Long id);

List findByUserNameOrEmail(String username, String email);

List findByUserNameIgnoreCase(String userName);

Long countByUserName(String userName);

List findByEmailLike(String email);

List findByUserNameOrderByEmailDesc(String email);

在Spring Data JPA中,根据方法名字生成对应的SQL语句的规则如表3.2所示,在接口中自定义的方法会根据关键字生成SQL语句,从而在开发中不需要手写SQL语句。

表3.2 Spring Data JPA的SQL语句生成规则

Spring Data JPA也支持手写SQL语句。例如,在UserRepository中添加一个根据ID查询User的方法,然后在@Query注解中完成对自定义SQL语句的编写和参数设置,注意Spring Data JPA的参数是从1开始,取第一个参数即为?1,代码如下:

/**

* 根据ID查询用户

*/

@Query("select * from user where id=?1")

User queryById(Long id);

在@Query注解中完成对SQL执行语句和参数的设置,然后调用queryById方法完成查询功能。在项目开发中使用Spring Data JPA这种ORM的框架能够极大地提高开发效率,它使用面向对象的方式直接对数据库进行操作,不用每一个操作都写SQL语句,只有遇到复杂的查询需求时,才手写SQL语句完成CRUD。

说明:CRUD一般对应数据库常见的增、查、改、删操作。

来源:程序员高级码农II一点号

相关推荐