JOOQ 从表中获取记录并将其插入到另一个表中

Question

我想从一个表中选择所有字段，获取另一个表的记录，然后将记录插入到该表中。但是，我收到一条错误消息，指出这些值为空。这是相关的代码：

    // Fetch
    PersonDeactivatedRecord person = getContext().selectFrom(PERSON)
            .where(PERSON.ID.eq(id))
            .fetchOneInto(PersonDeactivatedRecord.class);

    // Insert
    person.setDeactivatedOn(new Timestamp(System.currentTimeMillis()));
    getContext().insertInto(PERSON_DEACTIVATED)
            .set(person)
            .execute();

person_deactivated 表是person 表的副本加上一列 (deactivated_on)。我得到的错误是这样的：

org.jooq.exception.DataAccessException: SQL [insert into "xxx"."person_deactivated" ("deactivated_on") values (cast(? as timestamp))]; ERROR: null value in column "id" violates not-null constraint
  Detail: Failing row contains (null, null, null, null, null, null, null, null, null, ...)

请注意，当我调试此代码时，我看到 person 对象已按预期完全填充。知道我在这里缺少什么吗？

Answer 1

InsertSetStep.set(Record) 方法不会将整个person 记录插入到目标表中，而是只考虑那些值为“已更改”的字段。请参阅 Javadoc：

这与调用set(Map) 时将参数记录视为Map<Field<?>, Object> 相同，只是考虑了Record.changed() 标志以便仅更新更改的值。

因此，您有多种解决此问题的可能性（当然，我在这里列出的不止这些）：

1。将所有更改的标志设置为 true

这将是最简单的解决方法：

// Insert
person.setDeactivatedOn(new Timestamp(System.currentTimeMillis()));
person.changed(true); // Sets all flags to true
getContext().insertInto(PERSON_DEACTIVATED)
        .set(person)
        .execute();

2。编写单个查询

此解决方案的优点是您只有一个查询，这意味着：

1. 单台服务器往返（延迟更少）
2. 更好的锁定语义（数据库知道您在做什么，因此出现竞争条件的机会更少）

所以，你可以写：

getContext()
    .insertInto(PERSON_DEACTIVATED)
    .columns(PERSON_DEACTIVATED.fields())
    .select(
        select(Arrays
           .stream(PERSON_DEACTIVATED.fields())
           .map(f -> f.equals(PERSON_DEACTIVATED.DEACTIVATED_ON)
                   ? currentTimestamp()
                   : PERSON.field(f))
           .collect(Collectors.toList()))
       .from(PERSON)
       .where(PERSON.ID.eq(id))
    )
    .execute();

与往常一样，此答案假定您的代码中有以下静态导入：

import static org.jooq.impl.DSL.*;

上述查询会将PERSON 中的所有列插入PERSON_DEACTIVATED，除了DEACTIVATED_ON 列将被当前时间戳替换。