com.oceanbase.jdbc.internal.com.send

类 ComStmtExecute

java.lang.Object

com.oceanbase.jdbc.internal.com.send.ComStmtExecute

public class ComStmtExecute
extends Object

构造器概要

构造器

构造器和说明
ComStmtExecute()

方法概要

限定符和类型	方法和说明
static void	send(PacketOutputStream pos, int statementId, ParameterHolder[] parameters, int parameterCount, ColumnType[] parameterTypeHeader, byte cursorFlag, Protocol protocol) 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)
static void	writeCmdArrayBinding(int statementId, List<ParameterHolder[]> queryParameters, int queryParamtersSize, int parameterCount, ColumnType[] parameterTypeHeader, PacketOutputStream pos, byte cursorFlag, Protocol protocol)

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

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

构造器详细资料

ComStmtExecute

public ComStmtExecute()

方法详细资料

send

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

Send a prepare statement binary stream.

参数:

pos - database socket

statementId - prepareResult object received after preparation.

parameters - parameters

parameterCount - parameters number

parameterTypeHeader - parameters header

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

writeCmdArrayBinding

public static void writeCmdArrayBinding(int statementId,
                                        List<ParameterHolder[]> queryParameters,
                                        int queryParamtersSize,
                                        int parameterCount,
                                        ColumnType[] parameterTypeHeader,
                                        PacketOutputStream pos,
                                        byte cursorFlag,
                                        Protocol protocol)
                                 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)
                             throws IOException,
                                    SQLException

抛出:

IOException

SQLException