Class ClientPreparedStatement

java.lang.Object

org.apache.derby.client.am.ClientStatement

org.apache.derby.client.am.ClientPreparedStatement

All Implemented Interfaces:

AutoCloseable, PreparedStatement, Statement, Wrapper, PreparedStatementCallbackInterface, StatementCallbackInterface, UnitOfWorkListener

Direct Known Subclasses:

ClientCallableStatement, ClientPreparedStatement42

public class ClientPreparedStatement
extends ClientStatement
implements PreparedStatement, PreparedStatementCallbackInterface

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ClientPreparedStatement.PossibleTypes	PossibleTypes is information which is set of types.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	listenToUnitOfWork_
MaterialPreparedStatement	materialPreparedStatement_
(package private) boolean	outputRegistered_
(package private) ColumnMetaData	parameterMetaData_
(package private) boolean[]	parameterRegistered_
(package private) Object[]	parameters_
private boolean[]	parameterSet_
private ArrayList<int[]>	parameterTypeList
private final ClientPooledConnection	pooledConnection_
private String	positionedUpdateCursorName_
(package private) String	sql_

Fields inherited from class ClientStatement

agent_, autoGeneratedKeys_, batch_, cachedCursor_, cachedSingletonRowData_, connection_, cursorAttributesToSendOnPrepare_, cursorName_, doWriteTimeout, executeMethod__, executeQueryMethod__, executeUpdateMethod__, fetchDirection_, fetchSize_, generatedKeysColumnIndexes_, generatedKeysColumnNames_, generatedKeysResultSet_, isAutoCommittableStatement_, isCall__, isCatalogQuery_, isDeleteSql__, isInsertSql__, isPoolable, isPreparedStatement_, isQuery__, isUpdate__, isUpdateSql__, maxFieldSize_, maxRows_, openOnClient_, preparedStatementForAutoGeneratedKeys_, resultSet_, resultSetConcurrency_, resultSetHoldability_, resultSetList_, resultSetMetaData_, resultSetType_, singletonRowData_, sqlMode_, sqlUpdateMode_, timeout_, TIMEOUT_STATEMENT, timeoutArrayList, updateCount_

Fields inherited from interface Statement

CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO

Constructor Summary

Constructors

Constructor	Description
ClientPreparedStatement(Agent agent, ClientConnection 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.
ClientPreparedStatement(Agent agent, ClientConnection connection, String sql, Section section, ClientPooledConnection cpc)	The PreparedStatement constructor used for JDBC 2 positioned update statements.

Method Summary

Modifier and Type	Method	Description
void	addBatch()
void	addBatch(String sql)
(package private) void	checkForValidParameterIndex(int parameterIndex)
(package private) void	checkForValidScale(int scale)
private void	checkStatementValidity(SqlException sqle)
protected void	checkStatus()	Check for closed statement and extract the SQLException if it is raised.
private void	checkStreamLength(long length)	Check the length passed in for the stream that is to be set.
private void	checkThatAllParametersAreSet()
private void	checkTypeForSetAsciiStream(int parameterIndex)
private void	checkTypeForSetBinaryStream(int parameterIndex)
private void	checkTypeForSetBlob(int parameterIndex)
private void	checkTypeForSetCharacterStream(int parameterIndex)
private void	checkTypeForSetClob(int parameterIndex)
void	clearParameters()
void	completeDescribeInput(ColumnMetaData parameterMetaData, Sqlca sqlca)
void	completeDescribeOutput(ColumnMetaData resultSetMetaData, Sqlca sqlca)
void	completeLocalCommit(Iterator listenerIterator)
void	completeLocalRollback(Iterator listenerIterator)
private void	completePrepareDescribe()
boolean	execute()
boolean	execute(String sql)
boolean	execute(String sql, int autoGeneratedKeys)
boolean	execute(String sql, int[] columnIndexes)
boolean	execute(String sql, String[] columnNames)
int[]	executeBatch()
private long[]	executeBatchRequestX(boolean supportsQueryBatchRequest)
private long[]	executeBatchX(boolean supportsQueryBatchRequest)
long	executeLargeUpdate()
ResultSet	executeQuery()
ResultSet	executeQuery(String sql)
(package private) ClientResultSet	executeQueryX()
int	executeUpdate()
int	executeUpdate(String sql)
int	executeUpdate(String sql, int autoGeneratedKeys)
int	executeUpdate(String sql, int[] columnIndexes)
int	executeUpdate(String sql, String[] columnNames)
private long	executeUpdateX()
(package private) boolean	executeX()
private boolean[]	expandBooleanArray(boolean[] array, int newLength)
private Object[]	expandObjectArray(Object[] array, int newLength)
private void	flowExecute(int executeType)
(package private) void	flowPrepareDescribeInputOutput()
private ColumnMetaData	getColumnMetaDataX()
protected String	getJdbcStatementInterfaceName()	Returns the name of the java.sql interface implemented by this class.
ResultSetMetaData	getMetaData()
private ColumnMetaData	getMetaDataX()
ParameterMetaData	getParameterMetaData()
private ClientParameterMetaData	getParameterMetaDataX()
private void	initPreparedStatement()
private void	initPreparedStatement(String sql)
private void	initPreparedStatement(String sql, Section section)
protected void	initResetPreparedStatement()
void	listenToUnitOfWork()
protected void	markClosed(boolean removeListener)	This method cleans up client-side resources held by this Statement.
(package private) void	prepare()
private void	readDescribeInput()
private void	readExecute()
private void	readPrepareDescribeInput()
private void	readPrepareDescribeInputOutput()
void	reset(boolean fullReset)
(package private) void	resetForReuse()	Resets the prepared statement for reuse in a statement pool.
private void	resetParameters()
void	resetPreparedStatement(Agent agent, ClientConnection connection, String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, String[] columnNames, int[] columnIndexes)
private void	resetPreparedStatement(Agent agent, ClientConnection connection, String sql, Section section)
void	setArray(int parameterIndex, Array x)
void	setAsciiStream(int parameterIndex, InputStream x)	Sets the designated parameter to the given input stream.
void	setAsciiStream(int parameterIndex, InputStream x, int length)	We do this inefficiently and read it all in here.
void	setAsciiStream(int parameterIndex, InputStream x, long length)	We do this inefficiently and read it all in here.
void	setBigDecimal(int parameterIndex, BigDecimal x)
void	setBinaryStream(int parameterIndex, InputStream x)	Sets the designated parameter to the given input stream.
void	setBinaryStream(int parameterIndex, InputStream x, int length)	sets the parameter to the Binary Stream object
void	setBinaryStream(int parameterIndex, InputStream x, long length)	sets the parameter to the Binary Stream object
private void	setBinaryStreamX(int parameterIndex, InputStream x, int length)
void	setBlob(int parameterIndex, InputStream inputStream)	Sets the designated parameter to a InputStream object.
void	setBlob(int parameterIndex, InputStream inputStream, long length)	Sets the designated parameter to a InputStream object.
void	setBlob(int parameterIndex, Blob x)
private void	setBlobX(int parameterIndex, Blob x)
void	setBoolean(int parameterIndex, boolean x)
void	setByte(int parameterIndex, byte x)
void	setBytes(int parameterIndex, byte[] x)
(package private) void	setBytesX(int parameterIndex, byte[] x)
void	setCharacterStream(int parameterIndex, Reader x)	Sets the designated parameter to the given Reader object.
void	setCharacterStream(int parameterIndex, Reader x, int length)	Sets the designated parameter to the given Reader, which will have the specified number of bytes.
void	setCharacterStream(int parameterIndex, Reader x, long length)	Sets the designated parameter to the given Reader, which will have the specified number of bytes.
void	setClob(int parameterIndex, Reader reader)	Sets the designated parameter to a Reader object.
void	setClob(int parameterIndex, Reader reader, long length)	Sets the designated parameter to a Reader object.
void	setClob(int parameterIndex, Clob x)
private void	setClobX(int parameterIndex, Clob x)
void	setDate(int parameterIndex, Date x)
void	setDate(int parameterIndex, Date x, Calendar calendar)
void	setDouble(int parameterIndex, double x)
void	setFloat(int parameterIndex, float x)
(package private) void	setInput(int parameterIndex, Object input)
void	setInt(int parameterIndex, int x)
(package private) void	setIntX(int parameterIndex, int x)
void	setLong(int parameterIndex, long x)
(package private) void	setLongX(int parameterIndex, long x)
void	setNCharacterStream(int parameterIndex, Reader value)
void	setNCharacterStream(int index, Reader value, long length)
void	setNClob(int parameterIndex, Reader reader)
void	setNClob(int parameterIndex, Reader reader, long length)
void	setNClob(int index, NClob value)
void	setNString(int index, String value)
void	setNull(int parameterIndex, int jdbcType)
void	setNull(int parameterIndex, int jdbcType, String typeName)
(package private) void	setNullX(int parameterIndex, int jdbcType)
void	setObject(int parameterIndex, Object x)
void	setObject(int parameterIndex, Object x, int targetJdbcType)
void	setObject(int parameterIndex, Object x, int targetJdbcType, int scale)
private void	setObjectX(int parameterIndex, Object x, int targetJdbcType, int scale)
void	setRef(int parameterIndex, Ref x)
void	setRowId(int parameterIndex, RowId x)
void	setShort(int parameterIndex, short x)
(package private) void	setShortX(int parameterIndex, short x)
void	setSQLXML(int parameterIndex, SQLXML xmlObject)
void	setString(int parameterIndex, String x)
(package private) void	setStringX(int parameterIndex, String x)
void	setTime(int parameterIndex, Time x)
void	setTime(int parameterIndex, Time x, Calendar calendar)
void	setTimestamp(int parameterIndex, Timestamp x)
void	setTimestamp(int parameterIndex, Timestamp x, Calendar calendar)
private void	setUDTX(int parameterIndex, Object x)	Set a UDT parameter to an object value.
void	setUnicodeStream(int parameterIndex, InputStream x, int length)	Deprecated.
void	setURL(int parameterIndex, URL x)
private void	writeDescribeInput(Section section)
private void	writeExecute(Section section, ColumnMetaData parameterMetaData, Object[] inputs, int numInputColumns, boolean outputExpected, boolean chainedWritesFollowingSetLob)
private void	writeOpenQuery(Section section, int fetchSize, int resultSetType, int numInputColumns, ColumnMetaData parameterMetaData, Object[] inputs)
private void	writePrepareDescribeInput()
private void	writePrepareDescribeInputOutput()

Methods inherited from class ClientStatement

accumulateWarning, cacheCursorAttributesToSendOnPrepare, cancel, checkAutoGeneratedKeysParameters, checkForAppropriateSqlMode, checkForClosedStatement, checkForDuplicateCursorName, checkForStoredProcResultSetCount, clearBatch, clearWarnings, clearWarningsX, close, closeMeOnCompletion, closeOnCompletion, closeX, completeExecute, completeExecuteCall, completeExecuteCall, completeExecuteCallOpenQuery, completeExecuteImmediate, completeExecuteSetStatement, completeOpenQuery, completePrepare, completePrepareDescribeOutput, completeSqlca, escape, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeX, extractCursorNameFromWhereCurrentOf, finalize, getConnection, getConnectionCallbackInterface, getFetchDirection, getFetchSize, getGeneratedKeys, getGuessedResultSetMetaData, getLargeMaxRows, getLargeUpdateCount, getMaterialStatement, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getOwner, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getSection, getSqlWarnings, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, isQueryMode, isWrapperFor, markClosed, markResultSetsClosed, parseSqlAndSetSqlModes, parseStorProcReturnedScrollableRowset, prepareAutoGeneratedKeysStatement, readClose, readCloseResultSets, readExecuteCall, readOpenQuery, readPrepare, readPrepareDescribeOutput, readSetSpecialRegister, removeClientCursorNameFromCache, resetCursorNameAndRemoveFromWhereCurrentOfMappings, resetResultSetList, resetStatement, resetStatement, resultSetCommitting, resultSetCommitting, setCursorName, setEscapeProcessing, setFetchDirection, setFetchedRowBase, setFetchSize, setLargeMaxRows, setMaterialStatement, setMaxFieldSize, setMaxRows, setOwner, setPoolable, setQueryTimeout, setSection, setupCursorNameCacheAndMappings, setUpdateCount, substituteClientCursorNameWithServerCursorName, unwrap, writeClose, writeCloseResultSets, writeExecuteCall, writeOpenQuery, writePrepare, writePrepareDescribeOutput, writeSetSpecialRegister

Methods inherited from class Object

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

Methods inherited from interface PreparedStatement

setObject, setObject

Methods inherited from interface Statement

cancel, clearBatch, clearWarnings, close, closeOnCompletion, enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, getConnection, getFetchDirection, getFetchSize, getGeneratedKeys, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, isSimpleIdentifier, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout

Methods inherited from interface StatementCallbackInterface

accumulateWarning, completeExecute, completeExecuteCall, completeExecuteCall, completeExecuteCallOpenQuery, completeExecuteImmediate, completeExecuteSetStatement, completeOpenQuery, completePrepare, completePrepareDescribeOutput, completeSqlca, getConnectionCallbackInterface, getGuessedResultSetMetaData

Methods inherited from interface Wrapper

isWrapperFor, unwrap

Field Details

materialPreparedStatement_

public MaterialPreparedStatement materialPreparedStatement_

sql_

String sql_

outputRegistered_

boolean outputRegistered_

parameters_

Object[] parameters_

parameterSet_

private boolean[] parameterSet_

parameterRegistered_

boolean[] parameterRegistered_

parameterMetaData_

ColumnMetaData parameterMetaData_

parameterTypeList

private ArrayList<int[]> parameterTypeList

positionedUpdateCursorName_

private String positionedUpdateCursorName_

pooledConnection_

private final ClientPooledConnection pooledConnection_

listenToUnitOfWork_

private boolean listenToUnitOfWork_

Constructor Details

ClientPreparedStatement

public ClientPreparedStatement(Agent agent,
 ClientConnection connection,
 String sql,
 Section section,
 ClientPooledConnection cpc)
                        throws SqlException

The PreparedStatement constructor used for JDBC 2 positioned update statements. Called by material statement constructors. It has the ClientPooledConnection as one of its parameters this is used to raise the Statement Events when the prepared statement is closed

Parameters:

agent - The instance of NetAgent associated with this CallableStatement object.

connection - The connection object associated with this PreparedStatement Object.

sql - A String object that is the SQL statement to be sent to the database.

section - Section

cpc - The ClientPooledConnection wraps the underlying physical connection associated with this prepared statement. It is used to pass the Statement closed and the Statement error occurred events that occur back to the ClientPooledConnection.

Throws:

SqlException

ClientPreparedStatement

public ClientPreparedStatement(Agent agent,
 ClientConnection connection,
 String sql,
 int type,
 int concurrency,
 int holdability,
 int autoGeneratedKeys,
 String[] columnNames,
 int[] columnIndexes,
 ClientPooledConnection cpc)
                        throws SqlException

The PreparedStatementConstructor used for jdbc 2 prepared statements with scroll attributes. Called by material statement constructors. It has the ClientPooledConnection as one of its parameters this is used to raise the Statement Events when the prepared statement is closed

Parameters:

agent - The instance of NetAgent associated with this CallableStatement object.

connection - The connection object associated with this PreparedStatement Object.

sql - A String object that is the SQL statement to be sent to the database.

type - One of the ResultSet type constants.

concurrency - One of the ResultSet concurrency constants.

holdability - One of the ResultSet holdability constants.

autoGeneratedKeys - a flag indicating whether auto-generated keys should be returned.

columnNames - an array of column names indicating the columns that should be returned from the inserted row or rows.

columnIndexes - an array of column names indicating the columns that should be returned from the inserted row.

cpc - The ClientPooledConnection wraps the underlying physical connection associated with this prepared statement it is used to pass the Statement closed and the Statement error occurred events that occur back to the ClientPooledConnection.

Throws:

SqlException

Method Details

setInput

void setInput(int parameterIndex,
 Object input)

initPreparedStatement

private void initPreparedStatement()

initResetPreparedStatement

protected void initResetPreparedStatement()

Overrides:

initResetPreparedStatement in class ClientStatement

reset

public void reset(boolean fullReset)
           throws SqlException

Overrides:

reset in class ClientStatement

Throws:

SqlException

resetForReuse

void resetForReuse()
            throws SqlException

Resets the prepared statement for reuse in a statement pool.

Overrides:

resetForReuse in class ClientStatement

Throws:

SqlException - if the reset fails

See Also:

• ClientStatement.resetForReuse()

resetParameters

private void resetParameters()

resetPreparedStatement

private void resetPreparedStatement(Agent agent,
 ClientConnection connection,
 String sql,
 Section section)
                             throws SqlException

Throws:

SqlException

initPreparedStatement

private void initPreparedStatement(String sql,
 Section section)
                            throws SqlException

Throws:

SqlException

resetPreparedStatement

public void resetPreparedStatement(Agent agent,
 ClientConnection connection,
 String sql,
 int type,
 int concurrency,
 int holdability,
 int autoGeneratedKeys,
 String[] columnNames,
 int[] columnIndexes)
                            throws SqlException

Throws:

SqlException

initPreparedStatement

private void initPreparedStatement(String sql)
                            throws SqlException

Throws:

SqlException

prepare

void prepare()
      throws SqlException

Throws:

SqlException

addBatch

public void addBatch(String sql)
              throws SQLException

Specified by:

addBatch in interface Statement

Overrides:

addBatch in class ClientStatement

Throws:

SQLException

execute

public boolean execute(String sql)
                throws SQLException

Specified by:

execute in interface Statement

Overrides:

execute in class ClientStatement

Throws:

SQLException

executeQuery

public ResultSet executeQuery(String sql)
                       throws SQLException

Specified by:

executeQuery in interface Statement

Overrides:

executeQuery in class ClientStatement

Throws:

SQLException

executeUpdate

public int executeUpdate(String sql)
                  throws SQLException

Specified by:

executeUpdate in interface Statement

Overrides:

executeUpdate in class ClientStatement

Throws:

SQLException

executeQuery

public ResultSet executeQuery()
                       throws SQLException

Specified by:

executeQuery in interface PreparedStatement

Throws:

SQLException

executeQueryX

ClientResultSet executeQueryX()
                       throws SqlException

Throws:

SqlException

executeUpdate

public int executeUpdate()
                  throws SQLException

Specified by:

executeUpdate in interface PreparedStatement

Throws:

SQLException

executeUpdateX

private long executeUpdateX()
                     throws SqlException

Throws:

SqlException

setNull

public void setNull(int parameterIndex,
 int jdbcType)
             throws SQLException

Specified by:

setNull in interface PreparedStatement

Throws:

SQLException

setNullX

void setNullX(int parameterIndex,
 int jdbcType)
       throws SqlException

Throws:

SqlException

setNull

public void setNull(int parameterIndex,
 int jdbcType,
 String typeName)
             throws SQLException

Specified by:

setNull in interface PreparedStatement

Throws:

SQLException

setBoolean

public void setBoolean(int parameterIndex,
 boolean x)
                throws SQLException

Specified by:

setBoolean in interface PreparedStatement

Throws:

SQLException

setByte

public void setByte(int parameterIndex,
 byte x)
             throws SQLException

Specified by:

setByte in interface PreparedStatement

Throws:

SQLException

setShort

public void setShort(int parameterIndex,
 short x)
              throws SQLException

Specified by:

setShort in interface PreparedStatement

Throws:

SQLException

setShortX

void setShortX(int parameterIndex,
 short x)
        throws SqlException

Throws:

SqlException

setInt

public void setInt(int parameterIndex,
 int x)
            throws SQLException

Specified by:

setInt in interface PreparedStatement

Throws:

SQLException

setIntX

void setIntX(int parameterIndex,
 int x)
      throws SqlException

Throws:

SqlException

setLong

public void setLong(int parameterIndex,
 long x)
             throws SQLException

Specified by:

setLong in interface PreparedStatement

Throws:

SQLException

setLongX

void setLongX(int parameterIndex,
 long x)

setFloat

public void setFloat(int parameterIndex,
 float x)
              throws SQLException

Specified by:

setFloat in interface PreparedStatement

Throws:

SQLException

setDouble

public void setDouble(int parameterIndex,
 double x)
               throws SQLException

Specified by:

setDouble in interface PreparedStatement

Throws:

SQLException

setBigDecimal

public void setBigDecimal(int parameterIndex,
 BigDecimal x)
                   throws SQLException

Specified by:

setBigDecimal in interface PreparedStatement

Throws:

SQLException

setDate

public void setDate(int parameterIndex,
 Date x,
 Calendar calendar)
             throws SQLException

Specified by:

setDate in interface PreparedStatement

Throws:

SQLException

setDate

public void setDate(int parameterIndex,
 Date x)
             throws SQLException

Specified by:

setDate in interface PreparedStatement

Throws:

SQLException

setTime

public void setTime(int parameterIndex,
 Time x,
 Calendar calendar)
             throws SQLException

Specified by:

setTime in interface PreparedStatement

Throws:

SQLException

setTime

public void setTime(int parameterIndex,
 Time x)
             throws SQLException

Specified by:

setTime in interface PreparedStatement

Throws:

SQLException

setTimestamp

public void setTimestamp(int parameterIndex,
 Timestamp x,
 Calendar calendar)
                  throws SQLException

Specified by:

setTimestamp in interface PreparedStatement

Throws:

SQLException

setTimestamp

public void setTimestamp(int parameterIndex,
 Timestamp x)
                  throws SQLException

Specified by:

setTimestamp in interface PreparedStatement

Throws:

SQLException

setString

public void setString(int parameterIndex,
 String x)
               throws SQLException

Specified by:

setString in interface PreparedStatement

Throws:

SQLException

setStringX

void setStringX(int parameterIndex,
 String x)
         throws SqlException

Throws:

SqlException

setBytes

public void setBytes(int parameterIndex,
 byte[] x)
              throws SQLException

Specified by:

setBytes in interface PreparedStatement

Throws:

SQLException

setBytesX

void setBytesX(int parameterIndex,
 byte[] x)
        throws SqlException

Throws:

SqlException

setBinaryStream

public void setBinaryStream(int parameterIndex,
 InputStream x,
 long length)
                     throws SQLException

sets the parameter to the Binary Stream object

Specified by:

setBinaryStream in interface PreparedStatement

Parameters:

parameterIndex - the first parameter is 1, the second is 2, ...

x - the java input stream which contains the binary parameter value

length - the number of bytes in the stream

Throws:

SQLException - thrown on failure.

setBinaryStream

public void setBinaryStream(int parameterIndex,
 InputStream x,
 int length)
                     throws SQLException

sets the parameter to the Binary Stream object

Specified by:

setBinaryStream in interface PreparedStatement

Parameters:

parameterIndex - the first parameter is 1, the second is 2, ...

x - the java input stream which contains the binary parameter value

length - the number of bytes in the stream

Throws:

SQLException - thrown on failure.

setBinaryStreamX

private void setBinaryStreamX(int parameterIndex,
 InputStream x,
 int length)
                       throws SqlException

Throws:

SqlException

setAsciiStream

public void setAsciiStream(int parameterIndex,
 InputStream x,
 long length)
                    throws SQLException

We do this inefficiently and read it all in here. The target type is assumed to be a String.

Specified by:

setAsciiStream in interface PreparedStatement

Parameters:

parameterIndex - the first parameter is 1, the second is 2, ...

x - the java input stream which contains the ASCII parameter value

length - the number of bytes in the stream

Throws:

SQLException - thrown on failure.

setAsciiStream

public void setAsciiStream(int parameterIndex,
 InputStream x,
 int length)
                    throws SQLException

We do this inefficiently and read it all in here. The target type is assumed to be a String.

Specified by:

setAsciiStream in interface PreparedStatement

Parameters:

parameterIndex - the first parameter is 1, the second is 2, ...

x - the java input stream which contains the ASCII parameter value

length - the number of bytes in the stream

Throws:

SQLException - thrown on failure.

checkStreamLength

private void checkStreamLength(long length)
                        throws SQLException

Check the length passed in for the stream that is to be set. If length is larger than Integer.MAX_VALUE or smaller that 0, we fail by throwing an SQLException.

Parameters:

length - The length of the stream being set

Throws:

SQLException - Thrown for a negative or too large length.

checkTypeForSetAsciiStream

private void checkTypeForSetAsciiStream(int parameterIndex)
                                 throws SqlException,
SQLException

Throws:

SqlException

SQLException

checkTypeForSetBinaryStream

private void checkTypeForSetBinaryStream(int parameterIndex)
                                  throws SqlException,
SQLException

Throws:

SqlException

SQLException

checkTypeForSetCharacterStream

private void checkTypeForSetCharacterStream(int parameterIndex)
                                     throws SqlException,
SQLException

Throws:

SqlException

SQLException

checkTypeForSetBlob

private void checkTypeForSetBlob(int parameterIndex)
                          throws SqlException,
SQLException

Throws:

SqlException

SQLException

checkTypeForSetClob

private void checkTypeForSetClob(int parameterIndex)
                          throws SqlException,
SQLException

Throws:

SqlException

SQLException

setUnicodeStream

public void setUnicodeStream(int parameterIndex,
 InputStream x,
 int length)
                      throws SQLException

Deprecated.

Sets the specified parameter to the given input stream. Deprecated in JDBC 3.0 and this method will always just throw a feature not implemented exception.

Specified by:

setUnicodeStream in interface PreparedStatement

Parameters:

parameterIndex - the first parameter is 1, the second is 2, ...

x - the java input stream which contains the UNICODE parameter value

length - the number of bytes in the stream

Throws:

SQLException - throws feature not implemented.

setCharacterStream

public void setCharacterStream(int parameterIndex,
 Reader x)
                        throws SQLException

Sets the designated parameter to the given Reader object. When a very large UNICODE value is input to a LONGVARCHAR parameter, it may be more practical to send it via a java.io.Reader object. The data will be read from the stream as needed until end-of-file is reached. The JDBC driver will do any necessary conversion from UNICODE to the database char format.

Specified by:

setCharacterStream in interface PreparedStatement

Parameters:

parameterIndex - the first parameter is 1, the second is 2, ...

x - the java.io.Reader object that contains the Unicode data

Throws:

SQLException - if a database access error occurs or this method is called on a closed PreparedStatement

setCharacterStream

public void setCharacterStream(int parameterIndex,
 Reader x,
 long length)
                        throws SQLException

Sets the designated parameter to the given Reader, which will have the specified number of bytes.

Specified by:

setCharacterStream in interface PreparedStatement

Parameters:

parameterIndex - the index of the parameter to which this set method is applied

x - the java Reader which contains the UNICODE value

length - the number of bytes in the stream

Throws:

SQLException - thrown on failure.

setCharacterStream

public void setCharacterStream(int parameterIndex,
 Reader x,
 int length)
                        throws SQLException

Sets the designated parameter to the given Reader, which will have the specified number of bytes.

Specified by:

setCharacterStream in interface PreparedStatement

Parameters:

parameterIndex - the index of the parameter to which this set method is applied

x - the java Reader which contains the UNICODE value

length - the number of bytes in the stream

Throws:

SQLException - thrown on failure.

setBlob

public void setBlob(int parameterIndex,
 Blob x)
             throws SQLException

Specified by:

setBlob in interface PreparedStatement

Throws:

SQLException

setBlobX

private void setBlobX(int parameterIndex,
 Blob x)
               throws SqlException

Throws:

SqlException

setClob

public void setClob(int parameterIndex,
 Clob x)
             throws SQLException

Specified by:

setClob in interface PreparedStatement

Throws:

SQLException

setClobX

private void setClobX(int parameterIndex,
 Clob x)
               throws SqlException

Throws:

SqlException

setArray

public void setArray(int parameterIndex,
 Array x)
              throws SQLException

Specified by:

setArray in interface PreparedStatement

Throws:

SQLException

setRef

public void setRef(int parameterIndex,
 Ref x)
            throws SQLException

Specified by:

setRef in interface PreparedStatement

Throws:

SQLException

setObject

public void setObject(int parameterIndex,
 Object x)
               throws SQLException

Specified by:

setObject in interface PreparedStatement

Throws:

SQLException

setUDTX

private void setUDTX(int parameterIndex,
 Object x)
              throws SqlException,
SQLException

Set a UDT parameter to an object value.

Throws:

SqlException

SQLException

setObject

public void setObject(int parameterIndex,
 Object x,
 int targetJdbcType)
               throws SQLException

Specified by:

setObject in interface PreparedStatement

Throws:

SQLException

setObject

public void setObject(int parameterIndex,
 Object x,
 int targetJdbcType,
 int scale)
               throws SQLException

Specified by:

setObject in interface PreparedStatement

Throws:

SQLException

setObjectX

private void setObjectX(int parameterIndex,
 Object x,
 int targetJdbcType,
 int scale)
                 throws SqlException

Throws:

SqlException

clearParameters

public void clearParameters()
                     throws SQLException

Specified by:

clearParameters in interface PreparedStatement

Throws:

SQLException

execute

public boolean execute()
                throws SQLException

Specified by:

execute in interface PreparedStatement

Throws:

SQLException

executeX

boolean executeX()
          throws SqlException

Throws:

SqlException

addBatch

public void addBatch()
              throws SQLException

Specified by:

addBatch in interface PreparedStatement

Throws:

SQLException

executeBatch

public int[] executeBatch()
                   throws SQLException

Specified by:

executeBatch in interface Statement

Overrides:

executeBatch in class ClientStatement

Throws:

SQLException

getMetaData

public ResultSetMetaData getMetaData()
                              throws SQLException

Specified by:

getMetaData in interface PreparedStatement

Throws:

SQLException

getMetaDataX

private ColumnMetaData getMetaDataX()
                             throws SqlException

Throws:

SqlException

execute

public boolean execute(String sql,
 int autoGeneratedKeys)
                throws SQLException

Specified by:

execute in interface Statement

Overrides:

execute in class ClientStatement

Throws:

SQLException

execute

public boolean execute(String sql,
 String[] columnNames)
                throws SQLException

Specified by:

execute in interface Statement

Overrides:

execute in class ClientStatement

Throws:

SQLException

execute

public boolean execute(String sql,
 int[] columnIndexes)
                throws SQLException

Specified by:

execute in interface Statement

Overrides:

execute in class ClientStatement

Throws:

SQLException

executeUpdate

public int executeUpdate(String sql,
 int autoGeneratedKeys)
                  throws SQLException

Specified by:

executeUpdate in interface Statement

Overrides:

executeUpdate in class ClientStatement

Throws:

SQLException

executeUpdate

public int executeUpdate(String sql,
 String[] columnNames)
                  throws SQLException

Specified by:

executeUpdate in interface Statement

Overrides:

executeUpdate in class ClientStatement

Throws:

SQLException

executeUpdate

public int executeUpdate(String sql,
 int[] columnIndexes)
                  throws SQLException

Specified by:

executeUpdate in interface Statement

Overrides:

executeUpdate in class ClientStatement

Throws:

SQLException

setURL

public void setURL(int parameterIndex,
 URL x)
            throws SQLException

Specified by:

setURL in interface PreparedStatement

Throws:

SQLException

getParameterMetaData

public ParameterMetaData getParameterMetaData()
                                       throws SQLException

Specified by:

getParameterMetaData in interface PreparedStatement

Throws:

SQLException

getParameterMetaDataX

private ClientParameterMetaData getParameterMetaDataX()
                                               throws SqlException

Throws:

SqlException

getColumnMetaDataX

private ColumnMetaData getColumnMetaDataX()
                                   throws SqlException

Throws:

SqlException

writeExecute

private void writeExecute(Section section,
 ColumnMetaData parameterMetaData,
 Object[] inputs,
 int numInputColumns,
 boolean outputExpected,
 boolean chainedWritesFollowingSetLob)
                   throws SqlException

Throws:

SqlException

readExecute

private void readExecute()
                  throws SqlException

Throws:

SqlException

writeOpenQuery

private void writeOpenQuery(Section section,
 int fetchSize,
 int resultSetType,
 int numInputColumns,
 ColumnMetaData parameterMetaData,
 Object[] inputs)
                     throws SqlException

Throws:

SqlException

writeDescribeInput

private void writeDescribeInput(Section section)
                         throws SqlException

Throws:

SqlException

readDescribeInput

private void readDescribeInput()
                        throws SqlException

Throws:

SqlException

completeDescribeInput

public void completeDescribeInput(ColumnMetaData parameterMetaData,
 Sqlca sqlca)

Specified by:

completeDescribeInput in interface PreparedStatementCallbackInterface

completeDescribeOutput

public void completeDescribeOutput(ColumnMetaData resultSetMetaData,
 Sqlca sqlca)

Specified by:

completeDescribeOutput in interface PreparedStatementCallbackInterface

writePrepareDescribeInputOutput

private void writePrepareDescribeInputOutput()
                                      throws SqlException

Throws:

SqlException

readPrepareDescribeInputOutput

private void readPrepareDescribeInputOutput()
                                     throws SqlException

Throws:

SqlException

writePrepareDescribeInput

private void writePrepareDescribeInput()
                                throws SqlException

Throws:

SqlException

readPrepareDescribeInput

private void readPrepareDescribeInput()
                               throws SqlException

Throws:

SqlException

completePrepareDescribe

private void completePrepareDescribe()

expandObjectArray

private Object[] expandObjectArray(Object[] array,
 int newLength)

expandBooleanArray

private boolean[] expandBooleanArray(boolean[] array,
 int newLength)

flowPrepareDescribeInputOutput

void flowPrepareDescribeInputOutput()
                             throws SqlException

Throws:

SqlException

flowExecute

private void flowExecute(int executeType)
                  throws SqlException

Throws:

SqlException

executeBatchX

private long[] executeBatchX(boolean supportsQueryBatchRequest)
                      throws SqlException,
SQLException

Throws:

SqlException

SQLException

executeBatchRequestX

private long[] executeBatchRequestX(boolean supportsQueryBatchRequest)
                             throws SqlException,
BatchUpdateException

Throws:

SqlException

BatchUpdateException

listenToUnitOfWork

public void listenToUnitOfWork()

Specified by:

listenToUnitOfWork in interface UnitOfWorkListener

Overrides:

listenToUnitOfWork in class ClientStatement

completeLocalCommit

public void completeLocalCommit(Iterator listenerIterator)

Specified by:

completeLocalCommit in interface UnitOfWorkListener

Overrides:

completeLocalCommit in class ClientStatement

completeLocalRollback

public void completeLocalRollback(Iterator listenerIterator)

Specified by:

completeLocalRollback in interface UnitOfWorkListener

Overrides:

completeLocalRollback in class ClientStatement

getJdbcStatementInterfaceName

protected String getJdbcStatementInterfaceName()

Returns the name of the java.sql interface implemented by this class.

Overrides:

getJdbcStatementInterfaceName in class ClientStatement

Returns:

name of java.sql interface

checkForValidParameterIndex

void checkForValidParameterIndex(int parameterIndex)
                          throws SqlException

Throws:

SqlException

checkThatAllParametersAreSet

private void checkThatAllParametersAreSet()
                                   throws SqlException

Throws:

SqlException

checkForValidScale

void checkForValidScale(int scale)
                 throws SqlException

Throws:

SqlException

markClosed

protected void markClosed(boolean removeListener)

Description copied from class: ClientStatement

This method cleans up client-side resources held by this Statement. If removeListener is true, the Statement is removed from open statements list and PreparedStatement is also removed from commit and rollback listeners list. This is called from the close methods.

Overrides:

markClosed in class ClientStatement

Parameters:

removeListener - if true the Statement will be removed from the open statements list and PreparedStatement will also be removed from commit and rollback listeners list in org.apache.derby.client.am.Connection.

setAsciiStream

public void setAsciiStream(int parameterIndex,
 InputStream x)
                    throws SQLException

Sets the designated parameter to the given input stream. When a very large ASCII value is input to a LONGVARCHAR parameter, it may be more practical to send it via a java.io.InputStream. Data will be read from the stream as needed until end-of-file is reached. The JDBC driver will do any necessary conversion from ASCII to the database char format.

Specified by:

setAsciiStream in interface PreparedStatement

Parameters:

parameterIndex - the first parameter is 1, the second is 2, ...

x - the Java input stream that contains the ASCII parameter value

Throws:

SQLException - if a database access error occurs or this method is called on a closed PreparedStatement

setBinaryStream

public void setBinaryStream(int parameterIndex,
 InputStream x)
                     throws SQLException

Sets the designated parameter to the given input stream. When a very large binary value is input to a LONGVARBINARY parameter, it may be more practical to send it via a java.io.InputStream object. The data will be read from the stream as needed until end-of-file is reached.

Specified by:

setBinaryStream in interface PreparedStatement

Parameters:

parameterIndex - the first parameter is 1, the second is 2, ...

x - the java input stream which contains the binary parameter value

Throws:

SQLException - if a database access error occurs or this method is called on a closed PreparedStatement

setClob

public void setClob(int parameterIndex,
 Reader reader)
             throws SQLException

Sets the designated parameter to a Reader object.

Specified by:

setClob in interface PreparedStatement

Parameters:

parameterIndex - index of the first parameter is 1, the second is 2, ...

reader - an object that contains the data to set the parameter value to.

Throws:

SQLException - if parameterIndex does not correspond to a parameter marker in the SQL statement; if a database access error occurs; this method is called on a closed PreparedStatementor if parameterIndex does not correspond to a parameter marker in the SQL statement

setClob

public void setClob(int parameterIndex,
 Reader reader,
 long length)
             throws SQLException

Sets the designated parameter to a Reader object.

Specified by:

setClob in interface PreparedStatement

Parameters:

parameterIndex - index of the first parameter is 1, the second is 2, ...

reader - An object that contains the data to set the parameter value to.

length - the number of characters in the parameter data.

Throws:

SQLException - if parameterIndex does not correspond to a parameter marker in the SQL statement, or if the length specified is less than zero.

setBlob

public void setBlob(int parameterIndex,
 InputStream inputStream)
             throws SQLException

Sets the designated parameter to a InputStream object. This method differs from the setBinaryStream(int, InputStream) method because it informs the driver that the parameter value should be sent to the server as a BLOB. When the setBinaryStream method is used, the driver may have to do extra work to determine whether the parameter data should be sent to the server as a LONGVARBINARY or a BLOB

Specified by:

setBlob in interface PreparedStatement

Parameters:

parameterIndex - index of the first parameter is 1, the second is 2, ...

inputStream - an object that contains the data to set the parameter value to.

Throws:

SQLException - if a database access error occurs, this method is called on a closed PreparedStatement or if parameterIndex does not correspond to a parameter marker in the SQL statement

setBlob

public void setBlob(int parameterIndex,
 InputStream inputStream,
 long length)
             throws SQLException

Sets the designated parameter to a InputStream object.

Specified by:

setBlob in interface PreparedStatement

Parameters:

parameterIndex - index of the first parameter is 1, the second is 2, ...

inputStream - An object that contains the data to set the parameter value to.

length - the number of bytes in the parameter data.

Throws:

SQLException - if parameterIndex does not correspond to a parameter marker in the SQL statement, if the length specified is less than zero or if the number of bytes in the inputstream does not match the specfied length.

setNString

public void setNString(int index,
 String value)
                throws SQLException

Specified by:

setNString in interface PreparedStatement

Throws:

SQLException

setNCharacterStream

public void setNCharacterStream(int parameterIndex,
 Reader value)
                         throws SQLException

Specified by:

setNCharacterStream in interface PreparedStatement

Throws:

SQLException

setNCharacterStream

public void setNCharacterStream(int index,
 Reader value,
 long length)
                         throws SQLException

Specified by:

setNCharacterStream in interface PreparedStatement

Throws:

SQLException

setNClob

public void setNClob(int parameterIndex,
 Reader reader)
              throws SQLException

Specified by:

setNClob in interface PreparedStatement

Throws:

SQLException

setNClob

public void setNClob(int parameterIndex,
 Reader reader,
 long length)
              throws SQLException

Specified by:

setNClob in interface PreparedStatement

Throws:

SQLException

setRowId

public void setRowId(int parameterIndex,
 RowId x)
              throws SQLException

Specified by:

setRowId in interface PreparedStatement

Throws:

SQLException

setNClob

public void setNClob(int index,
 NClob value)
              throws SQLException

Specified by:

setNClob in interface PreparedStatement

Throws:

SQLException

setSQLXML

public void setSQLXML(int parameterIndex,
 SQLXML xmlObject)
               throws SQLException

Specified by:

setSQLXML in interface PreparedStatement

Throws:

SQLException

executeLargeUpdate

public long executeLargeUpdate()
                        throws SQLException

Specified by:

executeLargeUpdate in interface PreparedStatement

Throws:

SQLException

checkStatementValidity

private void checkStatementValidity(SqlException sqle)
                             throws SQLException

Throws:

SQLException

checkStatus

protected void checkStatus()
                    throws SQLException

Check for closed statement and extract the SQLException if it is raised.

Throws:

SQLException