Package org.openiam.sync.service.impl.srcadapter.adapters

Class RDBMSAdapter

java.lang.Object

org.openiam.sync.service.impl.srcadapter.adapters.AbstractSrcAdapter

org.openiam.sync.service.impl.srcadapter.adapters.RDBMSAdapter

All Implemented Interfaces:

SourceAdapter

@Component
public class RDBMSAdapter
extends AbstractSrcAdapter

Reads a CSV file for use during the synchronization process

Author:

suneet

Field Summary

Fields inherited from class org.openiam.sync.service.impl.srcadapter.adapters.AbstractSrcAdapter

auditLogHelper, mapper, propertyValueSweeper, provisionQueue, rabbitMQSender, scriptRunner, syncHelper, syncObjectProcessorFactory

Constructor Summary

Constructors

Constructor	Description
RDBMSAdapter()

Method Summary

Modifier and Type	Method	Description
protected LastRecordMetric	getRowTime(LineObject rowObj, SynchConfig config)
protected void	incrementalSyncProcessing(SynchConfig config)
Response	testConnection(SynchConfig config)
protected boolean	validatePartsGeneration(List<LineObject> allObjects, SynchConfig config)

Methods inherited from class org.openiam.sync.service.impl.srcadapter.adapters.AbstractSrcAdapter

buildAuditLog, decryptPassword, getLastRecGeneralizedTime, getLastRecordMetric, getObjectString, hasError, mean, performTransformationScript, processLineObject, processPart, setMetric, setMetric, startSynch, startSynch, sum

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RDBMSAdapter

public RDBMSAdapter()

Method Detail

validatePartsGeneration

protected boolean validatePartsGeneration(List<LineObject> allObjects,
                                          SynchConfig config)

Specified by:

validatePartsGeneration in class AbstractSrcAdapter

getRowTime

protected LastRecordMetric getRowTime(LineObject rowObj,
                                      SynchConfig config)

Specified by:

getRowTime in class AbstractSrcAdapter

incrementalSyncProcessing

protected void incrementalSyncProcessing(SynchConfig config)

Overrides:

incrementalSyncProcessing in class AbstractSrcAdapter

testConnection

public Response testConnection(SynchConfig config)