drools中query的用法小结

query queryName(参数列表)

end

QueryResults queryResults = kieSession.getQueryResults("query的名字",可选参数类表);

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) {}

});

// 不带参数的查询

query "query01"

     // 注意这个地方的 $p，java代码中需要用到

     $p: Person(age < 18)

end

// 不带参数的query查询

QueryResults queryResults = kieSession.getQueryResults( "query01" );

queryResults.iterator().forEachRemaining(row -> {

     // 那么这个地方的 $p 是怎么来的呢？其实是我们自己编写的drl query中写的

     Person person = (Person) row.get( "$p" );

     log.info( "query01从工作内存中获取的query: {}" , person);

});

// 带参数的查询

query query02(Integer $age)

     $p: Person(age < $age)

end

// 不带参数的query查询

// 带参数的query查询

queryResults = kieSession.getQueryResults( "query02" , 20 );

queryResults.iterator().forEachRemaining(row -> {

     Person person = (Person) row.get( "$p" );

     log.info( "query02从工作内存中获取的query: {}" , person);

});

// 带参数的查询-查询工作内存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

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();

}

// 定义一个查询，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