使用wso2 CEP处理空值

Question

我想使用附加条件来更新事件表（RDBMS），即其中的一列不为空。表名是MSISDNProfileDB，它在oracle数据库中。

from incomingStream#window.length(1) 
select correlation_MSISDN as MSISDN, 
     INTERACTION_DT as INTERACTION_DT 
update MSISDNProfileDB 
on MSISDNProfileDB.MSISDN == MSISDN 
and not(MSISDNProfileDB.column1 is null); 

它验证代码，但不更新INTERACTION_DT。出于测试目的，我将其更改为检查列是否为空，并手动从column1中删除数据。

from incomingStream#window.length(1) 
select correlation_MSISDN as MSISDN, 
     INTERACTION_DT as INTERACTION_DT 
update MSISDNProfileDB 
on MSISDNProfileDB.MSISDN == MSISDN 
and MSISDNProfileDB.column1 is null; 

...它仍然无法正常工作。但是，当我将列值更改为1并执行此操作时：

from incomingStream#window.length(1) 
select correlation_MSISDN as MSISDN, 
     INTERACTION_DT as INTERACTION_DT 
update MSISDNProfileDB 
on MSISDNProfileDB.MSISDN == MSISDN 
and MSISDNProfileDB.column1 == '1'; 

它的工作原理！所以，结论是cep与oracle db的空值有问题。有谁知道如何处理空值？

亲切的问候， 斯特凡

Answer 1

我碰到类似的问题就来了与MySQL。这个问题似乎是CEP将Siddhi查询解析为SQL的方式。我为此做了一个快速的fix，并且适用于我的场景。它应该也适用于你的情况，但还没有通过Oracle测试过。使用修复程序（假设您使用的是CEP 4.2.0）;

1. 删除siddhi-extension-event-table_3.1.2.jar从<cep>/repository/components/plugins/目录。

2. 将compiled jar添加到<cep>/repository/components/lib/的模具。

3. 使用以下查询;

   from incomingStream 
   select 
       correlation_MSISDN as MSISDN, 
       INTERACTION_DT as INTERACTION_DT 
   update MSISDNProfileDB 
   on MSISDNProfileDB.MSISDN == MSISDN and not (MSISDNProfileDB.column1 is null);