JDBC
JDBC를 사용하기 위해서는 자바 프로젝트에 JDBC드라이버를 추가해줘야 한다.
프로젝트를 우클릭 -> properties -> java build path -> library -> add external jar -> ojdbc.jar 추가
JDBC 객체
Connection : DB의 연결 정보를 담고 있는 객체
[Prepared] Statement : 연결된 DB의 sql문을 전달해서 실행하고, 결과를 받아내는 객체
ResultSet : SELECT문(쿼리)실행 후 조회된 결과를 담는 객체
각자의 pc(localhost)에 jdbc계정 연결 후 test테이블에 데이터 insert 하기
시작 전에 Class Test를 생성.
public static void main(String[] args) {
Scanner sc = new Scanner(System.in);
Connection conn = null; //DB연결 정보 보관 객체
Statement stmt = null; //SQL문을 전달해서 실행 후 결과를 받아올 객체
int result = 0;
System.out.println("번호 : ");
int tno = sc.nextInt();
System.out.println("이름 : ");
String tname = sc.next();
sc.nextLine();
//실행할 sql문(완전한 상태로 만듦, sql 뒤에는 ;이 없어야 한다.)
String sql = "INSERT INTO TEST VALUES("+tno+", '"+tname+"', SYSDATE)";
// 문자열일때 '' 감싸야한다.
try {
//1. JDBC Driver 등록
//Class.forname() -> 문자열로 주어진 클래스 이름을 찾아서 JVM에 로드함
Class.forName("oracle.jdbc.driver.OracleDriver"); //오류 시 오타 | ojdbc.jar 파일을 추가하지 않았을 떼
System.out.println("OracleDriver 등록 성공");
//127.0.0.1 -> 무조건적으로 지금 실행중인 컴퓨터의 ip(localhost)
//2. Connection 생성(url, 계정명, 비밀번호)
conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe","C##JDBC","JDBC");
conn.setAutoCommit(false);
//3. Statement 생성
stmt = conn.createStatement();
//4, 5. sql문 전달 후 결과를 받음(insert, update, delete -> 처리된 행 수 반환)
result = stmt.executeUpdate(sql);
//insert, update, delete -> stmt.executeUpdate : int
//select -> stmt.executeQuery() : ResultSet 자료구조로 반환
//6. 트랜잭션 처리
if (result > 0) {
conn.commit(); //sql의 commit
} else {
conn.rollback(); //sql의 rollback
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
//7. 다쓴 자원 반납(생성 역순)
stmt.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
sc.close();
if(result > 0) {
System.out.println("데이터 추가 성공");
} else {
System.out.println("데이터 추가 실패");
}
}Insert를 하면 Oracle DB의 test 테이블에 값이 추가된다.
각자의 pc(localhost)에 jdbc계정 연결 후 test테이블의 데이터를 select 하기
select -> 결과 : ResultSet로 반환 -> 데이터를 추출
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
ResultSet rset = null;
List<Test> list = new ArrayList<>();
//실행할 sql
String sql = "SELECT * FROM TEST";
try {
//1. JDBC 드라이버 등록
Class.forName("oracle.jdbc.driver.OracleDriver");
System.out.println("OracleDriver 등록 완료");
//2. Connection 생성(DB url, 계정명, 비밀번호)
conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe","C##JDBC","JDBC");
//3. Statement 생성
stmt = conn.createStatement();
//4, 5. sql문 전달하면서 결과받기(select -> ResultSet)
rset = stmt.executeQuery(sql);
//rset.next() -> rset의 다음 행이 있는지 없는지를 알려주고 다음행을 가르킨다.
//다음행이 없으면 false를 반환.
while(rset.next()) {
int tno = rset.getInt("TNO");
String tName = rset.getString("TNAME");
Date tDate = rset.getDate("TDATE");
list.add(new Test(tno, tName, tDate.toLocalDate()));
//list에 반복하는 동안 rset에 저장된 sql 결과의 컬럼명을 자료형에 맞게 변수에 저장.
//Test Class의 생성자를 통해 list에 add하여
//rset의 결과를 rset.next()가 false가 될때 까지 모두 저장.
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
rset.close();
stmt.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(list.isEmpty()) {
System.out.println("데이터가 없습니다.");
} else {
System.out.println(list);
}
}select는 하나의 행을 출력할 수 있지만, 많은 행을 출력할 수 있기 때문에 List에 저장한다.
PreparedStatement 객체 사용 -> sql문 형태를 먼저 정의하고 각 데이터는 추후에 넣는 방법
public static void main(String[] args) {
Scanner sc = new Scanner(System.in);
Connection conn = null;
PreparedStatement pstmt = null;
int result = 0;
System.out.print("수정할 번호를 입력하세요 : ");
int tno = sc.nextInt();
System.out.println("새로운 이름을 입력하세요 : ");
String newName = sc.next();
System.out.println("새로운 날짜를 입력하세요(YYYY-MM-DD) : ");
String newDate = sc.next();
sc.nextLine();
/*
String sql = "UPDATE TEST SET TNAME = '" + newName +
"', TDATE = TO_DATE('" + newDate + "', 'YYYY-MM-DD')" +
"WHERE TNO = " + tno;
*/
//PreparedStatement를 통해 형식을 뒤에서 처리
String sql = "UPDATE TEST SET TNAME=?, TDATE=TO_DATE(?, 'YYYY-MM-DD') WHERE TNO=?";
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
System.out.println("등록 완료");
conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe","C##JDBC","JDBC");
conn.setAutoCommit(false);
//미완성된 sql문을 전달해서 pstmt객체 생성
pstmt = conn.prepareStatement(sql);
//pstmt에 작성하지 않은 값들을 메서드를 통해 완성시키기(? 개수 만큼)
pstmt.setString(1, newName);
pstmt.setString(2, newDate);
pstmt.setInt(3, tno);
result = pstmt.executeUpdate();
if(result > 0) {
conn.commit();
} else {
conn.rollback();
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
pstmt.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(result > 0) {
System.out.println(result + "개의 행이 UPDATE");
} else {
System.out.println("UPDATE 실패");
}
}처음에 했던 statement를 통해 Stirng sql을 받아 실행하는 방식에서는 sql의 형식을 생각하며 String에 저장해야 하지만,
PreparedStatement는 printf처럼 형식을 뒤에서 처리하는 방식이다.
따라서 set자료형에서 자료형에 맞게 설정하면 된다.