Java Stream ORM现在带有JOIN

Speedment是一个Java Stream ORM工具包和运行时，它使您可以将数据库表作为标准Java Streams查看。由于不必混合使用Java和SQL，因此该应用程序变得更加紧凑，从而使其开发速度更快，更不容易出错并且更易于维护。流也严格地是类型安全的，并且是惰性构造的，因此当元素被流消耗时，仅从数据库中提取最小量的数据。

现在，新版本的Speedment 3.1.1“ Homer”还支持将动态联接的表视为标准Java Streams。开发开发数据库表之间关系的Java应用程序时，这很重要。

在下面的示例中，我使用了MySQL的开源Sakila电影数据库内容，您可以在此处下载。 Speedment适用于任何主要的关系数据库类型，例如Oracle，MySQL，Microsoft SQL Server，PostgreSQL，DB2，MariaDB，AS400等。

在单个表上流式传输

以下代码段将创建一个所有Film.RATING为“ PG-13”的Film对象的List ，并且该List按Film.LENGTH顺序排序：

List<Film> list = films.stream().filter(Film.RATING.equal("PG-13")).sorted(Film.LENGTH).collect(toList());

该流将在后台自动呈现给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 (`rating`  = ? COLLATE utf8_bin) 
ORDER BY`length` ASCvalues:[PG-13]

因此，优点是您可以使用类型安全的Java表示数据库查询，然后通过标准Java流使用结果。您不必编写任何SQL代码。

连接几张桌子

从“电影”表的Appart来看，Sakila数据库还包含其他表。其中之一是称为“语言”的表。每个Film实体都使用名为“ language_id”的列来为电影中使用的Language指定外键。

在此示例中，我将展示如何创建代表这两个表的联接的标准Java Stream。这样，我们可以获得匹配的Film/Language实体对的Java流。

Join对象是使用JoinComponent创建的，可以通过以下方式获得：

// Visit https://github.com/speedment/speedment
// to see how a Speedment app is created. It is easy!
Speedment app = …;JoinComponent joinComponent = app.getOrThrow(JoinComponent.class);

抓住JoinComponent ，就可以开始创建Join对象，如下所示：

Join<Tuple2<Film, Language>> join = joinComponent.from(FilmManager.IDENTIFIER).innerJoinOn(Language.LANGUAGE_ID).equal(Film.LANGUAGE_ID).build(Tuples::of);

现在我们已经定义了Join对象，我们可以创建实际的Java Stream：

join.stream().map(t2 -> String.format("The film '%s' is in %s",t2.get0().getTitle(), // get0() -> Filmt2.get1().getName()   // get1() -> Language)).forEach(System.out::println);

这将产生以下输出：

The film 'ACADEMY DINOSAUR' is in English
The film 'ACE GOLDFINGER' is in English
The film 'ADAPTATION HOLES' is in English
...

在上面的代码中，方法t2.get0()将从元组（ Film ）检索第一个元素，而方法t2.get1()将从元组（ Language ）检索第二个元素。默认通用元组内置在Speedment中，因此Tuple2不是Guava类。速度不依赖于任何其他库。在下面，您将看到如何为连接的表使用任何类构造函数。同样，Speedment将自动从Java渲染SQL代码，并将结果转换为Java Stream。如果启用流日志记录，我们可以确切看到如何呈现SQL代码：

SELECTA.`film_id`,A.`title`,A.`description`,A.`release_year`,A.`language_id`,A.`original_language_id`,A.`rental_duration`,A.`rental_rate`,A.`length`,A.`replacement_cost`,A.`rating`,A.`special_features`,A.`last_update`,B.`language_id`,B.`name`,B.`last_update` 
FROM `sakila`.`film` AS A
INNER JOIN `sakila`.`language` AS B 
ON(B.`language_id` = A.`language_id`)

有趣的是，可以创建一次Join对象，然后反复使用它来创建新的Streams。

多对多关系

Sakila数据库还定义了少数多对多关系。例如，表“ film_actor”包含将影片链接到演员的行。每部电影可以有多个演员，并且每个演员可能都出现在多部电影中。表格中的每一行都将特定的Film链接到特定的Actor 。例如，如果Film描述了12个Actor entities, then FilmActor包含12个条目，它们均具有相同的film_id但具有不同的actor_id。本示例的目的是创建Java Stream中所有电影和现身演员的完整列表。这是我们如何将三个表连接在一起的方法：

Join<Tuple3<FilmActor, Film, Actor>> join = joinComponent.from(FilmActorManager.IDENTIFIER).innerJoinOn(Film.FILM_ID).equal(FilmActor.FILM_ID).innerJoinOn(Actor.ACTOR_ID).equal(FilmActor.ACTOR_ID).build(Tuples::of);join.stream().forEach(System.out::println);

上面的代码将产生以下输出（为便于阅读而设置格式）：

...
Tuple3Impl {FilmActorImpl { actorId = 137, filmId = 249, lastUpdate = 2006-02-15 05:05:03.0 },FilmImpl { filmId = 249, title = DRACULA CRYSTAL, description =...,ActorImpl { actorId = 137, firstName = MORGAN, lastName = WILLIAMS,...}
}Tuple3Impl {FilmActorImpl { actorId = 137, filmId = 254, lastUpdate = 2006-02-15 05:05:03.0 },FilmImpl { filmId = 254, title = DRIVER ANNIE, description = ...,ActorImpl { actorId = 137, firstName = MORGAN, lastName = WILLIAMS, ...}
}Tuple3Impl {FilmActorImpl { actorId = 137, filmId = 263, lastUpdate = 2006-02-15 05:05:03.0 },FilmImpl { filmId = 263, title = DURHAM PANKY, description = ... },ActorImpl { actorId = 137, firstName = MORGAN, lastName = WILLIAMS,... }
}
...

加入自定义元组

正如我们在上面的例子中注意到，我们没有实际使用的FilmActor在Stream对象，因为它只是用来连接Film和Actor在加入阶段对象在一起。

当使用build()方法build() Join对象时，我们可以提供一个自定义构造函数，该构造函数要应用于数据库的传入实体。构造函数可以是任何类型，因此您可以编写自己的Java对象，该对象包含例如Film和Actor或它们包含的并且感兴趣的任何列。

在此示例中，我证明了（lambda）构造函数只是完全丢弃了链接的FilmActor对象：

Join<Tuple2<Film, Actor>> join = joinComponent.from(FilmActorManager.IDENTIFIER).innerJoinOn(Film.FILM_ID).equal(FilmActor.FILM_ID).innerJoinOn(Actor.ACTOR_ID).equal(FilmActor.ACTOR_ID).build((fa, f, a) -> Tuples.of(f, a));join.stream().forEach(System.out::println);

上面的代码将产生以下输出（为便于阅读而设置格式）：

...
Tuple2Impl {FilmImpl { filmId = 249, title = DRACULA CRYSTAL, description = ... },ActorImpl { actorId = 137, firstName = MORGAN, lastName = WILLIAMS, ...}
}
Tuple2Impl {FilmImpl { filmId = 254, title = DRIVER ANNIE, description = A... }, ActorImpl { actorId = 137, firstName = MORGAN, lastName = WILLIAMS,...}
}
Tuple2Impl {FilmImpl { filmId = 263, title = DURHAM PANKY, description = ... }, ActorImpl { actorId = 137, firstName = MORGAN, lastName = WILLIAMS,...}
}
...

因此，我们只会在Film中存在Actor下，获得匹配的Film和Actor实体对。在流中永远不会看到链接对象FilmActor 。