On Table Row

Process rows from DB Table using On Table Row Operation

This operation selects from a table at a regular interval and generates one message per obtained row. Optionally, you can provide watermark and ID columns. If a watermark column is provided, the values taken from that column are used to filter the contents of the next poll, so that only rows with a greater watermark value are returned. If an ID column is provided, this component automatically verifies that the same row is not picked twice by concurrent polls.

Create a project in anypoint studio and Configure the listener

Configure the Database connection

Drag and drop On Table Row from mule palette and configure the below parameters

• Table: Table name to process the records
• Watermark Column: The name of the column to use for a watermark. Values taken from this column are used to filter the contents of the next poll, so that only rows with a greater watermark value are processed.
• Id: The name of the column to consider as the row ID. If provided, this component makes sure that the same row is not processed twice by concurrent polls.
• Scheduling Frequency: Configures the scheduler that triggers the polling it can be either cron or the fixed frequency

Deploy the project and test the same, you can see newly inserted records with ID:3 is processed