| Package | Description |
|---|---|
| com.mysql.cj | |
| com.mysql.cj.protocol.a | |
| com.mysql.cj.protocol.a.authentication | |
| com.mysql.cj.protocol.a.result | |
| testsuite.regression | |
| testsuite.simple |
| Modifier and Type | Method and Description |
|---|---|
NativePacketPayload |
NativeSession.getSharedSendPacket()
Returns the packet used for sending data (used by PreparedStatement) with position set to 0.
|
NativePacketPayload |
ServerPreparedQuery.prepareExecutePacket() |
NativePacketPayload |
ServerPreparedQuery.sendExecutePacket(NativePacketPayload packet,
java.lang.String queryAsString) |
| 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> |
ServerPreparedQuery.readExecuteResult(NativePacketPayload resultPacket,
int maxRowsToRetrieve,
boolean createStreamingResultSet,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory,
java.lang.String queryAsString) |
NativePacketPayload |
ServerPreparedQuery.sendExecutePacket(NativePacketPayload packet,
java.lang.String queryAsString) |
private void |
ServerPreparedQuery.storeStreamOrReader(int parameterIndex,
NativePacketPayload packet,
java.io.Closeable streamOrReader) |
| 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> |
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 | Field and Description |
|---|---|
private NativePacketPayload |
NativeCapabilities.initialHandshakePacket |
(package private) NativePacketPayload |
SimplePacketReader.lastMessage |
protected NativePacketPayload |
NativeProtocol.reusablePacket
Use this when reading in rows to avoid thousands of new() calls, because the byte arrays just get copied out of the packet anyway
|
protected NativePacketPayload |
NativeProtocol.sharedSendPacket |
| Modifier and Type | Field and Description |
|---|---|
private java.util.Map<java.lang.String,AuthenticationPlugin<NativePacketPayload>> |
NativeAuthenticationProvider.authenticationPlugins
Contains instances of authentication plugins that implements
AuthenticationPlugin interface. |
private java.lang.ref.SoftReference<NativePacketPayload> |
NativeProtocol.loadFileBufRef
Packet used for 'LOAD DATA LOCAL INFILE'
We use a SoftReference, so that we don't penalize intermittent use of this feature
|
private MessageReader<NativePacketHeader,NativePacketPayload> |
TimeTrackingPacketReader.packetReader |
private MessageReader<NativePacketHeader,NativePacketPayload> |
DebugBufferingPacketReader.packetReader |
protected MessageReader<NativePacketHeader,NativePacketPayload> |
NativeProtocol.packetReader |
private MessageReader<NativePacketHeader,NativePacketPayload> |
TracingPacketReader.packetReader |
private MessageReader<NativePacketHeader,NativePacketPayload> |
MultiPacketReader.packetReader |
private MessageSender<NativePacketPayload> |
TimeTrackingPacketSender.packetSender |
private MessageSender<NativePacketPayload> |
TracingPacketSender.packetSender |
protected MessageSender<NativePacketPayload> |
NativeProtocol.packetSender |
private MessageSender<NativePacketPayload> |
DebugBufferingPacketSender.packetSender |
private Protocol<NativePacketPayload> |
NativeAuthenticationProvider.protocol |
private MessageSender<NativePacketPayload> |
CompressedPacketSenderTest.sender |
| Modifier and Type | Method and Description |
|---|---|
NativePacketPayload |
NativeMessageBuilder.buildClose() |
NativePacketPayload |
NativeMessageBuilder.buildComInitDb(NativePacketPayload sharedPacket,
byte[] dbName) |
NativePacketPayload |
NativeMessageBuilder.buildComInitDb(NativePacketPayload sharedPacket,
java.lang.String dbName) |
NativePacketPayload |
NativeMessageBuilder.buildComPing(NativePacketPayload sharedPacket) |
NativePacketPayload |
NativeMessageBuilder.buildComQuery(NativePacketPayload sharedPacket,
byte[] query) |
NativePacketPayload |
NativeMessageBuilder.buildComQuery(NativePacketPayload sharedPacket,
Session sess,
PreparedQuery preparedQuery,
QueryBindings bindings,
java.lang.String characterEncoding) |
NativePacketPayload |
NativeMessageBuilder.buildComQuery(NativePacketPayload sharedPacket,
java.lang.String query) |
NativePacketPayload |
NativeMessageBuilder.buildComQuery(NativePacketPayload sharedPacket,
java.lang.String query,
java.lang.String encoding) |
NativePacketPayload |
NativeMessageBuilder.buildComQuit(NativePacketPayload sharedPacket) |
NativePacketPayload |
NativeMessageBuilder.buildComSetOption(NativePacketPayload sharedPacket,
int val) |
NativePacketPayload |
NativeMessageBuilder.buildComShutdown(NativePacketPayload sharedPacket) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtClose(NativePacketPayload sharedPacket,
long serverStatementId) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtExecute(NativePacketPayload sharedPacket,
long serverStatementId,
byte flags,
boolean sendQueryAttributes,
PreparedQuery preparedQuery) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtFetch(NativePacketPayload sharedPacket,
long serverStatementId,
long numRowsToFetch) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtPrepare(NativePacketPayload sharedPacket,
byte[] query) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtPrepare(NativePacketPayload sharedPacket,
java.lang.String queryString,
java.lang.String characterEncoding) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtReset(NativePacketPayload sharedPacket,
long serverStatementId) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtSendLongData(NativePacketPayload sharedPacket,
long serverStatementId,
int parameterIndex,
byte[] longData) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtSendLongDataHeader(NativePacketPayload sharedPacket,
long serverStatementId,
int parameterIndex) |
NativePacketPayload |
NativeMessageBuilder.buildSqlStatement(java.lang.String statement) |
NativePacketPayload |
NativeMessageBuilder.buildSqlStatement(java.lang.String statement,
java.util.List<java.lang.Object> args) |
NativePacketPayload |
NativeProtocol.checkErrorMessage() |
private NativePacketPayload |
NativeProtocol.checkErrorMessage(int command)
Checks for errors in the reply packet, and if none, returns the reply
packet, ready for reading
|
private NativePacketPayload |
NativeAuthenticationProvider.createChangeUserPacket(ServerSession serverSession,
java.lang.String pluginName,
NativePacketPayload authData) |
private NativePacketPayload |
NativeAuthenticationProvider.createHandshakeResponsePacket(ServerSession serverSession,
java.lang.String pluginName,
NativePacketPayload authData) |
NativePacketPayload |
NativeCapabilities.getInitialHandshakePacket() |
NativePacketPayload |
NativeProtocol.getReusablePacket() |
NativePacketPayload |
NativeProtocol.getSharedSendPacket()
Returns the packet used for sending data (used by PreparedStatement) with position set to 0.
|
NativePacketPayload |
NativeProtocol.probeMessage(NativePacketPayload reuse) |
NativePacketPayload |
TimeTrackingPacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
DebugBufferingPacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
SimplePacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
TracingPacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
MultiPacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
NativeProtocol.readMessage(NativePacketPayload reuse) |
NativePacketPayload |
TimeTrackingPacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
DebugBufferingPacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
SimplePacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
TracingPacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
MultiPacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
private NativePacketPayload |
SimplePacketReader.readMessageLocal(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
NativeProtocol.sendCommand(Message queryPacket,
boolean skipCheck,
int timeoutMillis) |
NativePacketPayload |
NativeProtocol.sendFileToServer(java.lang.String fileName)
Reads and sends a file to the server for LOAD DATA LOCAL INFILE
|
private NativePacketPayload |
TracingPacketReader.traceMessage(NativePacketPayload buf,
int packetLength,
boolean reuse) |
| Modifier and Type | Method and Description |
|---|---|
private void |
NativeAuthenticationProvider.appendConnectionAttributes(NativePacketPayload buf,
java.lang.String attributes,
java.lang.String enc) |
NativePacketPayload |
NativeMessageBuilder.buildComInitDb(NativePacketPayload sharedPacket,
byte[] dbName) |
NativePacketPayload |
NativeMessageBuilder.buildComInitDb(NativePacketPayload sharedPacket,
java.lang.String dbName) |
NativePacketPayload |
NativeMessageBuilder.buildComPing(NativePacketPayload sharedPacket) |
NativePacketPayload |
NativeMessageBuilder.buildComQuery(NativePacketPayload sharedPacket,
byte[] query) |
NativePacketPayload |
NativeMessageBuilder.buildComQuery(NativePacketPayload sharedPacket,
Session sess,
PreparedQuery preparedQuery,
QueryBindings bindings,
java.lang.String characterEncoding) |
NativePacketPayload |
NativeMessageBuilder.buildComQuery(NativePacketPayload sharedPacket,
java.lang.String query) |
NativePacketPayload |
NativeMessageBuilder.buildComQuery(NativePacketPayload sharedPacket,
java.lang.String query,
java.lang.String encoding) |
NativePacketPayload |
NativeMessageBuilder.buildComQuit(NativePacketPayload sharedPacket) |
NativePacketPayload |
NativeMessageBuilder.buildComSetOption(NativePacketPayload sharedPacket,
int val) |
NativePacketPayload |
NativeMessageBuilder.buildComShutdown(NativePacketPayload sharedPacket) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtClose(NativePacketPayload sharedPacket,
long serverStatementId) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtExecute(NativePacketPayload sharedPacket,
long serverStatementId,
byte flags,
boolean sendQueryAttributes,
PreparedQuery preparedQuery) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtFetch(NativePacketPayload sharedPacket,
long serverStatementId,
long numRowsToFetch) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtPrepare(NativePacketPayload sharedPacket,
byte[] query) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtPrepare(NativePacketPayload sharedPacket,
java.lang.String queryString,
java.lang.String characterEncoding) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtReset(NativePacketPayload sharedPacket,
long serverStatementId) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtSendLongData(NativePacketPayload sharedPacket,
long serverStatementId,
int parameterIndex,
byte[] longData) |
NativePacketPayload |
NativeMessageBuilder.buildComStmtSendLongDataHeader(NativePacketPayload sharedPacket,
long serverStatementId,
int parameterIndex) |
void |
NativeProtocol.checkErrorMessage(NativePacketPayload resultPacket) |
private NativePacketPayload |
NativeAuthenticationProvider.createChangeUserPacket(ServerSession serverSession,
java.lang.String pluginName,
NativePacketPayload authData) |
ResultsetRow |
BinaryRowFactory.createFromMessage(NativePacketPayload rowPacket) |
ResultsetRow |
TextRowFactory.createFromMessage(NativePacketPayload rowPacket) |
ColumnDefinition |
ColumnDefinitionFactory.createFromMessage(NativePacketPayload packetPayload) |
private NativePacketPayload |
NativeAuthenticationProvider.createHandshakeResponsePacket(ServerSession serverSession,
java.lang.String pluginName,
NativePacketPayload authData) |
private void |
InputStreamValueEncoder.escapeblockFast(byte[] buf,
NativePacketPayload packet,
int size) |
private void |
BinaryRowFactory.extractNativeEncodedColumn(NativePacketPayload binaryData,
Field[] fields,
int columnIndex,
byte[][] unpackedRowData)
Copy the raw result bytes from the
|
static java.lang.String |
NativePacketPayload.extractSqlFromPacket(java.lang.String possibleSqlQuery,
NativePacketPayload packet,
int endOfQueryPacketPosition,
int maxQuerySizeToLog) |
NativeServerSessionStateController.NativeServerSessionStateChanges |
NativeServerSessionStateController.NativeServerSessionStateChanges.init(NativePacketPayload buf,
java.lang.String encoding) |
NativePacketPayload |
NativeProtocol.probeMessage(NativePacketPayload reuse) |
private void |
NativeAuthenticationProvider.proceedHandshakeWithPluggableAuthentication(NativePacketPayload challenge)
Performs an authentication handshake to authorize connection to a given database as a given MySQL user.
|
<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) |
<T extends Resultset> |
NativeProtocol.readAllResults(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory) |
NativePacketPayload |
NativeProtocol.readMessage(NativePacketPayload reuse) |
<T> T |
NativeProtocol.readServerStatusForResultSets(NativePacketPayload rowPacket,
boolean saveOldStatus) |
void |
NativeProtocol.rejectProtocol(NativePacketPayload msg) |
<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.
|
protected byte[] |
InputStreamValueEncoder.streamToBytes(java.io.InputStream in,
long length,
NativePacketPayload packet) |
private NativePacketPayload |
TracingPacketReader.traceMessage(NativePacketPayload buf,
int packetLength,
boolean reuse) |
private ResultsetRow |
BinaryRowFactory.unpackBinaryResultSetRow(Field[] fields,
NativePacketPayload binaryData)
Un-packs binary-encoded result set data for one row
|
protected Field |
ColumnDefinitionReader.unpackField(NativePacketPayload packet,
java.lang.String characterSetMetadata)
Unpacks the Field information from the given packet.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NativeProtocol.applyPacketDecorators(MessageSender<NativePacketPayload> sender,
MessageReader<NativePacketHeader,NativePacketPayload> messageReader)
Apply optional decorators to configured PacketSender and PacketReader.
|
void |
NativeProtocol.applyPacketDecorators(MessageSender<NativePacketPayload> sender,
MessageReader<NativePacketHeader,NativePacketPayload> messageReader)
Apply optional decorators to configured PacketSender and PacketReader.
|
void |
NativeAuthenticationProvider.init(Protocol<NativePacketPayload> prot,
PropertySet propSet,
ExceptionInterceptor excInterceptor) |
NativePacketPayload |
TimeTrackingPacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
DebugBufferingPacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
SimplePacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
TracingPacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
MultiPacketReader.probeMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
<T extends ProtocolEntity> |
NativeProtocol.read(java.lang.Class<Resultset> requiredClass,
int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> protocolEntityFactory) |
<T extends ProtocolEntity> |
NativeProtocol.read(java.lang.Class<T> requiredClass,
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) |
ColumnDefinition |
ColumnDefinitionReader.read(ProtocolEntityFactory<ColumnDefinition,NativePacketPayload> sf) |
ResultsetRow |
ResultsetRowReader.read(ProtocolEntityFactory<ResultsetRow,NativePacketPayload> sf)
Retrieve one row from the MySQL server.
|
<T extends Resultset> |
NativeProtocol.readAllResults(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory) |
NativePacketPayload |
TimeTrackingPacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
DebugBufferingPacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
SimplePacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
TracingPacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
NativePacketPayload |
MultiPacketReader.readMessage(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
private NativePacketPayload |
SimplePacketReader.readMessageLocal(java.util.Optional<NativePacketPayload> reuse,
NativePacketHeader header) |
<T extends ProtocolEntity> |
NativeProtocol.readNextResultset(T currentProtocolEntity,
int maxRows,
boolean streamResults,
boolean isBinaryEncoded,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory)
Read next result set from multi-result chain.
|
<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.
|
| Constructor and Description |
|---|
NativeCapabilities(NativePacketPayload initialHandshakePacket) |
| Modifier and Type | Field and Description |
|---|---|
private Protocol<NativePacketPayload> |
MysqlNativePasswordPlugin.protocol |
protected Protocol<NativePacketPayload> |
Sha256PasswordPlugin.protocol |
private Protocol<NativePacketPayload> |
MysqlOldPasswordPlugin.protocol |
private Protocol<NativePacketPayload> |
MysqlClearPasswordPlugin.protocol |
| Modifier and Type | Method and Description |
|---|---|
boolean |
AuthenticationFidoClient.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
AuthenticationKerberosClient.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
MysqlNativePasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
Sha256PasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
MysqlOldPasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
CachingSha2PasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
MysqlClearPasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
AuthenticationLdapSaslClientPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
| Modifier and Type | Method and Description |
|---|---|
void |
CachingSha2PasswordPlugin.init(Protocol<NativePacketPayload> prot) |
void |
AuthenticationLdapSaslClientPlugin.init(Protocol<NativePacketPayload> prot) |
void |
AuthenticationFidoClient.init(Protocol<NativePacketPayload> protocol,
MysqlCallbackHandler callbackHandler) |
void |
AuthenticationKerberosClient.init(Protocol<NativePacketPayload> prot,
MysqlCallbackHandler cbh) |
void |
MysqlNativePasswordPlugin.init(Protocol<NativePacketPayload> prot,
MysqlCallbackHandler cbh) |
void |
Sha256PasswordPlugin.init(Protocol<NativePacketPayload> prot,
MysqlCallbackHandler cbh) |
void |
MysqlOldPasswordPlugin.init(Protocol<NativePacketPayload> prot,
MysqlCallbackHandler cbh) |
void |
MysqlClearPasswordPlugin.init(Protocol<NativePacketPayload> prot,
MysqlCallbackHandler cbh) |
void |
AuthenticationLdapSaslClientPlugin.init(Protocol<NativePacketPayload> prot,
MysqlCallbackHandler cbh) |
boolean |
AuthenticationFidoClient.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
AuthenticationKerberosClient.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
MysqlNativePasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
Sha256PasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
MysqlOldPasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
CachingSha2PasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
MysqlClearPasswordPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
AuthenticationLdapSaslClientPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
| Modifier and Type | Field and Description |
|---|---|
protected NativePacketPayload |
AbstractBufferRow.rowFromServer |
| Modifier and Type | Field and Description |
|---|---|
private ProtocolEntityFactory<T,NativePacketPayload> |
ResultsetRowsStreaming.resultSetFactory |
protected ProtocolEntityFactory<ResultsetRow,NativePacketPayload> |
AbstractResultsetRows.rowFactory |
| Modifier and Type | Method and Description |
|---|---|
static OkPacket |
OkPacket.parse(NativePacketPayload buf,
java.lang.String errorMessageEncoding) |
| Constructor and Description |
|---|
BinaryBufferRow(NativePacketPayload buf,
ColumnDefinition cd,
ExceptionInterceptor exceptionInterceptor,
ValueDecoder valueDecoder) |
TextBufferRow(NativePacketPayload buf,
ColumnDefinition cd,
ExceptionInterceptor exceptionInterceptor,
ValueDecoder valueDecoder) |
| Constructor and Description |
|---|
ResultsetRowsStreaming(NativeProtocol io,
ColumnDefinition columnDefinition,
boolean isBinaryEncoded,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory)
Creates a new RowDataDynamic object.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ConnectionRegressionTest.AuthTestPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
ConnectionRegressionTest.TwoQuestionsPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
ConnectionRegressionTest.ThreeAttemptsPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ConnectionRegressionTest.AuthTestPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
ConnectionRegressionTest.TwoQuestionsPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
boolean |
ConnectionRegressionTest.ThreeAttemptsPlugin.nextAuthenticationStep(NativePacketPayload fromServer,
java.util.List<NativePacketPayload> toServer) |
| Modifier and Type | Method and Description |
|---|---|
private void |
AuthenticationTest.overrideSaslClientData(AuthenticationPlugin<NativePacketPayload> authPlugin,
java.lang.String nonce)
Overrides the random parts of the SCRAM-SHA-1 or SCRAM-SHA-256 authentication elements (
cnonce and clientFirstMessageBare) with
the given values from the official test vector specified in RFC 5802, Section 5 and RFC 7677, Section 3. |