Package google.registry.beam.common

Interface RegistryQuery<T>

All Superinterfaces:

Serializable

public interface RegistryQuery<T>
extends Serializable

Interface for query instances used by RegistryJpaIO.Read.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	RegistryQuery.CriteriaQuerySupplier<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	QUERY_FETCH_SIZE	Number of JPA entities to fetch in each batch during a query.

Method Summary

Modifier and Type	Method	Description
static <T> RegistryQuery<T>	createQuery(RegistryQuery.CriteriaQuerySupplier<T> criteriaQuery)	Returns a RegistryQuery from a CriteriaQuery supplier.
static <T> RegistryQuery<T>	createQuery(String sql, Map<String,Object> parameters, boolean nativeQuery)	Returns a RegistryQuery that creates a string query from constant text.
static <T> RegistryQuery<T>	createQuery(String jpql, Map<String,Object> parameters, Class<T> clazz)	Returns a RegistryQuery that creates a typed JPQL query from constant text.
static <T> T	detach(jakarta.persistence.EntityManager entityManager, T object)	Removes an object from the JPA session cache if applicable.
static void	detachObject(jakarta.persistence.EntityManager entityManager, Object object)
Stream<T>	stream()

Field Details

QUERY_FETCH_SIZE

static final int QUERY_FETCH_SIZE

Number of JPA entities to fetch in each batch during a query.

With Hibernate, for result streaming to work, a query's fetchSize property must be set to a non-zero value.

See Also:

• Constant Field Values

Method Details

stream

Stream<T> stream()

createQuery

static <T> RegistryQuery<T> createQuery(String sql,
 @Nullable
 Map<String,Object> parameters,
 boolean nativeQuery)

Returns a RegistryQuery that creates a string query from constant text.

Type Parameters:

T - Type of each row in the result set, Object in single-select queries, and Object[] in multi-select queries.

Parameters:

parameters - parameters to be substituted in the query.

nativeQuery - whether the given string is to be interpreted as a native query or JPQL.

createQuery

static <T> RegistryQuery<T> createQuery(String jpql,
 @Nullable
 Map<String,Object> parameters,
 Class<T> clazz)

Returns a RegistryQuery that creates a typed JPQL query from constant text.

Type Parameters:

T - Type of each row in the result set.

Parameters:

parameters - parameters to be substituted in the query.

createQuery

static <T> RegistryQuery<T> createQuery(RegistryQuery.CriteriaQuerySupplier<T> criteriaQuery)

Returns a RegistryQuery from a CriteriaQuery supplier.

A serializable supplier is needed in because CriteriaQuery itself must be created within a transaction, and we are not in a transaction yet when this function is called to set up the pipeline.

Type Parameters:

T - Type of each row in the result set.

detach

static <T> T detach(jakarta.persistence.EntityManager entityManager,
 T object)

Removes an object from the JPA session cache if applicable.

Parameters:

object - An object that represents a row in the result set. It may be a JPA entity, a non-entity object, or an array that holds JPA entities and/or non-entities.

detachObject

static void detachObject(jakarta.persistence.EntityManager entityManager,
 Object object)