Drools Introduction and General User Guide

KnowledgeBaseConfiguration kconf = KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
kconf.setOption( DeclarativeAgendaOption.ENABLED );
KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase(  kconf );

void blockActivation(Activation match);
void unblockAllActivations(Activation match);
void cancelActivation(Activation match);

rule rule1 @department('sales') when 
     $s : String( this == 'go1' ) 
then 
    list.add( kcontext.rule.name + ':' + $s ); 
end 
rule rule2 @department('sales') when 
     $s : String( this == 'go1' ) 
then 
    list.add( kcontext.rule.name + ':' + $s ); 
end 
rule blockerAllSalesRules @activationListener('direct') when 
     $s : String( this == 'go2' ) 
     $i : Activation( department == 'sales' ) 
then 
    list.add( $i.rule.name + ':' + $s  ); 
    kcontext.blockActivation( $i ); 
end

rule rule1 @department('sales') when 
     $s : String( this == 'go1' ) 
then 
    list.add( kcontext.rule.name + ':' + $s ); 
end 
rule rule2 @department('sales') when 
     $s : String( this == 'go1' ) 
then 
    list.add( kcontext.rule.name + ':' + $s ); 
end 
rule rule3 @department('sales') when 
     $s : String( this == 'go1' ) 
then 
    list.add( kcontext.rule.name + ':' + $s ); 
end 
rule countActivateInActive @activationListener('direct') when 
     $s : String( this == 'go2' ) 
     $active : Number( this == 1 ) from accumulate( $a : Activation( department == 'sales', active == true ), count( $a ) )
     $inActive : Number( this == 2 ) from  accumulate( $a : Activation( department == 'sales', active == false ), count( $a ) )
then 
    kcontext.halt( ); 
end 

declare entry-point X
    @doc( "This entry point is receives events from the message queue X" )
end

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

       xmlns:drools="http://drools.org/schema/drools-spring"       

       xmlns:camel="http://camel.apache.org/schema/spring"

       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd

                           http://drools.org/schema/drools-spring http://anonsvn.jboss.org/repos/labs/labs/jbossrules/trunk/drools-container/drools-spring/src/main/resources/org/drools/container/spring/drools-spring-1.0.0.xsd

                           http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">

  <drools:resource id="resource1" type="DRL" source="classpath:org/drools/container/spring/testSpring.drl"/>



  <drools:kbase id="kbase1">

    <drools:resources>

      <drools:resource type="DRL" source="classpath:org/drools/container/spring/testSpring.drl"/>

      <drools:resource ref="resource1"/>

      <drools:resource source="classpath:org/drools/container/spring/IntegrationExampleTest.xls" type="DTABLE">

        <drools:decisiontable-conf input-type="XLS" worksheet-name="Tables_2" />

      </drools:resource>

    </drools:resources>



    <drools:configuration>

      <drools:mbeans enabled="true" />

      <drools:event-processing-mode mode="STREAM" />

    </drools:configuration>

  </drools:kbase>

</beans>

<drools:ksession id="ksession1" type="stateless" name="stateless1" kbase="kbase1" />



<drools:ksession id="ksession2" type="stateful" kbase="kbase1" />

<drools:ksession id="ksession1" type="stateful"  kbase="kbase1" >

  <drools:configuration>

    <drools:work-item-handlers>

      <drools:work-item-handler name="handlername" ref="handlerid" />

    </drools:work-item-handlers>

    <drools:keep-reference enabled="true" />

    <drools:clock-type type="REALTIME"  /> 

  </drools:configuration>

</drools:ksession>

<bean id="ds" class="org.springframework.jdbc.datasource.DriverManagerDataSource">

  <property name="driverClassName" value="org.h2.Driver" />

  <property name="url" value="jdbc:h2:tcp://localhost/DroolsFlow" />

  <property name="username" value="sa" />

  <property name="password" value="" />

</bean>



<bean id="myEmf" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">

  <property name="dataSource" ref="ds" />

  <property name="persistenceUnitName" value="org.drools.persistence.jpa.local" />

</bean>



<bean id="txManager" class="org.springframework.orm.jpa.JpaTransactionManager">

  <property name="entityManagerFactory" ref="myEmf" />

</bean>



<drools:ksession id="jpaSingleSessionCommandService" type="stateful" kbase="kbase1">

  <drools:configuration>

    <drools:jpa-persistence>

      <drools:transaction-manager ref="txManager" />

      <drools:entity-manager-factory ref="myEmf" />

      <drools:variable-persisters>

         <drools:persister for-class="javax.persistence.Entity" implementation="org.drools.persistence.processinstance.persisters.JPAVariablePersister"/>

         <drools:persister for-class="java.lang.String" implementation="org.drools.container.spring.beans.persistence.StringVariablePersister"/>

         <drools:persister for-class="java.io.Serializable" implementation="org.drools.persistence.processinstance.persisters.SerializableVariablePersister"/>

      </drools:variable-persisters>  

    </drools:jpa-persistence>

  </drools:configuration>    

</drools:ksession>

<drools:ksession id="jpaSingleSessionCommandService" type="stateful" kbase="kbase1">

  <drools:script>

     <drools:insert-object ref="person1" />

     <drools:start-process process-id="proc name">

       <drools:parameter identifier="varName" ref="varRef" />

     </drools:start-process>

     <drools:fire-all-rules />

  </drools:script>    

</drools:ksession>

<execution-node id="node1" />



<drools:ksession id="ksession1" type="stateless" name="stateless1" kbase="kbase1" node="node1"/>



<drools:ksession id="ksession2" type="stateful" kbase="kbase1" node="node1"/>

<cxf:rsServer id="rsServer"  

              address="/kservice/rest"

              serviceClass="org.drools.jax.rs.CommandExecutorImpl">

   <cxf:providers>

      <bean class="org.drools.jax.rs.CommandMessageBodyReader"/>

   </cxf:providers>

</cxf:rsServer> 

<bean id="droolsPolicy" class="org.drools.camel.component.DroolsPolicy" />  

    

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">        

   <route>

      <from uri="cxfrs://bean://rsServer"/>

      <policy ref="droolsPolicy">

         <unmarshal ref="xstream" />       

         <to uri="drools://node/ksession1" />

         <marshal ref="xstream" />

      </policy>

   </route>           

</camelContext>

StatefulKnowledgeSession ksession = ...

 

// ... insert facts, fire rules, etc

 

SessionInspector inspector = new SessionInspector( ksession );

StatefulKnowledgeSessionInfo info = inspector.getSessionInfo();

String report = SessionReporter.generateReport( "simple", info, null );

final List updated = new ArrayList();

final List removed = new ArrayList();

final List added = new ArrayList();

 

ViewChangedEventListener listener = new ViewChangedEventListener() {           

 public void rowUpdated(Row row) {

  updated.add( row.get( "$price" ) );

 }

  

 public void rowRemoved(Row row) {

  removed.add( row.get( "$price" ) );

 }

  

 public void rowAdded(Row row) {

  added.add( row.get( "$price" ) );

 }

};       

 

// Open the LiveQuery

LiveQuery query = ksession.openLiveQuery( "cheeses",

                                          new Object[] { "cheddar", "stilton" },

                                          listener );

...

...

query.dispose() // make sure you call dispose when you want the query to close

timer ( int: <initial delay> <repeat interval>? )

timer ( int: 30s )

timer ( int: 30s 5m )

 

timer ( cron: <cron expression> )

timer ( cron:* 0/15 * * * ? )

rule "Send SMS every 15 minutes"

    timer (cron:* 0/15 * * * ?)

when

    $a : Alarm( on == true )

then

    channels[ "sms" ].insert( new Sms( $a.mobileNumber, "The alarm is still on" );

end

Calendar weekDayCal = QuartzHelper.quartzCalendarAdapter(org.quartz.Calendar quartzCal)

ksession.getCalendars().set( "week day", weekDayCal );

rule "weekdays are high priority"

   calendars "weekday"

   timer (int:0 1h)

when 

    Alarm()

then

    send( "priority high - we have an alarm );

end 


rule "weekend are low priority"

   calendars "weekend"

   timer (int:0 4h)

when 

    Alarm()

then

    send( "priority low - we have an alarm );

end

Package[] packages = pkgBuilder.getPackages();

RuleBase ruleBase = RuleBaseFactory.newRuleBase();

PackageBuilder pkgBuilder = new PackageBuilder( ruleBase, null );

declare StockTick
  @role( event )
  @timestamp( timestampAttr )

  companySymbol : String
  stockPrice : double
  timestampAttr : long
end

declare StockTick
  @role( event )
end

declare Person
  name : String
  age : int
end

KnowledgeBaseConfiguration config = KnowledgeBaseFactory.newKnowledgeBaseConfiguration();

config.setOption( AssertBehaviorOption.EQUALITY );

config.setOption( RemoveIdentitiesOption.YES );

config.setOption( AlphaThresholdOption.get(5) );

// collect the set of unique names in the working memory
$names : Set() from accumulate( Person( $n : name, $s : surname ),
                        collectSet( $n + " " + $s ) )

// collect the list of alarm codes from the alarms in the working memory
$codes : List() from accumulate( Alarm( $c : code, $s : severity ),
                         collectList( $c + $s ) )

declare Person
  @propertyChangeSupport
end

ksession.execute( CommandFactory.newInsert( person ) ); 

List<Command> cmds = new ArrayList<Command>();

cmds.add( CommandFactory.newSetGlobal( "list1", new ArrayList(), true ) );

cmds.add( CommandFactory.newInsert( new Person( "jon", 102 ), "person" ) );

cmds.add( CommandFactory.newQuery( "Get People" "getPeople" );


BatchExecutionResults results = ksession.execute( CommandFactory.newBatchExecution( cmds ) );

results.getValue( "list1" ); // returns the ArrayList

results.getValue( "person" ); // returns the inserted fact Person

results.getValue( "Get People" );// returns the query as a QueryResults instance.

end

Action executeResultHandler = PipelineFactory.newExecuteResultHandler();

Action assignResult = PipelineFactory.newAssignObjectAsResult();

assignResult.setReceiver( executeResultHandler );

Transformer outTransformer = PipelineFactory.newXStreamToXmlTransformer( BatchExecutionHelper.newXStreamMarshaller() );

outTransformer.setReceiver( assignResult );

KnowledgeRuntimeCommand batchExecution = PipelineFactory.newBatchExecutor();

batchExecution.setReceiver( outTransformer );

Transformer inTransformer = PipelineFactory.newXStreamFromXmlTransformer( BatchExecutionHelper.newXStreamMarshaller() );

inTransformer.setReceiver( batchExecution );

Pipeline pipeline = PipelineFactory.newStatelessKnowledgeSessionPipeline( ksession );

pipeline.setReceiver( inTransformer ); 

<batch-execution>

<insert out-identifier='outStilton'>

  <org.drools.Cheese>

    <type>stilton</type>

    <price>25</price>

    <oldPrice>0</oldPrice>

  </org.drools.Cheese>

</insert>

</batch-execution>

<batch-execution-results>

 <result identifier='outStilton'>

   <org.drools.Cheese>

     <type>stilton</type>

     <oldPrice>0</oldPrice>       

     <price>30</price>

   </org.drools.Cheese>

 </result>

</batch-execution-results>