#14 jdbc connection for candidate

metatron-app · Aug 17, 2018 · a52e8f1 · a52e8f1
1 parent c62c10f
commit a52e8f1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../java/app/metatron/discovery/domain/datasource/connection/jdbc/JdbcConnectionService.java b/.../java/app/metatron/discovery/domain/datasource/connection/jdbc/JdbcConnectionService.java
@@ -1102,8 +1102,8 @@ public List<Map<String, Object>> selectCandidateQuery(CandidateQueryRequest quer
     LinkIngestionInfo ingestionInfo = (LinkIngestionInfo) metaDataSource.getIngestionInfo();
 
     // TODO: 중복 코드를 해결 필요
-    JdbcDataConnection realConnection = jdbcDataConnection == null ?
-        ingestionInfo.getConnection() : jdbcDataConnection;
+    JdbcDataConnection realConnection = (JdbcDataConnection) metaDataSource.getJdbcConnectionForIngestion();
+
     if (realConnection instanceof MySQLConnection
         || realConnection instanceof HiveConnection
         || realConnection instanceof PrestoConnection) {