org.apache.openjpa.slice.jdbc
Class DistributedTemplate<T extends Statement>
java.lang.Object
   org.apache.openjpa.slice.jdbc.DistributedTemplate<T>
org.apache.openjpa.slice.jdbc.DistributedTemplate<T>
- All Implemented Interfaces: 
- Iterable<T>, Statement, Wrapper
- Direct Known Subclasses: 
- DistributedPreparedStatement, DistributedStatement
- public abstract class DistributedTemplate<T extends Statement> 
- extends Object- implements Statement, Iterable<T>
A template for multiple Statements being executed by multiple connections.
- Author:
- Pinaki Poddar
 
 
 
 
| Methods inherited from class java.lang.Object | 
| clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait | 
 
 
 
concreteImpl
static final Constructor<DistributedTemplate> concreteImpl
stmts
protected List<T extends Statement> stmts
con
protected final DistributedConnection con
master
protected T extends Statement master
DistributedTemplate
public DistributedTemplate(DistributedConnection c)
newInstance
public static DistributedTemplate newInstance(DistributedConnection conn)
- 
 
- 
 
iterator
public Iterator<T> iterator()
- 
- Specified by:
- iteratorin interface- Iterable<T extends Statement>
 
- 
 
add
public void add(T s)
- 
 
- 
 
addBatch
public void addBatch(String sql)
              throws SQLException
- 
- Specified by:
- addBatchin interface- Statement
 
- 
- Throws:
- SQLException
 
cancel
public void cancel()
            throws SQLException
- 
- Specified by:
- cancelin interface- Statement
 
- 
- Throws:
- SQLException
 
clearBatch
public void clearBatch()
                throws SQLException
- 
- Specified by:
- clearBatchin interface- Statement
 
- 
- Throws:
- SQLException
 
clearWarnings
public void clearWarnings()
                   throws SQLException
- 
- Specified by:
- clearWarningsin interface- Statement
 
- 
- Throws:
- SQLException
 
close
public void close()
           throws SQLException
- 
- Specified by:
- closein interface- Statement
 
- 
- Throws:
- SQLException
 
execute
public boolean execute(String arg0)
                throws SQLException
- 
- Specified by:
- executein interface- Statement
 
- 
- Throws:
- SQLException
 
execute
public boolean execute(String arg0,
                       int arg1)
                throws SQLException
- 
- Specified by:
- executein interface- Statement
 
- 
- Throws:
- SQLException
 
execute
public boolean execute(String arg0,
                       int[] arg1)
                throws SQLException
- 
- Specified by:
- executein interface- Statement
 
- 
- Throws:
- SQLException
 
execute
public boolean execute(String arg0,
                       String[] arg1)
                throws SQLException
- 
- Specified by:
- executein interface- Statement
 
- 
- Throws:
- SQLException
 
executeBatch
public int[] executeBatch()
                   throws SQLException
- 
- Specified by:
- executeBatchin interface- Statement
 
- 
- Throws:
- SQLException
 
executeQuery
public ResultSet executeQuery()
                       throws SQLException
- 
 
- 
- Throws:
- SQLException
 
executeQuery
public ResultSet executeQuery(String arg0)
                       throws SQLException
- 
- Specified by:
- executeQueryin interface- Statement
 
- 
- Throws:
- SQLException
 
executeUpdate
public int executeUpdate(String arg0)
                  throws SQLException
- 
- Specified by:
- executeUpdatein interface- Statement
 
- 
- Throws:
- SQLException
 
executeUpdate
public int executeUpdate(String arg0,
                         int arg1)
                  throws SQLException
- 
- Specified by:
- executeUpdatein interface- Statement
 
- 
- Throws:
- SQLException
 
executeUpdate
public int executeUpdate(String arg0,
                         int[] arg1)
                  throws SQLException
- 
- Specified by:
- executeUpdatein interface- Statement
 
- 
- Throws:
- SQLException
 
executeUpdate
public int executeUpdate(String arg0,
                         String[] arg1)
                  throws SQLException
- 
- Specified by:
- executeUpdatein interface- Statement
 
- 
- Throws:
- SQLException
 
getConnection
public Connection getConnection()
                         throws SQLException
- 
- Specified by:
- getConnectionin interface- Statement
 
- 
- Throws:
- SQLException
 
getFetchDirection
public int getFetchDirection()
                      throws SQLException
- 
- Specified by:
- getFetchDirectionin interface- Statement
 
- 
- Throws:
- SQLException
 
getFetchSize
public int getFetchSize()
                 throws SQLException
- 
- Specified by:
- getFetchSizein interface- Statement
 
- 
- Throws:
- SQLException
 
getGeneratedKeys
public ResultSet getGeneratedKeys()
                           throws SQLException
- 
- Specified by:
- getGeneratedKeysin interface- Statement
 
- 
- Throws:
- SQLException
 
getMaxFieldSize
public int getMaxFieldSize()
                    throws SQLException
- 
- Specified by:
- getMaxFieldSizein interface- Statement
 
- 
- Throws:
- SQLException
 
getMaxRows
public int getMaxRows()
               throws SQLException
- 
- Specified by:
- getMaxRowsin interface- Statement
 
- 
- Throws:
- SQLException
 
getMoreResults
public boolean getMoreResults()
                       throws SQLException
- 
- Specified by:
- getMoreResultsin interface- Statement
 
- 
- Throws:
- SQLException
 
getMoreResults
public boolean getMoreResults(int arg0)
                       throws SQLException
- 
- Specified by:
- getMoreResultsin interface- Statement
 
- 
- Throws:
- SQLException
 
getQueryTimeout
public int getQueryTimeout()
                    throws SQLException
- 
- Specified by:
- getQueryTimeoutin interface- Statement
 
- 
- Throws:
- SQLException
 
getResultSet
public ResultSet getResultSet()
                       throws SQLException
- 
- Specified by:
- getResultSetin interface- Statement
 
- 
- Throws:
- SQLException
 
getResultSetConcurrency
public int getResultSetConcurrency()
                            throws SQLException
- 
- Specified by:
- getResultSetConcurrencyin interface- Statement
 
- 
- Throws:
- SQLException
 
getResultSetHoldability
public int getResultSetHoldability()
                            throws SQLException
- 
- Specified by:
- getResultSetHoldabilityin interface- Statement
 
- 
- Throws:
- SQLException
 
getResultSetType
public int getResultSetType()
                     throws SQLException
- 
- Specified by:
- getResultSetTypein interface- Statement
 
- 
- Throws:
- SQLException
 
getUpdateCount
public int getUpdateCount()
                   throws SQLException
- 
- Specified by:
- getUpdateCountin interface- Statement
 
- 
- Throws:
- SQLException
 
getWarnings
public SQLWarning getWarnings()
                       throws SQLException
- 
- Specified by:
- getWarningsin interface- Statement
 
- 
- Throws:
- SQLException
 
setCursorName
public void setCursorName(String name)
                   throws SQLException
- 
- Specified by:
- setCursorNamein interface- Statement
 
- 
- Throws:
- SQLException
 
setEscapeProcessing
public void setEscapeProcessing(boolean flag)
                         throws SQLException
- 
- Specified by:
- setEscapeProcessingin interface- Statement
 
- 
- Throws:
- SQLException
 
setFetchDirection
public void setFetchDirection(int dir)
                       throws SQLException
- 
- Specified by:
- setFetchDirectionin interface- Statement
 
- 
- Throws:
- SQLException
 
setFetchSize
public void setFetchSize(int size)
                  throws SQLException
- 
- Specified by:
- setFetchSizein interface- Statement
 
- 
- Throws:
- SQLException
 
setMaxFieldSize
public void setMaxFieldSize(int size)
                     throws SQLException
- 
- Specified by:
- setMaxFieldSizein interface- Statement
 
- 
- Throws:
- SQLException
 
setMaxRows
public void setMaxRows(int n)
                throws SQLException
- 
- Specified by:
- setMaxRowsin interface- Statement
 
- 
- Throws:
- SQLException
 
setQueryTimeout
public void setQueryTimeout(int n)
                     throws SQLException
- 
- Specified by:
- setQueryTimeoutin interface- Statement
 
- 
- Throws:
- SQLException
 
Copyright © 2006-2011 Apache Software Foundation. All Rights Reserved.