WSO2 CEPを使用してMySQLデータベースを更新する

Question

ストリーム内の空の値を更新せずにMySQL Dbを更新する方法はありますか？入力データストリームに空の値が含まれている場合、現在空の値は "data_empty"値を使用していることを示します。その時、CEPはその値（ "data_empty"）でDBを更新します。私の目標は、空の値を更新せずに残りのものを更新することです。 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; 

Answer 1

空でない（シナリオでは「data_empty」ではない）値だけをデータベースに更新するのは難しいです。しかし、Siddhiには、ifThenElse(condition, value if true, value if false)という機能があり、これはあなたのシナリオで使用できます。 ifThenElse()とテーブルの更新（あなたのユースケースに似ています）の使用についてのアイデアを得るには、以下のサンプル実行プランを参照してください。

@Plan:name('IfThenElseExecutionPlan') 

@Import('inputStream:1.0.0') 
define stream dataIn (roomId int, roomType string, roomTemp float); 

@Export('outputStream:1.0.0') 
define stream dataOut (roomId int, roomType string, roomTemp float); 

@From(eventtable='rdbms', datasource.name='cepdatabase', table.name='roomTable') 
define table roomTable (roomId int, roomType string, roomTemp float); 

from dataIn[not((roomTable.roomId == roomId) in roomTable)] 
insert into updateStream; 

from dataIn join roomTable 
on roomTable.roomId == dataIn.roomId 
select dataIn.roomId as roomId, 
     ifThenElse(dataIn.roomType=='data_empty', roomTable.roomType, dataIn.roomType) as roomType, 
     ifThenElse(dataIn.roomTemp==0.0f, roomTable.roomTemp, dataIn.roomTemp) as roomTemp 
insert into updateStream; 

from updateStream 
insert overwrite roomTable 
on roomTable.roomId == roomId;