Package google.registry.persistence.transaction

Class BatchedQueries

java.lang.Object

google.registry.persistence.transaction.BatchedQueries

public final class BatchedQueries
extends Object

Helper for querying large data sets in batches.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BatchedQueries.BatchQuery<T>

Method Summary

Modifier and Type	Method	Description
static <T> Stream<com.google.common.collect.ImmutableList<T>>	loadAllOf(JpaTransactionManager jpaTm, Class<T> entityType, int batchSize)	Loads all entities of type T in batches.
static <T> Stream<com.google.common.collect.ImmutableList<T>>	loadAllOf(Class<T> entityType)
static <T> Stream<com.google.common.collect.ImmutableList<T>>	loadAllOf(Class<T> entityType, int batchSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

loadAllOf

public static <T>
Stream<com.google.common.collect.ImmutableList<T>> loadAllOf(Class<T> entityType)

loadAllOf

public static <T>
Stream<com.google.common.collect.ImmutableList<T>> loadAllOf(Class<T> entityType,
 int batchSize)

loadAllOf

public static <T>
Stream<com.google.common.collect.ImmutableList<T>> loadAllOf(JpaTransactionManager jpaTm,
 Class<T> entityType,
 int batchSize)

Loads all entities of type T in batches.

This method must not be nested in any transaction; same for the traversal of the returned Stream. Each batch is loaded in a separate transaction at the TRANSACTION_REPEATABLE_READ isolation level, and loads the snapshot of the batch at the batch's start time. New insertions or updates since then are not reflected in the result.