Merge pull request trinodb#8 from academy-codex/mr_trino_sybase_conne…

…ctor_fixes Mr trino sybase connector fixes
dbit-xia · Jul 20, 2021 · 112abf3 · 112abf3
2 parents b242817 + e17e2a3
commit 112abf3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/plugin/trino-sybase/src/test/java/io/trino/plugin/sybase/SybaseQueryRunner.java b/plugin/trino-sybase/src/test/java/io/trino/plugin/sybase/SybaseQueryRunner.java
@@ -13,6 +13,7 @@
  */
 package io.trino.plugin.sybase;
 
+import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import io.airlift.log.Logger;
 import io.airlift.log.Logging;
@@ -28,13 +29,15 @@
 import static io.trino.plugin.sybase.SybaseDataLoader.copyTpchTables;
 import static io.trino.plugin.tpch.TpchMetadata.TINY_SCHEMA_NAME;
 import static io.trino.testing.TestingSession.testSessionBuilder;
+import static io.trino.tpch.TpchTable.CUSTOMER;
+import static io.trino.tpch.TpchTable.NATION;
+import static io.trino.tpch.TpchTable.ORDERS;
+import static io.trino.tpch.TpchTable.REGION;
 
 public class SybaseQueryRunner
 {
     private SybaseQueryRunner() {}
 
-    private static final String TPCH_SCHEMA = "tpch";
-
     public static DistributedQueryRunner createSybaseQueryRunner(TestingSybaseServer server,
             Map<String, String> extraProperties,
             Map<String, String> connectorProperties,
@@ -82,9 +85,9 @@ public static void main(String[] args)
 
         DistributedQueryRunner queryRunner = createSybaseQueryRunner(
                 new TestingSybaseServer(),
-                ImmutableMap.of("http-server.http.port", "8080"),
                 ImmutableMap.of(),
-                TpchTable.getTables());
+                ImmutableMap.of(),
+                ImmutableList.of(CUSTOMER, NATION, ORDERS, REGION));
 
         Logger log = Logger.get(SybaseQueryRunner.class);
         log.info("======== SERVER STARTED ========");

diff --git a/plugin/trino-sybase/src/test/java/io/trino/plugin/sybase/TestingSybaseServer.java b/plugin/trino-sybase/src/test/java/io/trino/plugin/sybase/TestingSybaseServer.java
@@ -18,7 +18,6 @@
 
 import java.sql.Connection;
 import java.sql.DriverManager;
-import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;