Oracle과 JDBC 연동 테스트

요즘 ELK(Elasticsearch + Logstash + Kibana)로 뭐 좀 할 수 있는 거 없나 끄적이는 중..

아무래도 회사에서 직접 데이터를 가져올 수 있는 그 quality & quantity 모두 좀 쉽지가 않고(한낱 일개미 따위가..) 그 중에서도 또 실제로 big data나 machine learning쪽에 실습해볼만한 데이터도 흔치 않다.

그래도 일단은 한번쯤 직접 손으로 만져봐야 하는 것이니.. 아무 데이터나 서버에 있는 걸로 ELK 실습 중, 회사에서는 대부분 oracle DBMS를 쓰는데 이를 logstash와 연동하기 위해서 우선 JDBC로 oracle과 접속되는지 확인이 필요함.

mysql은 open source라서 그런가, 레퍼런스가 많은 거 같은데 의외로 oracle은 간단하게 테스트하는 방법이 없어서 기록해 둠ㅋㅋ

굉장히 잘 정리된 사이트 가 있고, 이대로 따라하면 됨.

JDK 1.8은 우선 깔고(요즘 ELK는 1.8 기준임)
JDBC를 여기서 - oracle 홈페이지 에서 다운받음

아래처럼 test code를 받고

 $ curl https://symwisedownload.symantec.com//resources/sites/SYMWISE/content/live/SOLUTIONS/219000/TECH219803/en_US/JDBCInfo.txt?__gda__=1503520521_2f84cfcdb0a24872390c20ae0f27c0db > JDBCInfo.java

컴파일 하여
```
 $ javac JDBCInfo.java
```

config에 맞게 돌려보면 끝

$ java JDBCInfo "jdbc:oracle:thin:<ID>/<PWD>@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=<IP>)(PORT=<PORT#>))(CONNECT_DATA=(SERVER=<TYPE>)(SERVICE_NAME=<SERVICE NAME)))"

fig1

다음에는 Logstash 설정을 통해 oracle에 있는 data를 migration할 예정.. 당분간은 쉽게쉽게, but 기록해두기

참고 - JDBC/Oracle test

import java.io.File;

import java.sql.*;
import java.util.Locale;
import java.util.StringTokenizer;

import oracle.jdbc.pool.OracleDataSource;

public class JDBCInfo {

  public static void main (String[] args) {

    String url      = null;
    String type     = null;
    String hostname = null;
    String sid      = null;
    String user     = null;
    String password = null;

    int    port     = 0;

    boolean shortParameter = false;

    if(args.length == 1) {
      url      = args[0];
      shortParameter = true;      
    }

    else if(args.length == 6) {
      type     = args[0];
      hostname = args[1];
      port     = Integer.parseInt(args[2]);
      sid      = args[3];
      user     = args[4];
      password = args[5];
    }

    else {
      System.out.println("Usage: java JDBCInfo <type> <hostname> <port> <sid> <user> <password>");
      System.out.println("OR ");
      System.out.println("Usage: java JDBCInfo <url>");
      System.exit(0);
    }

    try {
      OracleDataSource ods = new OracleDataSource();

      // Set properties for single URL.
      if ( shortParameter ) {
        ods.setURL(url);
      }
      // Set properties for parameters
      else {
        ods.setDriverType(type);
        ods.setServerName(hostname);
        ods.setPortNumber(port);
        ods.setDatabaseName(sid);
        ods.setUser(user);
        ods.setPassword(password);
      }

      // Retrieve connection.
      Connection conn = ods.getConnection();
      DatabaseMetaData meta = conn.getMetaData ();

      // gets driver info:
      System.out.println("\nDatabase\n==============");
      System.out.println(meta.getDatabaseProductVersion());
      System.out.println("\nJDBC\n==============");
      System.out.println(meta.getDriverName() + ": " + meta.getDriverVersion());
      System.out.println("\nConnection URL\n==============");
      System.out.println(meta.getURL());
    } catch (Exception e) {
      System.out.println("\nUsage: java JDBCInfo <type> <hostname> <port> <sid> <user> <password>");
      System.out.println("OR ");
      System.out.println("Usage: java JDBCInfo <url>");
      System.out.println("\nError occured: ");
      e.printStackTrace();
    }

    // Get JVM information.
    java.util.Properties props = System.getProperties();
    System.out.println("\nJVM\n===");
    System.out.println(props.getProperty("java.vm.vendor"));
    System.out.println(props.getProperty("java.vm.name"));
    System.out.println(props.getProperty("java.vm.version"));
    System.out.println(props.getProperty("java.version"));

    // Get environment information.
    System.out.println("\nLOCALE\n===========");
    System.out.println(Locale.getDefault());

    System.out.println( "\nBOOTSTRAP (sun.boot.class.path)\n==============================\n"
                     + System.getProperty("sun.boot.class.path") );
      System.out.println( "\nEXTENSION PACKAGES (java.ext.dirs)\n=================================\n"
                     + System.getProperty("java.ext.dirs") + "\n" );
      String [] dirs = new String [5];
      int cnt = 0;
      StringTokenizer st;
      //  if windows parse with ; else parse with :
      if (System.getProperty("os.name").toLowerCase().indexOf("win") >= 0)
           st=new StringTokenizer( System.getProperty("java.ext.dirs"), " ;");
      else
           st=new StringTokenizer( System.getProperty("java.ext.dirs"), " :");

      int tokenCount=st.countTokens();
          while (st.hasMoreTokens()) {
              dirs[cnt]=st.nextToken();
              System.out.println(dirs[cnt] + ": ");
              File folder = new File(dirs[cnt]);
              File[] listOfFiles = folder.listFiles();
              if (listOfFiles != null)
               for (int j = 0; j < listOfFiles.length; j++) System.out.println("      " + listOfFiles[j].getName());
              cnt++;

          }              


    // Get CLASSPATH
    String pathseparator = props.getProperty("path.separator");
    String classpath = props.getProperty("java.class.path");
    System.out.println("\nCLASSPATH\n=========");
    String[] strarr = classpath.split(pathseparator);
    for(int i = 0; i < strarr.length; i++)
      System.out.println(strarr[i]);

    // Get LIBRARY PATH     
    String libpath = props.getProperty("java.library.path");
    System.out.println("\nLIBRARYPATH\n===========");
    strarr = libpath.split(pathseparator);
    for(int i = 0; i < strarr.length; i++)
      System.out.println(strarr[i]);

  }//end of main

}//end of JDBCInfo

Written on August 22, 2017