query queryName(參數(shù)列表)
end

QueryResults queryResults = kieSession.getQueryResults("query的名字",可選參數(shù)類表);

kieSession.openLiveQuery("query的名字", new Object[]{可選參數(shù)}, new ViewChangedEventListener() {
    @Override
    public void rowInserted(Row row) {}
    @Override
    public void rowDeleted(Row row) { }
    @Override
    public void rowUpdated(Row row) {}
});

// 不帶參數(shù)的查詢
query "query01"
	// 注意這個地方的 $p，java代碼中需要用到
    $p: Person(age < 18)
end

// 不帶參數(shù)的query查詢
QueryResults queryResults = kieSession.getQueryResults("query01");
queryResults.iterator().forEachRemaining(row -> {
    // 那么這個地方的 $p 是怎么來的呢？其實是我們自己編寫的drl query中寫的
    Person person = (Person) row.get("$p");
    log.info("query01從工作內(nèi)存中獲取的query: {}", person);
});

// 帶參數(shù)的查詢
query query02(Integer $age)
    $p: Person(age < $age)
end

// 不帶參數(shù)的query查詢
// 帶參數(shù)的query查詢
queryResults = kieSession.getQueryResults("query02", 20);
queryResults.iterator().forEachRemaining(row -> {
    Person person = (Person) row.get("$p");
    log.info("query02從工作內(nèi)存中獲取的query: {}", person);
});

// 帶參數(shù)的查詢-查詢工作內(nèi)存Person對象的age的值小于外部傳遞進來的$age值
query query02(Integer $age)
    $p: Person(age < $age)
end
// 定義一個規(guī)則，當規(guī)則內(nèi)存中的Person的age小于18時，直接年齡+1
rule "rule_test_live_query_in_java"
    no-loop true
    when
        $p: Person($age:age < 18)
    then
        modify($p){
        	// 此處修改了工作內(nèi)存中age對象的值
            setAge($p.getAge() + 1)
        }
        System.out.println("更新來規(guī)則內(nèi)存中Person["+$p.getName()+"]的age:["+$p.getAge()+"]值");
end

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向工作內(nèi)存中插入Person: {}", person);
        }
        @Override
        public void rowDeleted(Row row) {
            Person person = (Person) row.get("$p");
            log.info("實時查詢-query02向工作內(nèi)存中刪除Person: {}", person);
        }
        @Override
        public void rowUpdated(Row row) {
            Person person = (Person) row.get("$p");
            log.info("實時查詢-query02向工作內(nèi)存中更新Person: {}", person);
        }
    });
    Person person1 = new Person("張三", 16);
    kieSession.insert(person1);
    kieSession.fireAllRules();
    kieSession.dispose();
}

// 定義一個查詢，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("張";) // 此處多個參數(shù)使用 , 分割，并且最后必須以 ; 結(jié)尾
    then
        System.out.println("在rule中使用query");
end