Java 8: запрос баз данных с использованием потоков

Когда я написал свое первое приложение для базы данных Java в конце 90-х, мне пришлось делать все самому. Было много кода, сбор ошибок и преобразование объектов, и этот код быстро становился очень сложным в обслуживании и, я должен признать, подвержен ошибкам.

Даже сегодня, когда вы работаете с базами данных, часто бывает трудно соединить два принципиально разных мира объектно-ориентированного языка, такого как Java, и реляционную базу данных. Часто вам нужно написать собственный слой отображения или вы можете использовать Object Relational Mapper (ORM), например, Hibernate. Часто удобно использовать ORM, но иногда его не так просто настроить правильно. Чаще всего ORM также замедляет работу вашего приложения.

Недавно я внес большой вклад в новый проект с открытым исходным кодом, названный Speedment, который, как надеются мы, внес вклад, облегчит жизнь нам, разработчикам приложений для баз данных Java 8.

Что такое Speedment Open Source?

Speedment Open Source — это новая библиотека, которая предоставляет много интересных функций Java 8. Он полностью написан на Java 8 с самого начала. Speedment использует стандартные потоки для запросов к базе данных, и благодаря этому вам не нужно изучать новый API запросов. Вам вообще не нужно думать о JDBC, ResultSet и других специфических для базы данных вещах.

Speedment анализирует существующую базу данных и генерирует код автоматически. Таким образом, вам не нужно писать одну строку кода для объектов базы данных. Сгенерированный код даже содержит автоматически сгенерированные JavaDocs. Это означает, что вам не нужно писать классы сущностей, такие как «Пользователь» или «Книга», в вашем коде Java. Вместо этого вы просто создаете (или используете существующую) базу данных, подключаете к ней Speedment, и Speedment анализирует структуру базы данных и генерирует классы сущностей, анализируя структуру базы данных.

Поскольку талисман Speedment с открытым исходным кодом — заяц, я использую зайцев во многих моих примерах. Давайте предположим, что у нас есть существующая (MySQL) таблица с именем «hare», которая выглядит следующим образом:

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)

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();
}

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

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