在 Drools 6 中从数据库加载和更新规则

Question

如何在启动时从数据库 table 加载规则并在 Drools 6.2.0 中从同一个 table 更新规则？我找到了一个使用 Drools 5 的 example，我可以将它从 Scala 转换为 Java，但看起来 API 已经发生了相当大的变化......我没有看到 RuleBaseFactory class，例如

如有任何示例或文档，我们将不胜感激。

Answer 1

我不确定 org.drools.RuleBaseFactory 是从哪里拍摄的。下面是在 Drools 5.3（可能更早）到 5.6 中是如何完成的：

KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
kbuilder.add( ..., ResourceType.DRL);
if( kbuilder.hasErrors() ){
    System.err.println( "### compilation errors ###" );
    KnowledgeBuilderErrors errors = kbuilder.getErrors();
    for( KnowledgeBuilderError err: errors ){
        System.err.println( err.toString() );
    }
    throw new IllegalStateException( "compile errors" );
}
KnowledgeBase kbase = kbuilder.newKnowledgeBase();
StatelessKnowledgeSession ksession = kbase.newStatelessKnowledgeSession();

省略号表示插入包含规则文本的数据的位置。检查 API 以找到合适的类型； java.lang.String 应该可以接受。

这是我在 6.2 中使用的方式：

KieServices kieServices = KieServices.Factory.get();
KieFileSystem kfs = kieServices.newKieFileSystem();
kfs.write( "src/main/resources/simple.drl", ... );
KieBuilder kieBuilder = kieServices.newKieBuilder( kfs ).buildAll();
Results results = kieBuilder.getResults();
if( results.hasMessages( Message.Level.ERROR ) ){
    System.out.println( results.getMessages() );
    throw new IllegalStateException( "### errors ###" );
}
KieContainer kieContainer =
    kieServices.newKieContainer( kieServices.getRepository().getDefaultReleaseId() );
KieBase kieBase = kieContainer.getKieBase();
kieSession = kieContainer.newKieSession();

Answer 2

drools-templates 有 ResultSetGenerator.java 方法 compile(resultSet, template) 来完成这项工作。

我有来自 HTTP 的数据要转换为规则。我找到了一种使用 ObjectDataCompiler 来执行此操作的方法。可能有些人会觉得这很有用。

ObjectDataCompiler compiler = new ObjectDataCompiler();
String generatedDRL = compiler.compile(ruleAttributes, new FileInputStream(REGULATION_TEMPLATE_FILE));

ruleAttributes 是

List<Map<String, String>> ruleAttributes = new ArrayList<>();
Map<String, String> rule1 = new HashMap<>();
rule1.put("ruleid", "2");
rule1.put("ifcondition", "abc: Abc(xyz.getId() == 2);");
rule1.put("thencondition", "myGlobal.setPqr(200.1D);");
ruleAttributes.add(rule1);

然后可以像这样创建 KieBase：

KieServices kieServices = KieServices.Factory.get();

KieHelper kieHelper = new KieHelper();

//multiple such resoures/rules can be added
byte[] b1 = generatedDRL.getBytes();
Resource resource1 = kieServices.getResources().newByteArrayResource(b1);
kieHelper.addResource(resource1, ResourceType.DRL);

KieBase kieBase = kieHelper.build();

可以这样应用规则：

KieSession kieSession = kieBase.newKieSession();
kieSession.setGlobal("myGlobal", myGlobal);
kieSession.insert(abc);
int numberOfRulesFired = kieSession.fireAllRules();
kieSession.dispose();

模板文件如下所示：

template header
ruleid
ifcondition
thencondition

import fk.sp.seldon.msku.MSKU

global com.something.blah.MyGlobal myGlobal

template "tmp1"

rule "@{ruleid}"
  dialect "mvel"
  when
    @{ifcondition}
  then
    @{thencondition};
end
end template

在 Drools 6 中从数据库加载和更新规则

Loading and updating rules from a database in Drools 6

java

drools