Drools休眠JPA註釋多對多示例DRL

Question

我是新的Hibernate和Drools，我希望這些流水評估給定Person的規則，並且只有在給定表上存在Person ID時纔會觸發。

例如：如果我有一個

表中調用 '人' 與字段：PERSONID = '1015'。 一個名爲'likes'的字段：id = 1，name = sports。

和一箇中間值表格稱爲'personLikes'字段：personID = 1015，idLikes = 1。

我加載具有三種不同的人：personID=1015，personID=1020，personID=1035。

在該情況下，僅對人code=1015執行規則。

問題是：我該如何構造該規則？

這是我的代碼。

DRL FILE：

 rule healthy when  
      p: Person() 
      i: Interes(nombre=="Sports") 
      InteresPersonaId(persona==p,interes==i) 
      //InteresesPersona(pk==ip)  

     then 
      System.out.println("OK" + p.id + "LIKES" +i.nombre); 


    end 

DB：

  CREATE TABLE IF NOT EXISTS `screb`.`person` (
       `idPerson` VARCHAR(15) NOT NULL, 
       `gender` CHAR(1) NULL DEFAULT NULL, 
       `age` INT(11) NULL DEFAULT NULL, 
       `estrato` INT(11) NULL DEFAULT NULL, 
       `idLocalizacion` INT(11) NULL DEFAULT NULL, 
       PRIMARY KEY (`idPerson`), 
       INDEX `FK_location_idx` (`idLocalizacion` ASC), 
       CONSTRAINT `FK_location` 
       FOREIGN KEY (`idLocalizacion`) 
       REFERENCES `screb`.`localizacion` (`idLocalizacion`) 
       ON DELETE NO ACTION 
       ON UPDATE NO ACTION) 
      ENGINE = InnoDB 
      DEFAULT CHARACTER SET = utf8; 

      USE `screb` ; 

      -- ----------------------------------------------------- 
      -- Table `screb`.`interes` 
      -- ----------------------------------------------------- 
      CREATE TABLE IF NOT EXISTS `screb`.`interes` (
       `idInteres` INT(11) NOT NULL AUTO_INCREMENT, 
       `nombre` VARCHAR(45) NULL DEFAULT NULL, 
       `descripcion` VARCHAR(45) NULL DEFAULT NULL, 
       PRIMARY KEY (`idInteres`)) 
      ENGINE = InnoDB 
      DEFAULT CHARACTER SET = utf8; 


      -- ----------------------------------------------------- 
      -- Table `screb`.`interesesxpersona` 
      -- ----------------------------------------------------- 
      CREATE TABLE IF NOT EXISTS `screb`.`interesesxpersona` (
       `persona` VARCHAR(15) NOT NULL DEFAULT '', 
       `Interes` INT(11) NOT NULL DEFAULT '0', 
       PRIMARY KEY (`persona`, `Interes`), 
       INDEX `FK_PERS_INT_idx` (`Interes` ASC), 
       CONSTRAINT `FK_IN_PER` 
       FOREIGN KEY (`persona`) 
       REFERENCES `screb`.`person` (`idPerson`) 
       ON DELETE NO ACTION 
       ON UPDATE NO ACTION, 
       CONSTRAINT `FK_PERS_INT` 
       FOREIGN KEY (`Interes`) 
       REFERENCES `screb`.`interes` (`idInteres`) 
       ON DELETE CASCADE 
       ON UPDATE CASCADE) 
      ENGINE = InnoDB 
      DEFAULT CHARACTER SET = utf8; 

類加載事實：

public class Campaign { 

      public static final void main(String[] args) { 
       KieContainer kc =  KieServices.Factory.get().getKieClasspathContainer(); 
       KieSession ksession = kc.newKieSession("CampaignKS"); 

       PersonManager person = new PersonManager(); 
       List<Person> list = person.listEvents(); 
       for(Person p :list){ 
        ksession.insert(p); 
       } 



       InteresManager interes = new InteresManager(); 
       List<Interes> listaIntereses = interes.listIntereses(); 
       for(Interes i :listaIntereses){ 
        ksession.insert(i); 
       } 



       ksession.fireAllRules(); 

       ksession.dispose(); 

      } 

     } 

映射類：

 @Entity 
       @Table(name="interes",schema="screb") 
       public class Interes implements java.io.Serializable { 

       public int idInteres; 
       public String nombre; 
       public String descripcion; 
       public Set<InteresesPersona> interesesP = new HashSet<InteresesPersona>(0); 


       public Interes(){} 
       public Interes(int interes,String nombre, String descripcion){ 
        this.idInteres=interes; 
        this.nombre=nombre; 
        this.descripcion=descripcion; 
       } 
       public Interes(int interes,String nombre, String descripcion, Set<InteresesPersona>interesesPersona){ 
        this.idInteres=interes; 
        this.nombre=nombre; 
        this.descripcion=descripcion; 
        this.interesesP=interesesPersona; 
       } 

       @Id @GeneratedValue 
       @Column(name="idInteres") 
       public int getIdInteres() { 
        return idInteres; 
       } 
       public void setIdInteres(int idInteres) { 
        this.idInteres = idInteres; 
       } 
       @Column(name="nombre") 
       public String getNombre() { 
        return nombre; 
       } 
       public void setNombre(String nombre) { 
        this.nombre = nombre; 
       } 
       @Column(name="descripcion") 
       public String getDescripcion() { 
        return descripcion; 
       } 
       public void setDescripcion(String descripcion) { 
        this.descripcion = descripcion; 
       } 

       @OneToMany(fetch = FetchType.LAZY, mappedBy = "pk.interes") 
       public Set<InteresesPersona> getInteresesP(){ 
        return this.interesesP; 

       } 
       public void setInteresesP(Set<InteresesPersona> interesesPersona){ 
        this.interesesP=interesesPersona; 

       } 
      } 

類InteresesPersona（PersonLikes）：

  @Entity 
      @Table(name="interes_persona",schema = "screb") 
      @AssociationOverrides({ 
        @AssociationOverride(name = "pk.persona", 
         joinColumns = @JoinColumn(name = "idPerson")), 
        @AssociationOverride(name = "pk.interes", 
         joinColumns = @JoinColumn(name = "idInteres")) }) 

      public class InteresesPersona implements java.io.Serializable{ 


       public InteresPersonaId pk = new InteresPersonaId(); 
       private Date createdDate; 

       public InteresesPersona(){} 

       @EmbeddedId 
       public InteresPersonaId getPk() { 
        return pk; 
       } 

       public void setPk(InteresPersonaId pk) { 
        this.pk = pk; 
       } 

       @Transient 
       public Person getPersona() { 
        return getPk().getPersona(); 
       } 

       public void setPersona(Person persona) { 
        getPk().setPersona(persona); 
       } 

       @Transient 
       public Interes getInteres() { 
        return getPk().getInteres(); 
       } 

       public void setInteres(Interes interes) { 
        getPk().setInteres(interes); 
       } 

       @Temporal(TemporalType.DATE) 
       @Column(name = "createdDate", nullable = false, length = 10) 
       public Date getCreatedDate() { 
        return this.createdDate; 
       } 

       public void setCreatedDate(Date createdDate) { 
        this.createdDate = createdDate; 
       } 


       public boolean equals(Object o) { 
        if (this == o) 
         return true; 
        if (o == null || getClass() != o.getClass()) 
         return false; 

        InteresesPersona that = (InteresesPersona) o; 

        if (getPk() != null ? !getPk().equals(that.getPk()) 
          : that.getPk() != null) 
         return false; 

        return true; 
       } 

       public int hashCode() { 
        return (getPk() != null ? getPk().hashCode() : 0); 
       } 


      } 

類InteresesPersonaID（PersonLikesID）

  @Embeddable 

      public class InteresPersonaId implements java.io.Serializable { 

       public Person persona; 
       public Interes interes; 

       @ManyToOne 
       public Person getPersona() { 
        return persona; 
       } 

       public void setPersona(Person persona) { 
        this.persona = persona; 
       } 

       @ManyToOne 
       public Interes getInteres() { 
        return interes; 
       } 

       public void setInteres(Interes interes) { 
        this.interes = interes; 
       } 

       public boolean equals(Object o) { 
        if (this == o) return true; 
        if (o == null || getClass() != o.getClass()) return false; 

        InteresPersonaId that = (InteresPersonaId) o; 

        if (persona != null ? !persona.equals(that.persona) : that.persona!= null) return false; 
        if (interes != null ? !interes.equals(that.interes) : that.interes != null) 
         return false; 

        return true; 
       } 

       public int hashCode() { 
        int result; 
        result = (persona != null ? persona.hashCode() : 0); 
        result = 31 * result + (interes != null ? interes.hashCode() : 0); 
        return result; 
       } 


      } 

類PERSON

  @Entity 
      @Table(name="person",schema="screb") 

      public class Person implements java.io.Serializable{ 

       public String id; 
       public char gender; 
       public int age; 
       public int estrato; 
       public Set<InteresesPersona> interesesP = new HashSet<InteresesPersona>(0); 


       public Person(){} 
       public Person(String id,char genero,int edad,int estrato){ 
        this.id=id; 
        this.gender=genero; 
        this.age=edad; 
        this.estrato=estrato; 
       } 
       public Person(String id,char genero,int edad,int estrato,Set<InteresesPersona>interesesPersona){ 
        this.id=id; 
        this.gender=genero; 
        this.age=edad; 
        this.estrato=estrato; 
        this.interesesP = interesesPersona; 
       } 

       @Id 
       @Column(name="idPerson") 
       public String getId() { 
        return id; 
       } 


       public void setId(String id) { 
        this.id = id; 
       } 

       @Column(name="gender") 
       public char getGender() { 
        return gender; 
       } 


       public void setGender(char gender) { 
        this.gender = gender; 
       } 

       @Column(name="age") 
       public int getAge() { 
        return age; 
       } 


       public void setAge(int age) { 
        this.age = age; 
       } 

       @Column(name="estrato") 
       public int getEstrato() { 
        return estrato; 
       } 


       public void setEstrato(int estrato) { 
        this.estrato = estrato; 
       }  

       @OneToMany(fetch = FetchType.LAZY, mappedBy= "pk.persona",cascade=CascadeType.ALL) 
       public Set<InteresesPersona> getInteresesP(){ 
        return this.interesesP; 

       } 

       public void setInteresesP(Set<InteresesPersona> interesesPersona){ 
        this.interesesP=interesesPersona; 

       } 

       @Override 
       public boolean equals(Object o){ 
        if(this==o){return true;} 
        if(o==null||getClass()!=o.getClass()){return false;} 

        Person person = (Person) o; 

        if (!id.equals(person.id)){return false;} 
        if (gender!=person.gender){return false;} 
        if (age!=person.age){return false;} 
        if (estrato!=person.estrato){return false;} 

        return true; 

       } 

       @Override 
       public int hashCode(){ 
        int result = id.hashCode(); 


        return result; 
       } 

      } 

類的PersonManager：

 public class PersonManager { 
      public List listEvents(){ 
       Session session= HibernateUtil.getSessionFactory().getCurrentSession(); 
       session.beginTransaction(); 
       Query query= session.createQuery("from Person"); 
       List<Person> list = query.list();  
       session.getTransaction().commit(); 



       return list; 
      } 
      } 

Answer 1

您的Java類有點多餘。這對編寫規則無關緊要，但可能會影響數據庫訪問。 InteresesPersona與InteresesPersonaId不同嗎？

rule "a person's interests a" 
when 
    Person($id: id, $pip: interesesP) 
    $ip: InteresesPersona() from $pip 
    Interes(interesesP contains $ip, $nom: nombre) 
then 
    System.out.println($id + " likes " + $nom); 
end 

每個人和利益組合的火災，由人員分組。 （重新排列，以將其交由興趣分組。）

如果你想插入InteresesPersonaId對象，你也可以寫

rule "a person's interests b" 
when 
    $ip: InteresesPersonaId($p: persona, $i: interes) 
    Person(this == $p, $id: id) 
    Interes(this == $i, $nom: nombre) 
then 
    System.out.println($id + " likes " + $nom); 
end 

但請注意，這條規則可以按隨機順序產生的結果，即，不被人分組。