io.vertx.db2client.impl.drda

Class DRDAQueryRequest

java.lang.Object

io.vertx.db2client.impl.drda.DRDARequest

io.vertx.db2client.impl.drda.DRDAConnectRequest

io.vertx.db2client.impl.drda.DRDAQueryRequest

public class DRDAQueryRequest
extends DRDAConnectRequest

Field Summary

Fields

Modifier and Type	Field and Description
static int	defaultFetchSize

Fields inherited from class io.vertx.db2client.impl.drda.DRDARequest

DB2_DRDA_CLIENT_ID, DB2_DRDA_SERVER_ID, metadata

Constructor Summary

Constructors

Constructor and Description
DRDAQueryRequest(io.netty.buffer.ByteBuf buffer, ConnectionMetaData metadata)

Method Summary

Modifier and Type	Method and Description
void	buildCLSQRY(Section section, String dbName, long queryInstanceIdentifier)
protected void	buildSQLATTRcommandData(String sql)
protected void	buildSQLSTTcommandData(String sql)
static boolean	isQuery(String sql)
protected void	markForCachingPKGNAMCSN()
protected int	popMarkForCachingPKGNAMCSN()
void	writeDescribeInput(Section section, String dbName)
void	writeExecute(Section section, String dbName, ColumnMetaData parameterMetaData, Object[] inputs, boolean outputExpected, boolean chained)
void	writeExecuteImmediate(String sql, Section section, String dbName)
void	writeFetch(Section section, String dbName, int fetchSize, long queryId)
void	writeOpenQuery(Section section, String dbName, int fetchSize, int resultSetType)
void	writeOpenQuery(Section section, String dbName, int fetchSize, int resultSetType, ColumnMetaData parameterMetaData, Object[] inputs)
void	writePrepareDescribeOutput(String sql, String dbName, Section section)

Methods inherited from class io.vertx.db2client.impl.drda.DRDAConnectRequest

buildACCRDB, buildACCSEC, buildEXCSAT, buildRDBCMM, buildSECCHK, getCorrelationToken

Methods inherited from class io.vertx.db2client.impl.drda.DRDARequest

completeCommand, createCommand, markLengthBytes, updateLengthBytes

Methods inherited from class java.lang.Object

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

Field Detail

defaultFetchSize

public static final int defaultFetchSize

See Also:

Constant Field Values

Constructor Detail

DRDAQueryRequest

public DRDAQueryRequest(io.netty.buffer.ByteBuf buffer,
                        ConnectionMetaData metadata)

Method Detail

isQuery

public static boolean isQuery(String sql)

Returns:

True if the SQL is a query (e.g. SELECT or WITH), false otherwise

Throws:

IllegalArgumentException - if the passed in SQL value is null

writePrepareDescribeOutput

public void writePrepareDescribeOutput(String sql,
                                       String dbName,
                                       Section section)

writeDescribeInput

public void writeDescribeInput(Section section,
                               String dbName)

writeOpenQuery

public void writeOpenQuery(Section section,
                           String dbName,
                           int fetchSize,
                           int resultSetType,
                           ColumnMetaData parameterMetaData,
                           Object[] inputs)

writeFetch

public void writeFetch(Section section,
                       String dbName,
                       int fetchSize,
                       long queryId)

writeOpenQuery

public void writeOpenQuery(Section section,
                           String dbName,
                           int fetchSize,
                           int resultSetType)

writeExecute

public void writeExecute(Section section,
                         String dbName,
                         ColumnMetaData parameterMetaData,
                         Object[] inputs,
                         boolean outputExpected,
                         boolean chained)

writeExecuteImmediate

public void writeExecuteImmediate(String sql,
                                  Section section,
                                  String dbName)

buildCLSQRY

public void buildCLSQRY(Section section,
                        String dbName,
                        long queryInstanceIdentifier)

buildSQLSTTcommandData

protected void buildSQLSTTcommandData(String sql)

buildSQLATTRcommandData

protected void buildSQLATTRcommandData(String sql)

markForCachingPKGNAMCSN

protected final void markForCachingPKGNAMCSN()

popMarkForCachingPKGNAMCSN

protected final int popMarkForCachingPKGNAMCSN()