一、背景
我們知道在drools中是存在工作內存的，我們的Fact對象會加入到工作內存中，同時我們自己也可以在drl文件中使用insert/modify/update/delete等方法，修改工作內存中對象的，那么我們怎么查詢修改之后的工作內存的值呢？而drools的query可以幫助我們實現這個功能。
二、需求
1、無參數query的使用
2、有參數query的使用
3、java代碼中openLiveQuery的使用
4、rule中使用query
三、前置需求
1、query的語法結構
query queryName(參數列表)
end注意事項：
query的名字在同一個KIE base的所有包中必須要唯一，一般情況下我們全局唯一即可。query沒有when和then的部分
2、java中如何獲取query的結果
1、通過getQueryResults獲取
QueryResults queryResults = kieSession.getQueryResults("query的名字",可選參數類表);
通過這種方式getQueryResults獲取到的結果只會獲取一次，如果工作內存中的數據發生了變化，則不會自動感知到。
2、通過openLiveQuery獲取
kieSession.openLiveQuery("query的名字", new Object[]{可選參數}, new ViewChangedEventListener() {
@Override
public void rowInserted(Row row) {}
@Override
public void rowDeleted(Row row) { }
@Override
public void rowUpdated(Row row) {}
});通過這種方式openLiveQuery是可以實時獲取到結果的，當工作內存中的數據發生變化，這個地方是可以感知到的。
四、實現
此處只列出部分核心代碼，一些無關的代碼不列出。
1、無參數query的使用
1、drl文件編寫
// 不帶參數的查詢
query "query01"
// 注意這個地方的 $p，java代碼中需要用到
$p: Person(age < 18)
end2、java文件編寫
// 不帶參數的query查詢
QueryResults queryResults = kieSession.getQueryResults("query01");
queryResults.iterator().forEachRemaining(row -> {
// 那么這個地方的 $p 是怎么來的呢？其實是我們自己編寫的drl query中寫的
Person person = (Person) row.get("$p");
log.info("query01從工作內存中獲取的query: {}", person);
});2、有參數query的使用
1、drl文件編寫
// 帶參數的查詢
query query02(Integer $age)
$p: Person(age < $age)
end2、java文件編寫
// 不帶參數的query查詢
// 帶參數的query查詢
queryResults = kieSession.getQueryResults("query02", 20);
queryResults.iterator().forEachRemaining(row -> {
Person person = (Person) row.get("$p");
log.info("query02從工作內存中獲取的query: {}", person);
});3、java代碼中openLiveQuery的使用
1、drl文件編寫
// 帶參數的查詢-查詢工作內存Person對象的age的值小于外部傳遞進來的$age值
query query02(Integer $age)
$p: Person(age < $age)
end
// 定義一個規則，當規則內存中的Person的age小于18時，直接年齡+1
rule "rule_test_live_query_in_java"
no-loop true
when
$p: Person($age:age < 18)
then
modify($p){
// 此處修改了工作內存中age對象的值
setAge($p.getAge() + 1)
}
System.out.println("更新來規則內存中Person["+$p.getName()+"]的age:["+$p.getAge()+"]值");
end解釋：
1、定義查詢query02查詢工作內存中的對象。
2、rule_test_live_query_in_java里面存在一個 modify($p) 這個操作會導致更新工作內存中對象的值。
3、no-loop true表達的是當前規則是否可以多次執行，就我們定義的這個規則，如果修改后的age<18那么可能還會導致規則的重新出發，加了no-loop true則只會觸發一次。
2、java文件編寫
public static void main(String[] args) {
KieServices kieServices = KieServices.get();
KieContainer kieContainer = kieServices.getKieClasspathContainer();
KieSession kieSession = kieContainer.newKieSession("query-ksession");
kieSession.addEventListener(new DebugRuleRuntimeEventListener());
kieSession.addEventListener(new DebugAgendaEventListener());
kieSession.addEventListener(new DebugProcessEventListener());
// 實時查詢
kieSession.openLiveQuery("query02", new Object[]{20}, new ViewChangedEventListener() {
@Override
public void rowInserted(Row row) {
Person person = (Person) row.get("$p");
log.info("實時查詢-query02向工作內存中插入Person: {}", person);
}
@Override
public void rowDeleted(Row row) {
Person person = (Person) row.get("$p");
log.info("實時查詢-query02向工作內存中刪除Person: {}", person);
}
@Override
public void rowUpdated(Row row) {
Person person = (Person) row.get("$p");
log.info("實時查詢-query02向工作內存中更新Person: {}", person);
}
});
Person person1 = new Person("張三", 16);
kieSession.insert(person1);
kieSession.fireAllRules();
kieSession.dispose();
}解釋：
1、此處先使用了openLiveQuery查詢。
2、讓后向工作內存中insert(person1)，并且觸發了所有的規則fireAllRules。
3、輸出結果
10:08:54.415 [main] INFO com.huan.drools.querys.DroolsLiveQueryApplication - 實時查詢-query02向工作內存中插入Person: Person(name=張三, age=16)
更新來規則內存中Person[張三]的age:[17]值
10:08:54.420 [main] INFO com.huan.drools.querys.DroolsLiveQueryApplication - 實時查詢-query02向工作內存中更新Person: Person(name=張三, age=17)
可以看到，openLiveQuery實時查詢到了工作內存中變更的對象。
4、rule中使用query
drl文件編寫
// 定義一個查詢，Person#name 需要以$prefix開頭
query personNameStartsWith(String $prefix)
Person(name.startsWith($prefix))
end
rule "rule_person_name_starts_with"
when
$p: Person($age:age < 18)
personNameStartsWith("張";) // 此處多個參數使用 , 分割，并且最后必須以 ; 結尾
then
System.out.println("在rule中使用query");
end如果出現了如下異常Query's must use positional or bindings, not field constraints: "張" : [Rule name='rule_person_name_starts_with']，這個是因為我們在rule中調用query時，參數沒有以;結尾。正確用法personNameStartsWith("張";)
?personNameStartsWith("張";) 和 personNameStartsWith("張";)是不一樣的。The ? symbol means the query is pull only, once the results are returned you will not receive further results as the underlying data changes
五、完整代碼
https://gitee.com/huan1993/spring-cloud-parent/tree/master/drools/drools-drl-query
六、參考鏈接
1、https://docs.drools.org/7.69.0.Final/drools-docs/html_single/index.html#drl-queries-con_drl-rules
到此這篇關于drools中query的使用的文章就介紹到這了,更多相關drools query使用內容請搜索html5模板網以前的文章希望大家以后多多支持html5模板網！