(31) [JDBC] 2일차 : JDBC(Java Data Connectivity)

 

ResultSet 

데이터베이스 결과 집합을 나타내는 테이더 테이블. 일반적으로 데이터베이스에 조회하는 문을 실행하여 생성된다. ResultSet객체는 현재 데이터 행을 가리키는 커서를 유지하며, 초기에 커서는 첫 번째 행 앞에 위치한다. 

 

PreparedSatement 

Statement 하위 인터페이스로 프리 컴파일(전 처리)된 SQL문을 나타내는 객체. SQL문은 프리 컴파일 되어 PreparedStatement객체에 저장되며, 이 객체를 반복적으로 사용하여 SQL문을 효율적으로 실행할 수 있다. 

1. 선행 컴파일 이루어진다 (자바에서 문제 있는지 먼저 체크)
2. 반복적인 작업을 할 경우 속도가 빠름  
3. 가장 많이 사용
4.  insert, update, delete 명령을 실행할 때 기본적으로 자동 commit 된다.
5. 필요 시, 자바에서 트랜잭션 처리를 해야 한다.

 

PreparedStatement 주요 메소드

1. executeUpdate()  
    insert, update, delete, create, alter, drop 등으로 쿼리 실행, DML 은 실행 행수를 반환하고, DDL 은 0을 반환한다
2. executeQuery()
    select 문 실행, select 실행 결과를 가지고 있는 ResultSet 객체를 반환
   
   

 

package db.item3;

import java.sql.Connection;
import java.sql.PreparedStatement;

import com.util.DBConn;

public class Ex01_PreparedStatement {
	/*
	 * PreparedStatement :Statement 하위 인터페이스 :프리 컴파일(전 처리)된 
	 * SQL문을 나타내는 객체 :쿼리를 실행할때는
	 * Statement를 사용하지 않고 :PreparedStatement를 사용한다
	 */

	public static void main(String[] args) {
		Connection conn = DBConn.getConnection();
		PreparedStatement pstmt = null;
		String sql;


		try {
			sql = "INSERT INTO score(hak,name,birth,kor,eng,mat)Values(?,?,TO_DATE(?,'YYYY-MM-DD'),?,?,?)";
			
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, "7788");
			pstmt.setString(2, "홍길동");
			pstmt.setString(3, "2000-10-15");
			pstmt.setString(4, "85");
			pstmt.setString(5, "95");
			pstmt.setString(6, "70");
			
			pstmt.executeUpdate();
			
			//두번째 사람 등록 
			
			pstmt.setString(1, "7789");
			pstmt.setString(2, "너자바");
			pstmt.setString(3, "2000-08-10");
			pstmt.setString(4, "75");
			pstmt.setString(5, "80");
			pstmt.setString(6, "90");
			
			pstmt.executeUpdate();

			System.out.println("등록 완료....");
				
		
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (pstmt != null) {
				try {
					pstmt.close();
				} catch (Exception e2) {

				}
			}
		}

	}

}

 

 

JDBC 프로그램 작성 순서 

1. DriverManager.getConnection() 에서 Connection 객체를 얻어 온다.
2. 쿼리 작성
3. SQL 를 인자로 PreparedStatement 객체를 생성
4.  쿼리의 in 파라미터를 setter 를 이용하여 설정한다
5. 쿼리 실행 select   : executeQuery(), 나머지 쿼리 : executeUpdate() 

 

 

ScoreDAOImpl

학번 검색 SELECT 메소드

//학번검색
	@Override
	public ScoreDTO findById(String hak) {
		ScoreDTO dto=null;
		PreparedStatement pstmt = null;
		ResultSet rs= null;
		String sql;
				
		
		
		try {	
			sql="SELECT hak,name,TO_CHAR(birth,'YYYY-MM-DD')birth,kor,eng,mat,(kor+eng+mat)tot,(kor+eng+mat)/3 ave FROM score WHERE hak=?";
			
			pstmt =conn.prepareStatement(sql);		
			
			pstmt.setString(1, hak);
			
			rs=pstmt.executeQuery();
			
			
			
			if(rs.next()) {
				dto=new ScoreDTO();
				
				dto.setHak(rs.getString("hak"));
				dto.setName(rs.getString("name"));
				dto.setBirth(rs.getString("birth"));
				dto.setKor(rs.getInt("kor"));
				dto.setEng(rs.getInt("eng"));
				dto.setMat(rs.getInt("mat"));
				dto.setTot(rs.getInt("tot"));
				dto.setAve(rs.getInt("ave"));
						
			}
		
		} catch (SQLException e) {
			e.printStackTrace();
			
		} finally {
			DBUtil.close(rs);
			DBUtil.close(pstmt);
		}
		
		return dto;
	}

 

ScoreUI
학범 검색 UI

	protected void findByHak() {
		System.out.println("\n학번검색...");
		
		String hak;
		
		try {
			System.out.println("검색할 학번?");
			hak=br.readLine();
			
			ScoreDTO dto = dao.findById(hak);
			
			if(dto==null) {
				System.out.println("등록된 자료가 아닙니다.\n");
				return;
			}
			
			printScore(dto);
		
		} catch (Exception e) {
			e.printStackTrace();
		}
		System.out.println();		
	}

 

 

 

ScoreDAOImpl

데이터 입력 메소드 

	@Override
	public int insertScore(ScoreDTO dto) throws SQLException {
		int result = 0;
		
		PreparedStatement pstmt = null;
		String sql;
		
		// insert into 테이블명(컬럼, 컬럼) values(값, 값)
		try {
			// 1) 쿼리(sql) 작성
			sql = "insert into score(hak, name, birth, kor, eng, mat) values(?,?,?,?,?,?)"; 
			
			// 2) 쿼리를 인자로 PreparedStatement 객체를 생성
			pstmt = conn.prepareStatement(sql);
			
			// 3) setter 를 이용하여 ? 에 값 할당 (순서 지켜서 넣어야 함)
			pstmt.setString(1,dto.getHak());
			pstmt.setString(2,dto.getName());
			pstmt.setString(3,dto.getBirth());
			pstmt.setInt(4,dto.getKor());
			pstmt.setInt(5,dto.getEng());
			pstmt.setInt(6,dto.getMat());
			
			// 4) 쿼리를 실행한다
			result = pstmt.executeUpdate();
			
		} catch (SQLException e) {
			throw e; // 예외 던지기
		} finally {
			// 5) 객체 close
			DBUtil.close(pstmt);
		}
		
		return result;
	}

 

 

 

ScoreUI

데이터 등록 UI구현과 예외처리 

	protected void insert() {
		System.out.println("\n자료 등록...");
		
		ScoreDTO dto = new ScoreDTO();
		
		try {
			System.out.print("학번?");
			dto.setHak(br.readLine());
			System.out.print("이름?");
			dto.setName(br.readLine());
			System.out.print("생년월일?");
			dto.setBirth(br.readLine());
			System.out.print("국어?");
			dto.setKor(Integer.parseInt(br.readLine()));
			System.out.print("영어?");
			dto.setEng(Integer.parseInt(br.readLine()));
			System.out.print("수학?");
			dto.setMat(Integer.parseInt(br.readLine()));
		
			dao.insertScore(dto);
			
			System.out.println("등록완료");
		
		} catch (NumberFormatException e) {
			System.out.println("에러= 점수는 숫자만 가능합니다.");
	
		} catch (SQLIntegrityConstraintViolationException e) {
			//NOT null 등의 제약조건을 위반할때 발생하는 예외
			//무결성 제약 조건 
			if(e.getErrorCode()==1) {
				System.out.println("에러-등록된 학번입니다.");
			}else if(e.getErrorCode()==1400) { // INSERT NOT NULL 제약 위반 
				System.out.println("에러 - 필수 입력 사항을 입력하지 않았습니다.");
			}else {
				System.out.println(e.toString());
			}
			
		
		} catch (SQLDataException e) {
			
			if(e.getErrorCode()==1840 || e.getErrorCode()==1861) {
				System.out.println("에러-날짜 형식이 올바르지 않습니다.");
			}else{
				System.out.println(e.toString());
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		
	}