MySQL Connector/J 9.2.0 · com.mysql.cj.AbstractQuery

Field Summary

Modifier and Type	Field and Description
protected List<Object>	batchedArgs Holds batched commands
private Query.CancelStatus	cancelStatus
protected Lock	cancelTimeoutLock Lock to prevent race between returning query results and noticing that query has been timed-out or cancelled.
protected String	charEncoding The character encoding to use (if available)
protected boolean	clearWarningsCalled Has clearWarnings() been called?
protected String	currentDb The database in use
private long	executeTime Elapsed time of the execution
protected int	fetchSize The number of rows to fetch at a time (currently ignored)
protected final Lock	lock
protected RuntimeProperty<Integer>	maxAllowedPacket
protected QueryAttributesBindings	queryAttributesBindings Query attributes bindings
protected Resultset.Type	resultSetType The type of this result set (scroll sensitive or in-sensitive)
public NativeSession	session
pack-priv static int	statementCounter Used to generate IDs when profiling.
protected final AtomicBoolean	statementExecuting Currently executing a statement?
protected int	statementId Used to identify this statement when profiling.
protected long	timeoutInMillis The timeout for a query

Constructor Summary

Access	Constructor and Description
public	AbstractQuery(NativeSession sess)

Method Summary

Modifier and Type	Method and Description
public void	addBatch(Object batch) Implements com.mysql.cj.Query.addBatch.
public void	checkCancelTimeout() Implements com.mysql.cj.Query.checkCancelTimeout.
public void	clearBatchedArgs() Implements com.mysql.cj.Query.clearBatchedArgs.
public void	closeQuery() Implements com.mysql.cj.Query.closeQuery.
public List<Object>	getBatchedArgs() Implements com.mysql.cj.Query.getBatchedArgs. Get the batched args as added by the addBatch method(s).
public Lock	getCancelTimeoutLock() Implements com.mysql.cj.Query.getCancelTimeoutLock.
public String	getCurrentDatabase() Implements com.mysql.cj.Query.getCurrentDatabase.
public long	getExecuteTime() Implements com.mysql.cj.Query.getExecuteTime. Returns the elapsed time for the server to execute the query.
public int	getId() Implements com.mysql.cj.Query.getId. Returns the query id used when profiling
public QueryAttributesBindings	getQueryAttributesBindings() Implements com.mysql.cj.Query.getQueryAttributesBindings.
public int	getResultFetchSize() Implements com.mysql.cj.Query.getResultFetchSize.
public <T extends Resultset, M extends Message> ProtocolEntityFactory<T, M>	getResultSetFactory() Implements com.mysql.cj.Query.getResultSetFactory.
public Resultset.Type	getResultType() Implements com.mysql.cj.Query.getResultType.
public NativeSession	getSession() Implements com.mysql.cj.Query.getSession.
public AtomicBoolean	getStatementExecuting() Implements com.mysql.cj.Query.getStatementExecuting.
public long	getTimeoutInMillis() Implements com.mysql.cj.Query.getTimeoutInMillis.
public boolean	isClearWarningsCalled() Implements com.mysql.cj.Query.isClearWarningsCalled.
public void	resetCancelledState() Implements com.mysql.cj.Query.resetCancelledState.
public void	setCancelStatus(Query.CancelStatus cs) Implements com.mysql.cj.Query.setCancelStatus.
public void	setClearWarningsCalled(boolean clearWarningsCalled) Implements com.mysql.cj.Query.setClearWarningsCalled.
public void	setCurrentDatabase(String currentDb) Implements com.mysql.cj.Query.setCurrentDatabase.
public void	setExecuteTime(long executeTime) Implements com.mysql.cj.Query.setExecuteTime.
public void	setResultFetchSize(int fetchSize) Implements com.mysql.cj.Query.setResultFetchSize.
public void	setResultType(Resultset.Type resultSetType) Implements com.mysql.cj.Query.setResultType.
public void	setTimeoutInMillis(long timeoutInMillis) Implements com.mysql.cj.Query.setTimeoutInMillis.
public CancelQueryTask	startQueryTimer(Query stmtToCancel, long timeout) Implements com.mysql.cj.Query.startQueryTimer.
public void	statementBegins() Implements com.mysql.cj.Query.statementBegins.
public void	stopQueryTimer(CancelQueryTask timeoutTask, boolean rethrowCancelReason, boolean checkCancelTimeout) Implements com.mysql.cj.Query.stopQueryTimer.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

batchedArgs	back to summary
protected List<Object> batchedArgs Holds batched commands

cancelStatus	back to summary
private Query.CancelStatus cancelStatus

cancelTimeoutLock	back to summary
protected Lock cancelTimeoutLock Lock to prevent race between returning query results and noticing that query has been timed-out or cancelled.

charEncoding	back to summary
protected String charEncoding The character encoding to use (if available)

clearWarningsCalled	back to summary
protected boolean clearWarningsCalled Has clearWarnings() been called?

currentDb	back to summary
protected String currentDb The database in use

executeTime	back to summary
private long executeTime Elapsed time of the execution

fetchSize	back to summary
protected int fetchSize The number of rows to fetch at a time (currently ignored)

lock	back to summary
protected final Lock lock

maxAllowedPacket	back to summary
protected RuntimeProperty<Integer> maxAllowedPacket

queryAttributesBindings	back to summary
protected QueryAttributesBindings queryAttributesBindings Query attributes bindings

resultSetType	back to summary
protected Resultset.Type resultSetType The type of this result set (scroll sensitive or in-sensitive)

session	back to summary
public NativeSession session

statementCounter	back to summary
pack-priv static int statementCounter Used to generate IDs when profiling.

statementExecuting	back to summary
protected final AtomicBoolean statementExecuting Currently executing a statement?

statementId	back to summary
protected int statementId Used to identify this statement when profiling.

timeoutInMillis	back to summary
protected long timeoutInMillis The timeout for a query

Constructor Detail

AbstractQuery	back to summary
public AbstractQuery(NativeSession sess)

Method Detail

addBatch	back to summary
public void addBatch(Object batch) Implements com.mysql.cj.Query.addBatch. Annotations @Override

addBatch

back to summary

public void addBatch(Object batch)

Implements com.mysql.cj.Query.addBatch.

Annotations

@Override

checkCancelTimeout	back to summary
public void checkCancelTimeout() Implements com.mysql.cj.Query.checkCancelTimeout. Annotations @Override

checkCancelTimeout

back to summary

public void checkCancelTimeout()

Implements com.mysql.cj.Query.checkCancelTimeout.

Annotations

@Override

clearBatchedArgs	back to summary
public void clearBatchedArgs() Implements com.mysql.cj.Query.clearBatchedArgs. Annotations @Override

clearBatchedArgs

back to summary

public void clearBatchedArgs()

Implements com.mysql.cj.Query.clearBatchedArgs.

Annotations

@Override

closeQuery	back to summary
public void closeQuery() Implements com.mysql.cj.Query.closeQuery. Annotations @Override

closeQuery

back to summary

public void closeQuery()

Implements com.mysql.cj.Query.closeQuery.

Annotations

@Override

getBatchedArgs	back to summary
public List<Object> getBatchedArgs() Implements com.mysql.cj.Query.getBatchedArgs. Doc from com.mysql.cj.Query.getBatchedArgs. Get the batched args as added by the addBatch method(s). The list is unmodifiable and might contain any combination of String, ClientPreparedQueryBindings, or ServerPreparedQueryBindings depending on how the parameters were batched. Returns:List<Object> an unmodifiable List of batched args Annotations @Override

getBatchedArgs

back to summary

public List<Object> getBatchedArgs()

Implements com.mysql.cj.Query.getBatchedArgs.

Doc from com.mysql.cj.Query.getBatchedArgs.

Get the batched args as added by the addBatch method(s). The list is unmodifiable and might contain any combination of String, ClientPreparedQueryBindings, or ServerPreparedQueryBindings depending on how the parameters were batched.

Returns:List<Object>

an unmodifiable List of batched args

Annotations

@Override

getCancelTimeoutLock	back to summary
public Lock getCancelTimeoutLock() Implements com.mysql.cj.Query.getCancelTimeoutLock. Annotations @Override

getCancelTimeoutLock

back to summary

public Lock getCancelTimeoutLock()

Implements com.mysql.cj.Query.getCancelTimeoutLock.

Annotations

@Override

getCurrentDatabase	back to summary
public String getCurrentDatabase() Implements com.mysql.cj.Query.getCurrentDatabase. Annotations @Override

getCurrentDatabase

back to summary

public String getCurrentDatabase()

Implements com.mysql.cj.Query.getCurrentDatabase.

Annotations

@Override

getExecuteTime	back to summary
public long getExecuteTime() Implements com.mysql.cj.Query.getExecuteTime. Doc from com.mysql.cj.Query.getExecuteTime. Returns the elapsed time for the server to execute the query. Returns:long the time it took for the server to execute the query. Annotations @Override

getExecuteTime

back to summary

public long getExecuteTime()

Implements com.mysql.cj.Query.getExecuteTime.

Doc from com.mysql.cj.Query.getExecuteTime.

Returns the elapsed time for the server to execute the query.

Returns:long

the time it took for the server to execute the query.

Annotations

@Override

getId	back to summary
public int getId() Implements com.mysql.cj.Query.getId. Doc from com.mysql.cj.Query.getId. Returns the query id used when profiling Returns:int id Annotations @Override

getId

back to summary

public int getId()

Implements com.mysql.cj.Query.getId.

Doc from com.mysql.cj.Query.getId.

Returns the query id used when profiling

Returns:int

Annotations

@Override

getQueryAttributesBindings	back to summary
public QueryAttributesBindings getQueryAttributesBindings() Implements com.mysql.cj.Query.getQueryAttributesBindings. Annotations @Override

getQueryAttributesBindings

back to summary

public QueryAttributesBindings getQueryAttributesBindings()

Implements com.mysql.cj.Query.getQueryAttributesBindings.

Annotations

@Override

getResultFetchSize	back to summary
public int getResultFetchSize() Implements com.mysql.cj.Query.getResultFetchSize. Annotations @Override

getResultFetchSize

back to summary

public int getResultFetchSize()

Implements com.mysql.cj.Query.getResultFetchSize.

Annotations

@Override

getResultSetFactory	back to summary
public <T extends Resultset, M extends Message> ProtocolEntityFactory<T, M> getResultSetFactory() Implements com.mysql.cj.Query.getResultSetFactory. Annotations @Override

getResultSetFactory

back to summary

public <T extends Resultset, M extends Message> ProtocolEntityFactory<T, M> getResultSetFactory()

Implements com.mysql.cj.Query.getResultSetFactory.

Annotations

@Override

getResultType	back to summary
public Resultset.Type getResultType() Implements com.mysql.cj.Query.getResultType. Annotations @Override

getResultType

back to summary

public Resultset.Type getResultType()

Implements com.mysql.cj.Query.getResultType.

Annotations

@Override

getSession	back to summary
public NativeSession getSession() Implements com.mysql.cj.Query.getSession. Annotations @Override

getSession

back to summary

public NativeSession getSession()

Implements com.mysql.cj.Query.getSession.

Annotations

@Override

getStatementExecuting	back to summary
public AtomicBoolean getStatementExecuting() Implements com.mysql.cj.Query.getStatementExecuting. Annotations @Override

getStatementExecuting

back to summary

public AtomicBoolean getStatementExecuting()

Implements com.mysql.cj.Query.getStatementExecuting.

Annotations

@Override

getTimeoutInMillis	back to summary
public long getTimeoutInMillis() Implements com.mysql.cj.Query.getTimeoutInMillis. Annotations @Override

getTimeoutInMillis

back to summary

public long getTimeoutInMillis()

Implements com.mysql.cj.Query.getTimeoutInMillis.

Annotations

@Override

isClearWarningsCalled	back to summary
public boolean isClearWarningsCalled() Implements com.mysql.cj.Query.isClearWarningsCalled. Annotations @Override

isClearWarningsCalled

back to summary

public boolean isClearWarningsCalled()

Implements com.mysql.cj.Query.isClearWarningsCalled.

Annotations

@Override

resetCancelledState	back to summary
public void resetCancelledState() Implements com.mysql.cj.Query.resetCancelledState. Annotations @Override

resetCancelledState

back to summary

public void resetCancelledState()

Implements com.mysql.cj.Query.resetCancelledState.

Annotations

@Override

setCancelStatus	back to summary
public void setCancelStatus(Query.CancelStatus cs) Implements com.mysql.cj.Query.setCancelStatus. Annotations @Override

setCancelStatus

back to summary

public void setCancelStatus(Query.CancelStatus cs)

Implements com.mysql.cj.Query.setCancelStatus.

Annotations

@Override

setClearWarningsCalled	back to summary
public void setClearWarningsCalled(boolean clearWarningsCalled) Implements com.mysql.cj.Query.setClearWarningsCalled. Annotations @Override

setClearWarningsCalled

back to summary

public void setClearWarningsCalled(boolean clearWarningsCalled)

Implements com.mysql.cj.Query.setClearWarningsCalled.

Annotations

@Override

setCurrentDatabase	back to summary
public void setCurrentDatabase(String currentDb) Implements com.mysql.cj.Query.setCurrentDatabase. Annotations @Override

setCurrentDatabase

back to summary

public void setCurrentDatabase(String currentDb)

Implements com.mysql.cj.Query.setCurrentDatabase.

Annotations

@Override

setExecuteTime	back to summary
public void setExecuteTime(long executeTime) Implements com.mysql.cj.Query.setExecuteTime. Annotations @Override

setExecuteTime

back to summary

public void setExecuteTime(long executeTime)

Implements com.mysql.cj.Query.setExecuteTime.

Annotations

@Override

setResultFetchSize	back to summary
public void setResultFetchSize(int fetchSize) Implements com.mysql.cj.Query.setResultFetchSize. Annotations @Override

setResultFetchSize

back to summary

public void setResultFetchSize(int fetchSize)

Implements com.mysql.cj.Query.setResultFetchSize.

Annotations

@Override

setResultType	back to summary
public void setResultType(Resultset.Type resultSetType) Implements com.mysql.cj.Query.setResultType. Annotations @Override

setResultType

back to summary

public void setResultType(Resultset.Type resultSetType)

Implements com.mysql.cj.Query.setResultType.

Annotations

@Override

setTimeoutInMillis	back to summary
public void setTimeoutInMillis(long timeoutInMillis) Implements com.mysql.cj.Query.setTimeoutInMillis. Annotations @Override

setTimeoutInMillis

back to summary

public void setTimeoutInMillis(long timeoutInMillis)

Implements com.mysql.cj.Query.setTimeoutInMillis.

Annotations

@Override

startQueryTimer	back to summary
public CancelQueryTask startQueryTimer(Query stmtToCancel, long timeout) Implements com.mysql.cj.Query.startQueryTimer. Annotations @Override

startQueryTimer

back to summary

public CancelQueryTask startQueryTimer(Query stmtToCancel, long timeout)

Implements com.mysql.cj.Query.startQueryTimer.

Annotations

@Override

statementBegins	back to summary
public void statementBegins() Implements com.mysql.cj.Query.statementBegins. Annotations @Override

statementBegins

back to summary

public void statementBegins()

Implements com.mysql.cj.Query.statementBegins.

Annotations

@Override

stopQueryTimer	back to summary
public void stopQueryTimer(CancelQueryTask timeoutTask, boolean rethrowCancelReason, boolean checkCancelTimeout) Implements com.mysql.cj.Query.stopQueryTimer. Annotations @Override

stopQueryTimer

back to summary

public void stopQueryTimer(CancelQueryTask timeoutTask, boolean rethrowCancelReason, boolean checkCancelTimeout)

Implements com.mysql.cj.Query.stopQueryTimer.

Annotations

@Override

public abstract Class AbstractQuery

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail