com.dsf.dbxtract.cdc.sample

Class TestHandler

java.lang.Object

com.dsf.dbxtract.cdc.sample.TestHandler

All Implemented Interfaces:

JournalHandler

public class TestHandler
extends java.lang.Object
implements JournalHandler

Sample handler (after import, journal entries are removed):

• journal: j$test
• batch size: 200 rows per batch
• target query: select * from test where key1 = :key1 and key2 = :key2

Author:

fabio de santi

Constructor Summary

Constructors

Constructor and Description
TestHandler()

Method Summary

Modifier and Type	Method and Description
int	getBatchSize()
java.lang.String	getJournalTable()
JournalStrategy	getStrategy() Establish the journal strategy: DELETE - removes imported rows from journal table WINDOW - memorizes
java.lang.String	getTargetQuery() Query parameters must be referenced just like in JPA's NamedQueries.
void	publish(Data data) Publish imported data to...

Methods inherited from class java.lang.Object

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

Constructor Detail

TestHandler

public TestHandler()

Method Detail

getJournalTable

public java.lang.String getJournalTable()

Specified by:

getJournalTable in interface JournalHandler

Returns:

journal table's name

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface JournalHandler

Returns:

number of rows to be imported for each execution

getTargetQuery

public java.lang.String getTargetQuery()

Query parameters must be referenced just like in JPA's NamedQueries.

Specified by:

getTargetQuery in interface JournalHandler

Returns:

data retrieval query

publish

public void publish(Data data)
             throws PublishException

Publish imported data to... (kafka, a file, a queue, another database, etc)

Specified by:

publish in interface JournalHandler

Parameters:

data - Data object

Throws:

PublishException - failed to publish retrieved data

getStrategy

public JournalStrategy getStrategy()

Description copied from interface: JournalHandler

Establish the journal strategy:

• DELETE - removes imported rows from journal table
• WINDOW - memorizes

Specified by:

getStrategy in interface JournalHandler

Returns:

the handler's journal strategy