org.mariadb.jdbc.internal.protocol

Class AsyncMultiRead

java.lang.Object

org.mariadb.jdbc.internal.protocol.AsyncMultiRead

All Implemented Interfaces:

java.util.concurrent.Callable<AsyncMultiReadResult>

public class AsyncMultiRead
extends java.lang.Object
implements java.util.concurrent.Callable<AsyncMultiReadResult>

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncMultiReadResult	asyncMultiReadResult
private AbstractMultiSend	bulkSend
private int	paramCount
private java.util.List<ParameterHolder[]>	parametersList
private Protocol	protocol
private java.util.List<java.lang.String>	queries
private Results	results
private int	sendCmdInitialCounter
private BulkStatus	status

Constructor Summary

Constructors

Constructor and Description
AsyncMultiRead(BulkStatus status, Protocol protocol, AbstractMultiSend bulkSend, int paramCount, Results results, java.util.List<ParameterHolder[]> parametersList, java.util.List<java.lang.String> queries, PrepareResult prepareResult) Read results async to avoid local and remote networking stack buffer overflow "lock".

Method Summary

Modifier and Type	Method and Description
AsyncMultiReadResult	call()

Methods inherited from class java.lang.Object

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

Field Detail

status

private final BulkStatus status

sendCmdInitialCounter

private final int sendCmdInitialCounter

protocol

private final Protocol protocol

bulkSend

private final AbstractMultiSend bulkSend

parametersList

private final java.util.List<ParameterHolder[]> parametersList

queries

private final java.util.List<java.lang.String> queries

results

private final Results results

paramCount

private final int paramCount

asyncMultiReadResult

private final AsyncMultiReadResult asyncMultiReadResult

Constructor Detail

AsyncMultiRead

public AsyncMultiRead(BulkStatus status,
                      Protocol protocol,
                      AbstractMultiSend bulkSend,
                      int paramCount,
                      Results results,
                      java.util.List<ParameterHolder[]> parametersList,
                      java.util.List<java.lang.String> queries,
                      PrepareResult prepareResult)

Read results async to avoid local and remote networking stack buffer overflow "lock".

Parameters:

status - bulk status

protocol - protocol

bulkSend - bulk sender object

paramCount - number of parameters

results - execution result

parametersList - parameter list

queries - queries

prepareResult - prepare result

Method Detail

call

public AsyncMultiReadResult call()
                          throws java.lang.Exception

Specified by:

call in interface java.util.concurrent.Callable<AsyncMultiReadResult>

Throws:

java.lang.Exception