Package org.mariadb.jdbc.internal.protocol

Class AsyncMultiRead

java.lang.Object

org.mariadb.jdbc.internal.protocol.AsyncMultiRead

All Implemented Interfaces:

Callable<AsyncMultiReadResult>

public class AsyncMultiRead
extends Object
implements Callable<AsyncMultiReadResult>

Field Summary

Fields

Modifier and Type	Field	Description
private final AsyncMultiReadResult	asyncMultiReadResult
private final AbstractMultiSend	bulkSend
private final ComStmtPrepare	comStmtPrepare
private final int	paramCount
private final List<ParameterHolder[]>	parametersList
private final Protocol	protocol
private final List<String>	queries
private final boolean	readPrepareStmtResult
private final Results	results
private final int	sendCmdInitialCounter
private final BulkStatus	status

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
AsyncMultiReadResult	call()

Methods inherited from class java.lang.Object

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

Field Details

comStmtPrepare

private final ComStmtPrepare comStmtPrepare

status

private final BulkStatus status

sendCmdInitialCounter

private final int sendCmdInitialCounter

protocol

private final Protocol protocol

readPrepareStmtResult

private final boolean readPrepareStmtResult

bulkSend

private final AbstractMultiSend bulkSend

parametersList

private final List<ParameterHolder[]> parametersList

queries

private final List<String> queries

results

private final Results results

paramCount

private final int paramCount

asyncMultiReadResult

private final AsyncMultiReadResult asyncMultiReadResult

Constructor Details

AsyncMultiRead

public AsyncMultiRead(ComStmtPrepare comStmtPrepare,
 BulkStatus status,
 Protocol protocol,
 boolean readPrepareStmtResult,
 AbstractMultiSend bulkSend,
 int paramCount,
 Results results,
 List<ParameterHolder[]> parametersList,
 List<String> queries,
 PrepareResult prepareResult)

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

Parameters:

comStmtPrepare - current prepare

status - bulk status

protocol - protocol

readPrepareStmtResult - must read prepare statement result

bulkSend - bulk sender object

paramCount - number of parameters

results - execution result

parametersList - parameter list

queries - queries

prepareResult - prepare result

Method Details

call

public AsyncMultiReadResult call()
                          throws Exception

Specified by:

call in interface Callable<AsyncMultiReadResult>

Throws:

Exception