This commit is contained in:
zyyang 2020-12-22 10:41:26 +08:00
parent b01f13bbd9
commit dbb866e374
1 changed files with 4 additions and 4 deletions

View File

@ -47,10 +47,10 @@ public class SqlSpeller {
StringBuilder sb = new StringBuilder(); StringBuilder sb = new StringBuilder();
sb.append("create table if not exists ").append(subTableMeta.getDatabase()).append(".").append(subTableMeta.getName()).append(" "); sb.append("create table if not exists ").append(subTableMeta.getDatabase()).append(".").append(subTableMeta.getName()).append(" ");
sb.append("using ").append(subTableMeta.getDatabase()).append(".").append(subTableMeta.getSupertable()).append(" "); sb.append("using ").append(subTableMeta.getDatabase()).append(".").append(subTableMeta.getSupertable()).append(" ");
String tagStr = subTableMeta.getTags().stream().filter(Objects::nonNull) // String tagStr = subTableMeta.getTags().stream().filter(Objects::nonNull)
.map(tagValue -> tagValue.getName() + " '" + tagValue.getValue() + "' ") // .map(tagValue -> tagValue.getName() + " '" + tagValue.getValue() + "' ")
.collect(Collectors.joining(",", "(", ")")); // .collect(Collectors.joining(",", "(", ")"));
sb.append("tags ").append(tagStr); sb.append("tags ").append(tagValues(subTableMeta.getTags()));
return sb.toString(); return sb.toString();
} }