如何对尚不存在的表使用Jooq？

Question

我有一个数据库（postgresql）与表Cdr。每个月都会在数据库中创建一个新表，该表具有与Table Cdr相同的模式，名为Cdr__（例如。Cdr_2016_04）。

我试图使用Jooq查询数据库，基于提供的日期。麻烦的是：

context.select(CDR.fields())
            .from("cdr_2017_01")
            .where(CDR.FIELD1.eq("somevalue")
                .and(CDR.FIELD2.notEqual("value 2")
                .and(CDR.FIELD2.notEqual("value 3")))
            .fetchInto(Cdr.class);

不起作用，因为它表明

组织。约克。例外DataAccessException:。。。来自cdr_2017_01，其中“公共”、“cdr”、“field1”和“公共”、“cdr”、“field2”

我尝试使用别名将其cdr_2017_01为cdr，但失败了，因为cdr已经存在。因为我使用CDR. FIELD1和CDR. field（），jooq要求from子句中的表是CDR。是否有某种方法可以使其通用，或者我不应该使用Jooq进行这种查询？

Answer 1

您得到的错误源于您在字段引用中使用生成的CDRliteral，例如CDR。字段1。所有这些字段都将使用“cdr”表完全限定，而不是您在from子句中输入的“cdr\u 2017\u 01”表。

您可以打开调试日志以查看jOOQ生成并发送到服务器的格式化SQL字符串。

最简单的解决方法是将您的"cdr_2017_01"表重新命名为"cdr"，如下所示：

context.select(CDR.fields())
        .from("cdr_2017_01 as cdr")
        .where(CDR.FIELD1.eq("somevalue")
            .and(CDR.FIELD2.notEqual("value 2")
            .and(CDR.FIELD2.notEqual("value 3")))
        .fetchInto(Cdr.class);

这在某种程度上适用于大多数查询。

您应该为此使用运行时架构/表映射功能。它正是为这些类型的多租户/分区用例而设计的。

然后，你可以这样写：

DSL.using(connection, new Settings()
       .withRenderMapping(new RenderMapping()
           .withSchemata(new MappedSchema()
               .withInput("my_schema_name")
               .withTables(new MappedTable()
                   .withInput(CDR.getName())
                   .withOutput(CDR.getName() + "_2017_01")))))
   .select(CDR.fields())
   .from(CDR)
   .where(CDR.FIELD1.eq("somevalue")
       .and(CDR.FIELD2.notEqual("value 2")
       .and(CDR.FIELD2.notEqual("value 3")))
   .fetchInto(Cdr.class);

当然，另一种选择可能是使用PostgreSQL的分区功能，在这种情况下，您可能不需要在客户机中显式指定表名：

https://www.postgresql.org/docs/current/static/ddl-partitioning.html