SpringData核心数据访问接口--PagingAndSortingRepository

PagingAndSortingRepository继承自CrudRepository接口，所以除了拥有CrudReposirory的功能外，他还增加了排序和分页查询的功能。

创建一个Maven项目，在src/main下新建一个名为resources的文件夹。

①修改pom.xml

<groupId>com.ysh</groupId>
<artifactId>pagingandsortingrepositorytest</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>pagingandsortingrepositorytest</name>
<url>http://maven.apache.org</url>

<parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>2.0.0.RELEASE</version>
  <relativePath/>
</parent>

   <properties>
  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  <java.version>1.8</java.version>
</properties>

<dependencies>


<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>


<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>


    <dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
</dependency>

         
     <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <scope>test</scope>
    </dependency>
</dependencies>
</project>

修改完之后，保存，右击项目名选择Maven---update project

②配置基本属性

在src/main/resources下新建一个全局配置文件，命名为application.properties

#数据库地址，其中springdatajpa是数据库名称

spring.datasource.url=jdbc:mysql://localhost:3306/springdatajpa

#数据库用户名

spring.datasource.username=root

#数据库密码，要改成自己的密码

spring.datasource.password=yourpassword

#数据库驱动，固定格式

spring.datasource.driverClassName=com.mysql.jdbc.Driver

#指定连接池中最大的活跃连接数

spring.datasource.max-active=20

#指定连接池最大的空闲连接

spring.datasource.max-idle=8

#指定必须保持连接的最小值

spring.datasource.min-idle=8

spring.datasource.initial-size=10

########################################################
### JPA持久化配置
########################################################
# 指定数据库类型
spring.jpa.database=MySQL
# 指定是否需要在日志中显示sql语句
spring.jpa.show-sql=true
# 指定自动创建|更新|验证数据库表结构等配置
# 表示如果数据库中存在持久化类对应的表就不创建，不存在就创建对应的表
spring.jpa.hibernate.ddl-auto=update
# 指定命名策略
spring.jpa.hibernate.naming-strategy=org.hibernate.cfg.ImprovedNamingStrategy
#指定数据库方言
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect

③创建持久化类

在com.ysh下新建4个包，bean(放置持久化类)、controller(控制器)、repository(定义数据访问接口的类)、service(业务逻辑处理类)

在bean下创建持久化类Article.java

package com.ysh.pagingandsortingrepositorytest.bean;

import java.io.Serializable;
import java.util.Date;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;

/**
* 商品对象
* */
@Entity
@Table(name="tb_article")
public class Article implements Serializable{

private static final long serialVersionUID = 1L;

@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private int id;
private String title;
private String supplier;
private Double price;
private String locality;
private Date putawayDate;
private int storage;
private String image;
private String description;
private Date createDate;
public int getId() {
  return id;
}
public void setId(int id) {
  this.id = id;
}
public String getTitle() {
  return title;
}
public void setTitle(String title) {
  this.title = title;
}
public String getSupplier() {
  return supplier;
}
public void setSupplier(String supplier) {
  this.supplier = supplier;
}
public Double getPrice() {
  return price;
}
public void setPrice(Double price) {
  this.price = price;
}
public String getLocality() {
  return locality;
}
public void setLocality(String locality) {
  this.locality = locality;
}
public Date getPutawayDate() {
  return putawayDate;
}
public void setPutawayDate(Date putawayDate) {
  this.putawayDate = putawayDate;
}
public int getStorage() {
  return storage;
}
public void setStorage(int storage) {
  this.storage = storage;
}
public String getImage() {
  return image;
}
public void setImage(String image) {
  this.image = image;
}
public String getDescription() {
  return description;
}
public void setDescription(String description) {
  this.description = description;
}
public Date getCreateDate() {
  return createDate;
}
public void setCreateDate(Date createDate) {
  this.createDate = createDate;
}

}

④定义数据访问层接口

在repository包下新建一个接口，命名为ArticleRepository,让该接口继承PagingAndSortingRepository

package com.ysh.pagingandsortingrepositorytest.repository;

import org.springframework.data.repository.PagingAndSortingRepository;

import com.ysh.pagingandsortingrepositorytest.bean.Article;

public interface ArticleRepository extends PagingAndSortingRepository<Article, Integer> {

}

在Spring Boot项目中，数据访问层接口无须提供实现，直接继承数据访问接口即可

⑤定义业务层类

ArticleService.java

package com.ysh.pagingandsortingrepositorytest.service;

import javax.annotation.Resource;

import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;

import com.ysh.pagingandsortingrepositorytest.bean.Article;
import com.ysh.pagingandsortingrepositorytest.repository.ArticleRepository;

@Service
public class ArticleService {

// 注入数据访问层接口对象
@Resource
private ArticleRepository articleRepository;

public Iterable<Article> findAllSort(Sort sort) {
return articleRepository.findAll(sort);
}

public Page<Article> findAll(Pageable page) {
return articleRepository.findAll(page);
}

}

⑥定义控制器类

在controller包下先新建一个控制器类，命名ArticleController

package com.ysh.pagingandsortingrepositorytest.controller;

import java.util.List;
import javax.annotation.Resource;

import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.ysh.pagingandsortingrepositorytest.bean.Article;
import com.ysh.pagingandsortingrepositorytest.service.ArticleService;

@RestController
@RequestMapping("/article")
public class ArticleController {

// 注入ArticleService
@Resource
private ArticleService articleService;

@RequestMapping("/sort")
public Iterable<Article> sortArticle() {
  // 指定排序参数对象：根据id，进行降序查询
  Sort sort = new Sort(Sort.Direction.DESC, "id");
  Iterable<Article> articleDatas = articleService.findAllSort(sort);
  return articleDatas;
}

@RequestMapping("/pager")
public List<Article> sortPagerArticle(int pageIndex) {
  // 指定排序参数对象：根据id，进行降序查询
  Sort sort = new Sort(Sort.Direction.DESC, "id");
  /**
   * 封装分页实体参数一：pageIndex表示当前查询的第几页(默认从0开始，0表示第一页) 参数二：表示每页展示多少数据，现在设置每页展示2条数据
   * 参数三：封装排序对象，根据该对象的参数指定根据id降序查询
   * */
  Pageable page = PageRequest.of(pageIndex - 1, 2, sort);
  Page<Article> articleDatas = articleService.findAll(page);
  System.out.println("查询总页数:" + articleDatas.getTotalPages());
  System.out.println("查询总记录数:" + articleDatas.getTotalElements());
  System.out.println("查询当前第几页:" + articleDatas.getNumber() + 1);
  System.out.println("查询当前页面的记录数:" + articleDatas.getNumberOfElements());
  // 查询出的结果数据集合
  List<Article> articles = articleDatas.getContent();
  System.out.println("查询当前页面的集合:" + articles);
  return articles;
}
}

⑦测试应用

启动MySql数据库，新建数据库springdatajpa数据库

新建App.java启动类

package com.ysh.pagingandsortingrepositorytest;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
* @SpringBootApplication指定这是一个 spring boot的应用程序.
*/
@SpringBootApplication
public class App
{
    public static void main( String[] args )
    {
    // SpringApplication 用于从main方法启动Spring应用的类。
        SpringApplication.run(App.class, args);
    }
}

项目启动后，JPA会在数据库中自动创建持久化类对应的tb_article表，然后打开此表，插入一些数据

打开浏览器，输入:localhost:8080/article/sort

请求会提交到ArticleController类的sortArticle方法进行处理，该方法执行顺序查询，将tb_article表中的数据以降序的方式查出并以JSON格式返回浏览器

用谷歌浏览器打开：

用火狐浏览器打开：

测试分页查询第一页商品数据，在浏览器中输入：http://localhost:8080/article/pager?pageIndex=1

请求会提交到ArticleController类的sortPageArticle方法中进行处理，该方法接受pageIndex参数，根据参数确定查询第几页数据

查询第一页数据

查询第二页数据：在浏览器中输入：http://localhost:8080/article/pager?pageIndex=2

附：项目目录结构

示例代码下载：

https://download.csdn.net/download/badao_liumang_qizhi/10549085

SpringData核心数据访问接口--PagingAndSortingRepository相关推荐

SpringData核心数据访问接口--CrudRepository示例
1.Spring Data JPA可以极大地简化JPA的写法,在几乎不用写接口实现的情况下完成对数据的访问和操作. 2.Spring Data通过提供Repository接口来约定数据访问的统一标准. ...
通用的数据访问 OleDbHelper 通用的数据访问接口 IDbHelper(转）
通用的数据访问 OleDbHelper http://www.cnblogs.com/jirigala/archive/2008/06/25/1229361.html 通用的数据访问接口 IDbHel ...
Java实训项目10：GUI学生信息管理系统 - 实现步骤 - 创建数据访问接口实现类
文章目录七.实现步骤 (六)创建数据访问接口实现类 1.创建学校数据访问接口实现类单元测试:对CollegeDaoImpl进行单元测试 (1)编写测试方法testFindById() (2)编写测 ...
Java实训项目9：GUI学生信息管理系统 - 实现步骤 - 创建数据访问接口
文章目录七.实现步骤 (五)创建数据访问接口 1.创建学校数据访问接口 2.创建状态数据访问接口 3.创建学生数据访问接口 4.创建用户数据访问接口七.实现步骤 (五)创建数据访问接口 DAO: ...
数据访问接口功能及含义
ADC 高级数据连接器(AdvancedDataConnector):提供绑定ADO数据源到窗体的数据绑定控件上.ADC主要是一种直接访问或者通过ADO访问远程OLEDB对象的一种技术,它也支持主要 ...
VB.NET学习笔记：ADO.NET操作ACCESS数据库——ADO.NET数据访问接口
一.ADO.NET概述 Ado.net基于XML和离线计算模型. ADO.net的两个核心组件:.Net数据提供程序.DataSet. .net数据提供程序用来与数据库的连接,如SQLServer.n ...
一致的数据访问技术ADO/OLE DB
Microsoft新近推出的UDA(Universal Data Access,一致数据访问技术)为关系型或非关系型数据访问提供了一致的访问接口,为企业级Intranet应用多层软件结构提供了数据 ...
【7】AccessDB快速数据访问
阅读目录 C#和VB数据访问的比较 AccessDB的设计数据库的连接三种主要操作错误输出及调试小结回到顶部 C#和VB数据访问的比较 C#中要进行一次普通的数据库查询,需要创建连接,再根据 ...
面对1.3 亿用户数据泄露，企业如何围绕核心数据构建安全管理体系？
大表哥 helen 再次重现江湖,并且带来不断的惊喜~~~ 据 FreeBuf 报道,8 月 28 日早上 6 点,暗网中文论坛中出现一个帖子,声称售卖华住旗下所有酒店数据,数据标价 8 个比特币,约 ...

SpringData核心数据访问接口--PagingAndSortingRepository

SpringData核心数据访问接口--PagingAndSortingRepository相关推荐

最新文章

热门文章