Prepared statement (선처리 방식)이란? 바인딩 변수(?)를 사용하여 sql의 반복되는 내용을 쉽게 구현 가능한 Statement이다. SQL 문장이 미리 컴파일되고, 실행 시간 동안 인수 값을 위한 공간을 확보할 수 있다는 점에서 Statement 객체와 다르다.
1) Statement 객체의 SQL은 실행될 때, 매번 서버에서 분석해야 하는 반면 PreparedStatement 객체는 한 번 분석되면 재사용이 용이하다.
2) 각각 인수에 대해 위치홀더(placeholder)를 사용하여 SQL 문을 정의할 수 있게 해준다. 위치 홀더는 ? 로 표현된다. 이를 사용하면 SQL Injection 공격에서 벗어날 수 있다.
3) 동일한 SQL문을 특정 값만 바꾸어서 여러 번 실행해야 할 때, 인수가 많아서 SQL 문을 정리해야 될 필요가 있을 때 사용하면 유용하다.
package pack5db;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class DbTest4 {
private Connection conn;
private PreparedStatement pstmt;
private ResultSet rs;
// PreparedStatement : 선처리 방식
// ? 연산자를 사용할 수 있다.
public DbTest4() {
dbloading();
accessDb();
}
private void dbloading() {
try {
Class.forName("org.mariadb.jdbc.Driver");
} catch (Exception e) {
System.out.println("로딩 실패 :" +e);
System.exit(0);
}
}
private void accessDb() {
try {
conn = DriverManager.getConnection("jdbc:mariadb://127.0.0.1:3306/test","root","비밀번호");
// 자료 추가
String isql = "insert into sangdata values(?,?,?,?)";
pstmt = conn.prepareStatement(isql);
pstmt.setString(1, "10"); // 사실 값은 외부에서 받는다고 가정
pstmt.setString(2, "신상품");
pstmt.setInt(3, 11);
pstmt.setString(4, "5000");
pstmt.executeUpdate();
// 자료 수정
String usql = "update sangdata set sang =?,su=?,dan=? where code=?"; // primary키인 code는 수정 x
pstmt = conn.prepareStatement(usql);
pstmt.setString(1, "볼펜");
pstmt.setString(2, "5");
pstmt.setString(3, "1100");
pstmt.setString(4, "10");
pstmt.executeUpdate();
// 자료 삭제
String dsql = "delete from sangdata where code = ? ";
pstmt = conn.prepareStatement(dsql);
pstmt.setInt(1, 10);
int result = pstmt.executeUpdate();
if (result > 0)
System.out.println("삭제 성공");
else
System.out.println("삭제 실패");
// 전체 자료 읽기
String sql = "select * from sangdata"; // *보단 칼럼명쓰는걸 권장
pstmt = conn.prepareStatement(sql); // 선처리 방식
rs = pstmt.executeQuery();
int cou = 0;
while(rs.next()) { // 자료가 2개 이상 올때
System.out.println(rs.getString("code") + " " +
rs.getString("sang") + " " +
rs.getString("su") + " " +
rs.getString("dan") + " ");
cou ++;
}
System.out.println("전체 건수 : "+cou);
System.out.println();
// 부분 자료 읽기
String bun = "1"; // 외부 예를 들어 키보드로 code를 입력 받는다고 가정
// sql = "select * from sangdata where code = " +bun; // Secure coding guideline에 위배
// pstmt = conn.prepareStatement(sql);
sql = "select * from sangdata where code = ? "; // ? 연산자를 사용
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, bun); // setInt도 사용가능 // 1번째 ?에 bun값이 매핑
rs = pstmt.executeQuery();
if(rs.next()) { // 자료가 1개 일때
System.out.println(rs.getString("code") + " " +
rs.getString("sang") + " " +
rs.getString("su") + " " +
rs.getString("dan"));
}else {
System.out.println("그런 자료는 없어요");
}
} catch (Exception e) {
System.out.println("accessDb err : " +e);
} finally {
try {
if (rs != null) rs.close();
if (pstmt != null) pstmt.close();
if (conn != null) conn.close();
} catch (Exception e2) {
// TODO: handle exception
}
}
}
public static void main(String[] args) {
new DbTest4();
}
}