Java 8：如何使用流方式查询数据库？

Speedment 是使用 ORM 方式操做数据库的一种选择，之前咱们须要100行操做数据库的 Java 代码，在 Java 8中，可能只须要一行代码。

在90年代末，我使用 Java 开发数据库应用的时候，许多代码逻辑都须要本身来编写，好比捕获异常、类型转换等，通过许多改动，最后这些代码变得难以维护和扩展。

因为关系型数据库操做语言和面向对象语言之间的差别，现在咱们仍然须要花费许多时间创建数据库与 Java 应用之间互相沟通的桥梁。一般，咱们能够编写本身的映射层（mapping layer），或者使用第三方的 ORM（Object Relational Mapper）对象关系映射框架，好比 Hibernate。ORM 框架虽然使用起来很方便，可是如何正确地配置和提升框架操做数据库的性能却不太容易，ORM 框架每每会使咱们的应用性能降低。

最近，我贡献了一个新的开源项目——Speedment，它能使咱们使用 Java 8 开发数据库应用程序变得更为快捷和高效。

##Speedment 是什么？

Speedment 是一个开源项目，它是一个基于 Java 8 的新特性开发的新的 Java 库，从这个项目开发开始，它的代码就所有使用 Java 8来编写。Speedment 使用标准流查询数据库,这使得开发者不须要学习任何新的查询 API ，以及没必要考虑 JDBC 、ResultSet 和其余有关数据库的指定的操做。

Speedment 会根据现有数据库来自动生成代码。因为它的这种方式，开发者不须要编写一行关于数据库实体（database entities）的代码。它生成的代码中也包含 JavaDocs 帮助文档，这使开发者不须要编写关于 User 或者 Book 等对象的实体类。取而代之地，咱们只须要建立或者使用一个现有的数据库，而后用 Speedment 去链接它，接着 Speedment 会分析数据库结构来生成实体类的代码。

更有趣的是，Speedment 用野兔来做为它的吉祥物。 在接下来的例子中，咱们会使用一个名为 “hare” 的数据库来给你们演示 Speedment 的使用方式。该数据库的表结构以下：

mysql> explain hare;
+-------+-------------+------+-----+---------+----------------+
| Field | Type        | Null | Key | Default | Extra          |
+-------+-------------+------+-----+---------+----------------+
| id    | int(11)     | NO   | PRI | NULL    | auto_increment |
| name  | varchar(45) | NO   |     | NULL    |                |
| color | varchar(45) | NO   |     | NULL    |                |
| age   | int(11)     | NO   |     | NULL    |                |
+-------+-------------+------+-----+---------+----------------+
4 rows in set (0.01 sec)

下面是 Speedment 根据数据库信息生成的一个相应的实体类（为简洁起见，咱们将 JavaDocs 在这里移除了）：

public interface Hare extends Entity<Hare> {
    public final static ReferenceComparableField<Hare, Integer> ID = new ReferenceComparableFieldImpl<>("id", Hare::getId, Hare::setId);
    public final static ReferenceComparableStringField<Hare> NAME = new ReferenceComparableStringFieldImpl<>("name", Hare::getName, Hare::setName);
    public final static ReferenceComparableStringField<Hare> COLOR = new ReferenceComparableStringFieldImpl<>("color", Hare::getColor, Hare::setColor);
    public final static ReferenceComparableField<Hare, Integer> AGE = new ReferenceComparableFieldImpl<>("age", Hare::getAge, Hare::setAge);
    Integer getId();
    String getName();
    String getColor();
    Integer getAge();
    Hare setId(Integer id);
    Hare setName(String name);
    Hare setColor(String color);
    Hare setAge(Integer age);
    /** Graph-like traversal methods eliminating JOINs */
    Stream<Carrot> findCarrotsByOwner();
    Stream<Carrot> findCarrotsByRival();
    Stream<Carrot> findCarrots();
}

我将用一篇单独的文章介绍 find*() 方法的用法，它能够被用来代替 SQL joins 操做。

##Queries查询示例

下面的例子展现如何查询 Hare 表的数据库信息：

List<Hare> oldHares = hares.stream()
    .filter(AGE.greaterThan(8))
    .collect(toList());

##智能流

上面的代码看起来已经遍历了 hare 数据库表的全部行，但实际上并非这样的。 Stream 是智能的，当它到达 collect() 操做的时候，会分析 filter 操做，并推断出 hare.age 大于8的列，所以会节省 hares 的流操做，产生与 “select * from hare where age > 8” 操做同样的效果。若是你使用了多个 filters，他们会被合并起来以节省流操做。下面是另外一种用流方式进行多个操做的例子：

long noOldHares = hares.stream()
    .filter(AGE.greaterThan(8))
    .mapToInt(Hare::getAge)
    .sorted()
    .count();

在上面的代码中，当流到达 count() 操做时，它将检查它本身的管道。首先会推断上面例子中的 AGE 操做，其次在不改变 count() 结果的状况下，会推断 mapToInt() 和 sorted() 操做，这些操做能够被消除，所以这段代码的操做被节省为 “select count(*) from hare where age > 8”。这意味着您可使用 Java 8 流而你没必要如此在乎流是如何转换为SQL的。

##如何下载和加入咱们

若是你想学习如何使用 Speedment 的 API 和在项目中如何使用 Speedment，能够访问网址 www.speedment.org，并能够在 gitter 上发表评论，也能够从 GitHub 上下载 Speedment 的源码，来贡献你本身的代码。

##总结

回顾早期的一些老项目，一个超过100行代码的数据库类，如今可使用 Java 8 缩减成1行代码。那是反转后的摩尔定律，在14年内（=7摩尔周期），行数大约减半了七次。这就是进步！

（编译自：https://dzone.com/articles/java-8-query-databases-using-streams）

OneAPM 为您提供端到端的 Java 应用性能解决方案，咱们支持全部常见的 Java 框架及应用服务器，助您快速发现系统瓶颈，定位异常根本缘由。分钟级部署，即刻体验，Java 监控历来没有如此简单。想阅读更多技术文章，请访问 OneAPM 官方技术博客。

本文转自 OneAPM 官方博客