Package ca.uhn.fhir.jpa.util

Class CurrentThreadCaptureQueriesListener

java.lang.Object

ca.uhn.fhir.jpa.util.BaseCaptureQueriesListener

ca.uhn.fhir.jpa.util.CurrentThreadCaptureQueriesListener

All Implemented Interfaces:

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

public class CurrentThreadCaptureQueriesListener
extends BaseCaptureQueriesListener

Constructor Summary

Constructors

Constructor	Description
CurrentThreadCaptureQueriesListener()

Method Summary

Modifier and Type	Method	Description
static SqlQueryList	getCurrentQueueAndStopCapturing()	Get the current queue of items and stop collecting
static int	logQueriesForCurrentThreadAndStopCapturing(int... theIndexes)	Log all captured SELECT queries
protected AtomicInteger	provideCommitCounter()
protected AtomicInteger	provideGetConnectionCounter()
protected Queue<SqlQuery>	provideQueryList()
protected AtomicInteger	provideRollbackCounter()
static void	startCapturing()	Starts capturing queries for the current thread.

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

countCommits, countGetConnections, countRollbacks, execute, execute, isCaptureQueryStackTrace, setCaptureQueryStackTrace

Methods inherited from class java.lang.Object

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

Constructor Details

CurrentThreadCaptureQueriesListener

public CurrentThreadCaptureQueriesListener()

Method Details

provideQueryList

protected Queue<SqlQuery> provideQueryList()

Specified by:

provideQueryList in class BaseCaptureQueriesListener

provideCommitCounter

protected AtomicInteger provideCommitCounter()

Specified by:

provideCommitCounter in class BaseCaptureQueriesListener

provideGetConnectionCounter

@Nullable
protected AtomicInteger provideGetConnectionCounter()

Specified by:

provideGetConnectionCounter in class BaseCaptureQueriesListener

provideRollbackCounter

protected AtomicInteger provideRollbackCounter()

Specified by:

provideRollbackCounter in class BaseCaptureQueriesListener

getCurrentQueueAndStopCapturing

public static SqlQueryList getCurrentQueueAndStopCapturing()

Get the current queue of items and stop collecting

startCapturing

public static void startCapturing()

Starts capturing queries for the current thread.

Note that you should strongly consider calling this in a try-finally block to ensure that you also call getCurrentQueueAndStopCapturing() afterward. Otherwise this method is a potential memory leak!

logQueriesForCurrentThreadAndStopCapturing

public static int logQueriesForCurrentThreadAndStopCapturing(int... theIndexes)

Log all captured SELECT queries

Returns:

Returns the number of queries captured