Jooq Java CTE неправильный рендеринг - PullRequest
Новая
       106

Jooq Java CTE неправильный рендеринг

1 голос

У меня есть CTE, который создается из DSL.values: 

final RowN[] rowNS = tasksId
                .stream()
                .map(x -> DSL.row(x.toString()))
                .toArray(RowN[]::new);

        CommonTableExpression<Record1<String>> cte = DSL
                .name("cte")
                .fields("id")
                .as(DSL
                        .select(
                                DSL.field("id", String.class)
                        )
                        .from(
                                DSL.values(rowNS).as("temp", "id")
                        )
                );

Затем я пытаюсь использовать его для получения необходимых значений из DB 

                dslContext
                        .with(
                                cte
                        )
                        .select(
                                DSL.field(TaskStateTable.taskId.getColumnName(), String.class),
                                DSL.field(TaskStateTable.state.getColumnName(), String.class)
                        )
                        .from(
                                DSL.table(tableNameProperties.getFullNameTableTaskState())
                        )
                        .join(
                                cte
                        )
                        .on(
                                DSL.field(tableNameProperties.getFullNameTableTaskState() + "." + TaskStateTable.taskId.getColumnName())
                                        .eq(cte.field("id"))
                        )
                        .fetchMap(
                                DSL.field(TaskStateTable.taskId.getColumnName(), String.class),
                                DSL.field(TaskStateTable.state.getColumnName(), String.class)
                        )

Но у меня есть только следующая ошибка 

jOOQ; uncategorized SQLException for SQL [with cte(id) as (select id from ((select null id where 1 = 0) union all (select * from (values(cast(? as varchar))) temp)) temp) select task_id, state from rtm.task_state join cte on rtm.task_state.task_id = cte.id]

Я полагаю, это происходит из-за (select * from (values ​​(cast (? as varchar))

Как исправить? Другие методы без cte работают нормально.

1 Ответ

1 голос

Проблема была там: 

DSL.field("id", String.class)

"Id" должен быть обернут DSL.name () 

DSL.field(DSL.name("id"), String.class)
...