无需修改jOOQ核心，如何修正其生成的错误或不准确DDL？

我大量使用jOOQ的Schema导出功能，但部分场景下jOOQ生成的数据库对象DDL存在错误或不准确。除了对生成的DDL字符串使用替换/正则命令外，是否有标准方法可微调生成的DDL？

示例场景 #

1. 创建表（禁用NO_ZERO_DATE模式）：

set sql_mode='';
create table test_date_types_table (
  timestamp_column_nullable timestamp null,
  timestamp_column_not_null timestamp not null,
  timestamp_column_default timestamp
);

2. 运行Java代码生成该表的DDL：

Connection conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:6000/sakila", "root", "admin");
Configuration configuration = new DefaultConfiguration().set(conn).set(SQLDialect.MYSQL.family());
Meta currentMeta = using(configuration).meta();

Query[] queries = currentMeta
        .filterSchemas(v -> v.getName().equalsIgnoreCase("sakila"))
        .ddl()
        .queries();

for (Query query : queries) {
    System.out.println(query);
}

3. jOOQ生成的错误DDL：

create table `sakila`.`test_date_types_table` (
  `timestamp_column_nullable` timestamp,
  `timestamp_column_not_null` timestamp not null default null,
  `timestamp_column_default` timestamp not null default null
)

4. 执行报错：

Invalid default value for 'timestamp_column_not_null'

5. 问题点：

• 原本非空的timestamp_column_not_null被错误添加了default null，导致执行失败
• 原本可为空的timestamp_column_default被错误标记为not null并添加default null

6. 期望生成的有效DDL：

create table `sakila`.`test_date_types_table` (
  `timestamp_column_nullable` timestamp,
  `timestamp_column_not_null` timestamp not null,
  `timestamp_column_default` timestamp
)

解决方案（无需修改jOOQ核心） #

1. 自定义DataTypeBinding或DataTypeConverter #

针对MySQL的timestamp类型做特殊处理，通过绑定器覆盖jOOQ对该类型的元数据解析和DDL生成逻辑：

public class MySQLTimestampBinding implements Binding<Timestamp, Timestamp> {
    // 实现Binding接口方法，重点在生成DDL时调整nullability和默认值逻辑
    // 例如生成列定义时，移除错误的default null，修正not null标记
}

在Configuration中注册该绑定：

configuration.set(new DefaultDataTypeProvider() {
    @Override
    public DataType<Timestamp> defaultDataType(SQLDialect dialect, Class<Timestamp> type) {
        if (type == Timestamp.class) {
            return super.defaultDataType(dialect, type).binding(new MySQLTimestampBinding());
        }
        return super.defaultDataType(dialect, type);
    }
});

2. 扩展MetaProvider修正元数据 #

自定义MetaProvider，在获取数据库元数据后，直接修正错误的列属性：

public class FixedMySQLMetaProvider extends DefaultMetaProvider {
    @Override
    public Meta provideMeta(Configuration configuration) {
        Meta originalMeta = super.provideMeta(configuration);
        // 遍历元数据中的表和列，修正timestamp列的nullability和默认值
        return originalMeta.map(m -> m.mapTables(t -> t.mapColumns(c -> {
            if (c.getDataType().getTypeName().equalsIgnoreCase("timestamp")) {
                // 移除非空列的错误default null
                if (!c.getDataType().nullable() && c.getDefaultValue() != null 
                    && c.getDefaultValue().equals(DSL.val(null))) {
                    return c.defaultValue(null).dataType(c.getDataType().nullable(false));
                }
                // 还原原本可为空的列
                if (c.getName().equals("timestamp_column_default")) {
                    return c.dataType(c.getDataType().nullable(true)).defaultValue(null);
                }
            }
            return c;
        })));
    }
}

将自定义Provider配置到Configuration：

configuration.set(new FixedMySQLMetaProvider());

3. 通过QueryPart API修改生成的DDL #

在生成DDL Query后，遍历每个Query，用jOOQ的API直接调整QueryPart结构，避免字符串替换：

List<Query> fixedQueries = new ArrayList<>();
for (Query query : queries) {
    if (query instanceof CreateTableQuery) {
        CreateTableQuery ctq = (CreateTableQuery) query;
        ctq.setColumns(ctq.getColumns().stream().map(col -> {
            if (col.getDataType().getTypeName().equalsIgnoreCase("timestamp")) {
                // 移除非空列的错误default null
                if (!col.getDataType().nullable() && col.getDefaultValue() != null 
                    && col.getDefaultValue().equals(DSL.val(null))) {
                    return col.defaultValue(null).dataType(col.getDataType().nullable(false));
                }
                // 还原可为空列的属性
                if (col.getName().equals("timestamp_column_default")) {
                    return col.dataType(col.getDataType().nullable(true)).defaultValue(null);
                }
            }
            return col;
        }).collect(Collectors.toList()));
        fixedQueries.add(ctq);
    } else {
        fixedQueries.add(query);
    }
}
// 输出修正后的DDL
for (Query query : fixedQueries) {
    System.out.println(query);
}

4. 指定具体版本的SQLDialect #

避免使用MYSQL.family()，改用对应MySQL版本的具体Dialect（如MYSQL_8_0），不同版本的Dialect对timestamp类型的处理逻辑可能不同：

Configuration configuration = new DefaultConfiguration()
        .set(conn)
        .set(SQLDialect.MYSQL_8_0);

内容的提问来源于stack exchange，提问作者mgramin