public class AsyncMultiRead extends java.lang.Object implements java.util.concurrent.Callable<AsyncMultiReadResult>
Modifier and Type | Field and Description |
---|---|
private AsyncMultiReadResult |
asyncMultiReadResult |
private AbstractMultiSend |
bulkSend |
private ComStmtPrepare |
comStmtPrepare |
private int |
paramCount |
private java.util.List<ParameterHolder[]> |
parametersList |
private Protocol |
protocol |
private java.util.List<java.lang.String> |
queries |
private boolean |
readPrepareStmtResult |
private Results |
results |
private int |
sendCmdInitialCounter |
private BulkStatus |
status |
Constructor and Description |
---|
AsyncMultiRead(ComStmtPrepare comStmtPrepare,
BulkStatus status,
Protocol protocol,
boolean readPrepareStmtResult,
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".
|
Modifier and Type | Method and Description |
---|---|
AsyncMultiReadResult |
call() |
private final ComStmtPrepare comStmtPrepare
private final BulkStatus status
private final int sendCmdInitialCounter
private final Protocol protocol
private final boolean readPrepareStmtResult
private final AbstractMultiSend bulkSend
private final java.util.List<ParameterHolder[]> parametersList
private final java.util.List<java.lang.String> queries
private final Results results
private final int paramCount
private final AsyncMultiReadResult asyncMultiReadResult
public AsyncMultiRead(ComStmtPrepare comStmtPrepare, BulkStatus status, Protocol protocol, boolean readPrepareStmtResult, AbstractMultiSend bulkSend, int paramCount, Results results, java.util.List<ParameterHolder[]> parametersList, java.util.List<java.lang.String> queries, PrepareResult prepareResult)
comStmtPrepare
- current preparestatus
- bulk statusprotocol
- protocolreadPrepareStmtResult
- must read prepare statement resultbulkSend
- bulk sender objectparamCount
- number of parametersresults
- execution resultparametersList
- parameter listqueries
- queriesprepareResult
- prepare resultpublic AsyncMultiReadResult call() throws java.lang.Exception
call
in interface java.util.concurrent.Callable<AsyncMultiReadResult>
java.lang.Exception