Spring Boot JPA中java 8 的应用实例
上篇文章中我们讲到了如何在Spring Boot中使用JPA。 本文我们将会讲解如何在Spring Boot JPA中使用java 8 中的新特习惯如：Optional, Stream API 和 CompletableFuture的使用。
Optional
我们从数据库中获取的数据有可能是空的，对于这样的情况Java 8 提供了Optional类，用来防止出现空值的情况。我们看下怎么在Repository 中定义一个Optional的方法：
public interface BookRepository extends JpaRepository<Book, Long> {
Optional<Book> findOneByTitle(String title);
}
我们看下测试方法怎么实现：
@Test
public void testFindOneByTitle(){
Book book = new Book();
book.setTitle("title");
book.setAuthor(randomAlphabetic(15));
bookRepository.save(book);
log.info(bookRepository.findOneByTitle("title").orElse(new Book()).toString());
}
Stream API
为什么会有Stream API呢？ 我们举个例子，如果我们想要获取数据库中所有的Book， 我们可以定义如下的方法：
public interface BookRepository extends JpaRepository<Book, Long> {
List<Book> findAll();
Stream<Book> findAllByTitle(String title);
}
上面的findAll方法会获取所有的Book，但是当数据库里面的数据太多的话，就会消耗过多的系统内存，甚至有可能导致程序崩溃。
为了解决这个问题，我们可以定义如下的方法：
Stream<Book> findAllByTitle(String title);
当你使用Stream的时候，记得需要close它。 我们可以使用java 8 中的try语句来自动关闭：
@Test
@Transactional
public void testFindAll(){
Book book = new Book();
book.setTitle("titleAll");
book.setAuthor(randomAlphabetic(15));
bookRepository.save(book);
try (Stream<Book> foundBookStream
= bookRepository.findAllByTitle("titleAll")) {
assertThat(foundBookStream.count(), equalTo(1l));
}
}
这里要注意， 使用Stream必须要在Transaction中使用。否则会报如下错误：
org.springframework.dao.InvalidDataAccessApiUsageException: You're trying to execute a streaming query method without a surrounding transaction that keeps the connection open so that the Stream can actually be consumed. Make sure the code consuming the stream uses @Transactional or any other way of declaring a (read-only) transaction.
所以这里我们加上了@Transactional 注解。
CompletableFuture
使用java 8 的CompletableFuture， 我们还可以异步执行查询语句：
@Async CompletableFuture<Book> findOneByAuthor(String author);
我们这样使用这个方法：
@Test
public void testByAuthor() throws ExecutionException, InterruptedException {
Book book = new Book();
book.setTitle("titleA");
book.setAuthor("author");
bookRepository.save(book);
log.info(bookRepository.findOneByAuthor("author").get().toString());
}
本文的例子可以参考https://github.com/ddean2009/learn-springboot2/tree/master/springboot-jpa
到此这篇关于Spring Boot JPA中java 8 的应用实例的文章就介绍到这了,更多相关java8中Spring Boot JPA使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
ClassLoader一个经常出现又让很多人望而却步的词,本文将试图以最浅显易懂的方式来讲解 ClassLoader,希望能对不了解该机制的朋友起到一点点作用2016-07-07
MyBatis-Flex+ShardingSphere-JDBC多数据源分库分表实现
本文介绍了使用MyBatis-Flex和ShardingSphere-JDBC实现多数据源分库分表的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2024-10-10
Java Socket 编程是指使用 Java 语言进行网络通信的过程，包括建立连接、传输数据和关闭连接等操作，本文将详细介绍Java Socket编程，需要的朋友可以参考下2023-05-05
这篇文章主要介绍了java 使用Scanner类接收从控制台输入的数据方式，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-08-08
MyBatis Plus 集成了多种主键策略,帮助用户快速生成主键,本文主要介绍了MyBatisPlus主键策略的实现,具有一定的参考价值,感兴趣的可以了解一下2023-10-10
使用java web 在jsp文件及Class中连接MySQL和SQLserver 的驱动方法
这篇文章主要介绍了使用java web 在jsp文件及Class中连接MySQL和SQLserver的驱动方法的相关资料,本文介绍的非常详细，具有参考借鉴价值，需要的朋友可以参考下2016-10-10
Java中的split方法可以将一个字符串按照指定的分隔符进行分割,返回一个字符串数组,这篇文章主要给大家介绍了关于Java split()方法中的特殊符号的相关资料,需要的朋友可以参考下2023-07-07
这篇文章主要介绍了Java设计模式中的抽象工厂模式解读,抽象工厂模式为创建一组相关或相互依赖的对象提供一个接口,而且无需指定他们的具体类,需要的朋友可以参考下2023-11-11
这篇文章主要介绍了JS实现冒泡排序，插入排序和快速排序并从input文本框中获取内容进行排序输出,需要的朋友可以参考下2015-07-07
这篇文章主要介绍了Java经典设计模式之策略模式,简单说明了策略模式的概念、原理并结合实例形式分析了java策略模式的具有用法与相关注意事项,需要的朋友可以参考下2017-08-08
最新评论