新增: 获取逻辑删除字段

master
曹世达 6 months ago
parent 4449fccd9c
commit 766ad4b98a

@ -20,7 +20,6 @@ import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.stream.Collectors;
public class TableBuilder { public class TableBuilder {
@ -104,15 +103,13 @@ public class TableBuilder {
result.setDecimalExists(columnInfo.stream() result.setDecimalExists(columnInfo.stream()
.anyMatch(column -> TypeUtils.JAVA_TYPE_DECIMAL.equals(column.getJavaType()))); .anyMatch(column -> TypeUtils.JAVA_TYPE_DECIMAL.equals(column.getJavaType())));
result.setInvalidColumns( result.setInvalidColumn(
columnInfo.stream() columnInfo.stream()
.map(ColumnInfo::getColumnName) .map(ColumnInfo::getColumnName)
.filter(columnName -> CfgUtils.getTableInvalidColumns().contains(columnName)) .filter(columnName -> CfgUtils.getTableInvalidColumns().contains(columnName))
.collect(Collectors.toList()) .findFirst().orElse(null)
); );
result.setInvalidColumnExists(!result.getInvalidColumns().isEmpty());
List<IndexInfo> indexInfoList = IndexBuilder.loadIndexInfo( List<IndexInfo> indexInfoList = IndexBuilder.loadIndexInfo(
result.getTableSchema(), result.getTableSchema(),
result.getTableName() result.getTableName()

@ -12,8 +12,7 @@ public class TableInfo {
private String tableName; private String tableName;
private Boolean dateExists; private Boolean dateExists;
private Boolean decimalExists; private Boolean decimalExists;
private Boolean invalidColumnExists; private String invalidColumn;
private List<String> invalidColumns = new ArrayList<>();
private List<ColumnInfo> columns = new ArrayList<>(); private List<ColumnInfo> columns = new ArrayList<>();
private Map<String, List<ColumnInfo>> indexes = new LinkedHashMap<>(); private Map<String, List<ColumnInfo>> indexes = new LinkedHashMap<>();
@ -57,20 +56,12 @@ public class TableInfo {
this.decimalExists = decimalExists; this.decimalExists = decimalExists;
} }
public Boolean getInvalidColumnExists() { public String getInvalidColumn() {
return invalidColumnExists; return invalidColumn;
} }
public void setInvalidColumnExists(Boolean invalidColumnExists) { public void setInvalidColumn(String invalidColumn) {
this.invalidColumnExists = invalidColumnExists; this.invalidColumn = invalidColumn;
}
public List<String> getInvalidColumns() {
return invalidColumns;
}
public void setInvalidColumns(List<String> invalidColumns) {
this.invalidColumns = invalidColumns;
} }
public List<ColumnInfo> getColumns() { public List<ColumnInfo> getColumns() {

Loading…
Cancel
Save