org.apache.openjpa.slice.jdbc
Class DistributedConnection
java.lang.Object
   org.apache.openjpa.slice.jdbc.DistributedConnection
org.apache.openjpa.slice.jdbc.DistributedConnection
- All Implemented Interfaces: 
- Connection, Wrapper
- public class DistributedConnection 
- extends Object- implements Connection
A virtual connection that contains multiple physical connections.
- Author:
- Pinaki Poddar
 
 
 
| Method Summary | 
|  void | abort(Executor executor)
 | 
|  void | clearWarnings()
 | 
|  void | close()
 | 
|  void | commit()
 | 
|  boolean | contains(Connection c)
 | 
|  Array | createArrayOf(String arg0,
              Object[] arg1)
 | 
|  Blob | createBlob()
 | 
|  Clob | createClob()
 | 
|  NClob | createNClob()
 | 
|  SQLXML | createSQLXML()
 | 
|  Statement | createStatement()
 | 
|  Statement | createStatement(int arg0,
                int arg1)
 | 
|  Statement | createStatement(int arg0,
                int arg1,
                int arg2)
 | 
|  Struct | createStruct(String arg0,
             Object[] arg1)
 | 
|  boolean | getAutoCommit()
 | 
|  String | getCatalog()
 | 
|  Properties | getClientInfo()
 | 
|  String | getClientInfo(String arg0)
 | 
|  int | getHoldability()
 | 
|  DatabaseMetaData | getMetaData()
 | 
|  int | getNetworkTimeout()
 | 
|  String | getSchema()
 | 
|  int | getTransactionIsolation()
 | 
|  Map<String,Class<?>> | getTypeMap()
 | 
|  SQLWarning | getWarnings()
 | 
|  boolean | isClosed()
 | 
|  boolean | isReadOnly()
 | 
|  boolean | isValid(int arg0)
 | 
|  boolean | isWrapperFor(Class<?> iface)
 | 
|  String | nativeSQL(String arg0)
 | 
|  CallableStatement | prepareCall(String arg0)
 | 
|  CallableStatement | prepareCall(String arg0,
            int arg1,
            int arg2)
 | 
|  CallableStatement | prepareCall(String arg0,
            int arg1,
            int arg2,
            int arg3)
 | 
|  PreparedStatement | prepareStatement(String arg0)
 | 
|  PreparedStatement | prepareStatement(String arg0,
                 int arg1)
 | 
|  PreparedStatement | prepareStatement(String arg0,
                 int[] arg1)
 | 
|  PreparedStatement | prepareStatement(String arg0,
                 int arg1,
                 int arg2)
 | 
|  PreparedStatement | prepareStatement(String arg0,
                 int arg1,
                 int arg2,
                 int arg3)
 | 
|  PreparedStatement | prepareStatement(String arg0,
                 String[] arg1)
 | 
|  void | releaseSavepoint(Savepoint arg0)
 | 
|  void | rollback()
 | 
|  void | rollback(Savepoint arg0)
 | 
|  void | setAutoCommit(boolean arg0)
 | 
|  void | setCatalog(String arg0)
 | 
|  void | setClientInfo(Properties arg0)
 | 
|  void | setClientInfo(String arg0,
              String arg1)
 | 
|  void | setHoldability(int arg0)
 | 
|  void | setNetworkTimeout(Executor executor,
                  int milliseconds)
 | 
|  void | setReadOnly(boolean arg0)
 | 
|  Savepoint | setSavepoint()
 | 
|  Savepoint | setSavepoint(String arg0)
 | 
|  void | setSchema(String schema)
 | 
|  void | setTransactionIsolation(int arg0)
 | 
|  void | setTypeMap(Map<String,Class<?>> arg0)
 | 
| 
 | unwrap(Class<T> iface)
 | 
 
| Methods inherited from class java.lang.Object | 
| clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait | 
 
DistributedConnection
public DistributedConnection(List<Connection> connections)
contains
public boolean contains(Connection c)
- 
 
- 
 
clearWarnings
public void clearWarnings()
                   throws SQLException
- 
- Specified by:
- clearWarningsin interface- Connection
 
- 
- Throws:
- SQLException
 
close
public void close()
           throws SQLException
- 
- Specified by:
- closein interface- Connection
 
- 
- Throws:
- SQLException
 
commit
public void commit()
            throws SQLException
- 
- Specified by:
- commitin interface- Connection
 
- 
- Throws:
- SQLException
 
createStatement
public Statement createStatement()
                          throws SQLException
- 
- Specified by:
- createStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
createStatement
public Statement createStatement(int arg0,
                                 int arg1)
                          throws SQLException
- 
- Specified by:
- createStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
createStatement
public Statement createStatement(int arg0,
                                 int arg1,
                                 int arg2)
                          throws SQLException
- 
- Specified by:
- createStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
getAutoCommit
public boolean getAutoCommit()
                      throws SQLException
- 
- Specified by:
- getAutoCommitin interface- Connection
 
- 
- Throws:
- SQLException
 
getCatalog
public String getCatalog()
                  throws SQLException
- 
- Specified by:
- getCatalogin interface- Connection
 
- 
- Throws:
- SQLException
 
getHoldability
public int getHoldability()
                   throws SQLException
- 
- Specified by:
- getHoldabilityin interface- Connection
 
- 
- Throws:
- SQLException
 
getMetaData
public DatabaseMetaData getMetaData()
                             throws SQLException
- 
- Specified by:
- getMetaDatain interface- Connection
 
- 
- Throws:
- SQLException
 
getTransactionIsolation
public int getTransactionIsolation()
                            throws SQLException
- 
- Specified by:
- getTransactionIsolationin interface- Connection
 
- 
- Throws:
- SQLException
 
getTypeMap
public Map<String,Class<?>> getTypeMap()
                                throws SQLException
- 
- Specified by:
- getTypeMapin interface- Connection
 
- 
- Throws:
- SQLException
 
getWarnings
public SQLWarning getWarnings()
                       throws SQLException
- 
- Specified by:
- getWarningsin interface- Connection
 
- 
- Throws:
- SQLException
 
isClosed
public boolean isClosed()
                 throws SQLException
- 
- Specified by:
- isClosedin interface- Connection
 
- 
- Throws:
- SQLException
 
isReadOnly
public boolean isReadOnly()
                   throws SQLException
- 
- Specified by:
- isReadOnlyin interface- Connection
 
- 
- Throws:
- SQLException
 
nativeSQL
public String nativeSQL(String arg0)
                 throws SQLException
- 
- Specified by:
- nativeSQLin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareCall
public CallableStatement prepareCall(String arg0)
                              throws SQLException
- 
- Specified by:
- prepareCallin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareCall
public CallableStatement prepareCall(String arg0,
                                     int arg1,
                                     int arg2)
                              throws SQLException
- 
- Specified by:
- prepareCallin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareCall
public CallableStatement prepareCall(String arg0,
                                     int arg1,
                                     int arg2,
                                     int arg3)
                              throws SQLException
- 
- Specified by:
- prepareCallin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareStatement
public PreparedStatement prepareStatement(String arg0)
                                   throws SQLException
- 
- Specified by:
- prepareStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareStatement
public PreparedStatement prepareStatement(String arg0,
                                          int arg1)
                                   throws SQLException
- 
- Specified by:
- prepareStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareStatement
public PreparedStatement prepareStatement(String arg0,
                                          int[] arg1)
                                   throws SQLException
- 
- Specified by:
- prepareStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareStatement
public PreparedStatement prepareStatement(String arg0,
                                          String[] arg1)
                                   throws SQLException
- 
- Specified by:
- prepareStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareStatement
public PreparedStatement prepareStatement(String arg0,
                                          int arg1,
                                          int arg2)
                                   throws SQLException
- 
- Specified by:
- prepareStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
prepareStatement
public PreparedStatement prepareStatement(String arg0,
                                          int arg1,
                                          int arg2,
                                          int arg3)
                                   throws SQLException
- 
- Specified by:
- prepareStatementin interface- Connection
 
- 
- Throws:
- SQLException
 
releaseSavepoint
public void releaseSavepoint(Savepoint arg0)
                      throws SQLException
- 
- Specified by:
- releaseSavepointin interface- Connection
 
- 
- Throws:
- SQLException
 
rollback
public void rollback()
              throws SQLException
- 
- Specified by:
- rollbackin interface- Connection
 
- 
- Throws:
- SQLException
 
rollback
public void rollback(Savepoint arg0)
              throws SQLException
- 
- Specified by:
- rollbackin interface- Connection
 
- 
- Throws:
- SQLException
 
setAutoCommit
public void setAutoCommit(boolean arg0)
                   throws SQLException
- 
- Specified by:
- setAutoCommitin interface- Connection
 
- 
- Throws:
- SQLException
 
setCatalog
public void setCatalog(String arg0)
                throws SQLException
- 
- Specified by:
- setCatalogin interface- Connection
 
- 
- Throws:
- SQLException
 
setHoldability
public void setHoldability(int arg0)
                    throws SQLException
- 
- Specified by:
- setHoldabilityin interface- Connection
 
- 
- Throws:
- SQLException
 
setReadOnly
public void setReadOnly(boolean arg0)
                 throws SQLException
- 
- Specified by:
- setReadOnlyin interface- Connection
 
- 
- Throws:
- SQLException
 
setSavepoint
public Savepoint setSavepoint()
                       throws SQLException
- 
- Specified by:
- setSavepointin interface- Connection
 
- 
- Throws:
- SQLException
 
setSavepoint
public Savepoint setSavepoint(String arg0)
                       throws SQLException
- 
- Specified by:
- setSavepointin interface- Connection
 
- 
- Throws:
- SQLException
 
setTransactionIsolation
public void setTransactionIsolation(int arg0)
                             throws SQLException
- 
- Specified by:
- setTransactionIsolationin interface- Connection
 
- 
- Throws:
- SQLException
 
setTypeMap
public void setTypeMap(Map<String,Class<?>> arg0)
                throws SQLException
- 
- Specified by:
- setTypeMapin interface- Connection
 
- 
- Throws:
- SQLException
 
isWrapperFor
public boolean isWrapperFor(Class<?> iface)
                     throws SQLException
- 
- Specified by:
- isWrapperForin interface- Wrapper
 
- 
- Throws:
- SQLException
 
unwrap
public <T> T unwrap(Class<T> iface)
         throws SQLException
- 
- Specified by:
- unwrapin interface- Wrapper
 
- 
- Throws:
- SQLException
 
createArrayOf
public Array createArrayOf(String arg0,
                           Object[] arg1)
                    throws SQLException
- 
- Specified by:
- createArrayOfin interface- Connection
 
- 
- Throws:
- SQLException
 
createBlob
public Blob createBlob()
                throws SQLException
- 
- Specified by:
- createBlobin interface- Connection
 
- 
- Throws:
- SQLException
 
createClob
public Clob createClob()
                throws SQLException
- 
- Specified by:
- createClobin interface- Connection
 
- 
- Throws:
- SQLException
 
createNClob
public NClob createNClob()
                  throws SQLException
- 
- Specified by:
- createNClobin interface- Connection
 
- 
- Throws:
- SQLException
 
createSQLXML
public SQLXML createSQLXML()
                    throws SQLException
- 
- Specified by:
- createSQLXMLin interface- Connection
 
- 
- Throws:
- SQLException
 
createStruct
public Struct createStruct(String arg0,
                           Object[] arg1)
                    throws SQLException
- 
- Specified by:
- createStructin interface- Connection
 
- 
- Throws:
- SQLException
 
getClientInfo
public Properties getClientInfo()
                         throws SQLException
- 
- Specified by:
- getClientInfoin interface- Connection
 
- 
- Throws:
- SQLException
 
getClientInfo
public String getClientInfo(String arg0)
                     throws SQLException
- 
- Specified by:
- getClientInfoin interface- Connection
 
- 
- Throws:
- SQLException
 
isValid
public boolean isValid(int arg0)
                throws SQLException
- 
- Specified by:
- isValidin interface- Connection
 
- 
- Throws:
- SQLException
 
setClientInfo
public void setClientInfo(Properties arg0)
                   throws SQLClientInfoException
- 
- Specified by:
- setClientInfoin interface- Connection
 
- 
- Throws:
- SQLClientInfoException
 
setClientInfo
public void setClientInfo(String arg0,
                          String arg1)
                   throws SQLClientInfoException
- 
- Specified by:
- setClientInfoin interface- Connection
 
- 
- Throws:
- SQLClientInfoException
 
abort
public void abort(Executor executor)
           throws SQLException
- 
 
- 
- Throws:
- SQLException
 
getNetworkTimeout
public int getNetworkTimeout()
                      throws SQLException
- 
 
- 
- Throws:
- SQLException
 
setNetworkTimeout
public void setNetworkTimeout(Executor executor,
                              int milliseconds)
                       throws SQLException
- 
 
- 
- Throws:
- SQLException
 
getSchema
public String getSchema()
                 throws SQLException
- 
 
- 
- Throws:
- SQLException
 
setSchema
public void setSchema(String schema)
               throws SQLException
- 
 
- 
- Throws:
- SQLException
 
Copyright © 2006-2013 Apache Software Foundation. All Rights Reserved.