Package org.apache.openjpa.slice.jdbc
Class DistributedPreparedStatement
- java.lang.Object
-
- org.apache.openjpa.slice.jdbc.DistributedTemplate<PreparedStatement>
-
- org.apache.openjpa.slice.jdbc.DistributedPreparedStatement
-
- All Implemented Interfaces:
AutoCloseable
,Iterable<PreparedStatement>
,PreparedStatement
,Statement
,Wrapper
public class DistributedPreparedStatement extends DistributedTemplate<PreparedStatement> implements PreparedStatement
A virtual PreparedStaement that delegates to a set of actual PreparedStatements.- Author:
- Pinaki Poddar
-
-
Field Summary
-
Fields inherited from class org.apache.openjpa.slice.jdbc.DistributedTemplate
con, master, stmts
-
Fields inherited from interface java.sql.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 DistributedPreparedStatement(DistributedConnection c)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addBatch()
void
clearParameters()
void
closeOnCompletion()
boolean
execute()
ResultSet
executeQuery()
int
executeUpdate()
ResultSetMetaData
getMetaData()
ParameterMetaData
getParameterMetaData()
boolean
isCloseOnCompletion()
void
setArray(int i, Array x)
void
setAsciiStream(int arg0, InputStream arg1)
void
setAsciiStream(int arg0, InputStream arg1, int arg2)
void
setAsciiStream(int arg0, InputStream arg1, long arg2)
void
setBigDecimal(int arg0, BigDecimal arg1)
void
setBinaryStream(int arg0, InputStream arg1)
void
setBinaryStream(int arg0, InputStream arg1, int arg2)
void
setBinaryStream(int arg0, InputStream arg1, long arg2)
void
setBlob(int arg0, InputStream arg1)
void
setBlob(int arg0, InputStream arg1, long arg2)
void
setBlob(int arg0, Blob arg1)
void
setBoolean(int arg0, boolean arg1)
void
setByte(int arg0, byte arg1)
void
setBytes(int arg0, byte[] arg1)
void
setCharacterStream(int arg0, Reader arg1)
void
setCharacterStream(int arg0, Reader arg1, int arg2)
void
setCharacterStream(int arg0, Reader arg1, long arg2)
void
setClob(int arg0, Reader arg1)
void
setClob(int arg0, Reader arg1, long arg2)
void
setClob(int arg0, Clob arg1)
void
setDate(int arg0, Date arg1)
void
setDate(int arg0, Date arg1, Calendar arg2)
void
setDouble(int arg0, double arg1)
void
setFloat(int arg0, float arg1)
void
setInt(int arg0, int arg1)
void
setLong(int arg0, long arg1)
void
setNCharacterStream(int arg0, Reader arg1)
void
setNCharacterStream(int arg0, Reader arg1, long arg2)
void
setNClob(int arg0, Reader arg1)
void
setNClob(int arg0, Reader arg1, long arg2)
void
setNClob(int arg0, NClob arg1)
void
setNString(int arg0, String arg1)
void
setNull(int arg0, int arg1)
void
setNull(int arg0, int arg1, String arg2)
void
setObject(int arg0, Object arg1)
void
setObject(int arg0, Object arg1, int arg2)
void
setObject(int arg0, Object arg1, int arg2, int arg3)
void
setRef(int arg0, Ref arg1)
void
setRowId(int arg0, RowId arg1)
void
setShort(int arg0, short arg1)
void
setSQLXML(int arg0, SQLXML arg1)
void
setString(int arg0, String arg1)
void
setTime(int arg0, Time arg1)
void
setTime(int arg0, Time arg1, Calendar arg2)
void
setTimestamp(int arg0, Timestamp arg1)
void
setTimestamp(int arg0, Timestamp arg1, Calendar arg2)
void
setUnicodeStream(int arg0, InputStream arg1, int arg2)
void
setURL(int arg0, URL arg1)
-
Methods inherited from class org.apache.openjpa.slice.jdbc.DistributedTemplate
add, addBatch, cancel, clearBatch, clearWarnings, close, execute, execute, execute, execute, executeBatch, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getConnection, getFetchDirection, getFetchSize, getGeneratedKeys, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isPoolable, isWrapperFor, iterator, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout, unwrap
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
Methods inherited from interface java.sql.PreparedStatement
executeLargeUpdate, setObject, setObject
-
Methods inherited from interface java.sql.Statement
addBatch, cancel, clearBatch, clearWarnings, close, enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, execute, execute, execute, execute, executeBatch, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getConnection, getFetchDirection, getFetchSize, getGeneratedKeys, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isPoolable, isSimpleIdentifier, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout
-
Methods inherited from interface java.sql.Wrapper
isWrapperFor, unwrap
-
-
-
-
Constructor Detail
-
DistributedPreparedStatement
public DistributedPreparedStatement(DistributedConnection c)
-
-
Method Detail
-
clearParameters
public void clearParameters() throws SQLException
- Specified by:
clearParameters
in interfacePreparedStatement
- Throws:
SQLException
-
execute
public boolean execute() throws SQLException
- Specified by:
execute
in interfacePreparedStatement
- Throws:
SQLException
-
executeQuery
public ResultSet executeQuery() throws SQLException
- Specified by:
executeQuery
in interfacePreparedStatement
- Overrides:
executeQuery
in classDistributedTemplate<PreparedStatement>
- Throws:
SQLException
-
executeUpdate
public int executeUpdate() throws SQLException
- Specified by:
executeUpdate
in interfacePreparedStatement
- Throws:
SQLException
-
getMetaData
public ResultSetMetaData getMetaData() throws SQLException
- Specified by:
getMetaData
in interfacePreparedStatement
- Throws:
SQLException
-
getParameterMetaData
public ParameterMetaData getParameterMetaData() throws SQLException
- Specified by:
getParameterMetaData
in interfacePreparedStatement
- Throws:
SQLException
-
setArray
public void setArray(int i, Array x) throws SQLException
- Specified by:
setArray
in interfacePreparedStatement
- Throws:
SQLException
-
setAsciiStream
public void setAsciiStream(int arg0, InputStream arg1, int arg2) throws SQLException
- Specified by:
setAsciiStream
in interfacePreparedStatement
- Throws:
SQLException
-
setBigDecimal
public void setBigDecimal(int arg0, BigDecimal arg1) throws SQLException
- Specified by:
setBigDecimal
in interfacePreparedStatement
- Throws:
SQLException
-
setBinaryStream
public void setBinaryStream(int arg0, InputStream arg1, int arg2) throws SQLException
- Specified by:
setBinaryStream
in interfacePreparedStatement
- Throws:
SQLException
-
setBlob
public void setBlob(int arg0, Blob arg1) throws SQLException
- Specified by:
setBlob
in interfacePreparedStatement
- Throws:
SQLException
-
setBoolean
public void setBoolean(int arg0, boolean arg1) throws SQLException
- Specified by:
setBoolean
in interfacePreparedStatement
- Throws:
SQLException
-
setByte
public void setByte(int arg0, byte arg1) throws SQLException
- Specified by:
setByte
in interfacePreparedStatement
- Throws:
SQLException
-
setBytes
public void setBytes(int arg0, byte[] arg1) throws SQLException
- Specified by:
setBytes
in interfacePreparedStatement
- Throws:
SQLException
-
setCharacterStream
public void setCharacterStream(int arg0, Reader arg1, int arg2) throws SQLException
- Specified by:
setCharacterStream
in interfacePreparedStatement
- Throws:
SQLException
-
setClob
public void setClob(int arg0, Clob arg1) throws SQLException
- Specified by:
setClob
in interfacePreparedStatement
- Throws:
SQLException
-
setDate
public void setDate(int arg0, Date arg1) throws SQLException
- Specified by:
setDate
in interfacePreparedStatement
- Throws:
SQLException
-
setDate
public void setDate(int arg0, Date arg1, Calendar arg2) throws SQLException
- Specified by:
setDate
in interfacePreparedStatement
- Throws:
SQLException
-
setDouble
public void setDouble(int arg0, double arg1) throws SQLException
- Specified by:
setDouble
in interfacePreparedStatement
- Throws:
SQLException
-
setFloat
public void setFloat(int arg0, float arg1) throws SQLException
- Specified by:
setFloat
in interfacePreparedStatement
- Throws:
SQLException
-
setInt
public void setInt(int arg0, int arg1) throws SQLException
- Specified by:
setInt
in interfacePreparedStatement
- Throws:
SQLException
-
setLong
public void setLong(int arg0, long arg1) throws SQLException
- Specified by:
setLong
in interfacePreparedStatement
- Throws:
SQLException
-
setNull
public void setNull(int arg0, int arg1) throws SQLException
- Specified by:
setNull
in interfacePreparedStatement
- Throws:
SQLException
-
setNull
public void setNull(int arg0, int arg1, String arg2) throws SQLException
- Specified by:
setNull
in interfacePreparedStatement
- Throws:
SQLException
-
setObject
public void setObject(int arg0, Object arg1) throws SQLException
- Specified by:
setObject
in interfacePreparedStatement
- Throws:
SQLException
-
setObject
public void setObject(int arg0, Object arg1, int arg2) throws SQLException
- Specified by:
setObject
in interfacePreparedStatement
- Throws:
SQLException
-
setObject
public void setObject(int arg0, Object arg1, int arg2, int arg3) throws SQLException
- Specified by:
setObject
in interfacePreparedStatement
- Throws:
SQLException
-
setRef
public void setRef(int arg0, Ref arg1) throws SQLException
- Specified by:
setRef
in interfacePreparedStatement
- Throws:
SQLException
-
setShort
public void setShort(int arg0, short arg1) throws SQLException
- Specified by:
setShort
in interfacePreparedStatement
- Throws:
SQLException
-
setString
public void setString(int arg0, String arg1) throws SQLException
- Specified by:
setString
in interfacePreparedStatement
- Throws:
SQLException
-
setTime
public void setTime(int arg0, Time arg1) throws SQLException
- Specified by:
setTime
in interfacePreparedStatement
- Throws:
SQLException
-
setTime
public void setTime(int arg0, Time arg1, Calendar arg2) throws SQLException
- Specified by:
setTime
in interfacePreparedStatement
- Throws:
SQLException
-
setTimestamp
public void setTimestamp(int arg0, Timestamp arg1) throws SQLException
- Specified by:
setTimestamp
in interfacePreparedStatement
- Throws:
SQLException
-
setTimestamp
public void setTimestamp(int arg0, Timestamp arg1, Calendar arg2) throws SQLException
- Specified by:
setTimestamp
in interfacePreparedStatement
- Throws:
SQLException
-
setURL
public void setURL(int arg0, URL arg1) throws SQLException
- Specified by:
setURL
in interfacePreparedStatement
- Throws:
SQLException
-
setUnicodeStream
public void setUnicodeStream(int arg0, InputStream arg1, int arg2) throws SQLException
- Specified by:
setUnicodeStream
in interfacePreparedStatement
- Throws:
SQLException
-
addBatch
public void addBatch() throws SQLException
- Specified by:
addBatch
in interfacePreparedStatement
- Throws:
SQLException
-
setAsciiStream
public void setAsciiStream(int arg0, InputStream arg1) throws SQLException
- Specified by:
setAsciiStream
in interfacePreparedStatement
- Throws:
SQLException
-
setAsciiStream
public void setAsciiStream(int arg0, InputStream arg1, long arg2) throws SQLException
- Specified by:
setAsciiStream
in interfacePreparedStatement
- Throws:
SQLException
-
setBinaryStream
public void setBinaryStream(int arg0, InputStream arg1) throws SQLException
- Specified by:
setBinaryStream
in interfacePreparedStatement
- Throws:
SQLException
-
setBinaryStream
public void setBinaryStream(int arg0, InputStream arg1, long arg2) throws SQLException
- Specified by:
setBinaryStream
in interfacePreparedStatement
- Throws:
SQLException
-
setBlob
public void setBlob(int arg0, InputStream arg1) throws SQLException
- Specified by:
setBlob
in interfacePreparedStatement
- Throws:
SQLException
-
setBlob
public void setBlob(int arg0, InputStream arg1, long arg2) throws SQLException
- Specified by:
setBlob
in interfacePreparedStatement
- Throws:
SQLException
-
setCharacterStream
public void setCharacterStream(int arg0, Reader arg1) throws SQLException
- Specified by:
setCharacterStream
in interfacePreparedStatement
- Throws:
SQLException
-
setCharacterStream
public void setCharacterStream(int arg0, Reader arg1, long arg2) throws SQLException
- Specified by:
setCharacterStream
in interfacePreparedStatement
- Throws:
SQLException
-
setClob
public void setClob(int arg0, Reader arg1) throws SQLException
- Specified by:
setClob
in interfacePreparedStatement
- Throws:
SQLException
-
setClob
public void setClob(int arg0, Reader arg1, long arg2) throws SQLException
- Specified by:
setClob
in interfacePreparedStatement
- Throws:
SQLException
-
setNCharacterStream
public void setNCharacterStream(int arg0, Reader arg1) throws SQLException
- Specified by:
setNCharacterStream
in interfacePreparedStatement
- Throws:
SQLException
-
setNCharacterStream
public void setNCharacterStream(int arg0, Reader arg1, long arg2) throws SQLException
- Specified by:
setNCharacterStream
in interfacePreparedStatement
- Throws:
SQLException
-
setNClob
public void setNClob(int arg0, NClob arg1) throws SQLException
- Specified by:
setNClob
in interfacePreparedStatement
- Throws:
SQLException
-
setNClob
public void setNClob(int arg0, Reader arg1) throws SQLException
- Specified by:
setNClob
in interfacePreparedStatement
- Throws:
SQLException
-
setNClob
public void setNClob(int arg0, Reader arg1, long arg2) throws SQLException
- Specified by:
setNClob
in interfacePreparedStatement
- Throws:
SQLException
-
setNString
public void setNString(int arg0, String arg1) throws SQLException
- Specified by:
setNString
in interfacePreparedStatement
- Throws:
SQLException
-
setRowId
public void setRowId(int arg0, RowId arg1) throws SQLException
- Specified by:
setRowId
in interfacePreparedStatement
- Throws:
SQLException
-
setSQLXML
public void setSQLXML(int arg0, SQLXML arg1) throws SQLException
- Specified by:
setSQLXML
in interfacePreparedStatement
- Throws:
SQLException
-
isCloseOnCompletion
public boolean isCloseOnCompletion() throws SQLException
- Specified by:
isCloseOnCompletion
in interfaceStatement
- Overrides:
isCloseOnCompletion
in classDistributedTemplate<PreparedStatement>
- Throws:
SQLException
-
closeOnCompletion
public void closeOnCompletion() throws SQLException
- Specified by:
closeOnCompletion
in interfaceStatement
- Overrides:
closeOnCompletion
in classDistributedTemplate<PreparedStatement>
- Throws:
SQLException
-
-