com.dsf.dbxtract.cdc.journal

Class SimpleJournalHandler

java.lang.Object

com.dsf.dbxtract.cdc.journal.SimpleJournalHandler

All Implemented Interfaces:

JournalHandler

public class SimpleJournalHandler
extends java.lang.Object
implements JournalHandler

A simple handler

Version:

0.1

Author:

fabio de santi

Constructor Summary

Constructors

Constructor and Description
SimpleJournalHandler(java.lang.String journalTable, java.lang.String query, int batchSize, Publisher publisher, JournalStrategy strategy)

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() The query to retrieve changed data can references columns from journal table as named parameters:
void	publish(Data data) Publishes captured data (like writing a file or publishing to a kafka queue).

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleJournalHandler

public SimpleJournalHandler(java.lang.String journalTable,
                            java.lang.String query,
                            int batchSize,
                            Publisher publisher,
                            JournalStrategy strategy)
                     throws ConfigurationException

Parameters:

journalTable - journal table's name

query - query for data retrieval

batchSize - number of rows per batch

publisher - Publisher object

strategy - journal strategy

Throws:

ConfigurationException - invalid parameters

Method Detail

getJournalTable

public java.lang.String getJournalTable()

Specified by:

getJournalTable in interface JournalHandler

Returns:

journal table name

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface JournalHandler

Returns:

processing batch size (maximum rows to be imported per cycle)

getTargetQuery

public java.lang.String getTargetQuery()

Description copied from interface: JournalHandler

The query to retrieve changed data can references columns from journal table as named parameters:

select * from mytable where pk = :pk

Specified by:

getTargetQuery in interface JournalHandler

Returns:

data retrieval query

publish

public void publish(Data data)
             throws PublishException

Description copied from interface: JournalHandler

Publishes captured data (like writing a file or publishing to a kafka queue).

Specified by:

publish in interface JournalHandler

Parameters:

data - retrieved data (see Data})

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