将 ORACLE Flashback 与 QueryDSL 结合使用

Question

我们正在使用 QueryDSL 通过我们的 SpringBoot 应用程序从 Oracle 数据库中批量读取数据。

final QFps fps = QFps.fps;
final SQLQuery<Tuple> query = queryFactory.select(fps.fpId, fps.fieldA, fps.fieldB)
                                          .from(fps)
                                          .where(fps.fpId.eq(fpId));

final String sql = query.getSQL().getSQL();
log.info("sql={}", sql);

return query.fetch();

生成以下可以成功执行的 SQL 查询：

select FPS.FP_ID, FPS.FIELD_A, FPS.FIELD_B
from FPS FPS  
where FPS.FP_ID = ?

同样适用于左连接：

final QFps fps = QFps.fps;
final QHalt halt = QHalt.halt;
final SQLQuery<Tuple> query = queryFactory.select(fps.fpId, fps.fieldA, fps.fieldB, halt.fieldC)
                                          .from(fps)
                                          .leftJoin(halt).on(fps.fieldA.eq(halt.id))
                                          .where(fps.fpId.eq(fpId));

final String sql = query.getSQL().getSQL();
log.info("sql={}", sql);

return query.fetch();

结果

select FPS.FP_ID, FPS.FIELD_A, FPS.FIELD_B, HALT.FIELD_C
from FPS FPS  
join HALT HALT on FPS.FIELD_A = HALT.ID
where FPS.FP_ID = ?

但是，由于我们需要查询特定时间点的数据，因此我们需要利用 Oracle 的闪回功能。基本上，为此需要在 table 名称和别名之间添加以下 SQL：

AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS')

即

select FPS.FP_ID, FPS.FIELD_A, FPS.FIELD_B, HALT.FIELD_C
from FPS AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') FPS  
join HALT AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') HALT on FPS.FIELD_A = HALT.ID
where FPS.FP_ID = ?

我尝试使用 .addFlag() 和 .addJoinFlag() 命令使它与 QueryDSL 一起工作，但没有成功。

final QFps fps = QFps.fps;
final SQLQuery<Tuple> query = queryFactory.select(fps.fpId, fps.fieldA, fps.fieldB)
                                          .from(fps)
                                          .addFlag(Position.BEFORE_FILTER, getFlashbackString())
                                          .where(fps.fpId.eq(fpId));

final String sql = query.getSQL().getSQL();
log.info("sql={}", sql);

return query.fetch();

创造

select FPS.FP_ID, FPS.FIELD_A, FPS.FIELD_B
from FPS FPS AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') 
where FPS.FP_ID = ?

具体来说，问题是闪回字符串添加在别名之后，而不是在table名称之间和别名。

使用联接时，情况变得更糟：

final QFps fps = QFps.fps;
final QHalt halt = QHalt.halt;
final SQLQuery<Tuple> query = queryFactory.select(fps.fpId, fps.fieldA, fps.fieldB, halt.fieldC)
                                          .from(fps)
                                          .addFlag(Position.BEFORE_FILTER, getFlashbackString())
                                          .leftJoin(halt).on(fps.fieldA.eq(halt.id))
                                          .addJoinFlag(getFlashbackString())
                                          .where(fps.fpId.eq(fpId));

final String sql = query.getSQL().getSQL();
log.info("sql={}", sql);

return query.fetch();

产生

select FPS.FP_ID, FPS.FIELD_A, FPS.FIELD_B, HALT.FIELD_C
from FPS FPS  
join  AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') HALT HALT on FPS.FIELD_A = HALT.ID AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') 
where FPS.FP_ID = ?

.addJoinFlag() 的结果被添加到之前 table 名称和 .addFlag() 内容被添加 - 毫不奇怪 - 就在where.

final QFps fps = QFps.fps;
final QHalt halt = QHalt.halt;
final SQLQuery<Tuple> query = queryFactory.select(fps.fpId, fps.fieldA, fps.fieldB, halt.fieldC)
                                          .from(fps)
                                          .addFlag(Position.BEFORE_FILTER, getFlashbackString())
                                          .leftJoin(halt).on(fps.fieldA.eq(halt.id))
                                          .addJoinFlag(getFlashbackString(), Position.BEFORE_CONDITION)
                                          .where(fps.fpId.eq(fpId));

final String sql = query.getSQL().getSQL();
log.info("sql={}", sql);

return query.fetch();

将其更改为

select FPS.FP_ID, FPS.FIELD_A, FPS.FIELD_B, HALT.FIELD_C
from FPS FPS  
join HALT HALT  AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') on FPS.FIELD_A = HALT.ID AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') 
where FPS.FP_ID = ?

也好不了多少

我试过各种可能的方法，但没有找到一种方法可以将要插入的字符串放在正确的位置。

我是否缺少另一种在查询的某些位置注入 SQL 的方法？

否则，我可以使用 QueryDSL 生成 SQL 字符串，然后自己使用正则表达式对其进行修改。有没有办法将这样的字符串传递给 QueryDSL 以便执行查询？

整合接受的答案

Jan-Willem Gmellig Meyling 给出的答案有效，我只想将其完全整合到我上面的示例中：

我创建了一个辅助方法：

  private static final String ADDITIONAL_FLASHBACK_EXPRESSION = "{0} AS OF TIMESTAMP TO_TIMESTAMP({1}, 'YYYY-MM-DD HH24:MI:SS') {2}";
  private static final DateTimeFormatter FLASHBACK_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");

public <T> Expression<String> getFlashbackExpresion(final Timestamp flashbackTimestamp, final RelationalPathBase<T> table) {
    if (flashbackTimestamp == null) {
      return Expressions.stringTemplate(WITHOUT_FLASHBACK_EXPRESSION, table, table);
    }
    
    final LocalDateTime timestamp = LocalDateTime.ofInstant(flashbackTimestamp.toInstant(), ZoneOffset.ofHours(0));
    final String timestampString = timestamp.format(FLASHBACK_FORMATTER);
    
    return Expressions.stringTemplate(ADDITIONAL_FLASHBACK_EXPRESSION, table, timestampString, table);
  }

使用它，我现在可以创建任意闪回路径以用于 from() 和 addJoin():

final Timestamp flashbackTimestamp = getFlashbackTimestamp();

final QFps fps = QFps.fps;
final QHalt halt = QHalt.halt;

final fpsFlashback = getFlashbackExpresion(flashbackTimestamp, fps);
final haltFlashback = getFlashbackExpresion(flashbackTimestamp, halt);

final SQLQuery<Tuple> query = queryFactory.select(fps.fpId, fps.fieldA, fps.fieldB, halt.fieldC);

query.from(fpsFlashback)
     .getMetadata().addJoin(JointType.LEFTJOIN, haltFlashback);
query.on(fps.fieldA.eq(halt.id))
     .where(fps.fpId.eq(fpId));

final String sql = query.getSQL().getSQL();
log.info("sql={}", sql);

return query.fetch();

产生

select FPS.FP_ID, FPS.FIELD_A, FPS.FIELD_B, HALT.FIELD_C
from FPS AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') FPS
join HALT AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23', 'YYYY-MM-DD HH24:MI:SS') HALT on FPS.FIELD_A = HALT.ID
where FPS.FP_ID = ?

这正是我想要的。

Answer 1

尽管 JoinFlags 用于实现类似的功能，但正如您所注意到的，JoinFlags 目前不能用于在路径表达式和别名之间插入标志。这实际上是因为连接别名嵌入在路径表达式中。

另一种将 SQL 的片段插入生成的查询的机制是通过 TemplateExpressions。尽管不存在 API 可将 TemplateExpressions 用作连接目标，但您可以通过基础查询元数据将任何表达式类型添加为连接：

// Even parameterized it for you :)
Expression flashback = Expressions.stringTemplate(
    "{0} AS OF TIMESTAMP TO_TIMESTAMP({1}, 'YYYY-MM-DD HH24:MI:SS') ",
    halt,
    '2021-01-26 14:48:23');


query.from(fps);
query.getMetadata().addJoin(JoinType.LEFTJOIN, flashback);
query.on(fps.fieldA.eq(halt.id));

如果您不喜欢上面代码段的语法，还有一些其他方法。您还可以看看我是如何在 JPA 的 QueryDSL 之上实现处理路径的： https://github.com/querydsl/querydsl/pull/2530/files 。但是，这需要您对 QueryDSL 核心进行更改类。

将 ORACLE Flashback 与 QueryDSL 结合使用

Using ORACLE Flashback with QueryDSL

java

sql

querydsl

flashback