嘉兴制作网站软件,营销型 网站建设流程,小游戏网站建设公司,文章收费wordpressSpringData JPA
JPA 简介#xff1a; JPA#xff08;Java Persistence API#xff09;是 Java 持久层规范#xff0c;定义了一些列 ORM 接口#xff0c;它本身是不能直接使用的#xff0c;因为接口需要实现才能使用#xff0c;Hibernate 框架就是实现 JPA 规范的框架。…SpringData JPA
JPA 简介 JPAJava Persistence API是 Java 持久层规范定义了一些列 ORM 接口它本身是不能直接使用的因为接口需要实现才能使用Hibernate 框架就是实现 JPA 规范的框架。 SpringData JPA 简介 Spring Data JPA 是 Spring 框架提供的对 JPA 规范的抽象通过约定的命名规范完成持久层接口的编写在不需要实现接口的情况下就可以实现对数据库的操作。简单理解就是通过 Spring Data JPA你只需要定义接口而不需要实现就能完成 CRUD 操作。 Spring Data JPA 本身并不是一个具体实现它只是一个抽象层底层还是需要 Hibernate 这样的 JPA 实现来提供支持。 Spring Data JPA 是一个全自动化的 ORM 框架底层是 Hibernate 框架提供支持开发者只需要调用接口方法即可不必关心 SQL 语句和结果集的解析非常方便 1. 添加 pom.xml 依赖
parentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.3.2.RELEASE/versionrelativePath/
/parent
dependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-jpa/artifactId/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdscoperuntime/scope/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency
/dependencies
2. 配置数据源 /src/main/resources/application.properties 配置文件中 ## 配置数据源
spring:datasource:url: jdbc:mysql://127.0.0.1:3306/wdzldb?useSSLfalseserverTimezoneAsia/Shanghaiusername: rootdriver-class-name: com.mysql.cj.jdbc.Driverpassword: rootjpa:show-sql: trueproperties:hibernate:format_sql: true # 格式化SQL# 生成SQL 驼峰命名属性默认加下划线的情况下面配置可以去掉下划线。hibernate:naming:physical-strategy: org.hibernate.boot.model.naming.PhysicalNamingStrategyStandardImpl
3. 编写实体类 注意这里使用的注解和 SpringData JDBC 的不同属性名出现 驼峰命名的也会默认映射为 book_name 的形式此时需要通过 Column 注解来映射。也可以在配置文件中统一配置关闭下划线。 注意常见错误
Caused by: java.lang.IllegalArgumentException: Not a managed type: class com.wdzl.pojo.Bookat org.hibernate.metamodel.internal.MetamodelImpl.managedType(MetamodelImpl.java:582)at org.hibernate.metamodel.internal.MetamodelImpl.managedType(MetamodelImpl.java:85)
原因实体类没有指定Entry 注解。 添加注解后会显示编译错误要求必须指定主键 Id 主键需要指定主键生成策略否则默认的是 GenerationType strategy() default GenerationType.AUTO; 默认的策略是序列应用于 Oracle 数据库 package com.wdzl.pojo;import lombok.Data;import javax.persistence.*;
import java.util.Date;Data
Entity //要求必须有Id
public class Book {IdGeneratedValue(strategy GenerationType.IDENTITY)Column(namebookid)private Integer bookId;Column(namebookname)private String bookName;private Float price;Columnprivate Date pubdate;private String author;
}
4. 编写持久层接口 注意这里继承的接口是 JpaRepository 在 JpaRepository 接口中包含了继承的 CRUD 方法如果需要组合条件查询可以遵循 “约定大于配置” 策略实现组合条件查询。 注意异常
Caused by: java.lang.IllegalArgumentException: Not a managed type: class java.lang.Objectat org.hibernate.metamodel.internal.MetamodelImpl.managedType(MetamodelImpl.java:582) ~[hibernate-core-5.4.32.Final.jar:5.4.32.Final]at org.hibernate.metamodel.internal.MetamodelImpl.managedType(MetamodelImpl.java:85) ~[hibernate-core-5.4.32.Final.jar:5.4.32.Final]
原因没有指定泛型 extends JpaRepositoryBook,Integer
IBookDao 类代码如下
下面方法通过默认约定名来实现
import com.wdzl.pojo.Book;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;import java.util.List;Repository
public interface IBookDao extends JpaRepositoryBook,Integer {// bookname?ListBook findBookByBookName(String bookName);// 等价于 between price ? and ?ListBook findBookByPriceBetween(Float price1,Float price2);//等价于 price?ListBook findBookByPriceAfter(Float price);//bookName like ? %实%ListBook findBookByBookNameContaining(String bookName);//bookName like ? %实%ListBook findBookByBookNameContains(String bookName);// bookName like %入门ListBook findBookByBookNameEndsWith(String bookName);}也可以通过 HQL 来定义方法的查询因为 SpringData Jpa 通过 Hibernate 实现的。
//注意下面是 HQL
Query(from Book where bookName like :bookname and price :price)
ListBook findCondtion(String bookname,Float price); 注意不支持 select * 5. 编写业务类
Service(bookService)
public class BookService {Autowiredprivate IBookDao bookDao;public ListBook queryAll(){return bookDao.findAll(); //这里不同jdbc 这里直接返回 list}public void save(Book book){bookDao.save(book);}public long count(){return bookDao.count();}
}
6. 编写测试类 注意测试类 一定要和启动类同包这里是代替了启动类 package com.wdzl;import com.wdzl.pojo.Book;
import com.wdzl.service.BookService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.test.context.SpringBootTest;import java.util.Date;SpringBootTest
SpringBootApplication //注意这里一定要和被测试类在同包 即启动类的位置
public class TestApplication {Autowiredprivate BookService bookService;Testpublic void testQuery(){bookService.queryAll().forEach(book - System.out.println(book));}Testpublic void save(){Book book new Book();book.setPubdate(new Date());book.setBookName(Java入门与提高);book.setPrice(34F);bookService.save(book); //主键不存在 执行插入}Testpublic void update(){Book book new Book();book.setBookId(9);book.setPubdate(new Date());book.setBookName(Java基础入门);book.setPrice(24F);bookService.save(book); //主键存在执行修改}
} 注意 在执行 save() 保存时如果设置了主键则会先进行查询再根据查询结果来执行操作如果查询记录存在则修改。否则不存在则插入。 如果主键策略没有指定自动增长则在执行 save() 时必须要设置主键。否则执行失败。 下面是设置了主键但是数据库表中不存在的执行效果
先执行了查询再执行了 insert 插入操作
Hibernate: selectbook0_.bookid as bookid1_0_0_,book0_.author as author2_0_0_,book0_.bookname as bookname3_0_0_,book0_.price as price4_0_0_,book0_.pubdate as pubdate5_0_0_ frombook book0_ wherebook0_.bookid?
Hibernate: insert intobook(author, bookname, price, pubdate) values(?, ?, ?, ?) 注意 从上面控制台打印的结果来看首先底层使用的Hibernate实现 其次先根据指定主键执行了查询来判断是否存在记录。 最后因为没有查询到记录而执行 insert 操作。 7. JpaRepository 中方法详解
1) 接口源码中方法
NoRepositoryBean
public interface JpaRepositoryT, ID extends PagingAndSortingRepositoryT, ID, QueryByExampleExecutorT {ListT findAll(); //查询全部ListT findAll(Sort var1); //排序查询ListT findAllById(IterableID var1); //按多个主键查询S extends T ListS saveAll(IterableS var1);void flush();S extends T S saveAndFlush(S var1);S extends T ListS saveAllAndFlush(IterableS var1);/** deprecated */Deprecateddefault void deleteInBatch(IterableT entities) { this.deleteAllInBatch(entities);}void deleteAllInBatch(IterableT var1);void deleteAllByIdInBatch(IterableID var1);void deleteAllInBatch();/** deprecated */DeprecatedT getOne(ID var1);T getById(ID var1);S extends T ListS findAll(ExampleS var1);S extends T ListS findAll(ExampleS var1, Sort var2);
}
2) 添加
public void save(){Book book new Book();book.setBookName(MySQL性能优化);book.setPrice(45f);bookDao.save(book);
}
3) 修改
public void update(){Book book bookDao.getById(25);book.setPubdate(new Date());book.setBookName(MySQL性能优化);book.setPrice(45f);bookDao.save(book);
}
注意
修改使用save方法如果新实例化的对象如果有主键且表中存在则直接修改操作
如果实例化对象同时指定主键但不存在也会自动插入操作。
但是如果先查询再修改则默认情况下会抛出异常
org.hibernate.LazyInitializationException: could not initialize proxy [com.wdzl.pojo.Book#25] - no Session
原因是默认使用了延时加载策略这样在查询后已经关闭了session,但有修改操作了没加载的属性。导致异常。
解决办法
在实体类上添加注解关闭延时加载 : Proxy(lazy false) 或 放入事务单元
Data
Entity
Proxy(lazy false)
public class Book {IdGeneratedValue(strategy GenerationType.IDENTITY)private Integer bookId;private String bookName;private Float price;private Date pubdate;private String author;
}
第二种修改方式使用HQL语句修改但不支持insert .
注意事务和允许修改注解 Transactional 和 Modifying
Modifying
Query(update Book set price:price where bookId:bookid) //类名和属性名
Transactional
int update(Float price,Integer bookid);
4) 删除
源码如下
Deprecated
default void deleteInBatch(IterableT entities) { //已经过时不用关注this.deleteAllInBatch(entities);
}void deleteAllInBatch(IterableT var1); //按对象批量删除void deleteAllByIdInBatch(IterableID var1); //按主键批量删除void deleteAllInBatch(); //全部删除
案例应用
//批量删除
// 生成SQL: Hibernate: delete from Book where bookId in (? , ? , ? , ?)
public void delByBatch(){ListInteger ids Arrays.asList(3,23,12,45);bookDao.deleteAllByIdInBatch(ids);
}
也可以使用 HQL语句来删除也需要事务支持。
Modifying
Query(delete from Book where bookName:bookName)
Transactional
int delete(String bookName);
也支持按约定规则命名方式来删除注意也需要事务支持
Transactional
void deleteBookByAuthor(String author);
// between
ListBook findBooksByPriceBetween(Float min,Float max);
// 模糊查询 like 语句
ListBook findBooksByBookNameLike(String bookName);
生成 SQL如下
Hibernate: select book0_.bookId as bookid1_0_, book0_.author as author2_0_, book0_.bookName as bookname3_0_, book0_.price as price4_0_, book0_.pubdate as pubdate5_0_ from Book book0_ where book0_.author?
Hibernate: delete from Book where bookId?
从上面可以看出在删除时先做查询再做删除。如果查询不到则不执行删除操作
5) 查询 ListT findAll(); //查询全部ListT findAll(Sort var1); //排序查询ListT findAllById(IterableID var1); //按多个主键查询T getById(ID var1);S extends T ListS findAll(ExampleS var1); // 条件查询S extends T ListS findAll(ExampleS var1, Sort var2);
条件查询
//条件查询
public void findBookByExample(){Book book new Book();book.setBookName(Java);book.setPrice(23f);book.setBookId(23);ExampleBook bookExample Example.of(book);bookDao.findAll(bookExample);
}
排序
//可以按指定属性排序
public void querySort(){//Order.desc()|asc()分别指定降序和升序Sort price Sort.by(Sort.Order.desc(price));ListBook all bookDao.findAll(price);all.forEach(System.out::println);
}
分页
public void queryByPage(){//分页查询 第一个参数页号从0开始第二参数每页显示记录数Pageable pageable PageRequest.of(2,2);bookDao.findAll(pageable).forEach(System.out::println);
}
6) 多对一 和 一对多 下面配置多对一关联关系。图书类关联依赖作者类。 注意不使用Data 为了避免 toString()在双向多对一时产生死循环。 图书类
Getter
Setter
Entity
//Proxy(lazy false)
public class Book {IdGeneratedValue(strategy GenerationType.IDENTITY)private Integer bookId;private String bookName;private Float price;private Date pubdate;
// private String author;
//JoinColumn(nameauthor) //关联的外键ManyToOne(fetch FetchType.LAZY)private Author author;
}
作者类
Entity(nameusertbl)
Getter
Setter
public class Author {Idprivate Integer userid;private String username;private String email;OneToMany(mappedBy author,fetch FetchType.LAZY)private SetBook books new HashSet();
}
图书关联查询作者 Transactionalpublic void manyToOne(){Book book bookDao.getById(22);System.out.println(book.getBookName()book.getAuthor());}
作者关联查询图书
Transactional
public void query(){Author author authorDao.findAuthorByUserid(5);SetBook books author.getBooks();books.forEach(s- System.out.println(s.getBookName()));
}
常见错误
org.hibernate.LazyInitializationException: could not initialize proxy [com.wdzl.pojo.Book#22] - no Session
原因
默认关联对象是延时加载的在查询对象后默认关闭session在后面使用到关联属性或对象时再去查询时已经不存在session可用了。所以抛出异常。
解决办法
可以使用事务让整个方法在一个事务单元中使用完毕后再自动关闭session.
7HQL HQLHibernate Query Language是 Hibernate 框架提供的面向对象的查询语言它是 SQL 的一个超集主要用来与关系型数据库进行交互但它使用的是面向对象的方式来表达查询。HQL 查询的对象不再是数据库表而是实体类及其属性。 /*** HQL*/
Repository
public interface IBookDao extends JpaRepositoryBook,Integer {//支持HQL
// Query(select book from Book book)Query(from Book)ListBook queryAllBook();Query(select bookId,bookName,author from Book)ListObject[] queryAll();/*** 如果要修改需要添加注解 Modifying Transactional* param price* param bookid* return*/ModifyingQuery(update Book set price:price where bookId:bookid)Transactionalint update(Float price,Integer bookid);ModifyingQuery(delete from Book where bookName:bookName)Transactionalint delete(String bookName);Transactionalvoid deleteBookByBookName(String bookname);}
