The DB Event inbound endpoint allows you to capture the data change via WSO2 ESB.
##Build
mvn clean install
###How You Can Contribute
You can create a third party connector and publish in WSO2 Connector Store.
Pre-requisites:
- Maven 3.x
- Java 1.6 or above
- The JDBC driver e.g:mysql-connector-java-5.1.36-bin.jar.
Tested Platform:
- Microsoft WINDOWS V-7
- Mac OSX 10.11.6
- Ubuntu 16.04 TLS
- wso2ei-6.1.1
- Java 1.8
-
To use the DB Event inbound endpoint, you need to download the inbound org.apache.synapse.dbevent.poll-1.0.0.jar from https://store.wso2.com and copy the jar to the <EI_HOME>/lib directory.
-
Place the mysql-connector-java-5.1.36-bin.jar into the directory <EI_HOME>/lib.
-
Configuration:
<inboundEndpoint xmlns="http://ws.apache.org/ns/synapse"
name="customIE"
sequence="request"
onError="fault"
class="org.wso2.carbon.inbound.poll.dbeventlistener.DBEventPollingConsumer"
suspend="false">
<parameters>
<parameter name="inbound.behavior">polling</parameter>
<parameter name="interval">10000</parameter>
<parameter name="sequential">true</parameter>
<parameter name="coordination">true</parameter>
<parameter name="driverName">com.mysql.jdbc.Driver</parameter>
<parameter name="url">jdbc:mysql://localhost/test</parameter>
<parameter name="username">root</parameter>
<parameter name="tableName">CDC_CUSTOM</parameter>
<parameter name="filteringCriteria">byLastUpdatedTimestampColumn</parameter>
<parameter name="filteringColumnName">LAST_UPDATED_DATE_TIME</parameter>
<parameter name="primaryKey">ID</parameter>
<parameter name="connectionValidationQuery">SELECT 1</parameter>
<parameter name="registryPath">customIE/timestamp</parameter>
</parameters>
</inboundEndpoint>- driverName - The class name of the database driver.
- url - The JDBC URL of the database.
- username - The user name used to connect to the database.
- password - The password used to connect to the database.
- tableName - The name of the table to capture the change.
- filteringCriteria - It can be one of these byLastUpdatedTimestampColumn or byBooleanColumn or deleteAfterPoll.
- filteringColumnName - The actual name of table column. It must be set if the filteringCriteria has the value 'byLastUpdatedTimestampColumn' or 'byBooleanColumn'.
- primaryKey - The primary key column name.
- connectionValidationQuery - The query to check the availability of the connection.
- registryPath - The registry path of the timestamp. This will be used to retrieve the records when the filteringCriteria has the value 'byLastUpdatedTimestampColumn'.