嗨,我想将Esper数据库适配器连接到我的应用程序。我的应用程序仅需要在发生事件时需要从数据库获取数据,并且如果数据库中的数据与事件数据匹配则需要解析到Update Listener。到目前为止,我已经完成了从Esper数据库适配器。
select * from pattern[every timer:interval(10)] as ep , sql:cep_demo ['select * from BasicEvent where eventId = 7']
但是问题是我只能在一定时间间隔内读取数据。但是我的要求是事件到达Esper Engine之后从Mysql数据库获取数据,并且如果数据库中的UserId与事件中的UserId匹配则抛出给侦听器。我想知道是否可能。
最佳答案
select * from Event, sql:cep_demo ['select * from BasicEvent where eventId = 7']