修正clickhouse迁移

This commit is contained in:
inrgihc
2023-09-22 22:35:17 +08:00
parent 956441044c
commit 34b7412bff

View File

@@ -116,6 +116,19 @@ public class ClickhouseMetadataQueryProvider extends AbstractMetadataProvider {
}
}
@Override
public List<ColumnDescription> queryTableColumnMeta(Connection connection, String schemaName,
String tableName) {
List<ColumnDescription> results = super.queryTableColumnMeta(connection, schemaName, tableName);
for (ColumnDescription column : results) {
if (StringUtils.equals(column.getFieldTypeName(), "Nullable(String)")
|| StringUtils.equals(column.getFieldTypeName(), "String")) {
column.setDisplaySize(Constants.CLOB_LENGTH);
}
}
return results;
}
@Override
public List<String> queryTablePrimaryKeys(Connection connection, String schemaName, String tableName) {
List<String> result = new ArrayList<>();