Package org.cyclos.impl.sql.postgresql

Class NativeQuery<Q extends QueryParameters,E extends SimpleEntity,P>

java.lang.Object

org.cyclos.impl.sql.postgresql.NativeQuery<Q,E,P>

Direct Known Subclasses:

AbstractUserNativeQuery, AdvertisementsNativeQuery, ContactsNativeQuery, RecordsNativeQuery

public abstract class NativeQuery<Q extends QueryParameters,E extends SimpleEntity,P>
extends Object

A native query, executed in Postgresql via Querydsl

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	NativeQuery.BaseProjection	Base class for projections in native queries
protected static class	NativeQuery.JpaQueryResult
protected static interface	NativeQuery.SQLQueryAction<T>	Action executed with an initialized query

Field Summary

Fields

Modifier and Type	Field	Description
protected ApplicationContext	applicationContext
protected BeanHandler	beanHandler
protected ConfigurationHandler	configurationHandler
protected ConversionHandler	conversionHandler
protected CustomFieldValueHandler	customFieldValueHandler
protected Class<E>	entityType
protected GroupsHandler	groupsHandler
protected JdbcTemplate	jdbcTemplate
protected Q	params
protected PhoneServiceLocal	phoneService
protected ProfileFieldHandler	profileFieldHandler
protected Class<P>	projectionType
protected RawEntityManagerHandler	rawEntityManagerHandler
protected TranslationHandler	translationHandler
protected UserServiceLocal	userService

Constructor Summary

Constructors

Constructor	Description
NativeQuery(Class<E> entityType, Class<P> projectionType, Q params)

Method Summary

Modifier and Type	Method	Description
protected <FV extends SBaseFieldValues<FV>,EV extends SBaseEnumValues<?>> void	addOrderBy(Class<FV> fvType, Class<EV> evType, com.querydsl.sql.SQLQuery<?> query, CustomField<?,?,?> customField, com.querydsl.core.types.dsl.NumberPath<Long> ownerIdPath, boolean descending)	Adds an order by condition for a given custom field value
protected Pair<TsVectorExpression,com.querydsl.core.BooleanBuilder>	appendUserProfileFieldKeywords(ProfileFieldSearchContext context, String keywords, TsVectorExpression tsvectors, SUsers u, boolean myBrokered)	Applies the filters for user profile fields.
static com.querydsl.core.types.Predicate	apply(UserProductsQueryResult r, SUsers u)
protected void	applyFullTextFilter(com.querydsl.sql.SQLQuery<?> query, TsVectorExpression tsvectors, STsQuery q, com.querydsl.core.BooleanBuilder keywordsCondition)
protected Collection<STsQuery>	applyUserProfileFieldFilters(ProfileFieldSearchContext context, com.querydsl.sql.SQLQuery<?> query, SUsers u, boolean myBrokered, Set<BaseValueForSearchDTO> profileFieldValues, SAddresses a)	Applies the filters for user profile fields.
int	count()	Returns the record count for the current query
protected NativeQuery.JpaQueryResult	createJpaQuery(com.querydsl.core.types.Expression<?> projection, Integer firstResult, Integer maxResults)
protected NativeQuery.JpaQueryResult	createJpaQueryForEntities(Integer firstResult, Integer maxResults)
protected <R> com.mysema.commons.lang.CloseableIterator<R>	doIterate(NativeQuery.JpaQueryResult result)
protected <R> R	doSingleResult(NativeQuery.JpaQueryResult result)
protected com.querydsl.sql.SQLQuery<?>	ensureQuery()
protected <FV extends SBaseFieldValues<FV>> FV	fieldValue(CustomField<?,?,?> customField, Class<FV> fvType)
protected void	filterByDatePeriod(com.querydsl.core.support.QueryBase<?> query, DatePeriodDTO period, com.querydsl.core.types.dsl.DateTimeExpression<Date> path)	Adds a query expression in a custom query (or subquery)
protected void	filterByDatePeriod(DatePeriodDTO period, com.querydsl.core.types.dsl.DateTimeExpression<Date> path)	Adds a query expression
protected <FV extends SBaseFieldValues<FV>,EV extends SBaseEnumValues<?>,DV extends SBaseDynaValues<?>> Pair<com.querydsl.core.BooleanBuilder,STsQuery>	getCustomFieldQueryCondition(Class<FV> fvType, Class<EV> evType, Class<DV> dvType, com.querydsl.core.types.dsl.NumberPath<Long> ownerIdPath, CustomField<?,?,?> customField, CustomFieldValueForSearchDTO valueForSearch, boolean canViewHidden)	Returns the condition for a custom field filter joining if necessary, plus an optional extra STsQuery that needs to be added to the query from clause
protected <T extends SBaseFieldValues<T>> Pair<com.querydsl.core.BooleanBuilder,STsQuery>	getCustomFieldQueryCondition(Class<T> fvType, Class<? extends SBaseEnumValues<?>> evType, Class<? extends SBaseDynaValues<?>> dvType, com.querydsl.core.types.dsl.NumberPath<Long> ownerIdPath, CustomField<?,?,?> customField, CustomFieldValueForSearchDTO valueForSearch)
protected Map<CustomField<?,?,?>,SBaseFieldValues<?>>	getFieldValues()
protected FormatterImpl	getFormatter()
protected org.apache.logging.log4j.Logger	getLogger()
protected abstract com.querydsl.sql.RelationalPath<?>	getMainEntityAlias()	Must be implemented in order to return the alias for the main entity in the query
protected abstract com.querydsl.core.types.Expression<P>	getProjection(com.querydsl.sql.SQLQuery<?> query, Integer totalCount)	Must be implemented in order to return projection for results in the query, given the total record count
com.querydsl.sql.SQLQuery<?>	getQuery()
protected SessionData	getSessionData()
protected abstract List<com.querydsl.core.types.Expression<?>>	initializeQuery(com.querydsl.sql.SQLQuery<?> query)	Initializes the query, returning additional from expressions that should be applied after all others
com.mysema.commons.lang.CloseableIterator<E>	iterateEntities()	Returns an iterator with JPA entities for the current query
com.mysema.commons.lang.CloseableIterator<Long>	iterateIds()	Returns an iterator with entity ids for the current query
com.mysema.commons.lang.CloseableIterator<P>	iterateResults()
protected <T extends SBaseFieldValues<T>> T	join(Class<T> fvType, Class<? extends SBaseEnumValues<?>> evType, com.querydsl.sql.SQLQuery<?> query, CustomField<?,?,?> customField, com.querydsl.core.types.dsl.NumberPath<Long> ownerIdPath)	Adds a join to a custom field value table
Page<E>	pageEntities()	Returns a page with entities for the current query
Page<P>	pageResults()
protected void	resetQuery()
SQLUserVisibilityApplier	visibility(com.querydsl.core.types.dsl.NumberPath<Long> userId, com.querydsl.core.types.dsl.NumberPath<Long> groupId)	Returns a visibility applier to add the user visibility rules for the given user id and group id paths.

Methods inherited from class java.lang.Object

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

Field Detail

entityType

protected Class<E extends SimpleEntity> entityType

projectionType

protected Class<P> projectionType

params

protected Q extends QueryParameters params

applicationContext

@Autowired
protected ApplicationContext applicationContext

rawEntityManagerHandler

@Autowired
protected RawEntityManagerHandler rawEntityManagerHandler

conversionHandler

@Autowired
protected ConversionHandler conversionHandler

groupsHandler

@Autowired
protected GroupsHandler groupsHandler

configurationHandler

@Autowired
protected ConfigurationHandler configurationHandler

beanHandler

@Autowired
protected BeanHandler beanHandler

profileFieldHandler

@Autowired
protected ProfileFieldHandler profileFieldHandler

phoneService

@Autowired
protected PhoneServiceLocal phoneService

translationHandler

@Autowired
protected TranslationHandler translationHandler

userService

@Autowired
protected UserServiceLocal userService

customFieldValueHandler

@Autowired
protected CustomFieldValueHandler customFieldValueHandler

jdbcTemplate

@Autowired
protected JdbcTemplate jdbcTemplate

Constructor Detail

NativeQuery

public NativeQuery(Class<E> entityType,
                   Class<P> projectionType,
                   Q params)

Method Detail

apply

public static com.querydsl.core.types.Predicate apply(UserProductsQueryResult r,
                                                      SUsers u)

count

public int count()

Returns the record count for the current query

getQuery

public com.querydsl.sql.SQLQuery<?> getQuery()

iterateEntities

public com.mysema.commons.lang.CloseableIterator<E> iterateEntities()

Returns an iterator with JPA entities for the current query

iterateIds

public com.mysema.commons.lang.CloseableIterator<Long> iterateIds()

Returns an iterator with entity ids for the current query

iterateResults

public com.mysema.commons.lang.CloseableIterator<P> iterateResults()

pageEntities

public Page<E> pageEntities()

Returns a page with entities for the current query

pageResults

public Page<P> pageResults()

visibility

public SQLUserVisibilityApplier visibility(com.querydsl.core.types.dsl.NumberPath<Long> userId,
                                           com.querydsl.core.types.dsl.NumberPath<Long> groupId)

Returns a visibility applier to add the user visibility rules for the given user id and group id paths.

addOrderBy

protected <FV extends SBaseFieldValues<FV>,EV extends SBaseEnumValues<?>> void addOrderBy(Class<FV> fvType,
                                                                                                Class<EV> evType,
                                                                                                com.querydsl.sql.SQLQuery<?> query,
                                                                                                CustomField<?,?,?> customField,
                                                                                                com.querydsl.core.types.dsl.NumberPath<Long> ownerIdPath,
                                                                                                boolean descending)

Adds an order by condition for a given custom field value

appendUserProfileFieldKeywords

protected Pair<TsVectorExpression,com.querydsl.core.BooleanBuilder> appendUserProfileFieldKeywords(ProfileFieldSearchContext context,
                                                                                                         String keywords,
                                                                                                         TsVectorExpression tsvectors,
                                                                                                         SUsers u,
                                                                                                         boolean myBrokered)

Applies the filters for user profile fields. Not as keywords, but as filters.

applyFullTextFilter

protected void applyFullTextFilter(com.querydsl.sql.SQLQuery<?> query,
                                   TsVectorExpression tsvectors,
                                   STsQuery q,
                                   com.querydsl.core.BooleanBuilder keywordsCondition)

applyUserProfileFieldFilters

protected Collection<STsQuery> applyUserProfileFieldFilters(ProfileFieldSearchContext context,
                                                            com.querydsl.sql.SQLQuery<?> query,
                                                            SUsers u,
                                                            boolean myBrokered,
                                                            Set<BaseValueForSearchDTO> profileFieldValues,
                                                            SAddresses a)

Applies the filters for user profile fields. Not as keywords, but as filters. Returns a collection of STsQuery that should be added to the query from.

createJpaQuery

protected NativeQuery.JpaQueryResult createJpaQuery(com.querydsl.core.types.Expression<?> projection,
                                                    Integer firstResult,
                                                    Integer maxResults)

createJpaQueryForEntities

protected NativeQuery.JpaQueryResult createJpaQueryForEntities(Integer firstResult,
                                                               Integer maxResults)

doIterate

protected <R> com.mysema.commons.lang.CloseableIterator<R> doIterate(NativeQuery.JpaQueryResult result)

doSingleResult

protected <R> R doSingleResult(NativeQuery.JpaQueryResult result)

ensureQuery

protected com.querydsl.sql.SQLQuery<?> ensureQuery()

fieldValue

protected <FV extends SBaseFieldValues<FV>> FV fieldValue(CustomField<?,?,?> customField,
                                                          Class<FV> fvType)

filterByDatePeriod

protected void filterByDatePeriod(DatePeriodDTO period,
                                  com.querydsl.core.types.dsl.DateTimeExpression<Date> path)

Adds a query expression

filterByDatePeriod

protected void filterByDatePeriod(com.querydsl.core.support.QueryBase<?> query,
                                  DatePeriodDTO period,
                                  com.querydsl.core.types.dsl.DateTimeExpression<Date> path)

Adds a query expression in a custom query (or subquery)

getCustomFieldQueryCondition

protected <FV extends SBaseFieldValues<FV>,EV extends SBaseEnumValues<?>,DV extends SBaseDynaValues<?>> Pair<com.querydsl.core.BooleanBuilder,STsQuery> getCustomFieldQueryCondition(Class<FV> fvType,
                                                                                                                                                                                                       Class<EV> evType,
                                                                                                                                                                                                       Class<DV> dvType,
                                                                                                                                                                                                       com.querydsl.core.types.dsl.NumberPath<Long> ownerIdPath,
                                                                                                                                                                                                       CustomField<?,?,?> customField,
                                                                                                                                                                                                       CustomFieldValueForSearchDTO valueForSearch,
                                                                                                                                                                                                       boolean canViewHidden)

Returns the condition for a custom field filter joining if necessary, plus an optional extra STsQuery that needs to be added to the query from clause

getCustomFieldQueryCondition

protected <T extends SBaseFieldValues<T>> Pair<com.querydsl.core.BooleanBuilder,STsQuery> getCustomFieldQueryCondition(Class<T> fvType,
                                                                                                                             Class<? extends SBaseEnumValues<?>> evType,
                                                                                                                             Class<? extends SBaseDynaValues<?>> dvType,
                                                                                                                             com.querydsl.core.types.dsl.NumberPath<Long> ownerIdPath,
                                                                                                                             CustomField<?,?,?> customField,
                                                                                                                             CustomFieldValueForSearchDTO valueForSearch)

getFieldValues

protected Map<CustomField<?,?,?>,SBaseFieldValues<?>> getFieldValues()

getFormatter

protected FormatterImpl getFormatter()

getLogger

protected org.apache.logging.log4j.Logger getLogger()

getMainEntityAlias

protected abstract com.querydsl.sql.RelationalPath<?> getMainEntityAlias()

Must be implemented in order to return the alias for the main entity in the query

getProjection

protected abstract com.querydsl.core.types.Expression<P> getProjection(com.querydsl.sql.SQLQuery<?> query,
                                                                       Integer totalCount)

Must be implemented in order to return projection for results in the query, given the total record count

getSessionData

protected SessionData getSessionData()

initializeQuery

protected abstract List<com.querydsl.core.types.Expression<?>> initializeQuery(com.querydsl.sql.SQLQuery<?> query)

Initializes the query, returning additional from expressions that should be applied after all others

join

protected <T extends SBaseFieldValues<T>> T join(Class<T> fvType,
                                                 Class<? extends SBaseEnumValues<?>> evType,
                                                 com.querydsl.sql.SQLQuery<?> query,
                                                 CustomField<?,?,?> customField,
                                                 com.querydsl.core.types.dsl.NumberPath<Long> ownerIdPath)

Adds a join to a custom field value table

resetQuery

protected void resetQuery()