JDBC 간단한 DBConnection 프로그램 (JDBC)

황제낙엽 2008.05.15 17:47 조회 수 : 155 추천:204

sitelink1  
sitelink2  
sitelink3  
sitelink4  
sitelink5  
sitelink6  

첨부파일 : DBConnection.zip ​

 

 

1. 첨부파일을 다운받아 에디터로 열어서 JDBC설정 부분은 적당히 수정하여 Database 접속 정보를 설정합니다.
2. 설정이 끝났으면 이제부터 DBConnection 클래스를 사용할 자신의 메인 프로그램에서 다음과 같은 코드로 커넥션을 생성하여 클래스를 사용합니다.

public static void main(String args[]) {   
    System.out.println("* 프로그램 시작");   
    try {   
        DBConnection.createConnection();   
        runCommand(); // 비즈니스 로직이 구현된 메서드   
    } catch (Exception e) {   
        System.out.println("* 프로그램 수행중 에러 발생 : " + e);   
    } finally {   
        DBConnection.close();   
    }   
    System.out.println("* 프로그램 종료");   
}

 

3. 일반적인 쿼리(Select) 또는 트랜잭션 쿼리(Update, Delete 등)를 사용하여 runCommand() 함수를 완성하세요.

public void runCommand() {

 

    //- 일반적인 쿼리의 경우 - 시작
    String query = "select m.mbr_id from member m, department d where m.mbr_id='"+mbr_id+"' and m.dpt_id=d.dpt_id";   
    ResultSet rset = DBConnection.executeQuery(query); 

    //- 일반적인 쿼리의 경우 - 끝

 

    //- 트랜잭션 쿼리의 경우 - 시작
    DBConnection.txOpen();   
    try {   
        String query = "delete from "+tableName+" where prgs_trn='"+prgs_trn+"'";   
        DBConnection.txExecuteUpdate(query);   
        DBConnection.txCommit();   
        System.out.println("* 정보를 삭제 조치 하였습니다.");   
    } catch (Exception e) {   
        System.out.println("* 삭제 도중 에러 발생 : "+e);   
        DBConnection.txRollBack();   
    } finally {   
        DBConnection.txClose();   
    } 

    //- 트랜잭션 쿼리의 경우 - 끝


}

 

4. 최종 사용 샘플

public class Tables {
    public static void main(String args[]) {
        System.out.println("* 프로그램 시작");
        Tables ta = new Tables();
        try {
            DBConnection.createConnection();
            ta.runCommand(); // 비즈니스 로직이 구현된 메서드
        } catch (Exception e) {
            System.out.println("* 프로그램 수행중 에러 발생 : " + e);
        } finally {
            DBConnection.close();
        }
        System.out.println("* 프로그램 종료");
    }

    public void runCommand() throws SQLException {
        String query = "select * from xe_documents";    
        ResultSet rset = DBConnection.executeQuery(query);
        ResultSetMetaData metaData = rset.getMetaData();

        int rowCount = metaData.getColumnCount();

        System.out.println("Table Name : " + metaData.getTableName(2));
        System.out.println("Field  tsizetDataType");

        for (int i = 0; i < rowCount; i++) {
            System.out.print(metaData.getColumnName(i + 1) + "  t");
            System.out.print(metaData.getColumnDisplaySize(i + 1) + "t");
            System.out.println(metaData.getColumnTypeName(i + 1));
        }

    }
}

이 게시물을
목록
쓰기 태그