public class MappingConnectionManager extends BaseTable implements IMappingConnectionManager
| Field | Type | Description |
|---|---|---|
| mappingname | VARCHAR(32) | Primary Key |
| description | VARCHAR(255) | |
| classname | VARCHAR(255) | |
| maxcount | BIGINT | |
| configxml | LONGTEXT |
| Modifier and Type | Class and Description |
|---|---|
protected static class |
MappingConnectionManager.MappingConnectionDescription
This is the object description for a mapping connection object.
|
protected static class |
MappingConnectionManager.MappingConnectionExecutor
This is the executor object for locating mapping 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 |
mappingField |
protected static String |
mappingsLock |
protected static String |
maxCountField |
protected static String |
nameField |
protected IThreadContext |
threadContext |
dbInterface, tableName| Constructor and Description |
|---|
MappingConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
IMappingConnection |
create()
Create a new repository connection object.
|
void |
deinstall()
Uninstall the manager.
|
void |
delete(String name)
Delete an authority connection.
|
void |
exportConfiguration(OutputStream os)
Export configuration
|
IMappingConnection[] |
getAllConnections()
Obtain a list of the repository connections, ordered by name.
|
IMappingConnection[] |
getAllNonLoopingConnections(String startingConnectionName)
Obtain a list of the mapping connections, ordered by name,
excluding those that would form a prerequisite loop if chosen.
|
protected static String |
getMappingConnectionKey(String connectionName)
Construct a key which represents an individual mapping connection.
|
protected void |
getMappingConnectionsChunk(MappingConnection[] rval,
Map returnIndex,
ArrayList params)
Read a chunk of mapping connections.
|
protected static String |
getMappingConnectionsKey()
Construct a key which represents the general list of mapping connectors.
|
protected MappingConnection[] |
getMappingConnectionsMultiple(String[] connectionNames)
Fetch multiple mapping connections at a single time.
|
String |
getMappingNameColumn()
Get the mapping connection name column.
|
void |
importConfiguration(InputStream is)
Import configuration
|
void |
install()
Install the manager.
|
protected boolean |
isReferenced(String mappingName)
Return true if the specified mapping name is referenced.
|
IMappingConnection |
load(String name)
Load a mapping connection by name.
|
IMappingConnection[] |
loadMultiple(String[] names)
Load multiple mapping connections by name.
|
protected int |
loadMultipleInternal(IMappingConnection[] rval,
int outputIndex,
String[] fetchNames,
int inputIndex,
int length) |
protected int |
maxClauseGetMappingConnectionsChunk()
Find the maximum number of clauses for getMappingConnectionsChunk.
|
boolean |
save(IMappingConnection object)
Save a mapping 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 static final String mappingField
protected final ICacheManager cacheManager
protected final IThreadContext threadContext
protected final ILockManager lockManager
protected static final String mappingsLock
protected static final int FETCH_MAX
public MappingConnectionManager(IThreadContext threadContext, IDBInterface database) throws ManifoldCFException
threadContext - is the thread context.ManifoldCFExceptionpublic void install()
throws ManifoldCFException
install in interface IMappingConnectionManagerManifoldCFExceptionpublic void deinstall()
throws ManifoldCFException
deinstall in interface IMappingConnectionManagerManifoldCFExceptionpublic void exportConfiguration(OutputStream os) throws IOException, ManifoldCFException
exportConfiguration in interface IMappingConnectionManagerIOExceptionManifoldCFExceptionpublic void importConfiguration(InputStream is) throws IOException, ManifoldCFException
importConfiguration in interface IMappingConnectionManagerIOExceptionManifoldCFExceptionpublic IMappingConnection[] getAllNonLoopingConnections(String startingConnectionName) throws ManifoldCFException
getAllNonLoopingConnections in interface IMappingConnectionManagerstartingConnectionName - is the name of the connection we would be starting with.
Pass null for all connections.ManifoldCFExceptionpublic IMappingConnection[] getAllConnections() throws ManifoldCFException
getAllConnections in interface IMappingConnectionManagerManifoldCFExceptionpublic IMappingConnection load(String name) throws ManifoldCFException
load in interface IMappingConnectionManagername - is the name of the mapping connection.ManifoldCFExceptionpublic IMappingConnection[] loadMultiple(String[] names) throws ManifoldCFException
loadMultiple in interface IMappingConnectionManagernames - are the names to load.ManifoldCFExceptionprotected int loadMultipleInternal(IMappingConnection[] rval, int outputIndex, String[] fetchNames, int inputIndex, int length) throws ManifoldCFException
ManifoldCFExceptionpublic IMappingConnection create() throws ManifoldCFException
create in interface IMappingConnectionManagerManifoldCFExceptionpublic boolean save(IMappingConnection object) throws ManifoldCFException
save in interface IMappingConnectionManagerobject - is the object to save.ManifoldCFExceptionpublic void delete(String name) throws ManifoldCFException
delete in interface IMappingConnectionManagername - is the name of the connection to delete. If the
name does not exist, no error is returned.ManifoldCFExceptionpublic String getMappingNameColumn()
getMappingNameColumn in interface IMappingConnectionManagerprotected boolean isReferenced(String mappingName) throws ManifoldCFException
mappingName - is the mapping name.ManifoldCFExceptionprotected static String getMappingConnectionsKey()
protected static String getMappingConnectionKey(String connectionName)
connectionName - is the name of the connector.protected MappingConnection[] getMappingConnectionsMultiple(String[] connectionNames) throws ManifoldCFException
connectionNames - are a list of connection names.ManifoldCFExceptionprotected int maxClauseGetMappingConnectionsChunk()
protected void getMappingConnectionsChunk(MappingConnection[] 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