com.oceanbase.jdbc.internal.com.send

类 ComStmtPrepareExecute

java.lang.Object

com.oceanbase.jdbc.internal.com.send.ComStmtPrepareExecute

public class ComStmtPrepareExecute
extends Object

构造器概要

构造器

构造器和说明
ComStmtPrepareExecute()

方法概要

限定符和类型	方法和说明
static ServerPrepareResult	read(Protocol protocol, PacketInputStream reader, ServerPrepareResult serverPrepareResult, Results results)
static void	readTailPacket(Protocol protocol, PacketInputStream reader, Results results, boolean hasResultSet)
static void	send(PacketOutputStream pos, Results results, int parameterCount, ParameterHolder[] parameters, ColumnType[] parameterTypeHeader, byte cursorFlag, Protocol protocol, ServerPrepareResult serverPrepareResult) Send a prepare statement binary stream.
static void	sendArrayBinding(PacketOutputStream pos, int statementId, List<ParameterHolder[]> queryParameters, int queryParamtersSize, int parameterCount, ColumnType[] parameterTypeHeader, byte cursorFlag, Protocol protocol, Results results, ServerPrepareResult serverPrepareResult)

从类继承的方法 java.lang.Object

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

构造器详细资料

ComStmtPrepareExecute

public ComStmtPrepareExecute()

方法详细资料

send

public static void send(PacketOutputStream pos,
                        Results results,
                        int parameterCount,
                        ParameterHolder[] parameters,
                        ColumnType[] parameterTypeHeader,
                        byte cursorFlag,
                        Protocol protocol,
                        ServerPrepareResult serverPrepareResult)
                 throws IOException,
                        SQLException

Send a prepare statement binary stream.

参数:

pos - database socket

results - prepareResult object received after preparation.

parameterCount - parameters number

parameterTypeHeader - parameters header received from last response

cursorFlag - cursor flag. Possible values :

1. CURSOR_TYPE_NO_CURSOR = fetch all
2. CURSOR_TYPE_READ_ONLY = fetch by bunch
3. CURSOR_TYPE_FOR_UPDATE = fetch by bunch with lock ?
4. CURSOR_TYPE_SCROLLABLE = //reserved, but not working

抛出:

IOException - if a connection error occur

SQLException

read

public static ServerPrepareResult read(Protocol protocol,
                                       PacketInputStream reader,
                                       ServerPrepareResult serverPrepareResult,
                                       Results results)
                                throws IOException,
                                       SQLException

抛出:

IOException

SQLException

readTailPacket

public static void readTailPacket(Protocol protocol,
                                  PacketInputStream reader,
                                  Results results,
                                  boolean hasResultSet)
                           throws IOException,
                                  SQLException

抛出:

IOException

SQLException

sendArrayBinding

public static void sendArrayBinding(PacketOutputStream pos,
                                    int statementId,
                                    List<ParameterHolder[]> queryParameters,
                                    int queryParamtersSize,
                                    int parameterCount,
                                    ColumnType[] parameterTypeHeader,
                                    byte cursorFlag,
                                    Protocol protocol,
                                    Results results,
                                    ServerPrepareResult serverPrepareResult)
                             throws IOException,
                                    SQLException

抛出:

IOException

SQLException