| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
NativeSession.execSQL(Query callingQuery,
java.lang.String query,
int maxRows,
NativePacketPayload packet,
boolean streamResults,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory,
ColumnDefinition cachedMetadata,
boolean isBatch)
Send a query to the server.
|
<T extends Resultset,M extends Message> |
Query.getResultSetFactory() |
<T extends Resultset,M extends Message> |
AbstractQuery.getResultSetFactory() |
<T extends Resultset> |
NativeSession.invokeQueryInterceptorsPost(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
boolean forceExecute) |
<T extends Resultset> |
NativeSession.invokeQueryInterceptorsPre(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
boolean forceExecute) |
<T extends Resultset> |
NoSubInterceptorWrapper.postProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
ServerSession serverSession) |
<T extends Resultset> |
NoSubInterceptorWrapper.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |
<T extends Resultset> |
ServerPreparedQuery.readExecuteResult(NativePacketPayload resultPacket,
int maxRowsToRetrieve,
boolean createStreamingResultSet,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory,
java.lang.String queryAsString) |
<T extends Resultset> |
ServerPreparedQuery.serverExecute(int maxRowsToRetrieve,
boolean createStreamingResultSet,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory) |
<T extends Resultset> |
ServerPreparedQueryTestcaseGenerator.serverExecute(int maxRowsToRetrieve,
boolean createStreamingResultSet,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory) |
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
QueryInterceptor.postProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
ServerSession serverSession)
Called after the given query has been sent to the server for processing.
|
<T extends Resultset> |
QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery)
Called before the given query is going to be sent to the server for processing.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset,M extends Message> |
StatementImpl.getResultSetFactory() |
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
LoadBalancedAutoCommitInterceptor.postProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
ServerSession serverSession) |
<T extends Resultset> |
LoadBalancedAutoCommitInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
SessionAssociationInterceptor.postProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
ServerSession serverSession) |
<T extends Resultset> |
ResultSetScannerInterceptor.postProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
ServerSession serverSession) |
<T extends Resultset> |
ServerStatusDiffInterceptor.postProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
ServerSession serverSession) |
<T extends Resultset> |
SessionAssociationInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |
<T extends Resultset> |
ResultSetScannerInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |
<T extends Resultset> |
ServerStatusDiffInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ResultSetInternalMethods
This interface is intended to be used by implementors of statement interceptors so that implementors can create static or dynamic (via
java.lang.reflect.Proxy) proxy instances of ResultSets.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ResultSetImpl |
class |
UpdatableResultSet
A result set that is updatable.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ProfilerEventHandler.processEvent(byte eventType,
Session session,
Query query,
Resultset resultSet,
long eventDuration,
java.lang.Throwable eventCreationPoint,
java.lang.String message) |
void |
LoggingProfilerEventHandler.processEvent(byte eventType,
Session session,
Query query,
Resultset resultSet,
long eventDuration,
java.lang.Throwable eventCreationPoint,
java.lang.String message) |
| Modifier and Type | Method and Description |
|---|---|
Resultset |
Resultset.getNextResultset()
Returns the next ResultSet in a multi-resultset "chain", if any,
null if none exists.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Resultset.setNextResultset(Resultset nextResultset) |
| Modifier and Type | Method and Description |
|---|---|
<T extends ProtocolEntity> |
Protocol.read(java.lang.Class<Resultset> requiredClass,
int maxRows,
boolean streamResults,
M resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,M> protocolEntityFactory)
Read protocol entity.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
NativeProtocol.invokeQueryInterceptorsPost(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
boolean forceExecute) |
<T extends Resultset> |
NativeProtocol.invokeQueryInterceptorsPre(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
boolean forceExecute) |
<T extends Resultset> |
NativeProtocol.readAllResults(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory) |
<T extends Resultset> |
NativeProtocol.sendQueryPacket(Query callingQuery,
NativePacketPayload queryPacket,
int maxRows,
boolean streamResults,
ColumnDefinition cachedMetadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory)
Send a query stored in a packet to the server.
|
<T extends Resultset> |
NativeProtocol.sendQueryString(Query callingQuery,
java.lang.String query,
java.lang.String characterEncoding,
int maxRows,
boolean streamResults,
ColumnDefinition cachedMetadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory)
Build a query packet from the given string and send it to the server.
|
| Modifier and Type | Method and Description |
|---|---|
Resultset |
ResultsetFactory.createFromProtocolEntity(ProtocolEntity protocolEntity) |
Resultset |
BinaryResultsetReader.read(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
ColumnDefinition metadata,
ProtocolEntityFactory<Resultset,NativePacketPayload> resultSetFactory) |
Resultset |
TextResultsetReader.read(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
ColumnDefinition metadata,
ProtocolEntityFactory<Resultset,NativePacketPayload> resultSetFactory) |
| Modifier and Type | Method and Description |
|---|---|
private java.lang.StringBuilder |
NativeProtocol.appendResultSetSlashGStyle(java.lang.StringBuilder appendTo,
Resultset rs) |
| Modifier and Type | Method and Description |
|---|---|
<T extends ProtocolEntity> |
NativeProtocol.read(java.lang.Class<Resultset> requiredClass,
int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> protocolEntityFactory) |
Resultset |
BinaryResultsetReader.read(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
ColumnDefinition metadata,
ProtocolEntityFactory<Resultset,NativePacketPayload> resultSetFactory) |
Resultset |
TextResultsetReader.read(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
ColumnDefinition metadata,
ProtocolEntityFactory<Resultset,NativePacketPayload> resultSetFactory) |
| Modifier and Type | Class and Description |
|---|---|
class |
NativeResultset |
| Modifier and Type | Field and Description |
|---|---|
protected Resultset |
NativeResultset.nextResultset |
| Modifier and Type | Method and Description |
|---|---|
Resultset |
NativeResultset.getNextResultset() |
| Modifier and Type | Method and Description |
|---|---|
void |
NativeResultset.setNextResultset(Resultset nextResultset) |
| Modifier and Type | Method and Description |
|---|---|
<T extends ProtocolEntity> |
XProtocol.read(java.lang.Class<Resultset> requiredClass,
int maxRows,
boolean streamResults,
XMessage resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,XMessage> protocolEntityFactory) |
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
BaseQueryInterceptor.postProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
ServerSession serverSession) |
<T extends Resultset> |
BaseQueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
ConnectionRegressionTest.Bug88227QueryInterceptor.postProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery,
T originalResultSet,
ServerSession serverSession) |
<T extends Resultset> |
CharsetRegressionTest.Bug73663QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
CharsetRegressionTest.TestSetNamesQueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
CharsetRegressionTest.Bug72712QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
CharsetRegressionTest.Bug95139QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
ConnectionRegressionTest.Bug75168QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
ConnectionRegressionTest.Bug75592QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
ConnectionRegressionTest.Bug56100QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
ConnectionRegressionTest.Bug88227QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |
<T extends Resultset> |
ConnectionRegressionTest.Bug104067QueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
MetaDataRegressionTest.QueryInterceptorBug61332.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
ConnectionTest.TestEnableEscapeProcessingQueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> str,
Query interceptedQuery) |
<T extends Resultset> |
MetadataTest.TestGetSqlKeywordsDynamicQueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |
<T extends Resultset> |
StatementsTest.QueryInfoQueryInterceptor.preProcess(java.util.function.Supplier<java.lang.String> sql,
Query interceptedQuery) |