Package ca.uhn.fhir.jpa.util

Class CircularQueueCaptureQueriesListener

java.lang.Object

ca.uhn.fhir.jpa.util.BaseCaptureQueriesListener

ca.uhn.fhir.jpa.util.CircularQueueCaptureQueriesListener

All Implemented Interfaces:

net.ttddyy.dsproxy.support.ProxyDataSourceBuilder.SingleMethodExecution, net.ttddyy.dsproxy.support.ProxyDataSourceBuilder.SingleQueryExecution

public class CircularQueueCaptureQueriesListener
extends BaseCaptureQueriesListener

This is a query listener designed to be plugged into a proxy DataSource. This listener keeps the last 1000 queries across all threads in a CircularFifoQueue, dropping queries off the end of the list as new ones are added.

Note that this class is really only designed for use in testing - It adds a non-trivial overhead to each query.

Field Summary

Fields

Modifier and Type	Field	Description
static final Predicate<String>	DEFAULT_SELECT_INCLUSION_CRITERIA

Constructor Summary

Constructors

Constructor	Description
CircularQueueCaptureQueriesListener()	Constructor

Method Summary

Modifier and Type	Method	Description
void	clear()	Clear all stored queries
int	countDeleteQueries()
int	countDeleteQueriesForCurrentThread()
int	countInsertQueries()
int	countInsertQueriesForCurrentThread()
int	countSelectQueries()
int	countSelectQueriesForCurrentThread()
int	countUpdateQueries()
int	countUpdateQueriesForCurrentThread()
List<SqlQuery>	getAllQueriesForCurrentThread()	Returns all queries executed on the current thread - Index 0 is oldest
List<SqlQuery>	getCapturedQueries()	Index 0 is oldest
int	getCommitCount()
List<SqlQuery>	getDeleteQueries()	Returns all UPDATE queries executed on the current thread - Index 0 is oldest
List<SqlQuery>	getDeleteQueriesForCurrentThread()	Returns all UPDATE queries executed on the current thread - Index 0 is oldest
List<SqlQuery>	getInsertQueries()	Returns all INSERT queries executed on the current thread - Index 0 is oldest
List<SqlQuery>	getInsertQueriesForCurrentThread()	Returns all INSERT queries executed on the current thread - Index 0 is oldest
int	getRollbackCount()
List<SqlQuery>	getSelectQueries()	Returns all SELECT queries executed on the current thread - Index 0 is oldest
List<SqlQuery>	getSelectQueriesForCurrentThread()	Returns all SELECT queries executed on the current thread - Index 0 is oldest
List<SqlQuery>	getUpdateQueries()	Returns all UPDATE queries executed on the current thread - Index 0 is oldest
List<SqlQuery>	getUpdateQueriesForCurrentThread()	Returns all UPDATE queries executed on the current thread - Index 0 is oldest
void	logAllQueries()	Log all captured queries
void	logAllQueriesForCurrentThread()	Log all captured queries
int	logDeleteQueries()	Log all captured DELETE queries
String	logDeleteQueriesForCurrentThread()	Log all captured DELETE queries
void	logFirstSelectQueryForCurrentThread()	Log first captured SELECT query
int	logInsertQueries()	Log all captured INSERT queries
int	logInsertQueries(Predicate<SqlQuery> theInclusionPredicate)	Log all captured INSERT queries
String	logInsertQueriesForCurrentThread()	Log all captured INSERT queries
List<SqlQuery>	logSelectQueries()	Log all captured SELECT queries
List<SqlQuery>	logSelectQueries(boolean theInlineParams, boolean theFormatSql)	Log all captured SELECT queries
String	logSelectQueriesForCurrentThread(int... theIndexes)	Log all captured SELECT queries
int	logUpdateQueries()	Log all captured INSERT queries
String	logUpdateQueriesForCurrentThread()	Log all captured UPDATE queries
protected AtomicInteger	provideCommitCounter()
protected Queue<SqlQuery>	provideQueryList()
protected AtomicInteger	provideRollbackCounter()
CircularQueueCaptureQueriesListener	setSelectQueryInclusionCriteria(Predicate<String> theSelectQueryInclusionCriteria)	Sets an alternate inclusion criteria for select queries.
void	startCollecting()	Start collecting queries (this is the default)
void	stopCollecting()	Stop collecting queries and discard any collected ones

Methods inherited from class ca.uhn.fhir.jpa.util.BaseCaptureQueriesListener

countCommits, countRollbacks, execute, execute, isCaptureQueryStackTrace, setCaptureQueryStackTrace

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SELECT_INCLUSION_CRITERIA

public static final Predicate<String> DEFAULT_SELECT_INCLUSION_CRITERIA

Constructor Details

CircularQueueCaptureQueriesListener

public CircularQueueCaptureQueriesListener()

Constructor

Method Details

setSelectQueryInclusionCriteria

public CircularQueueCaptureQueriesListener setSelectQueryInclusionCriteria(@Nonnull
 Predicate<String> theSelectQueryInclusionCriteria)

Sets an alternate inclusion criteria for select queries. This can be used to add additional criteria beyond the default value of DEFAULT_SELECT_INCLUSION_CRITERIA.

provideQueryList

protected Queue<SqlQuery> provideQueryList()

Specified by:

provideQueryList in class BaseCaptureQueriesListener

provideCommitCounter

protected AtomicInteger provideCommitCounter()

Specified by:

provideCommitCounter in class BaseCaptureQueriesListener

provideRollbackCounter

protected AtomicInteger provideRollbackCounter()

Specified by:

provideRollbackCounter in class BaseCaptureQueriesListener

clear

public void clear()

Clear all stored queries

startCollecting

public void startCollecting()

Start collecting queries (this is the default)

stopCollecting

public void stopCollecting()

Stop collecting queries and discard any collected ones

getCapturedQueries

public List<SqlQuery> getCapturedQueries()

Index 0 is oldest

getCommitCount

public int getCommitCount()

getRollbackCount

public int getRollbackCount()

getSelectQueries

public List<SqlQuery> getSelectQueries()

Returns all SELECT queries executed on the current thread - Index 0 is oldest

getInsertQueries

public List<SqlQuery> getInsertQueries()

Returns all INSERT queries executed on the current thread - Index 0 is oldest

getUpdateQueries

public List<SqlQuery> getUpdateQueries()

Returns all UPDATE queries executed on the current thread - Index 0 is oldest

getDeleteQueries

public List<SqlQuery> getDeleteQueries()

Returns all UPDATE queries executed on the current thread - Index 0 is oldest

getSelectQueriesForCurrentThread

public List<SqlQuery> getSelectQueriesForCurrentThread()

Returns all SELECT queries executed on the current thread - Index 0 is oldest

getInsertQueriesForCurrentThread

public List<SqlQuery> getInsertQueriesForCurrentThread()

Returns all INSERT queries executed on the current thread - Index 0 is oldest

getAllQueriesForCurrentThread

public List<SqlQuery> getAllQueriesForCurrentThread()

Returns all queries executed on the current thread - Index 0 is oldest

getUpdateQueriesForCurrentThread

public List<SqlQuery> getUpdateQueriesForCurrentThread()

Returns all UPDATE queries executed on the current thread - Index 0 is oldest

getDeleteQueriesForCurrentThread

public List<SqlQuery> getDeleteQueriesForCurrentThread()

Returns all UPDATE queries executed on the current thread - Index 0 is oldest

logUpdateQueriesForCurrentThread

public String logUpdateQueriesForCurrentThread()

Log all captured UPDATE queries

logSelectQueriesForCurrentThread

public String logSelectQueriesForCurrentThread(int... theIndexes)

Log all captured SELECT queries

logSelectQueries

public List<SqlQuery> logSelectQueries()

Log all captured SELECT queries

logSelectQueries

public List<SqlQuery> logSelectQueries(boolean theInlineParams,
 boolean theFormatSql)

Log all captured SELECT queries

logFirstSelectQueryForCurrentThread

public void logFirstSelectQueryForCurrentThread()

Log first captured SELECT query

logInsertQueriesForCurrentThread

public String logInsertQueriesForCurrentThread()

Log all captured INSERT queries

logAllQueriesForCurrentThread

public void logAllQueriesForCurrentThread()

Log all captured queries

logAllQueries

public void logAllQueries()

Log all captured queries

logInsertQueries

public int logInsertQueries()

Log all captured INSERT queries

logInsertQueries

public int logInsertQueries(Predicate<SqlQuery> theInclusionPredicate)

Log all captured INSERT queries

logUpdateQueries

public int logUpdateQueries()

Log all captured INSERT queries

logDeleteQueriesForCurrentThread

public String logDeleteQueriesForCurrentThread()

Log all captured DELETE queries

logDeleteQueries

public int logDeleteQueries()

Log all captured DELETE queries

countSelectQueries

public int countSelectQueries()

countInsertQueries

public int countInsertQueries()

countUpdateQueries

public int countUpdateQueries()

countDeleteQueries

public int countDeleteQueries()

countSelectQueriesForCurrentThread

public int countSelectQueriesForCurrentThread()

countInsertQueriesForCurrentThread

public int countInsertQueriesForCurrentThread()

countUpdateQueriesForCurrentThread

public int countUpdateQueriesForCurrentThread()

countDeleteQueriesForCurrentThread

public int countDeleteQueriesForCurrentThread()