Package com.valqueries.automapper

Class ValqueriesQueryImpl<T>

java.lang.Object

io.ran.CrudRepoBaseQuery<T,ValqueriesQuery<T>>

com.valqueries.automapper.BaseValqueriesQuery<T>

com.valqueries.automapper.ValqueriesQueryImpl<T>

All Implemented Interfaces:

ValqueriesGroupQuery<T>, ValqueriesQuery<T>, Setter, CrudRepository.InlineQuery<T,ValqueriesQuery<T>>, AutoCloseable

public class ValqueriesQueryImpl<T>
extends BaseValqueriesQuery<T>
implements ValqueriesQuery<T>, Setter, AutoCloseable

Field Summary

Fields inherited from class com.valqueries.automapper.BaseValqueriesQuery

groupByProperties

Fields inherited from class io.ran.CrudRepoBaseQuery

clazz, instance, queryWrapper, typeDescriber

Constructor Summary

Constructors

Constructor	Description
ValqueriesQueryImpl(ITransactionContext transactionContext, Class<T> modelType, GenericFactory genericFactory, MappingHelper mappingHelper, SqlDialect dialect)

Method Summary

Modifier and Type	Method	Description
ValqueriesQuery<T>	and(Consumer<ValqueriesQuery<T>> subQuery)	Match if all the sub-conditions match.
String	buildSimpleSelectSql(String tableAlias, String where, Collection<String> columns)
void	close()
protected void	concat(Property<?> resultProperty, String separator)
long	count()	Count the number of rows that match the query.
protected void	count(Property<?> property)
CrudRepository.CrudUpdateResult	delete()	Delete all entries that match the query.
<X> Stream<X>	distinct(Property<X> property)
ValqueriesQuery<T>	eq(Property.PropertyValue<?> propertyValue)
Stream<T>	execute()	Execute the query and return the results as a Stream.
<X> Stream<X>	executeSqlAndGetSingleColumn(Property<X> property, String sql)
ValqueriesQuery<T>	freetext(Property.PropertyValue<String> propertyValue)
String	getTableAlias()
String	getTableName(Clazz<?> toClass)
Stream<ValqueriesGroupResultRow>	groupByExecute()	Execute the query.
<X extends Comparable<? super X>> ValqueriesQuery<T>	gt(Property.PropertyValue<X> propertyValue)
<X extends Comparable<? super X>> ValqueriesQuery<T>	gte(Property.PropertyValue<X> propertyValue)
ValqueriesQuery<T>	in(Property.PropertyValueList<?> propertyValues)
ValqueriesQuery<T>	isNotNull(Property<?> property)
ValqueriesQuery<T>	isNull(Property<?> property)
ValqueriesQuery<T>	like(Property.PropertyValue<String> propertyValue)
ValqueriesQuery<T>	limit(int limit)	Limit the results to the given number of rows.
ValqueriesQuery<T>	limit(int offset, int limit)	Limit the results to the given number of rows, starting at the given offset.
<X extends Comparable<? super X>> ValqueriesQuery<T>	lt(Property.PropertyValue<X> propertyValue)
<X extends Comparable<? super X>> ValqueriesQuery<T>	lte(Property.PropertyValue<X> propertyValue)
protected <X extends Comparable<? super X>> void	max(Property<X> property)
protected <X extends Comparable<? super X>> void	min(Property<X> property)
ValqueriesQuery<T>	notEq(Property.PropertyValue<?> property)
ValqueriesQuery<T>	notIn(Property.PropertyValueList<?> propertyValues)
ValqueriesQuery<T>	notLike(Property.PropertyValue<String> propertyValue)
ValqueriesQuery<T>	or(Consumer<ValqueriesQuery<T>> subQuery)	Match if any of the sub-conditions match.
<X> Stream<X>	selectField(Property<X> property)
void	set(IStatement statement)
void	setEmpty()
<X extends Comparable<? super X>> ValqueriesQuery<T>	sortAscending(Property<X> property)
<X extends Comparable<? super X>> ValqueriesQuery<T>	sortDescending(Property<X> property)
<X, Z extends CrudRepository.InlineQuery<X, Z>> ValqueriesQuery<T>	subQuery(RelationDescriber relation, Consumer<Z> consumer)
protected void	sum(Property<? extends Number> property)
CrudRepository.CrudUpdateResult	update(Consumer<ValqueriesUpdate<T>> updater)
ValqueriesQuery<T>	withEager(RelationDescriber relation)

Methods inherited from class com.valqueries.automapper.BaseValqueriesQuery

aggregateAll, concat, concat, count, count, distinct, freetext, freetext, groupBy, groupBy, in, in, in, in, isNotNull, isNotNull, like, like, max, max, min, min, notIn, notIn, notIn, notIn, notLike, notLike, selectField, subQuery, subQuery, subQueryList, subQueryList, subQueryList, sum, sum

Methods inherited from class io.ran.CrudRepoBaseQuery

eq, eq, gt, gt, gte, gte, isNull, isNull, lt, lt, lte, lte, notEq, notEq, 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

Methods inherited from interface com.valqueries.automapper.ValqueriesQuery

aggregateAll, freetext, freetext, groupBy, groupBy, in, in, in, in, isNotNull, isNotNull, like, like, notIn, notIn, notIn, notIn, notLike, notLike, subQuery, subQuery, subQueryList, subQueryList, subQueryList

Constructor Details

ValqueriesQueryImpl

public ValqueriesQueryImpl(ITransactionContext transactionContext,
 Class<T> modelType,
 GenericFactory genericFactory,
 MappingHelper mappingHelper,
 SqlDialect dialect)

Method Details

and

public ValqueriesQuery<T> and(Consumer<ValqueriesQuery<T>> 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,ValqueriesQuery<T>>

Parameters:

subQuery - the sub query to be inside the AND statement

Returns:

the query, for chaining

or

public ValqueriesQuery<T> or(Consumer<ValqueriesQuery<T>> 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,ValqueriesQuery<T>>

Parameters:

subQuery - the sub query to be inside the OR statement

Returns:

the query, for chaining

eq

public ValqueriesQuery<T> eq(Property.PropertyValue<?> propertyValue)

Specified by:

eq in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

notEq

public ValqueriesQuery<T> notEq(Property.PropertyValue<?> property)

Specified by:

notEq in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

in

public ValqueriesQuery<T> in(Property.PropertyValueList<?> propertyValues)

Specified by:

in in interface ValqueriesQuery<T>

Specified by:

in in class BaseValqueriesQuery<T>

notIn

public ValqueriesQuery<T> notIn(Property.PropertyValueList<?> propertyValues)

Specified by:

notIn in interface ValqueriesQuery<T>

Specified by:

notIn in class BaseValqueriesQuery<T>

like

public ValqueriesQuery<T> like(Property.PropertyValue<String> propertyValue)

Specified by:

like in interface ValqueriesQuery<T>

Specified by:

like in class BaseValqueriesQuery<T>

notLike

public ValqueriesQuery<T> notLike(Property.PropertyValue<String> propertyValue)

Specified by:

notLike in interface ValqueriesQuery<T>

Specified by:

notLike in class BaseValqueriesQuery<T>

freetext

public ValqueriesQuery<T> freetext(Property.PropertyValue<String> propertyValue)

Specified by:

freetext in interface ValqueriesQuery<T>

Specified by:

freetext in class BaseValqueriesQuery<T>

gt

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

Specified by:

gt in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

gte

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

Specified by:

gte in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

lt

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

Specified by:

lt in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

lte

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

Specified by:

lte in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

subQuery

public <X,
Z extends CrudRepository.InlineQuery<X,
Z>>
ValqueriesQuery<T> subQuery(RelationDescriber relation,
 Consumer<Z> consumer)

Specified by:

subQuery in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

isNull

public ValqueriesQuery<T> isNull(Property<?> property)

Specified by:

isNull in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

isNotNull

public ValqueriesQuery<T> isNotNull(Property<?> property)

Specified by:

isNotNull in interface ValqueriesQuery<T>

Specified by:

isNotNull in class BaseValqueriesQuery<T>

buildSimpleSelectSql

public String buildSimpleSelectSql(String tableAlias,
 String where,
 Collection<String> columns)

getTableName

public String getTableName(Clazz<?> toClass)

withEager

public ValqueriesQuery<T> withEager(RelationDescriber relation)

Specified by:

withEager in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

sortAscending

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

Specified by:

sortAscending in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

sortDescending

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

Specified by:

sortDescending in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

limit

public ValqueriesQuery<T> 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,ValqueriesQuery<T>>

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 ValqueriesQuery<T> 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,ValqueriesQuery<T>>

Parameters:

limit - the number of rows to return

Returns:

the query, for chaining

See Also:

• CrudRepository.InlineQuery.limit(int, int)

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,ValqueriesQuery<T>>

Returns:

a Stream of the results

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,ValqueriesQuery<T>>

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,ValqueriesQuery<T>>

selectField

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

Specified by:

selectField in interface CrudRepository.InlineQuery<T,ValqueriesQuery<T>>

executeSqlAndGetSingleColumn

public <X> Stream<X> executeSqlAndGetSingleColumn(Property<X> property,
 String sql)

count

protected void count(Property<?> property)

Specified by:

count in class BaseValqueriesQuery<T>

sum

protected void sum(Property<? extends Number> property)

Specified by:

sum in class BaseValqueriesQuery<T>

max

protected <X extends Comparable<? super X>> void max(Property<X> property)

Specified by:

max in class BaseValqueriesQuery<T>

min

protected <X extends Comparable<? super X>> void min(Property<X> property)

Specified by:

min in class BaseValqueriesQuery<T>

concat

protected void concat(Property<?> resultProperty,
 String separator)

Specified by:

concat in class BaseValqueriesQuery<T>

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,ValqueriesQuery<T>>

Returns:

a CrudRepository.CrudUpdateResult with the number of rows affected

See Also:

• CrudRepository.CrudUpdateResult.affectedRows()

groupByExecute

public Stream<ValqueriesGroupResultRow> groupByExecute()

Description copied from interface: ValqueriesGroupQuery

Execute the query.

Specified by:

groupByExecute in interface ValqueriesGroupQuery<T>

Returns:

A stream of rows, each containing the values of the fields that were grouped by and the values of the aggregations, both in the same order they were queried.

set

public void set(IStatement statement)

Specified by:

set in interface Setter

close

public void close()

Specified by:

close in interface AutoCloseable

update

public CrudRepository.CrudUpdateResult update(Consumer<ValqueriesUpdate<T>> updater)

Specified by:

update in interface ValqueriesQuery<T>

getTableAlias

public String getTableAlias()

setEmpty

public void setEmpty()