小问题修复

This commit is contained in:
inrgihc
2025-09-29 21:58:10 +08:00
parent 65e9c07a8d
commit df75711376

View File

@@ -348,13 +348,13 @@ public class DorisMetadataQueryProvider extends AbstractMetadataProvider {
@Override
public void postAppendCreateTableSql(StringBuilder builder, String tblComment, List<String> primaryKeys,
SourceProperties tblProperties) {
if (StringUtils.isNotBlank(tblComment)) {
builder.append(String.format(" COMMENT '%s' ", tblComment.replace("'", "\\'" )));
}
if (CollectionUtils.isNotEmpty(primaryKeys)) {
String primaryKeyAsString = getPrimaryKeyAsString(primaryKeys);
// 自动分桶BUCKETS AUTO功能要求 Apache Doris 1.2.2 及以上版本
builder.append(" DISTRIBUTED BY HASH(").append(primaryKeyAsString).append(") BUCKETS AUTO");
if (StringUtils.isNotBlank(tblComment)) {
builder.append(String.format(" COMMENT='%s' ", tblComment.replace("'", "\\'")));
}
builder.append(" DISTRIBUTED BY HASH(").append(primaryKeyAsString).append(") BUCKETS AUTO ");
}
}