JDBC 연동
1. Connect/J - MySQL 제공하는 드라이버 로딩 단계
- Connect/J란 MySQL에 연결하기 위해 MySQL에서 제공하는 드라이버를 마라며, DB벤더에서 제공하는 드라이버들은 Class 들을 묶어 둔 jar 파일 형태
- jar 파일의 라이브러리 path 셋팅 단계
- Class 객체를 리턴하는 forName 메소드를 사용
- 드라이버는 MySQL에 연결할 때 한번만 로딩하면 되기 때문에 생성자 속에 구현하면 됨
// 드라이버를 클래스의 내용으로 읽는 부분
try {
Class.forName("com.mysql.cj.jdbc.Driver");
System.out.println("드라이버 로딩 성공");
} catch (ClassNotFoundException e){
e.printStackTrace();
}
2. DB 연결
- DB에 연결을 위해 Connection 생성 해야함
- Java.sql 안에 DriverManager 클래스가 존재함
- 해당 클래스에 포함된 메소드 중 getConnection() 메소드를 통해 지정된 주소의 DataBase와 연결할 수 있음.
// getConnection 구현 방법
String url = "jdbc:mysql://127.0.0.1:3306/dbname?serverTimezone=UTC&useUniCode=yes&characterEncoding=UTF-8";
String userId = "root";
String password = "1234";
Connection conn = DriverMaganger.getConnection(url, userId, password);
/*
1) url : DB 접근 요청하려는 주소
ex ) url = jdbc:mysql://127.0.0.1(요청 IP주소):3306(MySQL 설정 포트)/(데이터베이스명)?serverTimezone=UTC&useUniCode=yes&characterEncoding=UTF-8";
2) userId : 접근하려는 DB의 userID
3) password : 접근하려는 DB의 password
*/
3. SQL 실행 준비
- Statement 또는 PreparedStatement는 Connection으로 연결한 객체에 Query 작업을 실행하기 위한 객체
- Statement를 생성하고 사용하기 위해선 반드시 Connection이 먼저 연결되어야 함
- 최근엔 PreparedStaement 객체가 더 많이 사용됨
- Statement 객체의 SQL은 실행될 때마다 서버에서 분석
- PreparedStatement는 한번 분석 후 재사용에 용이
- 차이점 더 자세히...(https://webstone.tistory.com/56) 참조 하시면 좋을 듯!!
- PreparedStatement 객체는 Connection 객체의 PreparedStatement() 메소드를 사용해 생성, 메소드의 파라미터로 SQL 문을 담은 String 객체 필요
- 위치홀더(Placeholder)를 사용해 SQL 문장 정의 가능하며 위치 홀더는 ?로 표시하여 사용함
- SQL문 작성한 다음 PreparedStatement 객체를 생성해 매개값으로 sql문 전달
- 위치홀더에 들어갈 값은 PreparedStatement 객체의 setString(), setInt()의 메소드를 통해 셋팅 가능
- ?위치의 인덱스 번호와 셋팅할 값을 맞춰서 넣어주면 됨
// SQL 문 작성 (매개변수로 넘겨줄 String 형태의 sql문)
String sql = "insert into dbname (id, name, price, index)"
sql += "values (?, ?, ?, ?)";
// SQL문 실행 위해 PreparedStatement 객체 생성
PreparedStatement pstmt = conn.preparedStatement(sql);
// 값 세팅
/*
? 안에 들어가는 변수의 형에 따라 setString/setInt/... 등 맞춰주기
setString 첫 번째 매개변수에 들어가는 것은 ?의 인덱스 즉 ?의 순서
*/
pstmt.setString(1, productId);
pstmt.setString(2, productName);
pstmt.setInt(3, productPrice);
pstmt.setString(4, productIdx);
4. SQL 실행
- SQL 실행 위해 PreparedStatement 객체 안의 execute 메소드 활용
- Create(Insert 문) / Update(Update문) / Delete(Delete문) 실행 시 executeUpdate() 메소드 활용
- Read (Select 문) 실행 시 executeQuery() 메소드 사용
- executeQuery() 메소드
- preparedStatement에 셋팅 된 sql문을 실행 후 리턴 값으로 query의 처리 결과가 반환됨
- 즉 row 개수 반환하여 return 값이 int형의 숫자
// SQL문 실행 - preparedstatement 실행
int cnt = pstmt.executeUpdate();
System.out.println(cnt +"개 입력 성공!");
- executeQuery() 메소드
- preparedstatement에 셋팅된 sql문 실행 후 리턴 값으로 조회된 테이블 데이터를 select 형태로 반환
- 즉 return 값이 ResultSet 이므로 ResultSet에 next() 메서드를 활용하면 리턴된 테이블 데이터의 처음부터 데이터가 끝날 때까지 row() 별로 읽어옴
// SQL문 실행 - PrepareStatement 실행
String sql = "select product_id, product_name, product_price, product_desc \n";
sql += "from product";
PreparedStatement pstmt = conn.prepareStatement(sql);
ResultSet rs = pstmt.executeQuery();
// next() 에는 가져온 테이블에 처음 부분으로 올라가는 first() 기능이 포함됨
while(rs.next()){
String p_id = rs.getString("product_id");
String p_name = rs.getString("product_name");
int price = rs.getInt("product_price");
String Pdesc = rs.getString("product_desc");
System.out.println(p_id +" " + p_name +" " +price +" " + Pdesc);
}
5. SQL 연결 끊기
- DB 모두 사용 후 반드시 close() 메소드로 실행해 연결 끊어야 함
- 연결 끊는 순서는 연결했던 반대 순서로 끊기
- DB연결을 종료하지 않으면 쓰레기 값이 남아 오류가 발생할 수 있으므로 주의..!
- 역순으로 끊는 이유는 DB 끊으면 ResultSet이나, Statement에 쓰레기 값이 남을 수 있기 때문임
// 방법 1 -하나씩 모두 확인 후 끊어 주기
public void close(Connection conn, PreparedStatemet pstmt, ResultSet rs) {
try{
if(rs != null) rs.close();
if(pstmt != null) pstmt.close();
if(conn != null) conn.close();
} catch(SQLException e){
e.printStackTrace();
}
}
// 방법 2 - try-with-resources : try() 문에서 선언된 객체들에 대해
// try가 자동 종료될 때 자동으로 자원을 해제해주는 기능을 이용
/**
Connection, PreparedStatement, ResultSet 모두 AutoCloseable을 구현함
AutoCloseable은 try에 선언된 객체가 AutoCloseable을 구현했더라면 java가 try 구문이
종료될 때 자동을 close() 메소드를 해제
**/
try(Connection conn = DBconnection.getConnection();){
String sql = "select product_id, product_name, product_price, product_desc \n";
sql += "from product";
try(PreparedStatement pstmt = conn.preparedStatement(sql);
ResultSet rs = pstmt.executeQuery();){
while (rs.next()) {
String p_id = rs.getString("product_id");
String pname = rs.getString("product_name");
int Price = rs.getInt("product_price");
String Pdesc = rs.getString("product_desc");
System.out.println(p_id + " " + pname + " " + Price + " " + Pdesc);
}
} catch(SQLException e){
e.printStackTrace();
}
} catch(SQLException e){
e.printStackTrace();
}
// 방법 3 - AutoCloseable을 구현한 객체를 가변으로 받는 메소드 만들기
// close(인자1, 인자2, ...)로 넣어서 여러 파일에서 사용 가능
// 가변 인자를 받게 해주는 문법이 사용되므로 JDK 7 이후부터 이용 가능
public static void close(AutoCloseable... autoCloseable){
for(AutoCloseable ac : autoCloseable){
if(ac != null){
try {
ac.close();
} catch(Exception e){
e.printStackTrace();
}
}
}
}