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'.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent