public class OutputConnectionManager extends BaseTable implements IOutputConnectionManager
| 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 |
OutputConnectionManager.OutputConnectionDescription
This is the object description for an output connection object.
|
protected static class |
OutputConnectionManager.OutputConnectionExecutor
This is the executor object for locating output 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 static String |
outputsLock |
protected IThreadContext |
threadContext |
dbInterface, tableName| Constructor and Description |
|---|
OutputConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
checkConnectorExists(String name)
Check if underlying connector exists.
|
IOutputConnection |
create()
Create a new output 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.
|
IOutputConnection[] |
getAllConnections()
Obtain a list of the output connections, ordered by name.
|
String |
getConnectionNameColumn()
Return the name column.
|
protected static String |
getOutputConnectionKey(String connectionName)
Construct a key which represents an individual output connection.
|
protected void |
getOutputConnectionsChunk(OutputConnection[] rval,
Map returnIndex,
ArrayList params)
Read a chunk of output connections.
|
protected static String |
getOutputConnectionsKey()
Construct a key which represents the general list of output connectors.
|
protected OutputConnection[] |
getOutputConnectionsMultiple(String[] connectionNames)
Fetch multiple output connections at a single time.
|
void |
importConfiguration(InputStream is)
Import configuration
|
void |
install()
Install the manager.
|
IOutputConnection |
load(String name)
Load an output connection by name.
|
IOutputConnection[] |
loadMultiple(String[] names)
Load multiple output connections by name.
|
protected int |
loadMultipleInternal(IOutputConnection[] rval,
int outputIndex,
String[] fetchNames,
int inputIndex,
int length) |
protected int |
maxClauseGetOutputConnectionsChunk()
Calculate max number of clauses to send to getOutputConnectionsChunk.
|
boolean |
save(IOutputConnection object)
Save an output 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 outputsLock
protected static final int FETCH_MAX
public OutputConnectionManager(IThreadContext threadContext, IDBInterface database) throws ManifoldCFException
threadContext - is the thread context.ManifoldCFExceptionpublic void install()
throws ManifoldCFException
install in interface IOutputConnectionManagerManifoldCFExceptionpublic void deinstall()
throws ManifoldCFException
deinstall in interface IOutputConnectionManagerManifoldCFExceptionpublic void exportConfiguration(OutputStream os) throws IOException, ManifoldCFException
exportConfiguration in interface IOutputConnectionManagerIOExceptionManifoldCFExceptionpublic void importConfiguration(InputStream is) throws IOException, ManifoldCFException
importConfiguration in interface IOutputConnectionManagerIOExceptionManifoldCFExceptionpublic IOutputConnection[] getAllConnections() throws ManifoldCFException
getAllConnections in interface IOutputConnectionManagerManifoldCFExceptionpublic IOutputConnection load(String name) throws ManifoldCFException
load in interface IOutputConnectionManagername - is the name of the output connection.ManifoldCFExceptionpublic IOutputConnection[] loadMultiple(String[] names) throws ManifoldCFException
loadMultiple in interface IOutputConnectionManagernames - are the names to load.ManifoldCFExceptionprotected int loadMultipleInternal(IOutputConnection[] rval, int outputIndex, String[] fetchNames, int inputIndex, int length) throws ManifoldCFException
ManifoldCFExceptionpublic IOutputConnection create() throws ManifoldCFException
create in interface IOutputConnectionManagerManifoldCFExceptionpublic boolean save(IOutputConnection object) throws ManifoldCFException
save in interface IOutputConnectionManagerobject - is the object to save.ManifoldCFExceptionpublic void delete(String name) throws ManifoldCFException
delete in interface IOutputConnectionManagername - 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 IOutputConnectionManagerclassName - is the class name of the connector.ManifoldCFExceptionpublic boolean checkConnectorExists(String name) throws ManifoldCFException
checkConnectorExists in interface IOutputConnectionManagername - is the name of the connection to check.ManifoldCFExceptionpublic String getConnectionNameColumn()
getConnectionNameColumn in interface IOutputConnectionManagerprotected static String getOutputConnectionsKey()
protected static String getOutputConnectionKey(String connectionName)
connectionName - is the name of the connector.protected OutputConnection[] getOutputConnectionsMultiple(String[] connectionNames) throws ManifoldCFException
connectionNames - are a list of connection names.ManifoldCFExceptionprotected int maxClauseGetOutputConnectionsChunk()
protected void getOutputConnectionsChunk(OutputConnection[] rval, Map 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