Use Table#create instead of manually preparing tables in test

kawamuray · Nov 25, 2020 · 9429e72 · 9429e72
1 parent 587a52b
commit 9429e72
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/test/java/kmql/table/ConfigsTableTest.java b/src/test/java/kmql/table/ConfigsTableTest.java
@@ -58,10 +58,10 @@ public void prepareAllEnums() throws Exception {
         doReturn(result).when(adminClient).describeConfigs(any());
 
         try (Connection connection = SqlUtils.connection()) {
-            try (Statement stmt = connection.createStatement()) {
-                stmt.execute("CREATE TABLE brokers (id INT)");
-                stmt.execute("CREATE TABLE replicas (topic VARCHAR(255))");
-            }
+            // Prepare empty dependency tables
+            new BrokersTable().create(connection);
+            new ReplicasTable().create(connection);
+
             table.create(connection);
             table.prepare(connection, adminClient);