com.querydsl.sql

Class AbstractSQLQuery<T,Q extends AbstractSQLQuery<T,Q>>

java.lang.Object

com.querydsl.core.support.QueryBase<Q>

com.querydsl.core.support.FetchableQueryBase<T,Q>

com.querydsl.core.support.FetchableSubQueryBase<T,Q>

com.querydsl.sql.ProjectableSQLQuery<T,Q>

com.querydsl.sql.AbstractSQLQuery<T,Q>

Type Parameters:

T - result type

Q - concrete subtype

All Implemented Interfaces:

Fetchable<T>, FetchableQuery<T,Q>, FilteredClause<Q>, Query<Q>, SimpleQuery<Q>, ExtendedSubQuery<T>, Expression<T>, SubQueryExpression<T>, SQLCommonQuery<Q>, Serializable

Direct Known Subclasses:

MySQLQuery, OracleQuery, PostgreSQLQuery, SQLQuery, SQLServerQuery, TeradataQuery

public abstract class AbstractSQLQuery<T,Q extends AbstractSQLQuery<T,Q>>
extends ProjectableSQLQuery<T,Q>

AbstractSQLQuery is the base type for SQL query implementations

Author:

tiwe

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected SQLListeners	listeners
protected static String	PARENT_CONTEXT
protected boolean	useLiterals

Fields inherited from class com.querydsl.sql.ProjectableSQLQuery

configuration, firstUnionSubQuery, union, unionAll

Fields inherited from class com.querydsl.core.support.QueryBase

MDC_PARAMETERS, MDC_QUERY, queryMixin

Constructor Summary

Constructors

Constructor and Description
AbstractSQLQuery(Connection conn, Configuration configuration)
AbstractSQLQuery(Connection conn, Configuration configuration, QueryMetadata metadata)

Method Summary

Modifier and Type	Method and Description
void	addListener(SQLListener listener) Add a listener
SimpleExpression<T>	as(Path<?> alias) Create an alias for the expression
SimpleExpression<T>	as(String alias) Create an alias for the expression
protected void	cleanupMDC()
Q	clone()
abstract Q	clone(Connection connection)
protected void	clone(Q query)
protected SQLSerializer	createSerializer()
protected void	endContext(SQLListenerContext context) Called to end a SQL listener context
List<T>	fetch() Get the projection as a typed List
long	fetchCount() Get the count of matched elements
QueryResults<T>	fetchResults() Get the projection in QueryResults form
Q	forShare() FOR SHARE causes the rows retrieved by the SELECT statement to be locked as though for update.
Q	forShare(boolean fallbackToForUpdate) FOR SHARE causes the rows retrieved by the SELECT statement to be locked as though for update.
Q	forUpdate() If you use forUpdate() with a backend that uses page or row locks, rows examined by the query are write-locked until the end of the current transaction.
protected Configuration	getConfiguration()
ResultSet	getResults(Expression<?>... exprs) Get the results as an JDBC result set
com.mysema.commons.lang.CloseableIterator<T>	iterate() Get the projection as a typed closeable Iterator
protected void	logQuery(String queryString, Collection<Object> parameters)
protected void	onException(SQLListenerContextImpl context, Exception e) Called to make the call back to listeners when an exception happens
protected void	setParameters(PreparedStatement stmt, List<?> objects, List<Path<?>> constantPaths, Map<ParamExpression<?>,?> params)
void	setStatementOptions(StatementOptions statementOptions)
void	setUseLiterals(boolean useLiterals)
protected SQLListenerContextImpl	startContext(Connection connection, QueryMetadata metadata) Called to create and start a new SQL Listener context

Methods inherited from class com.querydsl.sql.ProjectableSQLQuery

accept, addFlag, addFlag, addFlag, addFlag, addJoinFlag, addJoinFlag, fetchOne, from, from, from, fullJoin, fullJoin, fullJoin, fullJoin, getSQL, innerJoin, innerJoin, innerJoin, innerJoin, join, join, join, join, leftJoin, leftJoin, leftJoin, leftJoin, on, on, rightJoin, rightJoin, rightJoin, rightJoin, serialize, toString, union, union, union, unionAll, unionAll, unionAll, with, with, with, withRecursive, withRecursive, withRecursive

Methods inherited from class com.querydsl.core.support.FetchableSubQueryBase

contains, contains, eq, eq, exists, getMetadata, getType, goe, goe, gt, gt, hashCode, isNotNull, isNull, loe, loe, lt, lt, ne, ne, notExists

Methods inherited from class com.querydsl.core.support.FetchableQueryBase

equals, fetchFirst, transform, uniqueResult

Methods inherited from class com.querydsl.core.support.QueryBase

distinct, groupBy, groupBy, having, having, limit, offset, orderBy, orderBy, restrict, set, where, where

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.querydsl.core.Query

groupBy, having

Methods inherited from interface com.querydsl.core.SimpleQuery

distinct, limit, offset, orderBy, restrict, set

Methods inherited from interface com.querydsl.core.FilteredClause

where

Methods inherited from interface com.querydsl.core.FetchableQuery

select, select, transform

Methods inherited from interface com.querydsl.core.Fetchable

fetchFirst

Field Detail

PARENT_CONTEXT

protected static final String PARENT_CONTEXT

listeners

protected SQLListeners listeners

useLiterals

protected boolean useLiterals

Constructor Detail

AbstractSQLQuery

public AbstractSQLQuery(@Nullable
                        Connection conn,
                        Configuration configuration)

AbstractSQLQuery

public AbstractSQLQuery(@Nullable
                        Connection conn,
                        Configuration configuration,
                        QueryMetadata metadata)

Method Detail

as

public SimpleExpression<T> as(String alias)

Create an alias for the expression

Parameters:

alias - alias

Returns:

this as alias

as

public SimpleExpression<T> as(Path<?> alias)

Create an alias for the expression

Parameters:

alias - alias

Returns:

this as alias

addListener

public void addListener(SQLListener listener)

Add a listener

Parameters:

listener - listener to add

fetchCount

public long fetchCount()

Description copied from interface: Fetchable

Get the count of matched elements

Specified by:

fetchCount in interface Fetchable<T>

Overrides:

fetchCount in class ProjectableSQLQuery<T,Q extends AbstractSQLQuery<T,Q>>

Returns:

row count

forUpdate

public Q forUpdate()

If you use forUpdate() with a backend that uses page or row locks, rows examined by the query are write-locked until the end of the current transaction. Not supported for SQLite and CUBRID

Returns:

the current object

forShare

public Q forShare()

FOR SHARE causes the rows retrieved by the SELECT statement to be locked as though for update. Supported by MySQL, PostgreSQL, SQLServer.

Returns:

the current object

Throws:

QueryException - if the FOR SHARE is not supported.

forShare

public Q forShare(boolean fallbackToForUpdate)

FOR SHARE causes the rows retrieved by the SELECT statement to be locked as though for update. Supported by MySQL, PostgreSQL, SQLServer.

Parameters:

fallbackToForUpdate - if the FOR SHARE is not supported and this parameter is true, the forUpdate() functionality will be used.

Returns:

the current object

Throws:

QueryException - if the FOR SHARE is not supported and fallbackToForUpdate is set to false.

createSerializer

protected SQLSerializer createSerializer()

Specified by:

createSerializer in class ProjectableSQLQuery<T,Q extends AbstractSQLQuery<T,Q>>

startContext

protected SQLListenerContextImpl startContext(Connection connection,
                                              QueryMetadata metadata)

Called to create and start a new SQL Listener context

Parameters:

connection - the database connection

metadata - the meta data for that context

Returns:

the newly started context

onException

protected void onException(SQLListenerContextImpl context,
                           Exception e)

Called to make the call back to listeners when an exception happens

Parameters:

context - the current context in play

e - the exception

endContext

protected void endContext(SQLListenerContext context)

Called to end a SQL listener context

Parameters:

context - the listener context to end

getResults

public ResultSet getResults(Expression<?>... exprs)

Get the results as an JDBC result set

Parameters:

exprs - the expression arguments to retrieve

Returns:

results as ResultSet

getConfiguration

protected Configuration getConfiguration()

iterate

public com.mysema.commons.lang.CloseableIterator<T> iterate()

Description copied from interface: Fetchable

Get the projection as a typed closeable Iterator

Returns:

closeable iterator

fetch

public List<T> fetch()

Description copied from interface: Fetchable

Get the projection as a typed List

Specified by:

fetch in interface Fetchable<T>

Overrides:

fetch in class FetchableQueryBase<T,Q extends AbstractSQLQuery<T,Q>>

Returns:

results in list form

fetchResults

public QueryResults<T> fetchResults()

Description copied from interface: Fetchable

Get the projection in QueryResults form

Returns:

results

setParameters

protected void setParameters(PreparedStatement stmt,
                             List<?> objects,
                             List<Path<?>> constantPaths,
                             Map<ParamExpression<?>,?> params)

logQuery

protected void logQuery(String queryString,
                        Collection<Object> parameters)

cleanupMDC

protected void cleanupMDC()

setUseLiterals

public void setUseLiterals(boolean useLiterals)

clone

protected void clone(Q query)

Overrides:

clone in class ProjectableSQLQuery<T,Q extends AbstractSQLQuery<T,Q>>

clone

public Q clone()

Specified by:

clone in class ProjectableSQLQuery<T,Q extends AbstractSQLQuery<T,Q>>

clone

public abstract Q clone(Connection connection)

setStatementOptions

public void setStatementOptions(StatementOptions statementOptions)