lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2022-07-04 09:18:24 +08:00
parent f05961cf07
commit 64eda4cdf7
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/org/redkale/source/DataSqlSource.java
View File

@@ -277,6 +277,10 @@ public abstract class DataSqlSource extends AbstractDataSource implements Functi
sb.append("CREATE TABLE IF NOT EXISTS ").append(info.getOriginTable()).append("(\n");
EntityColumn primary = null;
T one = info.constructorAttributes == null ? info.getCreator().create() : null;
List<String> comments = new ArrayList<>();
if (table != null && !table.comment().isEmpty()) {
comments.add("COMMENT ON TABLE " + info.getOriginTable() + " IS '" + table.comment().replace('\'', '"') + "'");
}
for (EntityColumn column : info.getDDLColumns()) {
if (column.primary) primary = column;
String sqltype = "VARCHAR(" + column.length + ")";
@@ -356,13 +360,14 @@ public abstract class DataSqlSource extends AbstractDataSource implements Functi
}
sb.append(" ").append(column.column).append(" ").append(sqltype).append(" ").append(sqlnull);
if (column.comment != null && !column.comment.isEmpty()) {
//postgresql不支持DDL中带comment
//postgresql不支持DDL中直接带comment
comments.add("COMMENT ON COLUMN " + info.getOriginTable() + "." + column.column + " IS '" + column.comment.replace('\'', '"') + "'");
}
sb.append(",\n");
}
sb.append(" PRIMARY KEY (").append(primary.column).append(")\n");
sb.append(")");
return Utility.ofArray(sb.toString());
return Utility.append(Utility.ofArray(sb.toString()), comments);
}
return null;
}