github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[jOOQ/jOOQ#15414] Can't generate code using CockroachDB materialized

Browse Source 
view
This commit is contained in:
Lukas Eder 2023-07-20 10:46:57 +02:00
parent 28f76ad760
commit 34c7faaaa3
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
jOOQ-meta/src/main/java/org/jooq/meta/postgres/PostgresMaterializedViewDefinition.java
View File

@ -111,15 +111,16 @@ public class PostgresMaterializedViewDefinition extends AbstractTableDefinition
PgNamespace nbt = PG_NAMESPACE.as("nbt");
PgNamespace nco = PG_NAMESPACE.as("nco");
Field<String> udtName = field("({0})::information_schema.sql_identifier", col.UDT_NAME.getDataType(), nvl(bt.TYPNAME, t.TYPNAME));
// [#8478] [#15414] CockroachDB can't use information_schema.sql_identifier
Field<String> udtName = field("({0})::varchar", col.UDT_NAME.getDataType(), nvl(bt.TYPNAME, t.TYPNAME));
Condition c1 = t.TYPTYPE.eq(inline("d"));
Condition c1array = bt.TYPELEM.ne(inline(0L)).and(bt.TYPLEN.eq(inline((short) -1)));
Condition c0array = t.TYPELEM.ne(inline(0L)).and(t.TYPLEN.eq(inline((short) -1)));
for (Record record : create().select(
field("({0})::information_schema.sql_identifier", col.COLUMN_NAME.getDataType(), a.ATTNAME).as(col.COLUMN_NAME),
field("({0})::information_schema.cardinal_number", col.ORDINAL_POSITION.getDataType(), a.ATTNUM).as(col.ORDINAL_POSITION),
field("({0})::information_schema.character_data", col.DATA_TYPE.getDataType(),
field("({0})::varchar", col.COLUMN_NAME.getDataType(), a.ATTNAME).as(col.COLUMN_NAME),
field("({0})::int", col.ORDINAL_POSITION.getDataType(), a.ATTNUM).as(col.ORDINAL_POSITION),
field("({0})::varchar", col.DATA_TYPE.getDataType(),
when(c1,
when(c1array, substring(udtName, inline(2)).concat(inline(" ARRAY")))
.when(nbt.NSPNAME.eq(inline("pg_catalog")), field("format_type({0}, NULL::integer)", String.class, t.TYPBASETYPE))
@ -128,14 +129,14 @@ public class PostgresMaterializedViewDefinition extends AbstractTableDefinition
when(c0array, substring(udtName, inline(2)).concat(inline(" ARRAY")))
.when(nt.NSPNAME.eq(inline("pg_catalog")), field("format_type({0}, NULL::integer)", String.class, a.ATTTYPID))
.otherwise(inline("USER-DEFINED")))).as(col.DATA_TYPE),
field("(information_schema._pg_char_max_length(information_schema._pg_truetypid(a.*, t.*), information_schema._pg_truetypmod(a.*, t.*)))::information_schema.cardinal_number", col.CHARACTER_MAXIMUM_LENGTH.getDataType()).as(col.CHARACTER_MAXIMUM_LENGTH),
field("(information_schema._pg_numeric_precision(information_schema._pg_truetypid(a.*, t.*), information_schema._pg_truetypmod(a.*, t.*)))::information_schema.cardinal_number", col.NUMERIC_PRECISION.getDataType()).as(col.NUMERIC_PRECISION),
field("(information_schema._pg_numeric_scale(information_schema._pg_truetypid(a.*, t.*), information_schema._pg_truetypmod(a.*, t.*)))::information_schema.cardinal_number", col.NUMERIC_SCALE.getDataType()).as(col.NUMERIC_SCALE),
field("({0})::information_schema.yes_or_no", col.IS_NULLABLE.getDataType(),
field("(information_schema._pg_char_max_length(information_schema._pg_truetypid(a.*, t.*), information_schema._pg_truetypmod(a.*, t.*)))::integer", col.CHARACTER_MAXIMUM_LENGTH.getDataType()).as(col.CHARACTER_MAXIMUM_LENGTH),
field("(information_schema._pg_numeric_precision(information_schema._pg_truetypid(a.*, t.*), information_schema._pg_truetypmod(a.*, t.*)))::integer", col.NUMERIC_PRECISION.getDataType()).as(col.NUMERIC_PRECISION),
field("(information_schema._pg_numeric_scale(information_schema._pg_truetypid(a.*, t.*), information_schema._pg_truetypmod(a.*, t.*)))::integer", col.NUMERIC_SCALE.getDataType()).as(col.NUMERIC_SCALE),
field("({0})::varchar", col.IS_NULLABLE.getDataType(),
when(condition(a.ATTNOTNULL).or(t.TYPTYPE.eq(inline("d")).and(t.TYPNOTNULL)), inline("NO"))
.otherwise(inline("YES"))).as(col.IS_NULLABLE),
field("(pg_get_expr({0}, {1}))::information_schema.character_data", col.COLUMN_DEFAULT.getDataType(), ad.ADBIN, ad.ADRELID).as(col.COLUMN_DEFAULT),
field("({0})::information_schema.sql_identifier", col.UDT_SCHEMA.getDataType(),
field("(pg_get_expr({0}, {1}))::varchar", col.COLUMN_DEFAULT.getDataType(), ad.ADBIN, ad.ADRELID).as(col.COLUMN_DEFAULT),
field("({0})::varchar", col.UDT_SCHEMA.getDataType(),
nvl(nbt.NSPNAME, nt.NSPNAME)).as(col.UDT_SCHEMA),
when(c1.and(c1array).or(not(c1).and(c0array)), substring(udtName, inline(2)))
.else_(udtName)