1.Spring Data JPA的概念
在介绍Spring Data JPA的时候,我们首先认识下Hibernate。Hibernate是数据访问解决技术的绝对霸主,使用O/R映射(Object-Relational Mapping)技术实现数据访问,O/R映射即将领域模型类和数据库的表进行映射,通过程序操作对象而实现表数据操作的能力,让数据访问操作无须关注数据库相关的技术。
随着Hibernate的盛行,Hibernate主导了EJB 3.0的JPA规范,JPA即Java Persistence API。JPA是一个基于O/R映射的标准规范(目前最新版本是JPA 2.1)。所谓规范即只定义标准规则(如注解、接口),不提供实现,软件提供商可以按照标准规范来实现,而使用者只需按照规范中定义的方式来使用,而不用和软件提供商的实现打交道。JPA的主要实现由Hibernate、EclipseLink和OpenJPA等,这也意味着我们只要使用JPA来开发,无论是哪一个开发方式都是一样的。
Spring Data JPA是Spring Data的一个子项目,它通过提供基于JPA的Repository极大地减少了JPA作为数据访问方案的代码量。
2、Spring Data Jpa ,JPA规范,和Hibernate 关系示意图
3、Spirng-Data-JPA优点
零配置,使用简单。
简化了我们的持久层开发工作,可以让我们持久层不用去书写具体实现代码,直接写一个继承Repository接口的Dao接口,然后开启JPA的注解扫描就可以进行持久层开发了(开启注解后,会自动扫描所有继承了Repository接口的子接口或者子实现,并自动将它交给Spring去进行管理,可以说是很好的与Spring整合)。SpringDataJPA提供了一些常用的ACID(数据库事务正确执行的四个要素基本缩写)抽象方法,我们可以直接拿来使用,此外,在这些抽象方法不够使用的时候,还提供了属性表达式、命名查询、Query注解等方式供我们使用.。
此外SpringDataJPA简化了分页的业务处理,它的Repository接口实现了
PagingAndSortingRepository接口,我们要做的只是将相关数据封装到
PagingAndSortingRepository接口中的findAll()方法中,它自动给我们返回Page对象,我们可以针对返回的Page对象根据我们的需求自动解析并封装成我们想要的JSON数据
4、Spring Data JPA入门
使用Spring Data jpa搭建入门案例,完成对mysql中数据表的简单增删改查、排序、分页等基础操作。
4.1、开发环境
maven + spring + mysql+hibernate + spring data jpa
4.2、创建数据库表
数据库表结构
SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;
-- ----------------------------
-- Table structure for tb_resume
-- ----------------------------
DROP TABLE IF EXISTS `tb_resume`;
CREATE TABLE `tb_resume` (
ìd` bigint(20) NOT NULL AUTO_INCREMENT,
àddress` varchar(255) DEFAULT NULL,
`name` varchar(255) DEFAULT NULL,
`phone` varchar(255) DEFAULT NULL,
PRIMARY KEY (ìd`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of tb_resume
-- ----------------------------
BEGIN;
INSERT INTO `tb_resume` VALUES (1, '北京', '张三', '131000000');
INSERT INTO `tb_resume` VALUES (2, '上海', '李四', '151000000');
INSERT INTO `tb_resume` VALUES (3, '广州', '王五', '153000000');
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;
4.3、创建maven项目 pom文件如下
4.0.0
com.lagou.edu
spring-data-jpa
1.0-SNAPSHOT
junit
junit
4.12
test
org.springframework.data
spring-data-jpa
2.1.8.RELEASE
javax.el
javax.el-api
3.0.1-b04
org.glassfish.web
javax.el
2.2.6
org.springframework
spring-aop
5.1.12.RELEASE
org.aspectj
aspectjweaver
1.8.13
org.springframework
spring-context
5.1.12.RELEASE
org.springframework
spring-context-support
5.1.12.RELEASE
org.springframework
spring-orm
5.1.12.RELEASE
org.springframework
spring-beans
5.1.12.RELEASE
org.springframework
spring-core
5.1.12.RELEASE
org.hibernate
hibernate-core
5.4.0.Final
org.hibernate
hibernate-entitymanager
5.4.0.Final
org.hibernate
hibernate-validator
5.4.0.Final
mysql
mysql-connector-java
5.1.46
com.alibaba
druid
1.1.21
org.springframework
spring-test
5.1.12.RELEASE
org.apache.maven.plugins
maven-compiler-plugin
3.1
11
11
UTF-8
4.5、配置Spring项目的配置文件
4.6、创建java对象和数据库表结构的映射
实体类和数据表映射关系使用注解 @Entity 和 @Table
实体属性和数据库字段映射 @Id 标识主键 @GeneratedValue 标识主键的生成策略 @Column 建立属性和字段映射
这些注解都是属于 javax.persistence.*; 包中
/**
* 简历实体类(在类中要使用注解建立实体类和数据表之间的映射关系以及属性和字段的映射关系)
* 1、实体类和数据表映射关系
* @Entity
* @Table
* 2、实体类属性和表字段的映射关系
* @Id 标识主键
* @GeneratedValue 标识主键的生成策略
* @Column 建立属性和字段映射
*/
@Entity
@Table(name = "tb_resume")
public class Resume {
@Id
/**
* 生成策略经常使用的两种:
* GenerationType.IDENTITY:依赖数据库中主键自增功能 Mysql
* GenerationType.SEQUENCE:依靠序列来产生主键 Oracle
*/
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
private Long id;
@Column(name = "name")
private String name;
@Column(name = "address")
private String address;
@Column(name = "phone")
private String phone;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
public String getPhone() {
return phone;
}
public void setPhone(String phone) {
this.phone = phone;
}
@Override
public String toString() {
return "Resume{" +
"id=" + id +
", name='" + name + '\'' +
", address='" + address + '\'' +
", phone='" + phone + '\'' +
'}';
}
}
4.7、编写java对象对应的dao接口 ResumeDao.java
- 一个符合SpringDataJpa要求的Dao层接口是需要继承JpaRepository和JpaSpecificationExecutor
- JpaRepository<操作的实体类类型,主键类型> 封装了基本的CRUD操作
- JpaSpecificationExecutor<操作的实体类类型> 封装了复杂的查询(分页、排序等)
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
public interface ResumeDao extends JpaRepository, JpaSpecificationExecutor {
}
4.8、新建单元测试类
import com.lagou.edu.pojo.Resume;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.*;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import javax.persistence.criteria.*;
import java.util.List;
import java.util.Optional;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext.xml"})
public class ResumeDaoTest {
// 要测试IOC哪个对象注入即可
@Autowired
private ResumeDao resumeDao;
}
5、简单的增删改查用例
5.1、通过主键id查询一条记录
直接使用resumeDao自带的方法就可实现基本的查询,返回Optional对象
@Test
public void testFindById(){
// 早期的版本 dao.findOne(id);
/* 方法打印的SQL
select resume0_.id as id1_0_0_,
resume0_.address as address2_0_0_, resume0_.name as name3_0_0_,
resume0_.phone as phone4_0_0_ from tb_resume resume0_ where resume0_.id=?
*/
Optional optional = resumeDao.findById(1l);
Resume resume = optional.get();
System.out.println(resume);
}
5.2、通过Example来多条件查询
org.springframework.data.domain.Example <目标对象>
@Test
public void testFindOne(){
Resume resume = new Resume();
resume.setId(1l);
resume.setName("张三");
Example example = Example.of(resume);
Optional one = resumeDao.findOne(example);
Resume resume1 = one.get();
System.out.println(resume1);
}
5.3、通过JpaRepository继承来的save方法,实现新增和更新
新增和更新都使用save方法,通过传入的对象的主键有无来区分,没有主键信息那就是新增,有主键信息就是更新。
@Test
public void testSave(){
// 新增和更新都使用save方法,通过传入的对象的主键有无来区分,没有主键信息那就是新增,有主键信息就是更新
Resume resume = new Resume();
resume.setId(5l);
resume.setName("赵六六");
resume.setAddress("成都");
resume.setPhone("132000000");
Resume save = resumeDao.save(resume);
System.out.println(save);
}
5.4、根据id删除
@Test
public void testDelete(){
resumeDao.deleteById(5l);
}
5.5、对结果进行分页
- 新建一个Pageable对象,设置分页值。参数1为页码,参数2为分页大小
- 查询的分页结果,保存在Page对象中。
@Test
public void testPage(){
/**
* 第一个参数:当前查询的页数,从0开始
* 第二个参数:每页查询的数量
*/
Pageable pageable = PageRequest.of(0,2);
//Pageable pageable = new PageRequest(0,2);
Page all = resumeDao.findAll(pageable);
System.out.println(all);
}
6、Jpql查询、原生sql查询、自定义方法命名查询、动态查询用例
6.1、jpql查询
- 正如Hibernate 有他自己的hql (Hibernate query language) ,JPA定义了自己的查询语言,名为 java persistence query language。
- jpql 将SQL语法和简单查询语义绑定在一起·使用这种语言编写的查询是可移植的,可以被编译成所有主流数据库服务器上的SQL。
- jpql 特征与原生SQL语句类似,并且完全面向对象,通过类名和属性访问,而不是表名和表的属性。
- jpql包含 select 、update、delete的语法,这里简单举个栗子。要详细使用时再查呗
- 在ResumeDao.java接口中定义一个方法,使用注解完成jpql的编写
@Query("from Resume where id=?1 and name=?2")
public List findByJpql(Long id,String name);
6.2、测试调用
@Test
public void testJpql(){
List list = resumeDao.findByJpql(1l, "张三");
for (int i = 0; i < list.size(); i++) {
Resume resume = list.get(i);
System.out.println(resume);
}
}
6.3、原生SQL查询
原生SQL查询,也是在dao接口的方法中使用注解编写sql,需要设置注解 nativeQuery = true,该属性默认为false
@Query(value = "select * from tb_resume where name like ?1 and address like ?2",nativeQuery = true)
public List findBySql(String name,String address);
@Test
public void testSql(){
List list = resumeDao.findBySql("李%", "上海%");
for (int i = 0; i < list.size(); i++) {
Resume resume = list.get(i);
System.out.println(resume);
}
}
7、动态查询
- 动态查询可以动态的组合想要查询的条件,使用的时候,需要实现 Specification接口,生成对象,传入查询方法
- Specification主要包含了 toPredicate(Root
root, CriteriaQuery> criteriaQuery, CriteriaBuilder criteriaBuilder)方法。需要重写该方法来定义查询的条件。 - root参数,用来获取对象的属性值
- CriteriaQuery 自定义查询方式,一般用不上。
- CriteriaBuilder 查询构造器,构造查询的条件。
7.1、单个条件查询用例
@Test
public void testSpecfication(){
/**
* 动态条件封装
* 匿名内部类
*
* toPredicate:动态组装查询条件
*
* 借助于两个参数完成条件拼装,,, select * from tb_resume where name='张三'
* Root: 获取需要查询的对象属性
* CriteriaBuilder:构建查询条件,内部封装了很多查询条件(模糊查询,精准查询)
*
* 需求:根据name(指定为"张三")查询简历
*/
Specification specification = new Specification() {
@Override
public Predicate toPredicate(Root root, CriteriaQuery> criteriaQuery, CriteriaBuilder criteriaBuilder) {
// 获取到name属性
Path<Object> name = root.get("name");
// 使用CriteriaBuilder针对name属性构建条件(精准查询)
Predicate predicate = criteriaBuilder.equal(name, "张三");
return predicate;
}
};
Optional optional = resumeDao.findOne(specification);
Resume resume = optional.get();
System.out.println(resume);
}
7.2、多个条件组合查询
@Test
public void testSpecficationMultiCon(){
/**
* 需求:根据name(指定为"张三")并且,address 以"北"开头(模糊匹配),查询简历
*/
Specification specification = new Specification() {
@Override
public Predicate toPredicate(Root root, CriteriaQuery> criteriaQuery, CriteriaBuilder criteriaBuilder) {
// 获取到name属性
Path<Object> name = root.get("name");
Path<Object> address = root.get("address");
// 条件1:使用CriteriaBuilder针对name属性构建条件(精准查询)
Predicate predicate1 = criteriaBuilder.equal(name, "张三");
// 条件2:address 以"北"开头(模糊匹配)
Predicate predicate2 = criteriaBuilder.like(address.as(String.class), "北%");
// 组合两个条件
Predicate and = criteriaBuilder.and(predicate1, predicate2);
return and;
}
};
Optional optional = resumeDao.findOne(specification);
Resume resume = optional.get();
System.out.println(resume);
}
8、总结
Srping Data JPA实现了对JPA规范的ORM框架的又一层封装,对于使用ORM框架的用户来说,切换为JPA的API来实现业务,后期更换ORM框架的话可以做到最少的修改。
对于Spring来说,他将SUN公司的JPA规范进行了封装,让使用JPA规范的持久层框架用户的操作变得更简单。官方自己说的 Spring Data JPA 旨在通过将工作量减少到实际需要的数量来显著改进数据访问层的实现。