Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
fix(postgres): correct table options
  • Loading branch information
pdxzzz committed Jun 18, 2024
commit f05d1512c5dcee6bf8d8798c3c60477b49f200df
Original file line number Diff line number Diff line change
Expand Up @@ -349,7 +349,7 @@ public String tableDDL(Connection connection, String databaseName, String schema
String tableOptions = resultSet.getString("table_options");
if (StringUtils.isNotBlank(tableOptions)) {
tableOptions = tableOptions.replace("{", "(").replace("}", ")");
return optionBuilder.append("with ").append(tableOptions).toString();
return optionBuilder.append(" with ").append(tableOptions).toString();
}
}
return null;
Expand Down Expand Up @@ -380,7 +380,7 @@ public String tableDDL(Connection connection, String databaseName, String schema
});
if (subTable) {
if (StringUtils.isNotBlank(options)) {
ddlBuilder.append("WITH ").append(options);
ddlBuilder.append(options);
}
return ddlBuilder.append("\n").append(tablespace).toString();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -424,7 +424,7 @@ private long addDBCache(Long dataSourceId, String databaseName, String schemaNam
Connection connection = Chat2DBContext.getConnection();
long n = 0;
try (ResultSet resultSet = connection.getMetaData().getTables(databaseName, schemaName, null,
new String[]{"TABLE", "SYSTEM TABLE","PARTITIONED TABLE"})) {
new String[]{"TABLE", "SYSTEM TABLE"})) {
List<TableCacheDO> cacheDOS = new ArrayList<>();
while (resultSet.next()) {
TableCacheDO tableCacheDO = new TableCacheDO();
Expand Down