Class ImportDumpConnection
- java.lang.Object
-
- de.akquinet.jbosscc.guttenbase.export.ImportDumpConnection
-
- All Implemented Interfaces:
AutoCloseable
,Connection
,Wrapper
public class ImportDumpConnection extends Object implements Connection
Special "Connection
" that supports reading data from a stream.© 2012-2034 akquinet tech@spree
- Author:
- M. Dahm
-
-
Field Summary
-
Fields inherited from interface java.sql.Connection
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE
-
-
Constructor Summary
Constructors Constructor Description ImportDumpConnection(Importer importer, DatabaseMetaData databaseMetaData)
-
Method Summary
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.sql.Connection
beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid
-
-
-
-
Constructor Detail
-
ImportDumpConnection
public ImportDumpConnection(Importer importer, DatabaseMetaData databaseMetaData)
-
-
Method Detail
-
initializeReadTable
public void initializeReadTable(TableMetaData table)
-
finalizeReadTable
public void finalizeReadTable(TableMetaData table)
-
prepareStatement
public PreparedStatement prepareStatement(String sql)
Returns custom PreparedStatement statement.- Specified by:
prepareStatement
in interfaceConnection
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceConnection
-
isClosed
public boolean isClosed()
- Specified by:
isClosed
in interfaceConnection
-
commit
public void commit()
- Specified by:
commit
in interfaceConnection
-
setAutoCommit
public void setAutoCommit(boolean autoCommit)
- Specified by:
setAutoCommit
in interfaceConnection
-
getAutoCommit
public boolean getAutoCommit()
- Specified by:
getAutoCommit
in interfaceConnection
-
rollback
public void rollback()
- Specified by:
rollback
in interfaceConnection
-
setReadOnly
public void setReadOnly(boolean readOnly)
- Specified by:
setReadOnly
in interfaceConnection
-
isReadOnly
public boolean isReadOnly()
- Specified by:
isReadOnly
in interfaceConnection
-
createStatement
public Statement createStatement()
- Specified by:
createStatement
in interfaceConnection
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface)
- Specified by:
isWrapperFor
in interfaceWrapper
-
prepareCall
public CallableStatement prepareCall(String sql)
- Specified by:
prepareCall
in interfaceConnection
-
nativeSQL
public String nativeSQL(String sql)
- Specified by:
nativeSQL
in interfaceConnection
-
getMetaData
public DatabaseMetaData getMetaData()
- Specified by:
getMetaData
in interfaceConnection
-
setCatalog
public void setCatalog(String catalog)
- Specified by:
setCatalog
in interfaceConnection
-
getCatalog
public String getCatalog()
- Specified by:
getCatalog
in interfaceConnection
-
setTransactionIsolation
public void setTransactionIsolation(int level)
- Specified by:
setTransactionIsolation
in interfaceConnection
-
getTransactionIsolation
public int getTransactionIsolation()
- Specified by:
getTransactionIsolation
in interfaceConnection
-
getWarnings
public SQLWarning getWarnings()
- Specified by:
getWarnings
in interfaceConnection
-
clearWarnings
public void clearWarnings()
- Specified by:
clearWarnings
in interfaceConnection
-
createStatement
public Statement createStatement(int resultSetType, int resultSetConcurrency)
- Specified by:
createStatement
in interfaceConnection
-
prepareStatement
public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
- Specified by:
prepareStatement
in interfaceConnection
-
prepareCall
public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency)
- Specified by:
prepareCall
in interfaceConnection
-
getTypeMap
public Map<String,Class<?>> getTypeMap()
- Specified by:
getTypeMap
in interfaceConnection
-
setTypeMap
public void setTypeMap(Map<String,Class<?>> map)
- Specified by:
setTypeMap
in interfaceConnection
-
setHoldability
public void setHoldability(int holdability)
- Specified by:
setHoldability
in interfaceConnection
-
getHoldability
public int getHoldability()
- Specified by:
getHoldability
in interfaceConnection
-
setSavepoint
public Savepoint setSavepoint()
- Specified by:
setSavepoint
in interfaceConnection
-
setSavepoint
public Savepoint setSavepoint(String name)
- Specified by:
setSavepoint
in interfaceConnection
-
rollback
public void rollback(Savepoint savepoint)
- Specified by:
rollback
in interfaceConnection
-
releaseSavepoint
public void releaseSavepoint(Savepoint savepoint)
- Specified by:
releaseSavepoint
in interfaceConnection
-
createStatement
public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
- Specified by:
createStatement
in interfaceConnection
-
prepareStatement
public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
- Specified by:
prepareStatement
in interfaceConnection
-
prepareCall
public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
- Specified by:
prepareCall
in interfaceConnection
-
prepareStatement
public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys)
- Specified by:
prepareStatement
in interfaceConnection
-
prepareStatement
public PreparedStatement prepareStatement(String sql, int[] columnIndexes)
- Specified by:
prepareStatement
in interfaceConnection
-
prepareStatement
public PreparedStatement prepareStatement(String sql, String[] columnNames)
- Specified by:
prepareStatement
in interfaceConnection
-
createClob
public Clob createClob()
- Specified by:
createClob
in interfaceConnection
-
createBlob
public Blob createBlob()
- Specified by:
createBlob
in interfaceConnection
-
createNClob
public NClob createNClob()
- Specified by:
createNClob
in interfaceConnection
-
createSQLXML
public SQLXML createSQLXML()
- Specified by:
createSQLXML
in interfaceConnection
-
isValid
public boolean isValid(int timeout)
- Specified by:
isValid
in interfaceConnection
-
setClientInfo
public void setClientInfo(String name, String value) throws SQLClientInfoException
- Specified by:
setClientInfo
in interfaceConnection
- Throws:
SQLClientInfoException
-
setClientInfo
public void setClientInfo(Properties properties) throws SQLClientInfoException
- Specified by:
setClientInfo
in interfaceConnection
- Throws:
SQLClientInfoException
-
getClientInfo
public String getClientInfo(String name)
- Specified by:
getClientInfo
in interfaceConnection
-
getClientInfo
public Properties getClientInfo()
- Specified by:
getClientInfo
in interfaceConnection
-
createArrayOf
public Array createArrayOf(String typeName, Object[] elements)
- Specified by:
createArrayOf
in interfaceConnection
-
createStruct
public Struct createStruct(String typeName, Object[] attributes)
- Specified by:
createStruct
in interfaceConnection
-
setSchema
public void setSchema(String schema)
- Specified by:
setSchema
in interfaceConnection
-
getSchema
public String getSchema()
- Specified by:
getSchema
in interfaceConnection
-
abort
public void abort(Executor executor)
- Specified by:
abort
in interfaceConnection
-
setNetworkTimeout
public void setNetworkTimeout(Executor executor, int milliseconds)
- Specified by:
setNetworkTimeout
in interfaceConnection
-
getNetworkTimeout
public int getNetworkTimeout()
- Specified by:
getNetworkTimeout
in interfaceConnection
-
-