com.dsf.dbxtract.cdc.sample

Class TestWindowHandler

java.lang.Object

com.dsf.dbxtract.cdc.sample.TestWindowHandler

All Implemented Interfaces:

JournalHandler

public class TestWindowHandler
extends java.lang.Object
implements JournalHandler

Sample window handler (no changes are made to journal tables):

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

Author:

fabio de santi

Constructor Summary

Constructors

Constructor and Description
TestWindowHandler()

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

TestWindowHandler

public TestWindowHandler()

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 - captured 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