java流寫入數(shù)據(jù)庫

在本文中，您將學(xué)習(xí)如何編寫純Java應(yīng)用程序，這些應(yīng)用程序能夠使用現(xiàn)有數(shù)據(jù)庫中的數(shù)據(jù)，而無需編寫一行SQL（或類似的語言，如HQL），而無需花費(fèi)數(shù)小時(shí)將所有內(nèi)容放在一起。 準(zhǔn)備好應(yīng)用程序之后，您將通過僅添加兩行代碼來學(xué)習(xí)如何使用JVM內(nèi)加速功能將延遲性能提高1000倍以上。

在本文中，我們將使用Speedment，它是一個(gè)Java流ORM，可以直接從數(shù)據(jù)庫模式生成代碼，并且可以自動(dòng)將Java Streams直接呈現(xiàn)為SQL，從而允許您使用純Java編寫代碼。

您還將發(fā)現(xiàn)，通過直接在RAM中運(yùn)行流的JVM內(nèi)存技術(shù)，數(shù)據(jù)訪問性能可以大大提高。

示例數(shù)據(jù)庫

我們將使用來自MySQL的示例數(shù)據(jù)庫Sakila。 它具有稱為電影，演員，類別等的表格，可以在此處免費(fèi)下載。

步驟1：連接到數(shù)據(jù)庫

我們將開始使用可以在此處找到的Speedment Initializer配置pom.xml文件。 按“下載”，您將獲得帶有自動(dòng)生成的Main.java文件的項(xiàng)目文件夾。

接下來，解壓縮項(xiàng)目文件夾的zip文件，打開命令行，轉(zhuǎn)到解壓縮的文件夾（pom.xml文件所在的文件夾）

然后，輸入以下命令：

mvn speedment:tool

這將啟動(dòng)Speedment工具并提示您輸入許可證密鑰。 選擇“開始免費(fèi)”，您將自動(dòng)免費(fèi)獲得許可證。 現(xiàn)在，您可以連接到數(shù)據(jù)庫并開始使用：

步驟2：產(chǎn)生程式碼

從數(shù)據(jù)庫中加載模式數(shù)據(jù)后，可以通過按“生成”按鈕來生成完整的Java域模型。

這只需要一兩秒鐘。

步驟3：編寫應(yīng)用程序代碼

與步驟2中的域模型一起，自動(dòng)生成了Speedment實(shí)例的構(gòu)建器。 打開Main.java文件，并使用以下代碼段替換main()方法中的代碼：

SakilaApplication app = new SakilaApplicationBuilder().withPassword("sakila-password") // Replace with your own password.build();

接下來，我們將編寫一個(gè)可以打印所有電影的應(yīng)用程序。 誠(chéng)然，這是一個(gè)很小的應(yīng)用程序，但是我們將在本文中對(duì)其進(jìn)行改進(jìn)。

// Obtains a FilmManager that allows us to // work with the "film" table FilmManager films = app.getOrThrow(FilmManager.class);// Create a stream of all films and print // each and every film films.stream().forEach(System.out::println);

這不是很簡(jiǎn)單嗎？

運(yùn)行時(shí)，Java流將在后臺(tái)自動(dòng)呈現(xiàn)為SQL。 為了真正看到呈現(xiàn)SQL代碼，請(qǐng)修改我們的應(yīng)用程序構(gòu)建器，并使用
STREAM日志類型：

SakilaApplication app = new SakilaApplicationBuilder().withPassword("sakila-password").withLogging(ApplicationBuilder.LogType.STREAM).build();

這是運(yùn)行應(yīng)用程序時(shí)SQL代碼的樣子：

SELECT `film_id`,`title`,`description`,`release_year`, `language_id`,`original_language_id`,`rental_duration`,`rental_rate`,`length`,`replacement_cost`,`rating`,`special_features`,`last_update`FROM`sakila`.`film`, values:[]

根據(jù)您選擇的數(shù)據(jù)庫類型（例如MySQL，MariaDB，PostgreSQL，Oracle，MS SQL Server，DB2，AS400等），呈現(xiàn)SQL代碼可能有所不同。 這些變化是自動(dòng)的。

上面的代碼將產(chǎn)生以下輸出（為簡(jiǎn)便起見，以下簡(jiǎn)稱）：

FilmImpl { filmId = 1, title = ACADEMY DINOSAUR, …, length = 86, ... } FilmImpl { filmId = 2, title = ACE GOLDFINGER, ..., length = 48, ...} FilmImpl { filmId = 3, title = ADAPTATION HOLES, ..., length = 50, ...} ...

步驟4：使用篩選器

Speedment流支持所有Stream操作，包括過濾器。 假設(shè)我們只想過濾那些長(zhǎng)于60分鐘的電影。 這可以通過將以下代碼行添加到我們的應(yīng)用程序中來完成：

films.stream().filter(Film.LENGTH.greaterThan(60)) .forEach(System.out::println);

呈現(xiàn)SQL：

SELECT `film_id`,`title`,`description`,`release_year`,`language_id`,`original_language_id`,`rental_duration`,`rental_rate`,`length`,`replacement_cost`,`rating`,`special_features`,`last_update` FROM `sakila`.`film` WHERE (`length` > ?),values:[60]

生成的輸出：

FilmImpl { filmId = 1, title = ACADEMY DINOSAUR, ..., length = 86, ... } FilmImpl { filmId = 4, title = AFFAIR PREJUDICE, ..., length = 117, ...} FilmImpl { filmId = 5, title = AFRICAN EGG, ... length = 130, ...}

過濾器可以組合以創(chuàng)建更復(fù)雜的表達(dá)式，如下所示：

films.stream().filter(Film.LENGTH.greaterThan(60).or(Film.LENGTH.lessThan(30))).forEach(System.out::println);

這將返回所有短于30分鐘或長(zhǎng)于1小時(shí)的電影。 檢查您的日志文件，您還將看到此Stream也呈現(xiàn)為SQL。

步驟5：定義元素的順序

默認(rèn)情況下，元素在流中出現(xiàn)的順序是不確定的。 要定義特定的訂單，您可以應(yīng)用
對(duì)這樣的流sorted()操作：

films.stream().filter(Film.LENGTH.greaterThan(60)).sorted(Film.TITLE).forEach(System.out::println);

呈現(xiàn)SQL：

SELECT `film_id`,`title`,`description`,`release_year`,`language_id`,`original_language_id`,`rental_duration`,`rental_rate`,`length`,`replacement_cost`,`rating`,`special_features`,`last_update` FROM `sakila`.`film` WHERE (`length` > ?) ORDER BY `length` ASC, values:[60]

生成的輸出：

FilmImpl { filmId = 77, title = BIRDS PERDITION,..., length = 61,...} FilmImpl { filmId = 106, title = BULWORTH COMMANDMENTS,..., length = 61,} FilmImpl { filmId = 114, title = CAMELOT VACATION,..., length = 61,..} ...

您還可以組成多個(gè)排序器來定義主要順序，次要順序等。

films.stream().filter(Film.LENGTH.greaterThan(60)).sorted(Film.LENGTH.thenComparing(Film.TITLE.reversed())).forEach(System.out::println);

這將按LENGTH順序（升序）然后按TITLE順序（降序）對(duì)影片元素進(jìn)行排序。 您可以組成任意數(shù)量的字段。

注意：如果要按升序組成兩個(gè)或多個(gè)字段，則應(yīng)使用該字段的方法
.comparator() 。 即
sorted(Film.LENGTH.thenComparing(Film.TITLE.comparator()))而不是 sorted(Film.LENGTH.thenComparing(Film.TITLE))

步驟6：分頁并避免大對(duì)象塊

通常，人們希望分頁結(jié)果以避免使用不必要的大對(duì)象塊。 假設(shè)我們希望每頁看到50個(gè)元素，我們可以編寫以下通用方法：

private static final int PAGE_SIZE = 50;public static <T> Stream<T> page(Manager<T> manager,Predicate<? super T> predicate,Comparator<? super T> comparator,int pageNo ) {return manager.stream().filter(predicate).sorted(comparator).skip(pageNo * PAGE_SIZE).limit(PAGE_SIZE); }

此實(shí)用程序方法可以使用ANY過濾器來分頁ANY表，并按ANY順序?qū)ζ溥M(jìn)行排序。

例如，調(diào)用：

page(films, Film.LENGTH.greaterThan(60), Film.TITLE, 3)

將返回長(zhǎng)度超過60分鐘的電影流，并按標(biāo)題顯示第三頁（即跳過150部電影并顯示以下50部電影）。

呈現(xiàn)SQL：

SELECT `film_id`,`title`,`description`,`release_year`,`language_id`,`original_language_id`,`rental_duration`,`rental_rate`,`length`,`replacement_cost`,`rating`,`special_features`,`last_update` FROM `sakila`.`film` WHERE(`length` > ?) ORDER BY`title` ASC LIMIT ? OFFSET ?, values:[60, 50, 150]

生成的輸出：

FilmImpl { filmId = 165, title = COLDBLOODED DARLING, ... length = 70,...} FilmImpl { filmId = 166, title = COLOR PHILADELPHIA, ..., length = 149... } FilmImpl { filmId = 167, title = COMA HEAD, ... length = 109,...} ...

同樣，如果我們使用其他數(shù)據(jù)庫類型，則SQL代碼將略有不同。

步驟7：JVM中的內(nèi)存加速

由于您在初始化器中使用了標(biāo)準(zhǔn)配置，因此在pom.xml文件中啟用了In-JVM內(nèi)存加速。 要在應(yīng)用程序中激活加速，只需修改初始化代碼，如下所示：

SakilaApplication app = new SakilaApplicationBuilder().withPassword("sakila-password").withBundle(InMemoryBundle.class).build();// Load data from the database into an in-memory snapshotapp.getOrThrow(DataStoreComponent.class).load();

現(xiàn)在，表流將直接從RAM提供，而不是呈現(xiàn)SQL查詢。 內(nèi)存索引也將加快篩選，排序和跳過。 內(nèi)存中的表和索引都存儲(chǔ)在堆外，因此它們不會(huì)增加垃圾回收的復(fù)雜性。

在我的筆記本電腦（Mac Book Pro，15英寸，2015年中，16 GB，i7 2.2 GHz）上，對(duì)于我計(jì)算與過濾器匹配的電影和經(jīng)過分類的電影流，與對(duì)在本地計(jì)算機(jī)上運(yùn)行MySQL數(shù)據(jù)庫（版本5.7.16）的標(biāo)準(zhǔn)安裝。

摘要

在本文中，您了解了使用純Java流查詢現(xiàn)有數(shù)據(jù)庫有多么容易。 您還了解了如何使用JVM內(nèi)存流技術(shù)加快對(duì)數(shù)據(jù)的訪問。 Sakila數(shù)據(jù)庫和Speedment均可免費(fèi)下載和使用，請(qǐng)自己嘗試。

翻譯自: https://www.javacodegeeks.com/2018/09/query-databases-using-java-streams.html

java流寫入數(shù)據(jù)庫

總結(jié)

以上是生活随笔為你收集整理的java流写入数据库_使用Java流查询数据库的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。