原文: http://zetcode.com/springboot/datajpaquery/

Spring Boot Data JPA @Query教程展示了如何使用 Data JPA @Query创建自定义查询。

Spring 是用于创建企业应用的流行 Java 应用框架。 Spring Boot 是 Spring 框架的演进,可帮助您轻松创建独立的,生产级的基于 Spring 的应用。

Spring Data JPA

Spring Data JPA 有助于实现基于 JPA 的存储库。 它增强了对基于 JPA 的数据访问层的支持。 它使构建使用数据访问技术的 Spring 支持的应用变得更加容易。 Spring Data JPA 是较大的 Spring Data 系列的一部分。

Spring Data JPA @Query

@Query注解直接在存储库方法上声明查找程序查询。 虽然在域类上使用了类似的@NamedQuery,但在Repository接口上使用了 Spring Data JPA @Query注解。 这样可以将域类从持久性特定的信息中解放出来,这是一件好事。

Spring Boot Data JPA @Query示例

以下应用是一个简单的 Spring Boot Web 应用,它使用 Data JPA @Query 创建一个自定义查询。

  1. pom.xml
  2. src
  3. ├───main
  4. ├───java
  5. └───com
  6. └───zetcode
  7. Application.java
  8. ├───controller
  9. MyController.java
  10. ├───model
  11. City.java
  12. ├───repository
  13. CityRepository.java
  14. └───service
  15. CityService.java
  16. ICityService.java
  17. └───resources
  18. application.properties
  19. data-h2.sql
  20. schema-h2.sql
  21. ├───static
  22. index.html
  23. └───templates
  24. showCities.ftl
  25. └───test
  26. └───java

这是项目结构。

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
  5. http://maven.apache.org/xsd/maven-4.0.0.xsd">
  6. <modelVersion>4.0.0</modelVersion>
  7. <groupId>com.zetcode</groupId>
  8. <artifactId>springbootcustomdatajpaquery</artifactId>
  9. <version>1.0-SNAPSHOT</version>
  10. <packaging>jar</packaging>
  11. <properties>
  12. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  13. <maven.compiler.source>11</maven.compiler.source>
  14. <maven.compiler.target>11</maven.compiler.target>
  15. </properties>
  16. <parent>
  17. <groupId>org.springframework.boot</groupId>
  18. <artifactId>spring-boot-starter-parent</artifactId>
  19. <version>2.1.1.RELEASE</version>
  20. </parent>
  21. <dependencies>
  22. <dependency>
  23. <groupId>com.h2database</groupId>
  24. <artifactId>h2</artifactId>
  25. <scope>runtime</scope>
  26. </dependency>
  27. <dependency>
  28. <groupId>org.springframework.boot</groupId>
  29. <artifactId>spring-boot-starter-web</artifactId>
  30. </dependency>
  31. <dependency>
  32. <groupId>org.springframework.boot</groupId>
  33. <artifactId>spring-boot-starter-freemarker</artifactId>
  34. </dependency>
  35. <dependency>
  36. <groupId>org.springframework.boot</groupId>
  37. <artifactId>spring-boot-starter-data-jpa</artifactId>
  38. </dependency>
  39. </dependencies>
  40. <build>
  41. <plugins>
  42. <plugin>
  43. <groupId>org.springframework.boot</groupId>
  44. <artifactId>spring-boot-maven-plugin</artifactId>
  45. </plugin>
  46. </plugins>
  47. </build>
  48. </project>

Maven POM 文件包含 H2 数据库,Freemarker 模板引擎和 Spring Boot Data JPA 的依赖项。

resources/application.properties

  1. server.servlet.contextPath=/myapp
  2. spring.main.banner-mode=off
  3. spring.datasource.platform=h2
  4. logging.level.org.hibernate.SQL=DEBUG
  5. spring.jpa.show-sql=true
  6. spring.jpa.hibernate.ddl-auto=none

application.properties文件中,我们编写了 Spring Boot 应用的各种配置设置。 server.servlet.contextPath设置上下文路径(应用名称)。 完成这些设置后,我们可以通过localhost:8080/myapp/访问该应用。 使用spring.main.banner-mode属性,我们可以关闭 Spring 横幅。

spring.datasource.platform设置数据库的供应商名称。 在初始化脚本中使用它。 spring.jpa.show-sql允许记录 SQL 语句。 最后,spring.jpa.hibernate.ddl-auto禁止从实体自动创建模式。

com/zetcode/model/City.java

  1. package com.zetcode.model;
  2. import java.util.Objects;
  3. import javax.persistence.Entity;
  4. import javax.persistence.GeneratedValue;
  5. import javax.persistence.GenerationType;
  6. import javax.persistence.Id;
  7. import javax.persistence.Table;
  8. @Entity
  9. @Table(name = "cities")
  10. public class City {
  11. @Id
  12. @GeneratedValue(strategy = GenerationType.AUTO)
  13. private Long id;
  14. private String name;
  15. private int population;
  16. public City() {
  17. }
  18. public City(String name, int population) {
  19. this.name = name;
  20. this.population = population;
  21. }
  22. public Long getId() {
  23. return id;
  24. }
  25. public void setId(Long id) {
  26. this.id = id;
  27. }
  28. public String getName() {
  29. return name;
  30. }
  31. public void setName(String name) {
  32. this.name = name;
  33. }
  34. public int getPopulation() {
  35. return population;
  36. }
  37. public void setPopulation(int population) {
  38. this.population = population;
  39. }
  40. @Override
  41. public int hashCode() {
  42. int hash = 7;
  43. hash = 79 * hash + Objects.hashCode(this.id);
  44. hash = 79 * hash + Objects.hashCode(this.name);
  45. hash = 79 * hash + this.population;
  46. return hash;
  47. }
  48. @Override
  49. public boolean equals(Object obj) {
  50. if (this == obj) {
  51. return true;
  52. }
  53. if (obj == null) {
  54. return false;
  55. }
  56. if (getClass() != obj.getClass()) {
  57. return false;
  58. }
  59. final City other = (City) obj;
  60. if (this.population != other.population) {
  61. return false;
  62. }
  63. if (!Objects.equals(this.name, other.name)) {
  64. return false;
  65. }
  66. return Objects.equals(this.id, other.id);
  67. }
  68. @Override
  69. public String toString() {
  70. var builder = new StringBuilder();
  71. builder.append("City{id=").append(id).append(", name=")
  72. .append(name).append(", population=")
  73. .append(population).append("}");
  74. return builder.toString();
  75. }
  76. }

这是City实体。 每个实体必须至少定义两个注解:@Entity@Id

  1. @Entity
  2. @Table(name = "cities")
  3. public class City {

@Entity注解指定该类是一个实体,并映射到数据库表。 @Table注解指定要用于映射的数据库表的名称。

  1. @Id
  2. @GeneratedValue(strategy = GenerationType.AUTO)
  3. private Long id;

@Id注解指定实体的主键,@GeneratedValue提供规范主键值的生成策略。

resources/schema-h2.sql

  1. CREATE TABLE cities(id INT PRIMARY KEY AUTO_INCREMENT,
  2. name VARCHAR(255), population INT);

启动应用时,将执行schema-h2.sql脚本。 它创建一个新的数据库表。

resources/data-h2.sql

  1. INSERT INTO cities(name, population) VALUES('Bratislava', 432000);
  2. INSERT INTO cities(name, population) VALUES('Budapest', 1759000);
  3. INSERT INTO cities(name, population) VALUES('Prague', 1280000);
  4. INSERT INTO cities(name, population) VALUES('Warsaw', 1748000);
  5. INSERT INTO cities(name, population) VALUES('Los Angeles', 3971000);
  6. INSERT INTO cities(name, population) VALUES('New York', 8550000);
  7. INSERT INTO cities(name, population) VALUES('Edinburgh', 464000);
  8. INSERT INTO cities(name, population) VALUES('Suzhou', 4327066);
  9. INSERT INTO cities(name, population) VALUES('Zhengzhou', 4122087);
  10. INSERT INTO cities(name, population) VALUES('Berlin', 3671000);

之后,执行data-h2.sql文件。 它用数据填充表。

com/zetcode/repository/CityRepository.java

  1. package com.zetcode.repository;
  2. import com.zetcode.model.City;
  3. import java.util.List;
  4. import org.springframework.data.jpa.repository.Query;
  5. import org.springframework.data.repository.CrudRepository;
  6. import org.springframework.stereotype.Repository;
  7. @Repository
  8. public interface CityRepository extends CrudRepository<City, Long> {
  9. @Query("select c from City c where c.name like %?1")
  10. List<City> findByNameEndsWith(String chars);
  11. }

通过从 Spring CrudRepository扩展,我们将为数据存储库实现一些方法。 另外,我们创建一个自定义的findByNameEndsWith()方法。

  1. @Query("select c from City c where c.name like %?1")
  2. List<City> findByNameEndsWith(String chars);

@Query注解包含自定义 JPQL 查询。 它返回名称以提供的字符结尾的城市。

com/zetcode/service/ICityService.java

  1. package com.zetcode.service;
  2. import com.zetcode.model.City;
  3. import java.util.List;
  4. public interface ICityService {
  5. List<City> findByNameEndsWith(String name);
  6. }

ICityService提供了一种获取所有以特定字符结尾的城市的契约方法。

com/zetcode/service/CityService.java

  1. package com.zetcode.service;
  2. import com.zetcode.model.City;
  3. import com.zetcode.repository.CityRepository;
  4. import java.util.List;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.stereotype.Service;
  7. @Service
  8. public class CityService implements ICityService {
  9. @Autowired
  10. private CityRepository repository;
  11. @Override
  12. public List<City> findByNameEndsWith(String name) {
  13. var cities = (List<City>) repository.findByNameEndsWith(name);
  14. return cities;
  15. }
  16. }

CityService包含findByNameEndsWith()方法的实现。 我们使用存储库从数据库检索数据。

  1. @Autowired
  2. private CityRepository repository;

注入CityRepository

  1. var cities = (List<City>) repository.findByNameEndsWith(name);

存储库的findByNameEndsWith()方法返回以某些字符结尾的城市列表。

com/zetcode/controller/MyController.java

  1. package com.zetcode.controller;
  2. import com.zetcode.model.City;
  3. import com.zetcode.service.ICityService;
  4. import java.util.List;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.stereotype.Controller;
  7. import org.springframework.ui.Model;
  8. import org.springframework.web.bind.annotation.GetMapping;
  9. import org.springframework.web.bind.annotation.RequestParam;
  10. @Controller
  11. public class MyController {
  12. @Autowired
  13. ICityService cityService;
  14. @GetMapping("/showCitiesEnding")
  15. public String findCitiesNameEndsWith(Model model, @RequestParam String name) {
  16. var cities = (List<City>) cityService.findByNameEndsWith(name);
  17. model.addAttribute("cities", cities);
  18. return "showCities";
  19. }
  20. }

MyController类用@Controller注解。

  1. @Autowired
  2. private ICityService cityService;

我们在cityService字段中插入ICityService

  1. @GetMapping("/showCitiesEnding")
  2. public String findCitiesNameEndsWith(Model model, @RequestParam String name) {
  3. var cities = (List<City>) cityService.findByNameEndsWith(name);
  4. model.addAttribute("cities", cities);
  5. return "showCities";
  6. }

我们将带有showCitiesEnding路径的请求映射到控制器的findCitiesNameEndsWith()方法。 该模型将获取匹配城市的列表,并将处理过程发送到showCities.ftl Freemarker 模板文件。

resources/templates/showCities.ftl

  1. <!DOCTYPE html>
  2. <html>
  3. <head>
  4. <title>Cities</title>
  5. <meta charset="UTF-8">
  6. <meta name="viewport" content="width=device-width, initial-scale=1.0">
  7. </head>
  8. <body>
  9. <h2>List of cities</h2>
  10. <table>
  11. <tr>
  12. <th>Id</th>
  13. <th>Name</th>
  14. <th>Population</th>
  15. </tr>
  16. <#list cities as city>
  17. <tr>
  18. <td>${city.id}</td>
  19. <td>${city.name}</td>
  20. <td>${city.population}</td>
  21. </tr>
  22. </#list>
  23. </table>
  24. </body>
  25. </html>

showCities.ftl模板文件中,我们在 HTML 表中显示数据。

resources/static/index.html

  1. <!DOCTYPE html>
  2. <html>
  3. <head>
  4. <title>Home page</title>
  5. <meta charset="UTF-8"/>
  6. <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
  7. </head>
  8. <body>
  9. <a href="showCitiesEnding?name=ou">Show cities ending in ou</a>
  10. </body>
  11. </html>

index.html中有一个链接,显示以ou字符结尾的城市。

com/zetcode/Application.java

  1. package com.zetcode;
  2. import org.springframework.boot.SpringApplication;
  3. import org.springframework.boot.autoconfigure.SpringBootApplication;
  4. @SpringBootApplication
  5. public class Application {
  6. public static void main(String[] args) {
  7. SpringApplication.run(Application.class, args);
  8. }
  9. }

Application设置 Spring Boot 应用。 @SpringBootApplication启用自动配置和组件扫描。

  1. $ mvn spring-boot:run

应用运行后,我们可以导航到localhost:8080/myapp/

在本教程中,我们展示了如何使用 Spring Data JPA @Query注解创建自定义 JPQL 查询。 您可能也对相关教程感兴趣:

列出所有 Spring Boot 教程