| Modifier and Type | Method and Description |
|---|---|
void |
ClientPooledConnection.informListeners(SqlException exception)
Inform listeners that an error has occured on the connection, if the
error severity is high enough.
|
| Modifier and Type | Method and Description |
|---|---|
ClientXADataSource |
ClientXAConnection.getDataSource() |
protected NetXAConnection |
ClientPooledConnection.getNetXAConnection(ClientBaseDataSource ds,
NetLogWriter logWriter,
String user,
String password,
int rmId)
creates and returns NetXAConnection.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DisconnectException |
class |
SqlWarning
This represents a warning versus a full exception.
|
| Modifier and Type | Field and Description |
|---|---|
SqlException |
Agent.accumulatedReadExceptions_ |
static SqlException |
Configuration.exceptionsOnLoadResources |
protected SqlException |
SqlException.nextException_ |
| Modifier and Type | Method and Description |
|---|---|
static SqlException |
Utils.accumulateSQLException(SqlException latestException,
SqlException accumulatedExceptions) |
SqlException |
SqlException.getNextException() |
static SqlException |
SqlException.javaException(LogWriter logWriter,
Throwable e)
Helper method to construct an exception which basically says that
we encountered an underlying Java exception
|
| Modifier and Type | Method and Description |
|---|---|
void |
Agent.accumulateDeferredException(SqlException e) |
void |
Agent.accumulateReadException(SqlException e) |
static SqlException |
Utils.accumulateSQLException(SqlException latestException,
SqlException accumulatedExceptions) |
void |
Agent.endBatchedReadChain(int[] updateCounts,
SqlException accumulatedExceptions) |
abstract Set |
Connection.handleFailover(Set failedUrls,
SqlException ex) |
static void |
ExceptionFormatter.printTrace(SqlException e,
PrintWriter printWriter,
String messageHeader,
boolean returnTokensOnly) |
void |
SqlException.setNextException(SqlException nextException) |
void |
LogWriter.traceDiagnosable(SqlException e) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ResultSet.absoluteX(int row) |
protected abstract boolean |
Connection.allowLocalCommitRollback_() |
protected void |
Agent.beginBatchedReadChain(Statement statement,
int batchSize) |
void |
Agent.beginBatchedWriteChain(Statement statement) |
protected void |
Agent.beginReadChain(Statement statement) |
protected void |
Agent.beginReadChainOutsideUOW() |
void |
Agent.beginWriteChain(Statement statement) |
void |
Agent.beginWriteChainOutsideUOW() |
static int |
Decimal.bigDecimalToPackedDecimalBytes(byte[] buffer,
int offset,
BigDecimal b,
int declaredPrecision,
int declaredScale,
String columnName)
Write a Java
java.math.BigDecimal to packed decimal bytes. |
protected abstract boolean |
Cursor.calculateColumnOffsetsForRow_(int row,
boolean allowServerFetch)
Calculate the column offsets for a row.
|
protected void |
ResultSet.checkAndThrowReceivedQueryTerminatingException() |
abstract void |
Agent.checkForChainBreakingException_() |
protected void |
Connection.checkForClosedConnection() |
protected void |
ResultSet.checkForClosedResultSet() |
protected void |
Statement.checkForDuplicateCursorName() |
protected void |
Agent.checkForExceptions() |
static void |
Utils.checkForNegativePositiveSqlcard(Sqlca sqlca,
ResultSet resultSet) |
static void |
Utils.checkForNegativePositiveSqlcard(Sqlca sqlca,
Statement statement) |
protected void |
Statement.checkForStoredProcResultSetCount(int executeType)
Checks that a stored procedure returns the correct number of
result sets given its execute type.
|
protected void |
DatabaseMetaData.checkServerJdbcVersionX(String method,
int major,
int minor)
Checks whether the server supports a JDBC version.
|
protected void |
SingleHopPreparedStatement.cleanSingleHopPrepStmnt() |
protected void |
Statement.cleanSingleHopPrepStmnt() |
void |
Connection.clearWarningsX() |
abstract void |
Agent.close_() |
void |
Agent.close() |
void |
Connection.closeForReuse(boolean statementPooling) |
void |
LogicalConnection.closeWithoutRecyclingToPool() |
void |
ResultSet.closeX() |
void |
Statement.closeX()
An untraced version of
close. |
void |
Connection.completeConnect() |
protected void |
Connection.completeReset(boolean isDeferredReset,
boolean closeStatementsOnClose,
boolean fullReset) |
protected void |
Connection.completeReset(boolean isDeferredReset,
boolean closeStatementsOnClose,
NetXAResource xares)
NOTE:The following comments are valid for the changes done as part of implementing statement caching only (see DERBY-3313 and linked issues). |
void |
Clob.convertFromAsciiToCharacterStream() |
protected Clob |
Clob.createClobWrapper(Clob clob,
String columnName) |
static int |
DateTime.dateToDateBytes(byte[] buffer,
int offset,
Date date,
Calendar cal)
Date is converted to a char representation in JDBC date format:
yyyy-mm-dd date format
and then converted to bytes using UTF8 encoding |
static int |
DateTime.dateToTimestampBytes(byte[] buffer,
int offset,
Date date,
Calendar cal)
java.sql.Date is converted to character representation that is in DERBY string
representation of a timestamp:
yyyy-mm-dd-hh.mm.ss.ffffff and then
converted to bytes using UTF8 encoding and written out to the buffer |
byte[] |
EncryptionManager.decryptData(byte[] cipherText,
int securityMechanism,
byte[] initVector,
byte[] targetPublicKey) |
protected void |
ResultSet.delete() |
byte[] |
EncryptionManager.encryptData(byte[] plainText,
int securityMechanism,
byte[] initVector,
byte[] targetPublicKey) |
void |
Agent.endReadChain() |
int[] |
PreparedStatement.executeBatchX(boolean supportsQueryBatchRequest,
int currExecSeq) |
void |
Agent.flow(Statement statement) |
boolean |
Connection.flowAutoCommit() |
void |
Agent.flowBatch(Statement statement,
int batchSize) |
void |
Connection.flowCommit() |
protected void |
SingleHopPreparedStatement.flowExecute(int executeType,
int currExecSeq) |
protected void |
PreparedStatement.flowExecute(int executeType,
int currExecSeq) |
protected void |
PreparedStatement.flowExecuteRead(int executeType,
com.pivotal.gemfirexd.internal.client.am.PreparedStatement.FlowExecuteContext ctx) |
protected com.pivotal.gemfirexd.internal.client.am.PreparedStatement.FlowExecuteContext |
PreparedStatement.flowExecuteWrite(int executeType,
int currExecSeq) |
void |
ResultSet.flowFetch() |
void |
Agent.flowOutsideUOW() |
protected void |
Connection.flowRollback() |
Array |
Cursor.getArray(int column) |
InputStream |
Cursor.getAsciiStream(int column) |
InputStream |
Cursor.getBinaryStream(int column) |
Blob |
Cursor.getBlob(int column) |
abstract Blob |
Cursor.getBlobColumn_(int column,
Agent agent,
boolean toBePublished)
Returns a
Blob object. |
Reader |
Cursor.getCharacterStream(int column) |
Clob |
Cursor.getClob(int column) |
abstract byte[] |
Cursor.getClobBytes_(int column,
int[] dataOffset) |
abstract Clob |
Cursor.getClobColumn_(int column,
Agent agent,
boolean toBePublished)
Returns a
Clob object. |
protected abstract String |
Cursor.getColumnLabel(int column) |
String |
ColumnMetaData.getColumnLabelX(int column) |
Section |
SectionManager.getDynamicSection(int resultSetHoldability) |
protected abstract void |
Cursor.getMoreData_() |
Object |
Cursor.getObject(int column) |
Section |
Section.getPositionedUpdateSection() |
static PrintWriter |
LogWriter.getPrintWriter(String fileName,
boolean fileAppend) |
Ref |
Cursor.getRef(int column) |
protected void |
ResultSet.getRowCount() |
protected Section |
SectionManager.getSection(Stack freeSections,
String packageName,
String cursorNamePrefix,
int resultSetHoldability) |
InputStream |
Cursor.getUnicodeStream(int column) |
abstract String |
DatabaseMetaData.getURL_() |
int |
Clob.getUTF8Length() |
abstract Set |
Connection.handleFailover(Set failedUrls,
SqlException ex) |
protected void |
Connection.initConnection(LogWriter logWriter,
String password,
ClientBaseDataSource dataSource) |
protected void |
ResultSet.insert() |
void |
Connection.lightReset() |
protected abstract void |
Lob.materializeStream()
Method to be implemented by subclasses, so that
#materializedStream(InputStream, String) can be called with subclass
specific parameters and the result assigned to the right stream.
|
protected void |
Blob.materializeStream()
Materialize the stream used for input to the database.
|
protected void |
Clob.materializeStream()
Materialize the stream used for input to the database.
|
protected InputStream |
Lob.materializeStream(InputStream is,
String typeDesc)
Materialize the given stream into memory and update the internal
length variable.
|
String |
Connection.nativeSQLX(String sql) |
protected abstract Agent |
Connection.newAgent_(LogWriter logWriter,
int loginTimeout,
String serverName,
int portNumber,
int clientSSLMode,
Properties properties) |
LogicalConnection |
ClientJDBCObjectFactory.newCachingLogicalConnection(Connection physicalConnection,
ClientPooledConnection pooledConnection,
JDBCStatementCache stmtCache)
Returns an instance of a
CachingLogicalConnection, which
provides caching of prepared statements. |
protected abstract CallableStatement |
Connection.newCallableStatement_(String sql,
int type,
int concurrency,
int holdability) |
CallableStatement |
ClientJDBCObjectFactory.newCallableStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
ClientPooledConnection cpc)
Returns an instance of com.pivotal.gemfirexd.internal.client.am.CallableStatement.
|
LogicalConnection |
ClientJDBCObjectFactory.newLogicalConnection(Connection physicalConnection,
ClientPooledConnection pooledConnection)
Returns an instance of LogicalConnection.
|
Connection |
ClientJDBCObjectFactory.newNetConnection(LogWriter netLogWriter,
ClientBaseDataSource clientDataSource,
String user,
String password)
This method returns an instance of NetConnection (or NetConnection40) class
which extends from com.pivotal.gemfirexd.internal.client.am.Connection
this implements the java.sql.Connection interface
|
Connection |
ClientJDBCObjectFactory.newNetConnection(LogWriter netLogWriter,
int driverManagerLoginTimeout,
String serverName,
int portNumber,
String databaseName,
Properties properties)
This method returns an instance of NetConnection (or NetConnection40)
class which extends from com.pivotal.gemfirexd.internal.client.am.Connection
this implements the java.sql.Connection interface
|
Connection |
ClientJDBCObjectFactory.newNetConnection(LogWriter netLogWriter,
String ipaddr,
int portNumber,
ClientBaseDataSource dataSource,
boolean isXAConn)
This methos returns an instance of NetConnection
(or NetConnection40) class which extends from
com.pivotal.gemfirexd.internal.client.am.Connection this implements the
java.sql.Connection interface
|
Connection |
ClientJDBCObjectFactory.newNetConnection(LogWriter netLogWriter,
String databaseName,
Properties properties)
This method returns an instance of NetConnection (or NetConnection40) class
which extends from com.pivotal.gemfirexd.internal.client.am.Connection
this implements the java.sql.Connection interface
|
Connection |
ClientJDBCObjectFactory.newNetConnection(LogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn)
This method returns an instance of NetConnection (or NetConnection40)
class which extends from com.pivotal.gemfirexd.internal.client.am.Connection
this implements the java.sql.Connection interface
|
Connection |
ClientJDBCObjectFactory.newNetConnection(LogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn,
ClientPooledConnection cpc)
This method returns an instance of NetConnection (or NetConnection40)
class which extends from com.pivotal.gemfirexd.internal.client.am.Connection
this implements the java.sql.Connection interface
This method is used to pass the ClientPooledConnection
object to the NetConnection object which can then be used to pass the
statement events back to the user
|
ResultSet |
ClientJDBCObjectFactory.newNetResultSet(Agent netAgent,
MaterialStatement netStatement,
Cursor cursor,
int qryprctyp,
int sqlcsrhld,
int qryattscr,
int qryattsns,
int qryattset,
long qryinsid,
int actualResultSetType,
int actualResultSetConcurrency,
int actualResultSetHoldability)
This method returns an instance of NetResultSet(or NetResultSet40)
which extends from com.pivotal.gemfirexd.internal.client.am.ResultSet
which implements java.sql.ResultSet
|
protected abstract PreparedStatement |
Connection.newPositionedUpdatePreparedStatement_(String sql,
Section section) |
protected abstract PreparedStatement |
Connection.newPreparedStatement_(String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes) |
PreparedStatement |
ClientJDBCObjectFactory.newPreparedStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes,
ClientPooledConnection cpc)
Returns an instance of PreparedStatement
(or PreparedStatement40) which implements java.sql.PreparedStatement
It has the ClientPooledConnection as one of its parameters
this is used to raise the Statement Events when the prepared
statement is closed
|
PreparedStatement |
ClientJDBCObjectFactory.newPreparedStatement(Agent agent,
Connection connection,
String sql,
Section section,
ClientPooledConnection cpc)
This method returns an instance of PreparedStatement
(or PreparedStatement40) which implements java.sql.PreparedStatement
It has the ClientPooledConnection as one of its parameters
this is used to raise the Statement Events when the prepared
statement is closed
|
protected abstract Statement |
Connection.newStatement_(int type,
int concurrency,
int holdability) |
Statement |
ClientJDBCObjectFactory.newStatement(Agent agent,
Connection connection)
This method provides an instance of Statement or Statement40
depending on the jdk version under use
|
Statement |
ClientJDBCObjectFactory.newStatement(Agent agent,
Connection connection,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes)
This method provides an instance of Statement or Statement40
depending on the jdk version under use
|
boolean |
Cursor.next()
Makes the next row the current row.
|
protected abstract void |
ResultSet.parseRowset_() |
void |
ResultSet.parseScrollableRowset() |
protected void |
ResultSet.positionToCurrentRowAndDelete() |
protected void |
ResultSet.positionToCurrentRowAndUpdate() |
protected abstract void |
Connection.preAgentInitialize(String password,
ClientBaseDataSource dataSource,
Properties properties) |
protected abstract void |
ResultSet.preClose_()
Method that is invoked by
closeX() before the
result set is actually being closed. |
CallableStatement |
Connection.prepareMessageProc(String sql) |
PreparedStatement |
LogicalConnection.preparePositionedUpdateStatement(String sql,
Section querySection) |
PreparedStatement |
Connection.preparePositionedUpdateStatement(String sql,
Section querySection) |
void |
Connection.readCommit() |
abstract void |
Connection.readCommitSubstitute_() |
abstract void |
ResultSet.readCursorClose_() |
void |
ResultSet.readDeleteRow() |
void |
MaterialPreparedStatement.readDescribeInput_() |
void |
PreparedStatement.readDescribeInput() |
void |
MaterialPreparedStatement.readDescribeOutput_() |
void |
PreparedStatement.readDescribeOutput() |
void |
MaterialPreparedStatement.readExecute_() |
void |
PreparedStatement.readExecute() |
void |
MaterialStatement.readExecuteCall_() |
void |
Statement.readExecuteCall() |
void |
MaterialStatement.readExecuteImmediate_() |
void |
Statement.readExecuteImmediate() |
void |
MaterialStatement.readExecuteImmediateForBatch_(String sql) |
void |
Statement.readExecuteImmediateForBatch(String sql) |
abstract void |
ResultSet.readFetch_() |
void |
ResultSet.readInsertRow() |
abstract void |
Connection.readLocalCommit_() |
abstract void |
Connection.readLocalRollback_() |
abstract void |
Connection.readLocalXACommit_() |
abstract void |
Connection.readLocalXARollback_() |
abstract void |
Connection.readLocalXAStart_() |
void |
MaterialStatement.readOpenQuery_() |
void |
Statement.readOpenQuery() |
abstract void |
ResultSet.readPositioningFetch_() |
void |
MaterialStatement.readPrepare_() |
void |
Statement.readPrepare() |
void |
MaterialStatement.readPrepareDescribeOutput_() |
void |
Statement.readPrepareDescribeOutput() |
void |
Connection.readRollback() |
abstract void |
ResultSet.readScrollableFetch_() |
void |
MaterialStatement.readSetSpecialRegister_() |
void |
Statement.readSetSpecialRegister() |
void |
MaterialStatement.readStatementID_() |
void |
Statement.readStatementID() |
void |
Connection.readTransactionStart() |
void |
ResultSet.readUpdateRow() |
protected abstract void |
Connection.readXACommit_() |
protected abstract void |
Connection.readXARollback_() |
protected InputStream |
UpdateSensitiveClobLocatorInputStream.reCreateStream()
Re-creates the underlying Locator stream
with the current position and the length
values if specified.
|
protected Reader |
UpdateSensitiveClobLocatorReader.reCreateStream()
Re-creates the underlying Locator stream
with the current position and the length
values if specified.
|
protected abstract InputStream |
UpdateSensitiveLOBLocatorInputStream.reCreateStream()
Abstract method that will be implemented by
the underlying streams specific to Clob and
Blob.
|
protected InputStream |
UpdateSensitiveBlobLocatorInputStream.reCreateStream()
Re-creates the underlying Locator stream
with the current position and the length
values if specified.
|
boolean |
ResultSet.repositionScrollableResultSetBeforeJDBC1PositionedUpdateDelete() |
protected abstract void |
Connection.reset_(LogWriter logWriter) |
void |
CallableStatement.reset(boolean fullReset) |
void |
Statement.reset(boolean fullReset) |
void |
PreparedStatement.reset(boolean fullReset) |
void |
Connection.reset(LogWriter logWriter) |
protected abstract void |
Agent.resetAgent_(LogWriter logWriter,
int loginTimeout,
String server,
int port) |
void |
Agent.resetAgent(Connection connection,
LogWriter logWriter,
int loginTimeout,
String server,
int port) |
protected abstract void |
Connection.resetCallableStatement_(CallableStatement cs,
String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
void |
CallableStatement.resetCallableStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability) |
void |
CallableStatement.resetCallableStatement(Agent agent,
Connection connection,
String sql,
Section section) |
void |
CallableStatement.resetCallableStatement(Agent agent,
Connection connection,
String sql,
Section section,
ColumnMetaData parameterMetaData,
ColumnMetaData resultSetMetaData) |
protected void |
Connection.resetConnection(LogWriter logWriter) |
protected void |
Connection.resetPrepareCall(CallableStatement cs) |
protected abstract void |
Connection.resetPreparedStatement_(PreparedStatement ps,
String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes) |
void |
PreparedStatement.resetPreparedStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes) |
void |
PreparedStatement.resetPreparedStatement(Agent agent,
Connection connection,
String sql,
Section section) |
void |
PreparedStatement.resetPreparedStatement(Agent agent,
Connection connection,
String sql,
Section section,
ColumnMetaData parameterMetaData,
ColumnMetaData resultSetMetaData) |
protected void |
Connection.resetPrepareStatement(PreparedStatement ps) |
protected abstract void |
Connection.resetStatement_(Statement statement,
int type,
int concurrency,
int holdability) |
void |
Statement.resetStatement(Agent agent,
Connection connection) |
void |
Statement.resetStatement(Agent agent,
Connection connection,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes) |
protected void |
Connection.resetStatement(Statement s) |
void |
Statement.resultSetCommitting(ResultSet closingRS)
Convenience method for resultSetCommitting(ResultSet, boolean)
|
boolean |
Statement.resultSetCommitting(ResultSet closingRS,
boolean writeChain)
Method that checks to see if any other ResultSets are open.
|
protected void |
Connection.setAutoCommitX(boolean autoCommit) |
protected void |
PreparedStatement.setBinaryStreamX(int parameterIndex,
InputStream x,
int length) |
void |
PreparedStatement.setBlobX(int parameterIndex,
Blob x) |
void |
PreparedStatement.setBytesX(int parameterIndex,
byte[] x) |
int |
Blob.setBytesX(long pos,
byte[] bytes,
int offset,
int len) |
protected void |
Connection.setCurrentSchema() |
Object |
CrossConverters.setObject(int targetType,
Object source,
String columnName) |
void |
ResultSet.setRowsetAfterLastEvent() |
void |
ResultSet.setRowsetBeforeFirstEvent() |
int |
Clob.setStringX(long pos,
String str,
int offset,
int len) |
protected void |
Connection.setTransactionIsolationX(int level)
Set the transaction isolation level as specified.
|
static void |
SingleHopPreparedStatement.sleepForRetry(Connection connection_) |
protected boolean |
Cursor.stepNext(boolean allowServerFetch)
Makes the next row the current row.
|
protected String |
Statement.substituteClientCursorNameWithServerCursorName(String sql,
Section section) |
byte[] |
EncryptionManager.substitutePassword(String userName,
String password,
byte[] sourceSeed_,
byte[] targetSeed_)
Strong Password Substitution (USRSSBPWD).
|
static int |
DateTime.timestampToDateBytes(byte[] buffer,
int offset,
Timestamp timestamp,
Calendar cal)
java.sql.Timestamp is converted to character representation that is in JDBC date escape
format:
yyyy-mm-dd, which is the same as JIS date format in DERBY string representation of a date. |
static int |
DateTime.timestampToTimestampBytes(byte[] buffer,
int offset,
Timestamp timestamp,
Calendar cal)
java.sql.Timestamp is converted to a character representation which is in DERBY string
representation of a timestamp:
yyyy-mm-dd-hh.mm.ss.ffffff. |
protected void |
ResultSet.update() |
static String |
Statement.upperCaseProcedureName(String procedureName) |
boolean |
Connection.willAutoCommitGenerateFlow() |
void |
Connection.writeCommit() |
abstract void |
Connection.writeCommitSubstitute_() |
abstract void |
ResultSet.writeCursorClose_(Section section) |
void |
MaterialPreparedStatement.writeDescribeInput_(Section section) |
void |
PreparedStatement.writeDescribeInput(Section section) |
void |
MaterialPreparedStatement.writeDescribeOutput_(Section section) |
void |
PreparedStatement.writeDescribeOutput(Section section) |
void |
MaterialPreparedStatement.writeExecute_(Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean chainedWritesFollowingSetLob) |
void |
MaterialPreparedStatement.writeExecute_(Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean batchOutput,
boolean chainedWritesFollowingSetLob) |
void |
PreparedStatement.writeExecute(Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean chainedWritesFollowingSetLob) |
void |
MaterialStatement.writeExecuteCall_(boolean outputExpected,
String procedureName,
Section section,
int fetchSize,
boolean suppressResultSets,
int resultSetType,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
Statement.writeExecuteCall(boolean outputExpected,
String procedureName,
Section section,
int fetchSize,
boolean suppressResultSets,
int resultSetType,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
MaterialStatement.writeExecuteImmediate_(String sql,
Section section) |
void |
Statement.writeExecuteImmediate(String sql,
Section section) |
abstract void |
ResultSet.writeFetch_(Section section) |
void |
MaterialStatement.writeGetStmtUUID(Section section) |
void |
Statement.writeGetStmtUUID(Section section) |
abstract void |
Connection.writeLocalCommit_() |
abstract void |
Connection.writeLocalRollback_() |
abstract void |
Connection.writeLocalXACommit_() |
abstract void |
Connection.writeLocalXARollback_() |
abstract void |
Connection.writeLocalXAStart_() |
void |
MaterialStatement.writeOpenQuery_(Section section,
int fetchSize,
int resultSetType) |
void |
MaterialPreparedStatement.writeOpenQuery_(Section section,
int fetchSize,
int resultSetType,
int numInputColumns,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
Statement.writeOpenQuery(Section section,
int fetchSize,
int resultSetType) |
abstract void |
ResultSet.writePositioningFetch_(Section section,
int orientation,
long rowToFetch) |
void |
MaterialStatement.writePrepare_(String sql,
Section section) |
void |
Statement.writePrepare(String sql,
Section section) |
void |
MaterialStatement.writePrepareDescribeOutput_(String sql,
Section section,
boolean needStatementUUID) |
void |
Statement.writePrepareDescribeOutput(String sql,
Section section,
boolean needStatementUUID) |
void |
Connection.writeRollback() |
abstract void |
ResultSet.writeScrollableFetch_(Section section,
int fetchSize,
int orientation,
long rowToFetch,
boolean resetQueryBlocks) |
void |
MaterialStatement.writeSetSpecialRegister_(Section section,
ArrayList sqlsttList) |
void |
Statement.writeSetSpecialRegister(ArrayList sqlsttList) |
void |
Connection.writeTransactionStart(Statement statement) |
protected abstract void |
Connection.writeXACommit_() |
protected abstract void |
Connection.writeXARollback_() |
protected abstract void |
Connection.writeXATransactionStart(Statement statement) |
| Constructor and Description |
|---|
BatchUpdateException(LogWriter logWriter,
ClientMessageId msgid,
Object[] args,
int[] updateCounts,
SqlException cause) |
BatchUpdateException(LogWriter logWriter,
String reason,
String sqlState,
int errorCode,
int[] updateCounts,
SqlException cause) |
DisconnectException(Agent agent,
SqlException e) |
| Constructor and Description |
|---|
BlobLocatorInputStream(Connection connection,
Blob blob)
Create an
InputStream for reading the
Blob value represented by the given locator based
Blob object. |
BlobLocatorInputStream(Connection connection,
Blob blob,
long position,
long length)
Create an
InputStream for reading the
Blob value represented by the given locator based
Blob object. |
BlobLocatorOutputStream(Connection connection,
Blob blob,
long pos)
Create an
OutputStream for writing to the
Blob value represented by the given locator based
Blob object. |
CachingLogicalConnection(Connection physicalConnection,
ClientPooledConnection pooledConnection,
JDBCStatementCache stmtCache)
Creates a new logical connection which caches prepared statements.
|
CachingLogicalConnection40(Connection physicalConnection,
ClientPooledConnection pooledConnection,
JDBCStatementCache stmtCache)
Creates a new logical connection which caches prepared statements.
|
CallableStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
ClientPooledConnection cpc)
Common constructor for jdbc 2 callable statements with scroll attributes.
|
CallableStatement40(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
ClientPooledConnection cpc)
Calls the superclass constructor and passes the parameters
|
Clob(Agent agent,
byte[] unconvertedBytes,
String charsetName,
int dataOffset,
String columnName) |
Clob(Agent agent,
InputStream inputStream,
String encoding,
int length,
String columnName) |
Clob(Agent agent,
InputStream inputStream,
String encoding,
String columnName)
Create a
Clob of unknown length with the specified
encoding. |
ClobLocatorInputStream(Connection connection,
Clob clob)
Create an
InputStream for reading the
Clob value represented by the given locator based
Clob object. |
ClobLocatorInputStream(Connection connection,
Clob clob,
long pos)
Create an
InputStream for reading the
Clob value represented by the given locator based
Clob object. |
ClobLocatorOutputStream(Connection connection,
Clob clob,
long pos)
Create an
OutputStream for writing to the
Clob value represented by the given locator based
Clob object. |
ClobLocatorReader(Connection connection,
Clob clob)
Create an
Reader for reading the
Clob value represented by the given locator based
Clob object. |
ClobLocatorReader(Connection connection,
Clob clob,
long pos,
long len)
Create an
Reader for reading the
Clob value represented by the given locator based
Clob object. |
ClobLocatorWriter(Connection connection,
Clob clob,
long pos)
Create a
Writer for writing to the
Clob value represented by the given locator based
Clob object. |
ClobOutputStream(Clob clob,
long offset) |
ClobWriter(Clob clob,
long offset) |
Connection(LogWriter logWriter,
boolean isXAConn,
ClientBaseDataSource dataSource) |
Connection(LogWriter logWriter,
int driverManagerLoginTimeout,
String serverName,
int portNumber,
String databaseName,
Properties properties) |
Connection(LogWriter logWriter,
String user,
String password,
boolean isXAConn,
ClientBaseDataSource dataSource) |
Connection(LogWriter logWriter,
String user,
String password,
ClientBaseDataSource dataSource) |
EncryptionManager(Agent agent) |
EncryptionManager(Agent agent,
String algorithm) |
LogicalConnection(Connection physicalConnection,
ClientPooledConnection pooledConnection) |
LogicalConnection40(Connection physicalConnection,
ClientPooledConnection pooledConnection) |
PreparedStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes,
ClientPooledConnection cpc)
The PreparedStatementConstructor used for jdbc 2 prepared statements
with scroll attributes.
|
PreparedStatement(Agent agent,
Connection connection,
String sql,
Section section,
ClientPooledConnection cpc)
The PreparedStatement constructor used for JDBC 2 positioned update
statements.
|
PreparedStatement40(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes,
ClientPooledConnection cpc)
The PreparedStatementConstructor used for jdbc 4 prepared statements
with scroll attributes.
|
PreparedStatement40(Agent agent,
Connection connection,
String sql,
Section section,
ClientPooledConnection cpc)
The PreparedStatement used for JDBC 4 positioned update statements.
|
SingleHopPreparedStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes,
ClientPooledConnection cpc) |
SingleHopPreparedStatement(Agent agent,
Connection connection,
String sql,
Section section,
ClientPooledConnection cpc) |
Statement(Agent agent,
Connection connection) |
Statement(Agent agent,
Connection connection,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes) |
Statement40(Agent agent,
Connection connection)
Calls the super class constructor to pass the parameters
|
Statement40(Agent agent,
Connection connection,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes)
Calls the superclass constructor to pass the arguments
|
UpdateSensitiveBlobLocatorInputStream(Connection con,
Blob blob)
Creates an instance of the BlobLocatorInputStream
and and calls the super class constructors with
appropriate initializers.
|
UpdateSensitiveBlobLocatorInputStream(Connection con,
Blob blob,
long position,
long length)
Creates an instance of the BlobLocatorInputStream.
|
UpdateSensitiveClobLocatorInputStream(Connection con,
Clob clob)
Creates an instance of the ClobLocatorInputStream
wrapped in a BufferedInputStream and and calls the
super class constructor with appropriate initializers.
|
UpdateSensitiveClobLocatorReader(Connection con,
Clob clob)
Initializes the Reader, updateCount, currentPos
and the connection to the appropriate values.
|
UpdateSensitiveClobLocatorReader(Connection con,
Clob clob,
long pos,
long len)
Initializes the Reader, updateCount, currentPos,
length and the connection to the appropriate values.
|
UpdateSensitiveLOBLocatorInputStream(Connection con,
Lob lob,
InputStream is)
Initializes the InputStream, updateCount, currentPos
and the connection to the appropriate values.
|
UpdateSensitiveLOBLocatorInputStream(Connection con,
Lob lob,
InputStream is,
long pos,
long len)
Initializes the InputStream, updateCount, currentPos,
length and the connection to the appropriate values.
|
| Modifier and Type | Field and Description |
|---|---|
SqlException |
NetAgent.exceptionOpeningSocket_ |
SqlException |
NetXAResource.exceptionsOnXA |
| Modifier and Type | Method and Description |
|---|---|
NetAgent |
NetConnection.createNewAgentOrReset(LogWriter logWriter,
int loginTimeout,
String thisUrl,
String serverName,
int[] port,
int clientSSLMode,
Set failedUrls,
SqlException failoverEx,
Connection.FailoverStatus status) |
Set |
NetConnection.handleFailover(Set failedUrls,
SqlException sqle) |
protected Set |
NetConnection.handleFailover(Set failedUrls,
SqlException ex,
Connection.FailoverStatus status) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
NetAgent.beginReadChain(Statement statement) |
protected void |
NetAgent.beginReadChainOutsideUOW() |
void |
NetAgent.beginWriteChain(Statement statement) |
void |
NetAgent.beginWriteChainOutsideUOW() |
protected void |
NetStatementRequest.buildOUTOVR(ResultSet resultSet,
ColumnMetaData resultSetMetaData) |
protected void |
NetPackageRequest.buildSQLATTRcommandData(String sql) |
protected void |
NetStatementRequest.buildSQLCADTA(int numColumns,
int[][] lidAndLengthOverrides) |
protected void |
NetStatementRequest.buildSQLDTA(int numColumns,
int[][] lidAndLengthOverrides,
boolean overrideExists,
Hashtable overrideMap,
ArrayList overrideArray) |
protected void |
NetStatementRequest.buildSQLDTAGRP(int numVars,
int[][] lidAndLengthOverrides,
boolean mddRequired,
Hashtable overrideMap) |
protected void |
NetStatementRequest.buildSQLDTARD(int numColumns,
int[][] lidAndLengthOverrides) |
protected void |
NetPackageRequest.buildSQLSTTcommandData(String sql) |
protected boolean |
NetCursor.calculateColumnOffsetsForRow_(int rowIndex,
boolean allowServerFetch)
Calculate the column offsets for a row.
|
void |
NetAgent.checkForChainBreakingException_() |
void |
NetAgent.close_() |
void |
NetConnection.closeForReuse()
Invalidates connection but keeps socket open.
|
void |
NetConnection.completeConnect() |
protected void |
NetConnection.completeReset(boolean isDeferredReset) |
protected void |
NetConnection.constructCrrtkn() |
abstract byte[] |
CcsidManager.convertFromUCS2(String sourceString,
Agent agent) |
byte[] |
EbcdicCcsidManager.convertFromUCS2(String sourceString,
Agent agent) |
abstract int |
CcsidManager.convertFromUCS2(String sourceString,
byte[] buffer,
int offset,
Agent agent) |
int |
EbcdicCcsidManager.convertFromUCS2(String sourceString,
byte[] buffer,
int offset,
Agent agent) |
protected NetConnection |
NetXAConnection.createNetConnection(NetLogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn,
ClientPooledConnection cpc)
Creates NetConnection for the supported version of jdbc.
|
NetAgent |
NetConnection.createNewAgentOrReset(LogWriter logWriter,
int loginTimeout,
String thisUrl,
String serverName,
int[] port,
int clientSSLMode,
Set failedUrls,
SqlException failoverEx,
Connection.FailoverStatus status) |
void |
NetConnection.doResetNow() |
void |
NetPackageRequest.encryptDataStream(int lengthLocation) |
void |
NetAgent.endReadChain() |
void |
NetConnection.flowConnect(String password,
int securityMechanism,
boolean doFailover) |
protected boolean |
NetConnection.flowReconnect(String password,
int securityMechanism) |
protected void |
NetConnection.flowSimpleConnect() |
Blob |
NetCursor.getBlobColumn_(int column,
Agent agent,
boolean toBePublished) |
byte[] |
NetCursor.getClobBytes_(int column,
int[] dataOffset) |
Clob |
NetCursor.getClobColumn_(int column,
Agent agent,
boolean toBePublished) |
protected String |
NetCursor.getColumnLabel(int column) |
NetConnection |
NetConnection.DSConnectionInfo.getConnectionForThisServerURLFromBQ(String host,
String port,
Connection conn) |
protected void |
NetCursor.getMoreData_() |
String |
NetDatabaseMetaData.getURL_() |
Set |
NetConnection.handleFailover(Set failedUrls,
SqlException sqle) |
protected Set |
NetConnection.handleFailover(Set failedUrls,
SqlException ex,
Connection.FailoverStatus status) |
protected Agent |
NetConnection.newAgent_(LogWriter logWriter,
int loginTimeout,
String serverName,
int portNumber,
int clientSSLMode,
Properties incomingProps) |
LogicalConnection |
ClientJDBCObjectFactoryImpl40.newCachingLogicalConnection(Connection physicalConnection,
ClientPooledConnection pooledConnection,
JDBCStatementCache stmtCache)
Returns an instance of a
CachingLogicalConnection, which
provides caching of prepared statements. |
protected CallableStatement |
NetConnection.newCallableStatement_(String sql,
int type,
int concurrency,
int holdability) |
CallableStatement |
ClientJDBCObjectFactoryImpl40.newCallableStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
ClientPooledConnection cpc)
Returns an instance of com.pivotal.gemfirexd.internal.client.am.CallableStatement.
|
LogicalConnection |
ClientJDBCObjectFactoryImpl40.newLogicalConnection(Connection physicalConnection,
ClientPooledConnection pooledConnection)
Returns an instance of LogicalConnection.
|
Connection |
ClientJDBCObjectFactoryImpl40.newNetConnection(LogWriter netLogWriter,
ClientBaseDataSource clientDataSource,
String user,
String password)
returns an instance of com.pivotal.gemfirexd.internal.client.net.NetConnection40
|
Connection |
ClientJDBCObjectFactoryImpl40.newNetConnection(LogWriter netLogWriter,
int driverManagerLoginTimeout,
String serverName,
int portNumber,
String databaseName,
Properties properties)
returns an instance of com.pivotal.gemfirexd.internal.client.net.NetConnection40
|
Connection |
ClientJDBCObjectFactoryImpl40.newNetConnection(LogWriter netLogWriter,
String ipaddr,
int portNumber,
ClientBaseDataSource dataSource,
boolean isXAConn)
returns an instance of com.pivotal.gemfirexd.internal.client.net.NetConnection40
|
Connection |
ClientJDBCObjectFactoryImpl40.newNetConnection(LogWriter netLogWriter,
String databaseName,
Properties properties)
returns an instance of com.pivotal.gemfirexd.internal.client.net.NetConnection40
|
Connection |
ClientJDBCObjectFactoryImpl40.newNetConnection(LogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn)
returns an instance of com.pivotal.gemfirexd.internal.client.net.NetConnection40
|
Connection |
ClientJDBCObjectFactoryImpl40.newNetConnection(LogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn,
ClientPooledConnection cpc)
Returns an instance of com.pivotal.gemfirexd.internal.client.net.NetConnection.
|
ResultSet |
ClientJDBCObjectFactoryImpl40.newNetResultSet(Agent netAgent,
MaterialStatement netStatement,
Cursor cursor,
int qryprctyp,
int sqlcsrhld,
int qryattscr,
int qryattsns,
int qryattset,
long qryinsid,
int actualResultSetType,
int actualResultSetConcurrency,
int actualResultSetHoldability)
returns an instance of com.pivotal.gemfirexd.internal.client.net.NetResultSet
|
protected PreparedStatement |
NetConnection.newPositionedUpdatePreparedStatement_(String sql,
Section section) |
protected PreparedStatement |
NetConnection.newPreparedStatement_(String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes) |
PreparedStatement |
ClientJDBCObjectFactoryImpl40.newPreparedStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes,
ClientPooledConnection cpc)
This method returns an instance of PreparedStatement
which implements java.sql.PreparedStatement.
|
PreparedStatement |
ClientJDBCObjectFactoryImpl40.newPreparedStatement(Agent agent,
Connection connection,
String sql,
Section section,
ClientPooledConnection cpc)
Returns an instance of com.pivotal.gemfirexd.internal.client.am.CallableStatement40
|
protected Statement |
NetConnection.newStatement_(int type,
int concurrency,
int holdability) |
Statement |
ClientJDBCObjectFactoryImpl40.newStatement(Agent agent,
Connection connection)
This method provides an instance of Statement40
|
Statement |
ClientJDBCObjectFactoryImpl40.newStatement(Agent agent,
Connection connection,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes)
This method provides an instance of Statement40
|
boolean |
NetSqldta.next() |
protected void |
NetResultSet.parseRowset_() |
protected void |
NetConnection.preAgentInitialize(String password,
ClientBaseDataSource dataSource,
Properties properties) |
protected void |
NetResultSet.preClose_()
Method that is invoked by
closeX() before the
result set is actually being closed. |
void |
NetXAConnection.readCommit() |
void |
NetConnection.readCommitSubstitute_() |
void |
ConnectionReply.readCommitSubstitute(ConnectionCallbackInterface connection) |
void |
NetResultSet.readCursorClose_() |
void |
ResultSetReply.readCursorClose(ResultSetCallbackInterface resultSet) |
void |
NetPreparedStatement.readDescribeInput_() |
void |
StatementReply.readDescribeInput(PreparedStatementCallbackInterface preparedStatement) |
void |
NetPreparedStatement.readDescribeOutput_() |
void |
StatementReply.readDescribeOutput(PreparedStatementCallbackInterface preparedStatement) |
void |
NetPreparedStatement.readExecute_() |
void |
StatementReply.readExecute(PreparedStatementCallbackInterface preparedStatement) |
void |
NetStatement.readExecuteCall_() |
void |
StatementReply.readExecuteCall(StatementCallbackInterface statement) |
void |
NetStatement.readExecuteImmediate_() |
void |
StatementReply.readExecuteImmediate(StatementCallbackInterface statement) |
void |
NetStatement.readExecuteImmediateForBatch_(String sql) |
void |
NetResultSet.readFetch_() |
void |
ResultSetReply.readFetch(ResultSetCallbackInterface resultSet) |
void |
NetConnection.readLocalCommit_() |
void |
ConnectionReply.readLocalCommit(ConnectionCallbackInterface connection) |
void |
NetConnection.readLocalRollback_() |
void |
ConnectionReply.readLocalRollback(ConnectionCallbackInterface connection) |
void |
NetConnection.readLocalXACommit_() |
void |
NetXAConnection.readLocalXACommit_() |
void |
ConnectionReply.readLocalXACommit(ConnectionCallbackInterface connection) |
void |
NetConnection.readLocalXARollback_() |
void |
NetXAConnection.readLocalXARollback_() |
void |
ConnectionReply.readLocalXARollback(ConnectionCallbackInterface connection) |
void |
NetConnection.readLocalXAStart_() |
void |
NetXAConnection.readLocalXAStart_() |
void |
ConnectionReply.readLocalXAStart(ConnectionCallbackInterface connection) |
void |
NetStatement.readOpenQuery_() |
void |
StatementReply.readOpenQuery(StatementCallbackInterface statement) |
void |
NetResultSet.readPositioningFetch_() |
void |
ResultSetReply.readPositioningFetch(ResultSetCallbackInterface resultSet) |
void |
NetStatement.readPrepare_() |
void |
StatementReply.readPrepare(StatementCallbackInterface statement) |
void |
NetStatement.readPrepareDescribeOutput_() |
void |
StatementReply.readPrepareDescribeOutput(StatementCallbackInterface statement) |
void |
NetXAConnection.readRollback() |
void |
NetResultSet.readScrollableFetch_() |
void |
ResultSetReply.readScrollableFetch(ResultSetCallbackInterface resultSet) |
void |
NetStatement.readSetSpecialRegister_() |
void |
StatementReply.readSetSpecialRegister(StatementCallbackInterface statement) |
void |
NetStatement.readStatementID_() |
void |
StatementReply.readStatementID(StatementCallbackInterface statement) |
void |
NetConnection.readTransactionStart() |
protected void |
NetConnection.readXACommit_()
Invokes readCommit on NetXAConnection
|
protected void |
NetConnection.readXARollback_()
Invokes writeRollback on NetXAConnection
|
boolean |
NetAgent.reconnectAgent(LogWriter logWriter,
int loginTimeout,
String server,
int port) |
protected void |
NetConnection.reset_(LogWriter logWriter) |
protected void |
NetAgent.resetAgent_(LogWriter netLogWriter,
int loginTimeout,
String server,
int port) |
protected void |
NetConnection.resetCallableStatement_(CallableStatement cs,
String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
void |
NetConnection.resetNetConnection(LogWriter logWriter) |
protected void |
NetConnection.resetPreparedStatement_(PreparedStatement ps,
String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes) |
protected void |
NetConnection.resetStatement_(Statement statement,
int type,
int concurrency,
int holdability) |
void |
NetConnection.DSConnectionInfo.returnConnection(NetConnection conn) |
protected void |
Request.updateLengthBytes() |
void |
NetXAConnection.writeCommit() |
void |
NetConnection.writeCommitSubstitute_() |
void |
NetConnectionRequest.writeCommitSubstitute(NetConnection connection) |
void |
ConnectionRequestInterface.writeCommitSubstitute(NetConnection connection) |
void |
NetResultSet.writeCursorClose_(Section section) |
void |
NetResultSetRequest.writeCursorClose(NetResultSet resultSet,
Section section) |
void |
ResultSetRequestInterface.writeCursorClose(NetResultSet resultSet,
Section section) |
void |
NetPreparedStatement.writeDescribeInput_(Section section) |
void |
StatementRequestInterface.writeDescribeInput(NetPreparedStatement materialPreparedStatement,
Section section) |
void |
NetStatementRequest.writeDescribeInput(NetPreparedStatement materialPreparedStatement,
Section section) |
void |
NetPreparedStatement.writeDescribeOutput_(Section section) |
void |
StatementRequestInterface.writeDescribeOutput(NetPreparedStatement materialPreparedStatement,
Section section) |
void |
NetStatementRequest.writeDescribeOutput(NetPreparedStatement materialPreparedStatement,
Section section) |
void |
NetPreparedStatement.writeExecute_(Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean chainedWritesFollowingSetLob) |
void |
NetPreparedStatement.writeExecute_(Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean batchOutput,
boolean chainedWritesFollowingSetLob) |
void |
StatementRequestInterface.writeExecute(NetPreparedStatement materialPreparedStatement,
Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean chainedWritesFollowingSetLob) |
void |
NetStatementRequest.writeExecute(NetPreparedStatement materialPreparedStatement,
Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean chained) |
void |
StatementRequestInterface.writeExecute(NetPreparedStatement materialPreparedStatement,
Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean batchOutput,
boolean chainedWritesFollowingSetLob) |
void |
NetStatementRequest.writeExecute(NetPreparedStatement materialPreparedStatement,
Section section,
ColumnMetaData parameterMetaData,
Object[] inputs,
int numInputColumns,
boolean outputExpected,
boolean batchOutput,
boolean chained) |
void |
NetStatement.writeExecuteCall_(boolean outputExpected,
String procedureName,
Section section,
int fetchSize,
boolean suppressResultSets,
int resultSetType,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
StatementRequestInterface.writeExecuteCall(NetStatement materialStatement,
boolean outputExpected,
String procedureName,
Section section,
int fetchSize,
boolean suppressResultSets,
int resultSetType,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
NetStatementRequest.writeExecuteCall(NetStatement materialStatement,
boolean outputExpected,
String procedureName,
Section section,
int fetchSize,
boolean suppressResultSets,
int resultSetType,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
NetStatement.writeExecuteImmediate_(String sql,
Section section) |
void |
StatementRequestInterface.writeExecuteImmediate(NetStatement materialStatement,
String sql,
Section section) |
void |
NetStatementRequest.writeExecuteImmediate(NetStatement materialStatement,
String sql,
Section section) |
void |
NetResultSet.writeFetch_(Section section) |
void |
NetResultSetRequest.writeFetch(NetResultSet resultSet,
Section section,
int fetchSize) |
void |
ResultSetRequestInterface.writeFetch(NetResultSet resultSet,
Section section,
int fetchSize) |
void |
NetStatement.writeGetStmtUUID(Section section) |
void |
StatementRequestInterface.writeGetStmtUUID(Section section) |
void |
NetStatementRequest.writeGetStmtUUID(Section section) |
void |
NetConnection.writeLocalCommit_() |
void |
NetConnectionRequest.writeLocalCommit(NetConnection connection) |
void |
ConnectionRequestInterface.writeLocalCommit(NetConnection connection) |
void |
NetConnection.writeLocalRollback_() |
void |
NetConnectionRequest.writeLocalRollback(NetConnection connection) |
void |
ConnectionRequestInterface.writeLocalRollback(NetConnection connection) |
void |
NetConnection.writeLocalXACommit_() |
void |
NetXAConnection.writeLocalXACommit_() |
void |
NetConnectionRequest.writeLocalXACommit(NetConnection conn) |
void |
ConnectionRequestInterface.writeLocalXACommit(NetConnection connection) |
void |
NetXAConnectionRequest.writeLocalXACommit(NetConnection conn) |
void |
NetConnection.writeLocalXARollback_() |
void |
NetXAConnection.writeLocalXARollback_() |
void |
NetConnectionRequest.writeLocalXARollback(NetConnection conn) |
void |
ConnectionRequestInterface.writeLocalXARollback(NetConnection connection) |
void |
NetXAConnectionRequest.writeLocalXARollback(NetConnection conn) |
void |
NetConnection.writeLocalXAStart_() |
void |
NetXAConnection.writeLocalXAStart_() |
void |
NetConnectionRequest.writeLocalXAStart(NetConnection connection) |
void |
ConnectionRequestInterface.writeLocalXAStart(NetConnection connection) |
void |
NetStatement.writeOpenQuery_(Section section,
int fetchSize,
int resultSetType) |
void |
NetPreparedStatement.writeOpenQuery_(Section section,
int fetchSize,
int resultSetType,
int numInputColumns,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
StatementRequestInterface.writeOpenQuery(NetPreparedStatement materialPreparedStatement,
Section section,
int fetchSize,
int resultSetType,
int numInputColumns,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
NetStatementRequest.writeOpenQuery(NetPreparedStatement materialPreparedStatement,
Section section,
int fetchSize,
int resultSetType,
int numInputColumns,
ColumnMetaData parameterMetaData,
Object[] inputs) |
void |
StatementRequestInterface.writeOpenQuery(NetStatement materialStatement,
Section section,
int fetchSize,
int resultSetType) |
void |
NetStatementRequest.writeOpenQuery(NetStatement materialStatement,
Section section,
int fetchSize,
int resultSetType) |
void |
NetResultSet.writePositioningFetch_(Section section,
int orientation,
long rowToFetch) |
void |
NetResultSetRequest.writePositioningFetch(NetResultSet resultSet,
Section section,
int orientation,
long rowToFetch) |
void |
ResultSetRequestInterface.writePositioningFetch(NetResultSet resultSet,
Section section,
int orientation,
long rowToFetch) |
void |
NetStatement.writePrepare_(String sql,
Section section) |
void |
StatementRequestInterface.writePrepare(NetStatement materialStatement,
String sql,
Section section) |
void |
NetStatementRequest.writePrepare(NetStatement materialStatement,
String sql,
Section section) |
void |
NetStatement.writePrepareDescribeOutput_(String sql,
Section section,
boolean needStatementUUID) |
void |
StatementRequestInterface.writePrepareDescribeOutput(NetStatement materialStatement,
String sql,
Section section,
boolean needStatementUUID) |
void |
NetStatementRequest.writePrepareDescribeOutput(NetStatement materialStatement,
String sql,
Section section,
boolean needStatementUUID) |
void |
NetXAConnection.writeRollback() |
void |
NetResultSet.writeScrollableFetch_(Section section,
int fetchSize,
int orientation,
long rowToFetch,
boolean resetQueryBlocks) |
void |
NetResultSetRequest.writeScrollableFetch(NetResultSet resultSet,
Section section,
int fetchSize,
int orientation,
long rowToFetch,
boolean resetQueryBlocks) |
void |
ResultSetRequestInterface.writeScrollableFetch(NetResultSet resultSet,
Section section,
int fetchSize,
int orientation,
long rowToFetch,
boolean resetQueryBlocks) |
void |
NetStatement.writeSetSpecialRegister_(Section section,
ArrayList sqlsttList) |
void |
StatementRequestInterface.writeSetSpecialRegister(Section section,
ArrayList sqlsttList) |
void |
NetStatementRequest.writeSetSpecialRegister(Section section,
ArrayList sqlsttList) |
void |
NetConnection.writeTransactionStart(Statement statement) |
void |
NetXAConnection.writeTransactionStart(Statement statement) |
protected void |
NetConnection.writeXACommit_()
Invokes write commit on NetXAConnection
|
protected void |
NetConnectionRequest.writeXaCommit(NetConnection conn,
Xid xid) |
protected void |
NetXAConnectionRequest.writeXaCommit(NetConnection conn,
Xid xid) |
void |
NetConnectionRequest.writeXaEndUnitOfWork(NetConnection conn) |
void |
NetXAConnectionRequest.writeXaEndUnitOfWork(NetConnection conn) |
protected void |
NetConnectionRequest.writeXaForget(NetConnection conn,
Xid xid) |
protected void |
NetXAConnectionRequest.writeXaForget(NetConnection conn,
Xid xid) |
protected void |
NetConnectionRequest.writeXaPrepare(NetConnection conn) |
protected void |
NetXAConnectionRequest.writeXaPrepare(NetConnection conn) |
protected void |
NetConnectionRequest.writeXaRecover(NetConnection conn,
int flag) |
protected void |
NetXAConnectionRequest.writeXaRecover(NetConnection conn,
int flag) |
protected void |
NetConnection.writeXARollback_()
Invokes writeRollback on NetXAConnection
|
protected void |
NetConnectionRequest.writeXaRollback(NetConnection conn,
Xid xid) |
protected void |
NetXAConnectionRequest.writeXaRollback(NetConnection conn,
Xid xid) |
void |
NetConnectionRequest.writeXaStartUnitOfWork(NetConnection conn) |
void |
NetXAConnectionRequest.writeXaStartUnitOfWork(NetConnection conn) |
protected void |
NetConnection.writeXATransactionStart(Statement statement) |
| Constructor and Description |
|---|
NetAgent(NetConnection netConnection,
LogWriter logWriter) |
NetConnection(NetLogWriter netLogWriter,
ClientBaseDataSource dataSource,
String user,
String password) |
NetConnection(NetLogWriter netLogWriter,
int driverManagerLoginTimeout,
String serverName,
int portNumber,
String databaseName,
Properties properties) |
NetConnection(NetLogWriter netLogWriter,
String ipaddr,
int portNumber,
ClientBaseDataSource dataSource,
boolean isXAConn) |
NetConnection(NetLogWriter netLogWriter,
String databaseName,
Properties properties) |
NetConnection(NetLogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn) |
NetConnection(NetLogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn,
ClientPooledConnection cpc)
This constructor is called from the ClientPooledConnection object
to enable the NetConnection to pass
this on to the associated
prepared statement object thus enabling the prepared statement object
to inturn raise the statement events to the ClientPooledConnection object |
NetConnection40(NetLogWriter netLogWriter,
ClientBaseDataSource dataSource,
String user,
String password) |
NetConnection40(NetLogWriter netLogWriter,
int driverManagerLoginTimeout,
String serverName,
int portNumber,
String databaseName,
Properties properties) |
NetConnection40(NetLogWriter netLogWriter,
String ipaddr,
int portNumber,
ClientBaseDataSource dataSource,
boolean isXAConn) |
NetConnection40(NetLogWriter netLogWriter,
String databaseName,
Properties properties) |
NetConnection40(NetLogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn) |
NetConnection40(NetLogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn,
ClientPooledConnection cpc)
The constructor for the NetConnection40 class which contains
implementations of JDBC 4.0 specific methods in the java.sql.Connection
interface.
|
NetXAConnection(NetLogWriter netLogWriter,
String user,
String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn,
ClientPooledConnection cpc)
The construcor for the NetXAConnection.
|
| Modifier and Type | Method and Description |
|---|---|
static LogWriter |
ClientBaseDataSource.computeDncLogWriter(Connection connection,
PrintWriter logWriter,
String traceDirectory,
String traceFile,
boolean traceFileAppend,
String logWriterInUseSuffix,
int traceFileSuffixIndex,
int traceLevel) |
static LogWriter |
ClientBaseDataSource.computeDncLogWriterForNewConnection(PrintWriter logWriter,
String traceDirectory,
String traceFile,
boolean traceFileAppend,
int traceLevel,
String logWriterInUseSuffix,
int traceFileSuffixIndex) |
static int |
ClientBaseDataSource.getClientSSLMode(Properties properties) |
static int |
ClientBaseDataSource.getSSLModeFromString(String s) |
void |
ClientBaseDataSource.setSsl(String mode) |
static Properties |
ClientBaseDataSource.tokenizeAttributes(String attributeString,
Properties properties) |
| Modifier and Type | Method and Description |
|---|---|
protected Properties |
ClientDRDADriver.getURLProperties(Matcher m,
Properties properties) |
Copyright © 2010-2015 Pivotal Software, Inc. All rights reserved.