search

wso2 / streaming-integrator-tooling

Apache License 2.0
45 stars 33 forks source link

ETL Wizard - Cannot configure deletion in RDBMS table in ETL destination #117

Open sybernix opened 4 years ago

sybernix commented 4 years ago

Description: The following siddhi app cannot be implemented using ETL wizard

@App:name("DeleteUserData")

@source(type = 'cdc', url = 'jdbc:mysql://localhost:3306/production?useSSL=false', username = 'root', password = 'root', table.name = 'UnregisteredUserTable', operation = 'insert',
    @map(type = 'keyvalue'))
define stream unregisterUserStream (user_id long, status string);

@Store(type="rdbms", jdbc.url="jdbc:mysql://localhost:3306/production?useSSL=false", username="root", password="root", jdbc.driver.name="com.mysql.jdbc.Driver")
@PrimaryKey("user_id")
define table UserDataTable (user_id long, username string, reg_date string, package string, address string, mobile_number string);

@info(name='Delete User Data Query') 
from unregisterUserStream
delete UserDataTable
    on UserDataTable.user_id == user_id;

RDBMS store destination only allows insertions in ETL wizard

Affected Product Version: 1.1.0