public class DatabaseConnector extends AbstractConnector
cfgDir, dnaPool, log, MESSAGE_RECORDING_FORMAT_BINARY, MESSAGE_RECORDING_FORMAT_XML
Constructor and Description |
---|
DatabaseConnector(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getConnectionString() |
java.lang.String |
getDriver() |
java.lang.String |
getIdField() |
java.lang.String |
getJdbcPassword() |
java.lang.String |
getJdbcUser() |
static ServiceType |
getMetaData()
This static method returns all the details of the class without it having
to be constructed.
|
java.lang.String |
getPostSql() |
java.lang.String |
getPreSql() |
java.lang.String |
getSql() |
void |
setConfig(ConnectorConfig config) |
void |
setConnectionString(java.lang.String connectionString) |
void |
setDriver(java.lang.String driver) |
void |
setIdField(java.lang.String idField) |
void |
setJdbcPassword(java.lang.String jdbcPassword) |
void |
setJdbcUser(java.lang.String jdbcUser) |
void |
setPostSql(java.lang.String postSql) |
void |
setPreSql(java.lang.String preSql) |
void |
setSql(java.lang.String sql) |
void |
startCrawling() |
void |
stopCrawling() |
addDocumentListener, feed, flush, getBatchSize, getConnectorState, getDocIdPrefix, getState, publishDocument, publishDocuments, publishFlush, setBatchSize, setDocIdPrefix, setState
addListener, addListener, addTask, addTask, addTask, addTaskOneShot, allowDisplay, allowDisplay, attach, attach, broadcastState, buildDna, buildDna, buildDnaKeys, buildDnaNames, clearLastError, close, containsTask, copyShallowFrom, createPeer, createPeer, createRootReserved, detach, detach, detach, echoHeartbeat, error, error, error, getAttached, getCfgDir, getComm, getDeclaredMethodNames, getDeclaredMethods, getDescription, getDna, getDnaString, getHostName, getInbox, getInstanceId, getIntanceName, getInterfaceSet, getLastError, getMessageSet, getMetaData, getMethodMap, getMethodNames, getMethods, getMethodToolTip, getMsg, getName, getNotifyList, getNotifyListKeySet, getOutbox, getPeerKey, getPeerName, getServiceResourceFile, getSimpleName, getTasks, getThisThread, getType, hasError, hasPeers, help, help, in, info, info, invoke, invoke, invoke, invokeOn, isAttached, isAttached, isLocal, isReady, isRunning, isRuntime, isVirtual, load, load, logTimeEnable, mergeDna, mergeDna, mergePeerDna, movePeerDna, out, out, preProcessHook, preRoutingHook, publishError, publishQueueStats, publishState, publishStats, publishStatus, purgeTask, purgeTasks, releasePeers, releaseService, removeAllListeners, removeListener, requiresSecurity, reserve, reserve, reserveRoot, reserveRoot, reserveRootAs, run, save, save, save, send, send, send, send, sendBlocking, sendBlocking, sendBlocking, sendBlocking, sendPeer, setInstanceId, setName, setPeer, setSecurityProvider, setState, setThisThread, setVirtual, sleep, stackToString, startHeartbeat, startPeer, startPeer, startRecording, startService, stopHeartbeat, stopMsgRecording, stopService, subscribe, subscribe, subscribe, toString, unsubscribe, unsubscribe, unsubscribe, updateStats, warn, warn
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName
public void setConfig(ConnectorConfig config)
setConfig
in class AbstractConnector
public void startCrawling()
public void stopCrawling()
public java.lang.String getDriver()
public void setDriver(java.lang.String driver)
public java.lang.String getConnectionString()
public void setConnectionString(java.lang.String connectionString)
public java.lang.String getJdbcUser()
public void setJdbcUser(java.lang.String jdbcUser)
public java.lang.String getJdbcPassword()
public void setJdbcPassword(java.lang.String jdbcPassword)
public java.lang.String getPreSql()
public void setPreSql(java.lang.String preSql)
public java.lang.String getSql()
public void setSql(java.lang.String sql)
public java.lang.String getPostSql()
public void setPostSql(java.lang.String postSql)
public java.lang.String getIdField()
public void setIdField(java.lang.String idField)
public static ServiceType getMetaData()