public static String buildAddColumnDDL()

in src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java [96:116]

• 20 lines of code
• 3 McCabe index (conditional complexity)

    public static String buildAddColumnDDL(
            String database, String tableName, RecordDescriptor.FieldDescriptor field) {
        String name = field.getName();
        String typeName = field.getTypeName();
        String comment = field.getComment();
        String defaultValue = field.getDefaultValue();

        String addDDL =
                String.format(
                        ADD_DDL,
                        identifier(database) + "." + identifier(tableName),
                        identifier(name),
                        typeName);
        if (defaultValue != null) {
            addDDL = addDDL + " DEFAULT " + quoteDefaultValue(defaultValue);
        }
        if (StringUtils.isNotEmpty(comment)) {
            addDDL = addDDL + " COMMENT '" + quoteComment(comment) + "'";
        }
        return addDDL;
    }