问题描述
我们正在使用 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();
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.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_B,HALT.FIELD_C
from FPS FPS
join HALT HALT on FPS.FIELD_A = HALT.ID
where FPS.FP_ID = ?
但是,由于我们需要查询某些时间点的数据,因此需要利用 Oracle 的 Flashback 功能。基本上,为此需要在表名和别名之间添加以下sql:
AS OF TIMESTAMP TO_TIMESTAMP('2021-01-26 14:48:23','YYYY-MM-DD HH24:MI:SS')
即
select FPS.FP_ID,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.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_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 = ?
具体来说,问题是闪回字符串被添加在别名之后而不是表名和别名之间。
使用连接时,情况变得更糟:
final QFps fps = QFps.fps;
final QHalt halt = QHalt.halt;
final sqlQuery<Tuple> query = queryFactory.select(fps.fpId,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,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()
的结果添加在表名之前,并且添加了 .addFlag()
内容 - 毫不奇怪 - 就在 where
之前。
final QFps fps = QFps.fps;
final QHalt halt = QHalt.halt;
final sqlQuery<Tuple> query = queryFactory.select(fps.fpId,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,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 = ?
也好不到哪里去。
我尝试了各种可能的方法,但没有找到将要插入的字符串放置在正确位置的方法。
如果做不到这一点,我可以使用 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,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,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,'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 = ?
这正是我想要的。
解决方法
虽然 JoinFlags 用于实现类似的功能,但正如您所注意到的,JoinFlags 目前不能用于在路径表达式和别名之间插入标志。这实际上是因为连接别名嵌入在路径表达式中。
另一种将 SQL 片段插入到生成的查询中的机制是通过 TemplateExpressions
。尽管不存在使用 TemplateExpressions
作为连接目标的 API,但您可以通过底层查询元数据将任何表达式类型添加为连接:
// 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));
如果您不喜欢上述代码段的语法,还有其他一些方法。您还可以看看我是如何在 QueryDSL 之上为 JPA 实现处理过的路径的: https://github.com/querydsl/querydsl/pull/2530/files 。但是,这需要您在 QueryDSL 核心类中引入更改。