使用Postgres(和AWS Redshift)DB Link与JOOQ

Question

我们正试图在Postgres和AWS Redshift DB之间建立一个DB链接(这不是问题(，但我们正在使用JOOQ为其构建DB Query。

什么在起作用如果两个表在同一个数据库中，我们可以为我们想要获取的数据编写JOIN SQL查询。例如，如果我们有一个查询：

SELECT somefields
FROM dblink('global_database'::text, '
SELECT
... some data selected...) t1(username text, location int, createdAt timestamptz)
JOIN user_meta t2 on "userId" = t1.userId
AND createdAt between ... some date range ...
WHERE ...'
GROUP BY ...
ORDER BY ... DESC;

现在我们正在使用JOOQ:构建查询

Query query = dslContext
.select(somefields))
.from(table(TABLE))
.rightJoin(TABLE_TWO).on(getJoinOnCondition())
.where(whereCondition)
.groupBy(groupByFields)
.orderBy(orderByFields)
.limit((int) pageRequest.getPageSize());

如何在JOOQ查询中建立DB链接？

Answer 1

分两步完成：

• 分别为两个数据库生成代码。使用<outputSchemaToDefault>true</outputSchemaToDefault>确保Redshift表没有关联的架构，请参阅手册
• 无论何时使用dblink，当您将Redshift表放在FROM子句中时，请将其包装在纯SQL模板中，否则请使用生成的类，例如使用以下实用程序：

static Table<?> dblink(String conn, Table<?> table, Field<?>... fields) {
return table("dblink({0}, {1}) as {2}({3})",
inline(conn),
inline(DSL.using(POSTGRES).render(select(fields).from(table))),
table.getUnqualifiedName(),
list(
Stream.of(fields)
.map(f -> DSL.sql("{0} {1}",
f.getUnqualifiedName(),
sql(f.getDataType().getCastTypeName())
))
.toArray(QueryPart[]::new)
)
);
}

通常的静态导入是隐含的：

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

然后像这样使用这个实用程序：

Query query = dslContext
.select(somefields))
.from(dblink("global_database", TABLE, TABLE.fields()))
.rightJoin(TABLE_TWO).on(getJoinOnCondition())
// You can now use TABLE as if it were a local table
.where(whereCondition)
.groupBy(groupByFields)
.orderBy(orderByFields)
.limit((int) pageRequest.getPageSize());