有什么方法可以在不更新流中的空值的情况下更新 MySQL Db。如果我的输入数据流包含一些空值,则当前使用“data_empty”值指示该空值。那时,CEP 使用该值(“data_empty”)更新数据库。我的目标是在不更新空值的情况下更新其余内容。是否可以使用 siddhi 和 WSO2 CEP。
@Plan:name('DBUpdateExecutionPlan')
@Import('testStream:1.0.0')
define stream input (id string, param1 string, param2 string);
@Export('testOutStream:1.0.0')
define stream output (id string, param1 string, param2 string);
@from(eventtable = 'rdbms' , datasource.name = 'MYSQL' , table.name = 'cep')
define table cepTable (id string, param1 string, param2 string) ;
from input#window.time(0 sec)
select *
update cepTable on id == cepTable.id;