Package io.ran

Class TestDoubleQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

java.lang.Object

io.ran.CrudRepoBaseQuery<T,Z>

io.ran.TestDoubleQuery<T,Z>

All Implemented Interfaces:

CrudRepository.InlineQuery<T,Z>

Direct Known Subclasses:

TestDoubleQuery

public abstract class TestDoubleQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>
extends CrudRepoBaseQuery<T,Z>
implements CrudRepository.InlineQuery<T,Z>

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	delayLimit
protected final GenericFactory	factory
protected final List<Predicate<T>>	filters
protected final TestDoubleIndex	index
protected final List<Supplier<Set<Object>>>	indexLookups
protected Integer	limit
protected final MappingHelper	mappingHelper
protected int	offset
protected final List<Comparator<T>>	sorts
protected final TestDoubleStore<Object,T>	store
protected final TestDoubleDb	testDoubleDb

Fields inherited from class io.ran.CrudRepoBaseQuery

clazz, genericFactory, instance, queryWrapper, typeDescriber

Constructor Summary

Constructors

Constructor	Description
TestDoubleQuery(Class<T> modelType, GenericFactory genericFactory, MappingHelper mappingHelper, TestDoubleDb testDoubleDb)

Method Summary

Modifier and Type	Method	Description
Z	and(Consumer<Z> subQuery)	Match if all the sub-conditions match.
long	count()	Count the number of rows that match the query.
CrudRepository.CrudUpdateResult	delete()	Delete all entries that match the query.
<X> Stream<X>	distinct(Property<X> property)
Z	eq(Property.PropertyValue<?> propertyValue)
Stream<T>	execute()	Execute the query and return the results as a Stream.
protected Stream<T>	executeInternal()
protected abstract Z	getQuery(Class<?> queryClass)
<X extends Comparable<? super X>> Z	gt(Property.PropertyValue<X> propertyValue)
<X extends Comparable<? super X>> Z	gte(Property.PropertyValue<X> propertyValue)
Z	isNull(Property<?> property)
Z	limit(int limit)	Limit the results to the given number of rows.
Z	limit(int offset, int limit)	Limit the results to the given number of rows, starting at the given offset.
<X extends Comparable<? super X>> Z	lt(Property.PropertyValue<X> propertyValue)
<X extends Comparable<? super X>> Z	lte(Property.PropertyValue<X> propertyValue)
Z	notEq(Property.PropertyValue<?> propertyValue)
Z	or(Consumer<Z> subQuery)	Match if any of the sub-conditions match.
<X> Stream<X>	selectField(Property<X> property)
<X extends Comparable<? super X>> Z	sortAscending(Property<X> property)
<X extends Comparable<? super X>> Z	sortDescending(Property<X> property)
<X, Y extends CrudRepository.InlineQuery<X, Y>> Z	subQuery(RelationDescriber relationDescriber, Consumer<Y> consumer)
Z	withEager(RelationDescriber relationDescriber)

Methods inherited from class io.ran.CrudRepoBaseQuery

distinct, eq, eq, gt, gt, gte, gte, isNull, isNull, lt, lt, lte, lte, notEq, notEq, selectField, sortAscending, sortAscending, sortDescending, sortDescending, withEager, withEager

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.ran.CrudRepository.InlineQuery

distinct, eq, eq, gt, gt, gte, gte, isNull, isNull, lt, lt, lte, lte, notEq, notEq, selectField, sortAscending, sortAscending, sortDescending, sortDescending, withEager, withEager

Field Details

filters

protected final List<Predicate<T>> filters

indexLookups

protected final List<Supplier<Set<Object>>> indexLookups

sorts

protected final List<Comparator<T>> sorts

mappingHelper

protected final MappingHelper mappingHelper

testDoubleDb

protected final TestDoubleDb testDoubleDb

store

protected final TestDoubleStore<Object,T> store

index

protected final TestDoubleIndex index

factory

protected final GenericFactory factory

offset

protected int offset

limit

protected Integer limit

delayLimit

protected boolean delayLimit

Constructor Details

TestDoubleQuery

public TestDoubleQuery(Class<T> modelType,
 GenericFactory genericFactory,
 MappingHelper mappingHelper,
 TestDoubleDb testDoubleDb)

Method Details

and

public Z and(Consumer<Z> subQuery)

Description copied from interface: CrudRepository.InlineQuery

Match if all the sub-conditions match. The conditions in your sub query will be AND-ed together. Since this is the default behavior, this method is intended to be used inside CrudRepository.InlineQuery.or(Consumer).

Example:

 query.or(or -> or.eq(Person::getName, "Mike").and(and -> and.eq(Person::getName, "Bob").eq(Person::getAge, 42)));
 

Will result into the following SQL: WHERE (name = 'Mike' OR (name = 'Bob' AND age = 42))

Specified by:

and in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

Parameters:

subQuery - the sub query to be inside the AND statement

Returns:

the query, for chaining

or

public Z or(Consumer<Z> subQuery)

Description copied from interface: CrudRepository.InlineQuery

Match if any of the sub-conditions match. The conditions in your sub query will be OR-ed together.

Example:

 query.or(sub -> sub.eq(Person::getName, "Bob").eq(Person::getAge, 42));
 

Will result into the following SQL: WHERE (name = 'Bob' OR age = 42)

Specified by:

or in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

Parameters:

subQuery - the sub query to be inside the OR statement

Returns:

the query, for chaining

eq

public Z eq(Property.PropertyValue<?> propertyValue)

Specified by:

eq in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

notEq

public Z notEq(Property.PropertyValue<?> propertyValue)

Specified by:

notEq in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

gt

public <X extends Comparable<? super X>> Z gt(Property.PropertyValue<X> propertyValue)

Specified by:

gt in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

gte

public <X extends Comparable<? super X>> Z gte(Property.PropertyValue<X> propertyValue)

Specified by:

gte in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

lt

public <X extends Comparable<? super X>> Z lt(Property.PropertyValue<X> propertyValue)

Specified by:

lt in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

lte

public <X extends Comparable<? super X>> Z lte(Property.PropertyValue<X> propertyValue)

Specified by:

lte in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

isNull

public Z isNull(Property<?> property)

Specified by:

isNull in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

withEager

public Z withEager(RelationDescriber relationDescriber)

Specified by:

withEager in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

sortAscending

public <X extends Comparable<? super X>> Z sortAscending(Property<X> property)

Specified by:

sortAscending in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

sortDescending

public <X extends Comparable<? super X>> Z sortDescending(Property<X> property)

Specified by:

sortDescending in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

limit

public Z limit(int offset,
 int limit)

Description copied from interface: CrudRepository.InlineQuery

Limit the results to the given number of rows, starting at the given offset.

Offset is 0-based (the first row is 0).

Offset is inclusive, limit is the size of the returned collection.

Example:

 query.limit(10, 20)
 

This will return rows 10, 11, 12, ..., 29.

Specified by:

limit in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

Parameters:

offset - the offset to start at

limit - the number of rows to return

Returns:

the query, for chaining

See Also:

• CrudRepository.InlineQuery.limit(int)

limit

public Z limit(int limit)

Description copied from interface: CrudRepository.InlineQuery

Limit the results to the given number of rows.

Example:

 query.limit(10)
 

This will return the first 10 rows.

Specified by:

limit in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

Parameters:

limit - the number of rows to return

Returns:

the query, for chaining

See Also:

• CrudRepository.InlineQuery.limit(int, int)

subQuery

public <X,
Y extends CrudRepository.InlineQuery<X,
Y>>
Z subQuery(RelationDescriber relationDescriber,
 Consumer<Y> consumer)

Specified by:

subQuery in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

getQuery

protected abstract Z getQuery(Class<?> queryClass)

execute

public Stream<T> execute()

Description copied from interface: CrudRepository.InlineQuery

Execute the query and return the results as a Stream.

This is a terminal operation. As such, the query should not be reused after this method is called.

The resulting Stream from the operation may be a lazy stream, meaning that the results are not fetched from the database until they are accessed. As such it is important that a terminal operation is performed on the stream within a reasonable time frame to avoid holding database connections open.

Specified by:

execute in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

Returns:

a Stream of the results

executeInternal

protected Stream<T> executeInternal()

count

public long count()

Description copied from interface: CrudRepository.InlineQuery

Count the number of rows that match the query.

This is a terminal operation. As such, the query should not be reused after this method is called.

Specified by:

count in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

Returns:

the number of rows that match the query

distinct

public <X> Stream<X> distinct(Property<X> property)

Specified by:

distinct in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

selectField

public <X> Stream<X> selectField(Property<X> property)

Specified by:

selectField in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

delete

public CrudRepository.CrudUpdateResult delete()

Description copied from interface: CrudRepository.InlineQuery

Delete all entries that match the query.

This is a terminal operation. As such, the query should not be reused after this method is called.

WARNING: If you invoke no query methods prior to this, all rows in the table with be deleted.

Specified by:

delete in interface CrudRepository.InlineQuery<T,Z extends CrudRepository.InlineQuery<T,Z>>

Returns:

a CrudRepository.CrudUpdateResult with the number of rows affected

See Also:

• CrudRepository.CrudUpdateResult.affectedRows()