public class TransformationConnectionManager extends BaseTable implements ITransformationConnectionManager
| Field | Type | Description |
|---|---|---|
| connectionname | VARCHAR(32) | Primary Key |
| description | VARCHAR(255) | |
| classname | VARCHAR(255) | |
| maxcount | BIGINT | |
| configxml | LONGTEXT |
| Modifier and Type | Class and Description |
|---|---|
protected static class |
TransformationConnectionManager.TransformationConnectionDescription
This is the object description for a transformation connection object.
|
protected static class |
TransformationConnectionManager.TransformationConnectionExecutor
This is the executor object for locating transformation connection objects.
|
| Modifier and Type | Field and Description |
|---|---|
static String |
_rcsid |
protected ICacheManager |
cacheManager |
protected static String |
classNameField |
protected static String |
configField |
protected static String |
descriptionField |
protected static int |
FETCH_MAX |
protected ILockManager |
lockManager |
protected static String |
maxCountField |
protected static String |
nameField |
protected IThreadContext |
threadContext |
protected static String |
transformationsLock |
dbInterface, tableName| Constructor and Description |
|---|
TransformationConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
checkConnectorExists(String name)
Check if underlying connector exists.
|
ITransformationConnection |
create()
Create a new transformation connection object.
|
void |
deinstall()
Uninstall the manager.
|
void |
delete(String name)
Delete an output connection.
|
void |
exportConfiguration(OutputStream os)
Export configuration
|
String[] |
findConnectionsForConnector(String className)
Get a list of output connections that share the same connector.
|
ITransformationConnection[] |
getAllConnections()
Obtain a list of the transformation connections, ordered by name.
|
String |
getConnectionNameColumn()
Return the name column.
|
protected static String |
getTransformationConnectionKey(String connectionName)
Construct a key which represents an individual transformation connection.
|
protected void |
getTransformationConnectionsChunk(TransformationConnection[] rval,
Map<String,Integer> returnIndex,
ArrayList params)
Read a chunk of transformation connections.
|
protected static String |
getTransformationConnectionsKey()
Construct a key which represents the general list of transformation connectors.
|
protected TransformationConnection[] |
getTransformationConnectionsMultiple(String[] connectionNames)
Fetch multiple output connections at a single time.
|
void |
importConfiguration(InputStream is)
Import configuration
|
void |
install()
Install the manager.
|
ITransformationConnection |
load(String name)
Load a transformation connection by name.
|
ITransformationConnection[] |
loadMultiple(String[] names)
Load multiple transformation connections by name.
|
protected int |
loadMultipleInternal(ITransformationConnection[] rval,
int outputIndex,
String[] fetchNames,
int inputIndex,
int length) |
protected int |
maxClauseGetTransformationConnectionsChunk()
Calculate max number of clauses to send to getTransformationConnectionsChunk.
|
boolean |
save(ITransformationConnection object)
Save a transformation connection object.
|
addTableIndex, analyzeTable, beginTransaction, buildConjunctionClause, constructCountClause, constructDistinctOnClause, constructDoubleCastClause, constructOffsetLimitClause, constructRegexpClause, constructSubstringClause, endTransaction, findConjunctionClauseMax, getDatabaseCacheKey, getDBInterface, getMaxInClause, getMaxOrClause, getSleepAmt, getTableIndexes, getTableName, getTableSchema, getTransactionID, getWindowedReportMaxRows, makeTableKey, noteModifications, performAddIndex, performAlter, performCommit, performCreate, performDelete, performDrop, performInsert, performModification, performQuery, performQuery, performRemoveIndex, performUpdate, prepareRowForSave, readRow, reindexTable, signalRollback, sleepForclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetTableNamepublic static final String _rcsid
protected static final String nameField
protected static final String descriptionField
protected static final String classNameField
protected static final String maxCountField
protected static final String configField
protected final ICacheManager cacheManager
protected final IThreadContext threadContext
protected final ILockManager lockManager
protected static final String transformationsLock
protected static final int FETCH_MAX
public TransformationConnectionManager(IThreadContext threadContext, IDBInterface database) throws ManifoldCFException
threadContext - is the thread context.ManifoldCFExceptionpublic void install()
throws ManifoldCFException
install in interface ITransformationConnectionManagerManifoldCFExceptionpublic void deinstall()
throws ManifoldCFException
deinstall in interface ITransformationConnectionManagerManifoldCFExceptionpublic void exportConfiguration(OutputStream os) throws IOException, ManifoldCFException
exportConfiguration in interface ITransformationConnectionManagerIOExceptionManifoldCFExceptionpublic void importConfiguration(InputStream is) throws IOException, ManifoldCFException
importConfiguration in interface ITransformationConnectionManagerIOExceptionManifoldCFExceptionpublic ITransformationConnection[] getAllConnections() throws ManifoldCFException
getAllConnections in interface ITransformationConnectionManagerManifoldCFExceptionpublic ITransformationConnection load(String name) throws ManifoldCFException
load in interface ITransformationConnectionManagername - is the name of the transformation connection.ManifoldCFExceptionpublic ITransformationConnection[] loadMultiple(String[] names) throws ManifoldCFException
loadMultiple in interface ITransformationConnectionManagernames - are the names to load.ManifoldCFExceptionprotected int loadMultipleInternal(ITransformationConnection[] rval, int outputIndex, String[] fetchNames, int inputIndex, int length) throws ManifoldCFException
ManifoldCFExceptionpublic ITransformationConnection create() throws ManifoldCFException
create in interface ITransformationConnectionManagerManifoldCFExceptionpublic boolean save(ITransformationConnection object) throws ManifoldCFException
save in interface ITransformationConnectionManagerobject - is the object to save.ManifoldCFExceptionpublic void delete(String name) throws ManifoldCFException
delete in interface ITransformationConnectionManagername - is the name of the connection to delete. If the
name does not exist, no error is returned.ManifoldCFExceptionpublic String[] findConnectionsForConnector(String className) throws ManifoldCFException
findConnectionsForConnector in interface ITransformationConnectionManagerclassName - is the class name of the connector.ManifoldCFExceptionpublic boolean checkConnectorExists(String name) throws ManifoldCFException
checkConnectorExists in interface ITransformationConnectionManagername - is the name of the connection to check.ManifoldCFExceptionpublic String getConnectionNameColumn()
getConnectionNameColumn in interface ITransformationConnectionManagerprotected static String getTransformationConnectionsKey()
protected static String getTransformationConnectionKey(String connectionName)
connectionName - is the name of the connector.protected TransformationConnection[] getTransformationConnectionsMultiple(String[] connectionNames) throws ManifoldCFException
connectionNames - are a list of connection names.ManifoldCFExceptionprotected int maxClauseGetTransformationConnectionsChunk()
protected void getTransformationConnectionsChunk(TransformationConnection[] rval, Map<String,Integer> returnIndex, ArrayList params) throws ManifoldCFException
rval - is the place to put the read policies.returnIndex - is a map from the object id (resource id) and the rval index.params - is the set of parameters.ManifoldCFException