91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Spring Boot JPA中java 8 的應用實例

發布時間:2020-09-17 22:10:30 來源:腳本之家 閱讀:152 作者:flydean 欄目:編程語言

上篇文章中我們講到了如何在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使用內容請搜索億速云以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持億速云!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

麟游县| 桦南县| 兴山县| 辛集市| 余江县| 玉山县| 哈尔滨市| 顺平县| 日土县| 夹江县| 本溪市| 山阳县| 太仆寺旗| 泾源县| 沈阳市| 深圳市| 屏边| 沂南县| 石首市| 龙山县| 稻城县| 新竹市| 新乐市| 家居| 霸州市| 郑州市| 湖口县| 广丰县| 土默特右旗| 天津市| 丹凤县| 浏阳市| 南安市| 大埔区| 中山市| 嘉定区| 新闻| 云梦县| 正镶白旗| 喀什市| 铜鼓县|