Spring Data 支持 java8 特性
spring data 现在支持java8的一些特性,如Optional,Stream API 以及CompletableFuture。
本文通过几个示例浏览下这些框架特性。
Optional
CRUD repository方法,返回结果可以使用Optional包装。
public interface CrudRepository<T, ID> extends Repository<T, ID> {
Optional<T> findById(ID id);
}
当返回Optional实例,这是非常有用的提示,返回结果可能不存在。
所以,现在我们需要指定返回类型为Optional。
public interface UserRepository extends JpaRepository<User, Integer> {
Optional<User> findOneByName(String name);
}
Stream API
spring data也提供了对java8最重要的特性Stream API的支持。以前,只要我们需要返回多余一条记录,就需要使用collection。
public interface UserRepository extends JpaRepository<User, Integer> {
// ...
List<User> findAll();
// ...
}
这种实现其中一个问题就消耗内存。因为必须在内存中加载并保持所有的返回对象。我们可以利用分页进行改进。
public interface UserRepository extends JpaRepository<User, Integer> {
// ...
Page<User> findAll(Pageable pageable);
// ...
}
在一些场景,这足够应付,但也有时分页也无法解决,因为大量的请求需要分会数据。
因为java8 Stream API 和 JPA 的支持 ,我们能定义repository 方法返回Stream对象:
public interface UserRepository extends JpaRepository<User, Integer> {
// ...
Stream<User> findAllByName(String name);
// ...
}
Spring Data 使用实现规范提供的流式结果 (Hibernate 使用 ScrollableResultSet, EclipseLink 使用 ScrollableCursor). 减少数据库查询大量内存消耗,因此这比前面提到的两种实现速度要快.
处理流数据时用完需要关闭。
我们可以使用try-with-resources的colse()方法。同时需要注意,调用respository方法必须在一个事务中,否则会婆异常。
CompletableFuture
spring data repositories利用java8的CompletableFuture和spring异步方法执行机制支持方法异步运行:
@Async CompletableFuture<User> findOneByStatus(Integer status);
客户端调用方法立刻返回future对象,但方法将在另一个线程中继续执行。
总结
本文总结了java8和spring data整合的特性及完整示例实现。