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, sleepFor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getTableName
public 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.ManifoldCFException
public void install() throws ManifoldCFException
install
in interface IOutputConnectionManager
ManifoldCFException
public void deinstall() throws ManifoldCFException
deinstall
in interface IOutputConnectionManager
ManifoldCFException
public void exportConfiguration(OutputStream os) throws IOException, ManifoldCFException
exportConfiguration
in interface IOutputConnectionManager
IOException
ManifoldCFException
public void importConfiguration(InputStream is) throws IOException, ManifoldCFException
importConfiguration
in interface IOutputConnectionManager
IOException
ManifoldCFException
public IOutputConnection[] getAllConnections() throws ManifoldCFException
getAllConnections
in interface IOutputConnectionManager
ManifoldCFException
public IOutputConnection load(String name) throws ManifoldCFException
load
in interface IOutputConnectionManager
name
- is the name of the output connection.ManifoldCFException
public IOutputConnection[] loadMultiple(String[] names) throws ManifoldCFException
loadMultiple
in interface IOutputConnectionManager
names
- are the names to load.ManifoldCFException
protected int loadMultipleInternal(IOutputConnection[] rval, int outputIndex, String[] fetchNames, int inputIndex, int length) throws ManifoldCFException
ManifoldCFException
public IOutputConnection create() throws ManifoldCFException
create
in interface IOutputConnectionManager
ManifoldCFException
public boolean save(IOutputConnection object) throws ManifoldCFException
save
in interface IOutputConnectionManager
object
- is the object to save.ManifoldCFException
public void delete(String name) throws ManifoldCFException
delete
in interface IOutputConnectionManager
name
- is the name of the connection to delete. If the
name does not exist, no error is returned.ManifoldCFException
public String[] findConnectionsForConnector(String className) throws ManifoldCFException
findConnectionsForConnector
in interface IOutputConnectionManager
className
- is the class name of the connector.ManifoldCFException
public boolean checkConnectorExists(String name) throws ManifoldCFException
checkConnectorExists
in interface IOutputConnectionManager
name
- is the name of the connection to check.ManifoldCFException
public String getConnectionNameColumn()
getConnectionNameColumn
in interface IOutputConnectionManager
protected 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.ManifoldCFException
protected 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