Drools查询。它们是如何评估和执行的？

Question

我在概念验证应用程序中评估Drools6。我要么误解了Drools中的查询是如何工作的，要么我没有正确地实现某些东西。谁能给我解释一下这种行为：

rule "Patient Intake: Valid new Patients without a Medical History require a Review"
    ruleflow-group "Patient Intake"
    when
        $patient : Patient( status == PatientStatus.NEW )
        not Invalid( value == $patient )
    then
        modify( $patient ){
            setStatus( PatientStatus.PENDING_REVIEW )
        };

        insert( new Valid( $patient ) );
    end

query "Intake Results"
    Valid( $patients : value )
end

valid/invalid对象的使用方式与使用trait类似，但是文档表明trait特性仍然是实验性的/可能会改变，所以我暂时选择了这个替代方案。我认为这个问题很简单。我正在使用无状态会话，并像调用决策服务一样调用引擎。下面的代码片段显示了如何调用引擎（目前有些值是硬编码的）：

StatelessKieSession kSession = kContainer.newStatelessKieSession( "TestKSession" );
KieRuntimeLogger auditLog = KieServices.Factory.get().getLoggers().newFileLogger( kSession, "audit" );
kSession.setGlobal( "logger", logger );

List<Command> commands = new ArrayList<Command>();
commands.add( CommandFactory.newInsertElements( request.getAllFacts() ) );
commands.add( CommandFactory.newQuery( "$patients", "Intake Results" ) );
commands.add( CommandFactory.newStartProcess( "x.y.z.intake" );

ExecutionResults results = kSession.execute( CommandFactory.newBatchExecution( commands ) );
auditLog.close();

我这样处理结果：

    private void processResults( ExecutionResults results ) {
        QueryResults qr = (QueryResults) results.getValue( "$patients" );
        for ( QueryResultsRow row : qr ) {
            // ... this code is never executed
        }
}

在控制台中，我看到println语句，QueryResult大小为0。但是，如果我将查询更改为只collect$patterns:Object()，则QueryResult大小是通过CommandFactory插入的对象数，并且不包括作为规则RHS的一部分插入的对象。当我检查审核日志时，我看到确实插入了Valid类型的对象。

为什么我的查询没有返回预期的结果？是我实现了错误的东西，还是我只是误解了查询的工作方式？

谢谢，詹姆斯

Answer 1

命令的添加顺序很重要。添加查询命令是向引擎发出执行该查询的信号，因此在进程启动之前插入事实并运行查询。

关键是将添加查询和开始处理的行反转。现在应改为：

List<Command> commands = new ArrayList<Command>();
commands.add( CommandFactory.newInsertElements( request.getAllFacts() ) );
commands.add( CommandFactory.newStartProcess( "x.y.z.intake" );
commands.add( CommandFactory.newQuery( "$patients", "Intake Results" ) );