Зачем закрывать Stream после получения данных из JPA

Ответ

Закрытие Stream в JPA критически важно для освобождения ресурсов базы данных. Давайте разберемся, почему это необходимо и какие проблемы возникают, если этого не делать.

Что такое Stream в контексте JPA

Stream в JPA — это специальный вид результата запроса, который возвращает данные лениво (по требованию), а не сразу загружает их в память. Это полезно для работы с большими наборами данных.

// JPA query возвращает Stream
Stream<User> stream = entityManager
    .createQuery("SELECT u FROM User u", User.class)
    .getResultStream();

Почему нужно закрывать Stream

1. Освобождение конекта к базе данных

Когда вы открываете Stream, JPA создает курсор в базе данных и удерживает соединение. Если не закрыть Stream, это соединение остается занято.

// ПЛОХО: соединение остается открытым
Stream<User> stream = entityManager
    .createQuery("SELECT u FROM User u", User.class)
    .getResultStream();
    
stream.forEach(user -> System.out.println(user.getName()));
// Stream никогда не закрывается — connection leak!

// ХОРОШО: используем try-with-resources
try (Stream<User> stream = entityManager
    .createQuery("SELECT u FROM User u", User.class)
    .getResultStream()) {
    stream.forEach(user -> System.out.println(user.getName()));
}
// Stream автоматически закроется

2. Предотвращение утечки соединений (Connection Leak)

Пул соединений имеет лимит (обычно 10-20 соединений). Если вы не закроете Stream, соединения закончатся.

3. Утечка памяти

Stream удерживает ссылки на загруженные объекты. Если Stream не закрыть, эти объекты не будут удалены garbage collector'ом.

4. Несогласованность данных

Неправильное управление Stream может привести к блокировке других операций.

Правильные способы работы со Stream

1. Try-with-resources (рекомендуется)

try (Stream<User> stream = entityManager
    .createQuery("SELECT u FROM User u", User.class)
    .getResultStream()) {
    stream
        .filter(user -> user.getAge() > 18)
        .limit(100)
        .forEach(user -> processUser(user));
} // Stream автоматически закроется и вернет соединение

2. Явный close()

Stream<User> stream = entityManager
    .createQuery("SELECT u FROM User u", User.class)
    .getResultStream();

try {
    stream.forEach(user -> processUser(user));
} finally {
    stream.close();
}

3. Без Stream (если данных мало)

Если данных немного, используйте обычный список:

List<User> users = entityManager
    .createQuery("SELECT u FROM User u", User.class)
    .getResultList();

users.stream()
    .filter(user -> user.getAge() > 18)
    .forEach(user -> processUser(user));

Best Practices

1. Всегда используйте try-with-resources

public List<UserDTO> getActiveUsers(int limit) {
    try (Stream<User> stream = entityManager
        .createQuery("SELECT u FROM User u WHERE u.active = true", User.class)
        .getResultStream()) {
        return stream
            .limit(limit)
            .map(UserDTO::fromEntity)
            .collect(Collectors.toList());
    }
}

2. Обрабатывайте в Stream, не после

// ПЛОХО: закрываем Stream перед forEach
try (Stream<User> stream = ...) {
    
}
stream.forEach(user -> {...});

// ХОРОШО: все операции внутри try-block
try (Stream<User> stream = ...) {
    stream.forEach(user -> {...});
}

3. Материализуйте результат в методе

public List<User> getUsers() {
    try (Stream<User> stream = entityManager
        .createQuery("SELECT u FROM User u", User.class)
        .getResultStream()) {
        return stream.collect(Collectors.toList());
    }
}

4. Используйте @Transactional для управления сессией

@Service
public class UserService {
    @Transactional(readOnly = true)
    public List<User> findAndProcess() {
        try (Stream<User> stream = entityManager
            .createQuery("SELECT u FROM User u", User.class)
            .getResultStream()) {
            return stream.collect(Collectors.toList());
        } // Транзакция закроется, соединение вернется в пул
    }
}

Реальные проблемы

1. Connection Pool Exhaustion

Если вы открыли 10 Stream'ов и не закрыли их, пул из 10 соединений исчерпан. Новые запросы будут ждать таймаута.

2. OutOfMemoryError при работе с большими данными

Eсли не использовать Stream вообще, все данные загружаются в память сразу. Stream помогает только если его правильно закрыть.

3. Deadlock в базе данных

Открытый Stream может заблокировать другие операции, особенно на UPDATE/INSERT запросах.

Вывод

Закрытие Stream в JPA — это не рекомендация, а обязательный процесс. Невыполнение этого требования приводит к утечке соединений, утечке памяти и падению производительности приложения. Всегда используйте try-with-resources конструкцию для гарантированного закрытия Stream.