Skip to content

Commit

Permalink
[apache#5289][Improvement] CatalogMysqlDriverIT miss driver url
Browse files Browse the repository at this point in the history
  • Loading branch information
lsyulong committed Nov 6, 2024
1 parent cecf73e commit de12f47
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1245,6 +1245,9 @@ void testMySQLSpecialTableName() {
String t3_name = "t_12";
Column t3_col = Column.of(t3_name, Types.LongType.get(), "id", false, false, null);
Index[] t3_indexes = {Indexes.unique("u3_key", new String[][] {{t3_name}})};
if (tableCatalog.tableExists(NameIdentifier.of(schemaName, t3_name))) {
tableCatalog.dropTable(NameIdentifier.of(schemaName, t3_name));
}
columns = new Column[] {t3_col};
tableIdentifier = NameIdentifier.of(schemaName, t3_name);
tableCatalog.createTable(
Expand Down Expand Up @@ -1296,11 +1299,8 @@ void testMySQLSpecialTableName() {

Table t3 = tableCatalog.loadTable(NameIdentifier.of(schemaName, t3_name));
Arrays.stream(t3.columns()).anyMatch(c -> Objects.equals(c.name(), "t_12"));
System.out.println("t3_indexs indexs length "+t3_indexes.length);
System.out.println("t3 indexs length "+t3.index().length);
if (tableCatalog.tableExists(NameIdentifier.of(schemaName, t3_name))) {
tableCatalog.dropTable(NameIdentifier.of(schemaName, t3_name));
}
System.out.println("t3_indexs indexs length " + t3_indexes.length);
System.out.println("t3 indexs length " + t3.index().length);
ITUtils.assertionsTableInfo(
t3_name,
table_comment,
Expand Down

0 comments on commit de12f47

Please sign in to comment.