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, 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 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.ManifoldCFException
public void install() throws ManifoldCFException
install
in interface IMappingConnectionManager
ManifoldCFException
public void deinstall() throws ManifoldCFException
deinstall
in interface IMappingConnectionManager
ManifoldCFException
public void exportConfiguration(OutputStream os) throws IOException, ManifoldCFException
exportConfiguration
in interface IMappingConnectionManager
IOException
ManifoldCFException
public void importConfiguration(InputStream is) throws IOException, ManifoldCFException
importConfiguration
in interface IMappingConnectionManager
IOException
ManifoldCFException
public IMappingConnection[] getAllNonLoopingConnections(String startingConnectionName) throws ManifoldCFException
getAllNonLoopingConnections
in interface IMappingConnectionManager
startingConnectionName
- is the name of the connection we would be starting with.
Pass null for all connections.ManifoldCFException
public IMappingConnection[] getAllConnections() throws ManifoldCFException
getAllConnections
in interface IMappingConnectionManager
ManifoldCFException
public IMappingConnection load(String name) throws ManifoldCFException
load
in interface IMappingConnectionManager
name
- is the name of the mapping connection.ManifoldCFException
public IMappingConnection[] loadMultiple(String[] names) throws ManifoldCFException
loadMultiple
in interface IMappingConnectionManager
names
- are the names to load.ManifoldCFException
protected int loadMultipleInternal(IMappingConnection[] rval, int outputIndex, String[] fetchNames, int inputIndex, int length) throws ManifoldCFException
ManifoldCFException
public IMappingConnection create() throws ManifoldCFException
create
in interface IMappingConnectionManager
ManifoldCFException
public boolean save(IMappingConnection object) throws ManifoldCFException
save
in interface IMappingConnectionManager
object
- is the object to save.ManifoldCFException
public void delete(String name) throws ManifoldCFException
delete
in interface IMappingConnectionManager
name
- is the name of the connection to delete. If the
name does not exist, no error is returned.ManifoldCFException
public String getMappingNameColumn()
getMappingNameColumn
in interface IMappingConnectionManager
protected boolean isReferenced(String mappingName) throws ManifoldCFException
mappingName
- is the mapping name.ManifoldCFException
protected 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.ManifoldCFException
protected 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