모두의 지식 저장고

간단한 JDBC 프로그램으로 오라클과 티베로에 접속 해서 데이터를 조회 하는 샘플 소스를 공유 합니다. 

JDBC 샘플 소스 

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;


public class JDBC_ConnectionTest {

	public static final String TIBERO_JDBC_CLASS_NAME = "com.tmax.tibero.jdbc.TbDriver";
	public static final String ORACLE_JDBC_CLASS_NAME = "oracle.jdbc.driver.OracleDriver";

	public static void main(String args[]) {

		String DB_USER = "tibero";
		String DB_PASSWORD = "tmax";
		String TB_DB_CONNECTION = "jdbc:tibero:thin:@127.0.0.1:17000:tibero";
		String ORA_DB_CONNECTION = "jdbc:oracle:thin:@127.0.0.1:1521:orclcdb";
		
		String DB_TYPE ="oracle";

		try {

			Properties prop = new Properties();
			prop.put("user", DB_USER);
			prop.put("password", DB_PASSWORD);
			Connection conn = null;
			
			if(DB_TYPE.equals("tibero")){
				Class.forName(TIBERO_JDBC_CLASS_NAME);
				conn = DriverManager.getConnection(TB_DB_CONNECTION, prop);
			}else{
				Class.forName(ORACLE_JDBC_CLASS_NAME);
				conn = DriverManager.getConnection(ORA_DB_CONNECTION, prop);
			}
							
			Statement stmt = conn.createStatement();
			
			try {
				stmt.executeQuery("drop table book");
	
			} catch (Exception e) {
				// TODO: handle exception
				e.printStackTrace();
			}
			
			String table =" create table book     \n"  
						+ " (book_id number primary key  \n " 
						+ " ,title varchar(200)  \n " 
						+ " ,category varchar(200)  \n " 
						+ " ,price number    \n " 
						+ " ,insert_date date default current_timestamp \n " 
						+ " )  \n " ;

			stmt.executeQuery(table);
			
			ResultSet rs = null;
			stmt.executeUpdate("insert into book( book_id, title,category,price) values(1,'JDBC program','IT BOOK',20000)");

			rs = stmt.executeQuery("select * From book");
			
			System.out.println("==================== 단건조회 =====================");
			while(rs.next()){
				
				System.out.println(String.format("book_id:[%d],title:[%s],category:[%s],price:[%d],insert_date:[%s]"
						,rs.getInt(1),rs.getString(2),rs.getString(3),rs.getInt(4),rs.getString(5)));
			}
			System.out.println("=============================================");

			/*Table batch insert*/
			PreparedStatement psmt = conn.prepareStatement("insert into book( book_id, title,category,price) values(?,?,?,?)");

			for (int i = 2; i <= 50; i++) {

				psmt.setInt(1, i);
				psmt.setString(2, "JDBC program_" + i);
				psmt.setString(3, "IT BOOK_" + i);
				psmt.setInt(4, 20000 + (i * 100));

				psmt.addBatch();
			}

			psmt.executeBatch();		
			
			
			System.out.println("==================== batch insert 조회 =====================");
			rs = stmt.executeQuery("select * From book");
			while(rs.next()){
				
				System.out.println(String.format("book_id:[%d],title:[%s],category:[%s],price:[%d],insert_date:[%s]"
						,rs.getInt(1),rs.getString(2),rs.getString(3),rs.getInt(4),rs.getString(5)));
			}
			System.out.println("=============================================");
			
			rs.close();
			stmt.close();
			psmt.cancel();
			conn.close();

		} catch (Exception e) {
			e.printStackTrace();
		}
	}


}

jdbc 드라이버 네임 설정

• 티베로와 오라클 드라이버 명을 설정합니다. .

jdbc URL 설정 

• 티베로와 오라클 URL 을 설정합니다. 

jdbc Connection 생성 

jdbc 단건 입력 후 조회

jdbc batch insert 후 조회 

PreparedStatement addBatch() 를 이용해 여러건을 한번에 입력후 조회 합니다. 

jdbc connection 종료

테스트 결과 

• jdbc 컴파일 및 실행 
• 윈도우와 리눅스 컴파일시 구분자가 다르다 리눅스 ':' , 윈도우=>';'

#윈도우
javac -classpath .;tibero6-jdbc.jar;ojdbc8.jar JDBC_ConnectionTest.java 
java  -classpath .;tibero6-jdbc.jar;ojdbc8.jar JDBC_ConnectionTest 

#리눅스
javac -classpath .:tibero6-jdbc.jar:ojdbc8.jar JDBC_ConnectionTest.java 
java  -classpath .:tibero6-jdbc.jar:ojdbc8.jar JDBC_ConnectionTest

• 실행결과

간단하게 파일 비교 하는 java 소스 공유합니다. 

두개의  텍스트 파일을 비교하는 간단한 코드입니다. 

단점은 원본 파일 대상으로 라인 by 라인으로 비교를 하기 때문에 중간에 비교대상 라인이 다르면 모두 다르게 출력되게 됩니다. ㅠㅠ 

소스  파일

package ims;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.util.TreeMap;

public class FileCompare {

	// 두개 파일 비교
	public static void main(String[] args) throws IOException {
		// String original file = args[0];
		// String compare file = args[1];

		String oldfilename = "D:\\test1.sql";
		String newfilename = "D:\\test2.sql";

		FileCompare comp = new FileCompare();
		String result = comp.compareFile(oldfilename, newfilename);
		if (result.length()>0) {
			String diffFilename =new File(newfilename).getName();
			FileWriter diff = new FileWriter(diffFilename+".error",false);
			System.out.println("file is different");
			System.out.println(String.format("[%s][%s]|[%s] ", "line", "original file", "compare file"));
			System.out.println(result);
			diff.write(result);
			diff.flush();
			diff.close();

		} else {
			System.out.println("file is equal");
			
		}


	}

	public String compareFile(String oldfilename, String newfilename) throws IOException {
		TreeMap<Integer, String> compare = new TreeMap<Integer, String>();
		File oldfile = new File(oldfilename);
		File newfile = new File(newfilename);
		BufferedReader bf = null;
		StringBuffer errorLine = new StringBuffer();
		try {
			bf = new BufferedReader(new FileReader(oldfile));
			int key = 0;
			// old file read
			while (true) {
				String str = bf.readLine();
				if (str == null)
					break;
				compare.put(++key, str);
			}

			bf = new BufferedReader(new FileReader(newfile));
			key = 0;

			// old file vs new file compare

			while (true) {
				String str = bf.readLine();
				if (str == null)
					break;
				if (!str.equals(compare.get(++key))) {
					errorLine.append(String.format("[%d]:[%s]|[%s]\n", key, str, compare.get(key)));
				}

			}

		} catch (IOException E) {
		}
		bf.close();
		return errorLine.toString();
	}

}

실행결과

디렉토리내 파일이 존재 하는지 확인하는 java 코드입니다 .

디렉토리를 조회후 파일이 있는지 확인하고 디렉토리내 또 다른 디렉토리가 존재 한다면 재귀 함수 호출을 통해 

하위 파일 까지 출력 하는 코드 입니다. 

Oracle 샘플 스키마 스크립트를 가지고 테스트해보겠습니다. 

import java.io.File;
import java.io.IOException;
import java.security.AccessControlException;
import java.sql.SQLException;
import java.util.ArrayList;

public class DirectoryFileList {

	public static void main(String[] args)
			throws AccessControlException, SQLException, ClassNotFoundException, IOException {

		String path = "D:\\998.Tmp\\db-sample-schemas-19.2\\db-sample-schemas-19.2";

		ArrayList al = new ArrayList<String>();
		subDirList(path, al);

	}

	public static void subDirList(String source, ArrayList<String> list) {

		File dir = new File(source);
		File[] fileList = dir.listFiles();

		try {

			for (int i = 0; i < fileList.length; i++) {

				File file = fileList[i];

				if (file.isFile()) {

					// 파일이 있다면 파일 이름 출력
					System.out.println("\t File name :" + file.getAbsoluteFile());
					list.add(file.getParent() + File.separator + file.getName());

				} else if (file.isDirectory()) {

					System.out.println("Directory name:" + file.getName());
					// 서브디렉토리가 존재하면 재귀적 방법으로 다시 탐색
					list.add(file.getParent() + File.separator + file.getName());
					subDirList(file.getCanonicalPath().toString(), list);

				}

			}

		} catch (IOException e) {
			e.printStackTrace();
		}

	}

}

실행결과

리눅스에서 OpenJdk 설치하는 방법에 대해 소개 하고 설치된 버전을 손쉽게 변경하는 방법에대해 알아보겠습니다. 

java 설치 (JDK: Java Development Kit: javac)

jdk 설치 리스트 확인 

yum list java*jdk-devel

yum install java-1.8.0-openjdk-devel.x86_64

JRE 설치( Java Runtime Environment:java)

yum list java*jdk 

yum install java-1.8.0-openjdk.x86_64

java version 변경

• alternatives --config [java/javac] 명령어 수행 후  변경하고자 하는 번호를 선택 하면 됩니다.

javac 버전 변경