java.lang.Object
- org.apache.openjpa.slice.jdbc.DistributedTemplate<T>

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Iterable<T>, java.sql.Statement, java.sql.Wrapper

Direct Known Subclasses:

DistributedPreparedStatement, DistributedStatement
```
public class DistributedTemplate<T extends java.sql.Statement>
extends java.lang.Object
implements java.sql.Statement, java.lang.Iterable<T>
```
A template for multiple Statements being executed by multiple connections.

Author:

Pinaki Poddar

Field Summary

Fields
Modifier and Type Field Description

protected DistributedConnection con

protected T master

protected java.util.List<T> 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

DistributedTemplate(DistributedConnection c)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`add(T s)`
`void`	`addBatch(java.lang.String sql)`
`void`	`cancel()`
`void`	`clearBatch()`
`void`	`clearWarnings()`
`void`	`close()`
`void`	`closeOnCompletion()`
`boolean`	`execute(java.lang.String arg0)`
`boolean`	`execute(java.lang.String arg0, int arg1)`
`boolean`	`execute(java.lang.String arg0, int[] arg1)`
`boolean`	`execute(java.lang.String arg0, java.lang.String[] arg1)`
`int[]`	`executeBatch()`
`java.sql.ResultSet`	`executeQuery()`
`java.sql.ResultSet`	`executeQuery(java.lang.String arg0)`
`int`	`executeUpdate(java.lang.String arg0)`
`int`	`executeUpdate(java.lang.String arg0, int arg1)`
`int`	`executeUpdate(java.lang.String arg0, int[] arg1)`
`int`	`executeUpdate(java.lang.String arg0, java.lang.String[] arg1)`
`java.sql.Connection`	`getConnection()`
`int`	`getFetchDirection()`
`int`	`getFetchSize()`
`java.sql.ResultSet`	`getGeneratedKeys()`
`int`	`getMaxFieldSize()`
`int`	`getMaxRows()`
`boolean`	`getMoreResults()`
`boolean`	`getMoreResults(int arg0)`
`int`	`getQueryTimeout()`
`java.sql.ResultSet`	`getResultSet()`
`int`	`getResultSetConcurrency()`
`int`	`getResultSetHoldability()`
`int`	`getResultSetType()`
`int`	`getUpdateCount()`
`java.sql.SQLWarning`	`getWarnings()`
`boolean`	`isClosed()`
`boolean`	`isCloseOnCompletion()`
`boolean`	`isPoolable()`
`boolean`	`isWrapperFor(java.lang.Class<?> arg0)`
`java.util.Iterator<T>`	`iterator()`
`void`	`setCursorName(java.lang.String name)`
`void`	`setEscapeProcessing(boolean flag)`
`void`	`setFetchDirection(int dir)`
`void`	`setFetchSize(int size)`
`void`	`setMaxFieldSize(int size)`
`void`	`setMaxRows(int n)`
`void`	`setPoolable(boolean arg0)`
`void`	`setQueryTimeout(int n)`
`<T> T`	`unwrap(java.lang.Class<T> arg0)`

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.Statement
enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, getLargeMaxRows, getLargeUpdateCount, isSimpleIdentifier, setLargeMaxRows

Field Detail

stmts

protected java.util.List<T extends java.sql.Statement> stmts

con

protected final DistributedConnection con

master

protected T extends java.sql.Statement master

Constructor Detail

DistributedTemplate

public DistributedTemplate(DistributedConnection c)

Method Detail
- iterator
```
public java.util.Iterator<T> iterator()
```
  Specified by:
  
  iterator in interface java.lang.Iterable<T extends java.sql.Statement>
- add
```
public void add(T s)
```
- addBatch
```
public void addBatch(java.lang.String sql)
              throws java.sql.SQLException
```
  Specified by:
  
  addBatch in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- cancel
```
public void cancel()
            throws java.sql.SQLException
```
  Specified by:
  
  cancel in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- clearBatch
```
public void clearBatch()
                throws java.sql.SQLException
```
  Specified by:
  
  clearBatch in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- clearWarnings
```
public void clearWarnings()
                   throws java.sql.SQLException
```
  Specified by:
  
  clearWarnings in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- close
```
public void close()
           throws java.sql.SQLException
```
  Specified by:
  
  close in interface java.lang.AutoCloseable
  
  Specified by:
  
  close in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- execute
```
public boolean execute(java.lang.String arg0)
                throws java.sql.SQLException
```
  Specified by:
  
  execute in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- execute
```
public boolean execute(java.lang.String arg0,
                       int arg1)
                throws java.sql.SQLException
```
  Specified by:
  
  execute in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- execute
```
public boolean execute(java.lang.String arg0,
                       int[] arg1)
                throws java.sql.SQLException
```
  Specified by:
  
  execute in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- execute
```
public boolean execute(java.lang.String arg0,
                       java.lang.String[] arg1)
                throws java.sql.SQLException
```
  Specified by:
  
  execute in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- executeBatch
```
public int[] executeBatch()
                   throws java.sql.SQLException
```
  Specified by:
  
  executeBatch in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- executeQuery
```
public java.sql.ResultSet executeQuery()
                                throws java.sql.SQLException
```
  Throws:
  
  java.sql.SQLException
- executeQuery
```
public java.sql.ResultSet executeQuery(java.lang.String arg0)
                                throws java.sql.SQLException
```
  Specified by:
  
  executeQuery in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- executeUpdate
```
public int executeUpdate(java.lang.String arg0)
                  throws java.sql.SQLException
```
  Specified by:
  
  executeUpdate in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- executeUpdate
```
public int executeUpdate(java.lang.String arg0,
                         int arg1)
                  throws java.sql.SQLException
```
  Specified by:
  
  executeUpdate in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- executeUpdate
```
public int executeUpdate(java.lang.String arg0,
                         int[] arg1)
                  throws java.sql.SQLException
```
  Specified by:
  
  executeUpdate in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- executeUpdate
```
public int executeUpdate(java.lang.String arg0,
                         java.lang.String[] arg1)
                  throws java.sql.SQLException
```
  Specified by:
  
  executeUpdate in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getConnection
```
public java.sql.Connection getConnection()
                                  throws java.sql.SQLException
```
  Specified by:
  
  getConnection in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getFetchDirection
```
public int getFetchDirection()
                      throws java.sql.SQLException
```
  Specified by:
  
  getFetchDirection in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getFetchSize
```
public int getFetchSize()
                 throws java.sql.SQLException
```
  Specified by:
  
  getFetchSize in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getGeneratedKeys
```
public java.sql.ResultSet getGeneratedKeys()
                                    throws java.sql.SQLException
```
  Specified by:
  
  getGeneratedKeys in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getMaxFieldSize
```
public int getMaxFieldSize()
                    throws java.sql.SQLException
```
  Specified by:
  
  getMaxFieldSize in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getMaxRows
```
public int getMaxRows()
               throws java.sql.SQLException
```
  Specified by:
  
  getMaxRows in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getMoreResults
```
public boolean getMoreResults()
                       throws java.sql.SQLException
```
  Specified by:
  
  getMoreResults in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getMoreResults
```
public boolean getMoreResults(int arg0)
                       throws java.sql.SQLException
```
  Specified by:
  
  getMoreResults in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getQueryTimeout
```
public int getQueryTimeout()
                    throws java.sql.SQLException
```
  Specified by:
  
  getQueryTimeout in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getResultSet
```
public java.sql.ResultSet getResultSet()
                                throws java.sql.SQLException
```
  Specified by:
  
  getResultSet in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getResultSetConcurrency
```
public int getResultSetConcurrency()
                            throws java.sql.SQLException
```
  Specified by:
  
  getResultSetConcurrency in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getResultSetHoldability
```
public int getResultSetHoldability()
                            throws java.sql.SQLException
```
  Specified by:
  
  getResultSetHoldability in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getResultSetType
```
public int getResultSetType()
                     throws java.sql.SQLException
```
  Specified by:
  
  getResultSetType in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getUpdateCount
```
public int getUpdateCount()
                   throws java.sql.SQLException
```
  Specified by:
  
  getUpdateCount in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- getWarnings
```
public java.sql.SQLWarning getWarnings()
                                throws java.sql.SQLException
```
  Specified by:
  
  getWarnings in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- setCursorName
```
public void setCursorName(java.lang.String name)
                   throws java.sql.SQLException
```
  Specified by:
  
  setCursorName in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- setEscapeProcessing
```
public void setEscapeProcessing(boolean flag)
                         throws java.sql.SQLException
```
  Specified by:
  
  setEscapeProcessing in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- setFetchDirection
```
public void setFetchDirection(int dir)
                       throws java.sql.SQLException
```
  Specified by:
  
  setFetchDirection in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- setFetchSize
```
public void setFetchSize(int size)
                  throws java.sql.SQLException
```
  Specified by:
  
  setFetchSize in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- setMaxFieldSize
```
public void setMaxFieldSize(int size)
                     throws java.sql.SQLException
```
  Specified by:
  
  setMaxFieldSize in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- setMaxRows
```
public void setMaxRows(int n)
                throws java.sql.SQLException
```
  Specified by:
  
  setMaxRows in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- setQueryTimeout
```
public void setQueryTimeout(int n)
                     throws java.sql.SQLException
```
  Specified by:
  
  setQueryTimeout in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- isWrapperFor
```
public boolean isWrapperFor(java.lang.Class<?> arg0)
                     throws java.sql.SQLException
```
  Specified by:
  
  isWrapperFor in interface java.sql.Wrapper
  
  Throws:
  
  java.sql.SQLException
- unwrap
```
public <T> T unwrap(java.lang.Class<T> arg0)
             throws java.sql.SQLException
```
  Specified by:
  
  unwrap in interface java.sql.Wrapper
  
  Throws:
  
  java.sql.SQLException
- isClosed
```
public boolean isClosed()
                 throws java.sql.SQLException
```
  Specified by:
  
  isClosed in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- isPoolable
```
public boolean isPoolable()
                   throws java.sql.SQLException
```
  Specified by:
  
  isPoolable in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- setPoolable
```
public void setPoolable(boolean arg0)
                 throws java.sql.SQLException
```
  Specified by:
  
  setPoolable in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- isCloseOnCompletion
```
public boolean isCloseOnCompletion()
                            throws java.sql.SQLException
```
  Specified by:
  
  isCloseOnCompletion in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException
- closeOnCompletion
```
public void closeOnCompletion()
                       throws java.sql.SQLException
```
  Specified by:
  
  closeOnCompletion in interface java.sql.Statement
  
  Throws:
  
  java.sql.SQLException

Modifier and Type	Field	Description
`protected DistributedConnection`	`con`
`protected T`	`master`
`protected java.util.List<T>`	`stmts`

Class DistributedTemplate<T extends java.sql.Statement>

Field Summary

Fields inherited from interface java.sql.Statement

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface java.lang.Iterable

Methods inherited from interface java.sql.Statement

Field Detail

stmts

con

master

Constructor Detail

DistributedTemplate

Method Detail

iterator

add

addBatch

cancel

clearBatch

clearWarnings

close

execute

execute

execute

execute

executeBatch

executeQuery

executeQuery

executeUpdate

executeUpdate

executeUpdate

executeUpdate

getConnection

getFetchDirection

getFetchSize

getGeneratedKeys

getMaxFieldSize

getMaxRows

getMoreResults

getMoreResults

getQueryTimeout

getResultSet

getResultSetConcurrency

getResultSetHoldability

getResultSetType

getUpdateCount

getWarnings

setCursorName

setEscapeProcessing

setFetchDirection

setFetchSize

setMaxFieldSize

setMaxRows

setQueryTimeout

isWrapperFor

unwrap

isClosed

isPoolable

setPoolable

isCloseOnCompletion

closeOnCompletion