如何使用Camel JPA在hibernate@EntityListener操作后将数据写入表

Question

我正在将数据插入SQL Server表。在插入过程中，我需要检查是否有任何现有行正在更新，然后更新另一个表，写入更新的列。例如：
表1：插入的新行A1和更新的行A2
表2：应创建两行

<Old Value> <New Value> <Unique Key>
""            A1              PK1    --for insert
"Dummy Val"   A2              PK2    --for update

我用的是阿帕奇骆驼，冬眠，jpa

插入数据的主表：

@Entity(name = "tableName")
@EntityListeners(value = updateEntityListener.class)
public class ExampleTable{

    @Column(name = "col1")
    private int col1;
    //getter setter
    @Override
    public String toString() {
        return "data";
    }

听众

import javax.persistence.PostLoad;
import javax.persistence.PostPersist;
import javax.persistence.PostUpdate;

public class updateEntityListener{
    private String preUpdate = "";
    private String postUpdate = "";

    @PostPersist
    public void postPersist(final ExampleTable ex) {
//Insert data in another table
        System.out.println("Row inserted");
    }

    @PostUpdate
    public void postUpdate(final ExampleTable ex) {
        postUpdate = ex.toString();
        if (!preUpdate.equals(postUpdate)) {
            System.out.println("Row Updated");
            // Insert in new table, compare from postLoad
        }
    }
    @PostLoad
    public void postLoad(final ExampleTable ex) {
        preUpdate = ex.toString();
    }
}

camel Builder（Java DSL）

from("timer:invoke?repeatCount=1")
        .log("Processing ${id}")
        .toD("https4://URL")
        .inheritErrorHandler(true)
        .unmarshal()
        .json(JsonLibrary.Jackson)
        .split(body())
        .parallelProcessing()
        .process(new MyProcessor())
        .to("jpa:ExampleTable")

我需要将数据写入表2中，但不确定代码中的位置以及如何写入。感谢您的帮助。如果这个问题已经被问到，请告诉我该链接。

Answer 1

我找到了解决方案，分享给其他人，让他们在遇到类似情况时也能使用
为实体中的第二个表创建了列

@Entity(name = "tableName")
@EntityListeners(value = updateEntityListener.class)
public class ExampleTable{

    @Column(name = "col1")
    private int col1;
    @Transient
    private List<Table2> auditInfo = new ArrayList<Table2>();
    //getter setter
    @Override
    public String toString() {
        return "data";
    }

侦听器更改：

import javax.persistence.PostLoad;
import javax.persistence.PostPersist;
import javax.persistence.PostUpdate;

public class updateEntityListener{
    private String preUpdate = "";
    private String postUpdate = "";

    @PostPersist
    public void postPersist(final ExampleTable ex) {
//Insert data in another table
ex.setAuditInfo(new Object()); //Actual object instead of new Object()
        System.out.println("Row inserted");
    }

    @PostUpdate
    public void postUpdate(final ExampleTable ex) {
        postUpdate = ex.toString();
        if (!preUpdate.equals(postUpdate)) {
            System.out.println("Row Updated");
            // Insert in new table, compare from postLoad
            ex.setAuditInfo(new Object()); 
        }
    }
    @PostLoad
    public void postLoad(final ExampleTable ex) {
        preUpdate = ex.toString();
    }
}

最后，生成器更改：

from("timer:invoke?repeatCount=1")
        .log("Processing ${id}")
        .toD("https4://URL")
        .inheritErrorHandler(true)
        .unmarshal()
        .json(JsonLibrary.Jackson)
        .split(body())
        .parallelProcessing()
        .process(new MyProcessor())
        .to("jpa:ExampleTable")
        .process(new Processor() {
                public void process(Exchange arg0) throws Exception {
                    List<Table2> info= ((ExampleTable) arg0.getIn().getBody()).getAuditInfo();
                    if (null != info&& info.size() > 0) {
                        arg0.getIn().setBody(info);
                    }else{
                        arg0.getIn().setBody(new ArrayList<Table2>());
                    }

                }
            })
            .to("jpa:Table2?entityType=java.util.ArrayList");

Answer 2

我建议使用一种类似于实时审计如何与Envers协同工作的方法。

您要做的是注册各种PostXXXEventListener实现，以满足您的需要，然后让这些侦听器根据正在处理的当前操作保留新实体。

看看org内部。冬眠事件spi了解详细信息。