Skip to content

Commit

Permalink
fix the problem of getTables method (#61)
Browse files Browse the repository at this point in the history
  • Loading branch information
Jasmine-ge authored Nov 1, 2024
1 parent 2f54883 commit e423417
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -738,6 +738,9 @@ public ResultSet getTables(String catalog,
"string");

List<String> typeList = types != null ? Arrays.asList(types) : null;
if (typeList != null) {
typeList.replaceAll(type -> type.equals("STREAM") ? "TABLE" : type);
}
while (result.next()) {
List<String> row = new ArrayList<>();
row.add(TimeplusDefines.DEFAULT_CATALOG);
Expand All @@ -758,7 +761,7 @@ public ResultSet getTables(String catalog,
type = "OTHER"; // not a real table
break;
default:
type = "STREAM";
type = "TABLE";
break;
}
row.add(type);
Expand Down

0 comments on commit e423417

Please sign in to comment.