드라이버 로드: Class.forName() DriverManager: 로드된 드라이버를 통해서 Connectrion을 활성화해주는 객체
Connection: DB 연결
Statement: SQL 쿼리 실행: SQL을 실행하는 객체 ResultSet: SQL문 실행 후 데이터를 받는 객체
excute(): 결괏값 처리
close() DB 연결 해제
JDBC 설치
1. Connector 다운로드
커넥터 다운 받는 방법은 多
oracle connector - jdbc 검색 - 다운로드 - ojdbc8.jar 다운로드 jar: 자바 파일의 압축형
2. 라이브러리 추가
3. 드라이버 클래스 (암기x)
MySQL: "com.mysql.jdbc.Driver"
Oracle: "oracle.jdbc.driver.OracleDriver"
AuthDAO.java
//드라이버 로드
Class.forName("oracle.jdbc.driver.OracleDriver");
4. URL 패턴 (암기x)
MySQL: "jdbc:mysql://호스트이름:포트번호/DB이름"
Oracle: "jdbc:oracle:thin:호스트이름:포트번호:DB이름"
PDB 경우: "jdbc:orcle:thin:호스트이름:포트번호/XEPDB1" 11ver 이상은 : 에서 / 로 바뀜 CDB(Container Database) 안에 여러 개의 PDB(Pluggable Database) 사용할 수 있음
MainClass.java
//상수 사용시 데이터베이스가 바뀌면 여기만 바뀌면 됨
public static final String URL = "jdbc:oracle:thin:@localhost:1521:xe";
//호스트 이름: IP주소 ▶ @localhost
//포트 번호 ▶ 1521
//DB 이름: 데이터베이스의 스키마명 ▶ xe
public static final String UID = "hr";
public static final String UPW = "hr";
JDBC 실행순서 (Statement)
Connection 객체
데이터베이스와 자바 연결
연결이 끝난 뒤에는 반드시 close() 메서드를 호출하여 Connection 객체가 사용한 시스템 자원을 반환해야 함
Statement = PreparedStatement 객체 (▼설명)
Statement와 PreparedStatement 객체는 동일한 기능을 제공하나 업그레이드 된 PreparedStatement 사용하면 됨
Connect 객체로부터 Statement를 생성하고 쿼리문 실행
setString (int parameterIndex, String x)
지정된 매개변수를 x값으로 설정
setString, setInt, setDate, setTimestamp 등
▲ sql문의 ?를 설정해주는 작업이라서 select에서 데이터를 가져올 때 필터링으로 사용 가능
executeUpdate()
Insert, Update, Delete 쿼리문 실행
데이터를 가져오는 작업, ResultSet객체 반환
executeQuery()
Select 쿼리문 실행
실행시키는 작업, int형 반환(성공 0, 실패 1)
ResultSet 객체 - select 에서만 사용
위의 executeQuery() 메서드 안에 있는 객체로 select 쿼리문의 결과를 ResultSet 객체에 담아서 리
next()
다음 값 확인 (하나씩 전진, 후진은 x) 다음 행이 있으면 true를 반환하고 전진
getString()
지정한 컬럼 값을 String으로 읽음
getInt()
지정한 컬럼 값을 int 타입으로 읽음
getDouble()
지정한 컬럼 값을 double 타입으로 읽음
PrepareStatement 실행 순서
Statement 객체를 대신하는 PreparedStatement 객체
값을 지정할 때 물음표(?)로 처리하기 때문에 값을 간단히 지정 가능
첫번째 물음표의 인덱스는 1이며, 이후 순서대로 인덱스 값이 1씩 증가
JDBC 실습
insert
package jdbc.ex;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class JDBCInsert {
public static void main(String[] args) {
//insert
String url = "jdbc:oracle:thin:@localhost:1521:xe"; //주소, @작성해야함
String uid = "hr"; //계정 아이디
String upw = "hr"; //비밀번호
String sql = "insert into auth values( seq_auth.nextval , ?, ?)"; //auth 컬럼 3개
Connection conn = null;
PreparedStatement pstmt = null;
// throws exception을 던지니까 try-catch
try {
//드라이버 로드
Class.forName("oracle.jdbc.driver.OracleDriver");
//connection - DB 연결
conn = DriverManager.getConnection(url, uid, upw);
//statement 객체 - sql문을 실행시키기 위한 query 전송 객체
pstmt = conn.prepareStatement(sql);
//?값 세팅 - 첫번째부터 1번 순서 (setString, setInt, setDate, setTimestamp)
pstmt.setString(1, "홍길동"); //1은 물음표를 나타냄, 물음표가 2개 이므로 1,2가 나옴
pstmt.setString(2, "프로그래머"); //직접 값을 적지 않고 변수화 가능
//sql 실행 (select문은 query 문장으로 실행, i, d, u문은 update 메서드로 실행) - i,d,u는 완전 똑같음 sql문만 바뀜
int result = pstmt.executeUpdate(); //업데이트문은 정수형 반환, 성공(1), 실패(0) 반환
// executeUpdate는 정수형 반환
if(result == 1) {
System.out.println("성공");
} else {
System.out.println("실패");
}
} catch(Exception e ) {
e.printStackTrace(); //에러 로그를 봐야 하니까
} finally {
try { //객체 계속 쌓여서 close 필수로 해줌
conn.close();
pstmt.close();
} catch (Exception e2) {
System.out.println("close 에러");
}
} //end try ~ catch ~ finally
} //end main
}
package jdbc.ex;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class JDBCSelect {
public static void main(String[] args) {
//insert
String url = "jdbc:oracle:thin:@localhost:1521:xe"; //주소, @작성해야함
String uid = "hr"; //계정 아이디
String upw = "hr"; //비밀번호
String sql = "select * from auth order by auth_id desc"; //?가 없으니까 아래에서 딱히 할게 없음
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null; //결과 저장 객체, select 결과를 반환받을 객체
try {
//드라이버 로드
Class.forName("oracle.jdbc.driver.OracleDriver");
//conn
conn = DriverManager.getConnection(url, uid, upw);
//pstmt
pstmt = conn.prepareStatement(sql);
//?값에 대한 처리 x
//sql 실행 (select의 실행 - 데이터를 가져오는 작업)
rs = pstmt.executeQuery();
//executeQuery는 ResultSet형으로 반환
//그대로 실행된 결과가 rs에 담김
while (rs.next()) { //다음 row가 있다면 true
//한 행에 대한 처리(getInt, getString, getDouble, getTimestamp, getDate)
int auth_id = rs.getInt("auth_id");
String name = rs.getString("name"); //컬럼명
String job = rs.getString("job");
System.out.println("번호:" + auth_id + ", 이름:" + name + ",직업:" + job);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try { //객체 계속 쌓여서 close 필수로 해줌
conn.close();
pstmt.close();
} catch (Exception e2) {
System.out.println("close 에러");
}
} //end try ~ catch ~ finally
} //end main
}
Connection객체 - prepareStatement객체 - executeQuery() 쿼리문 실행(데이터 가져오기) - next(), get()으로 한 행에 대한 처리
select2 - 조건O
package jdbc.ex;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Scanner;
public class JDBCSelect2 {
public static void main(String[] args) {
/*
* 사원수를 입력받습니다.
* employees, departments 테이블에서 부서별 사원수가 입력받은 사원수보다 큰 데이터를 select
* 출력할 컬럼은 부서명, 사원수, 부서아이디
*/
Scanner scan = new Scanner(System.in);
System.out.println("사원수 입력>");
String tmp = scan.nextLine();
int c = Integer.parseInt(tmp);
//변수선언
String url = "jdbc:oracle:thin:@localhost:1521:xe"; //주소, @작성해야함
String uid = "hr"; //계정 아이디
String upw = "hr"; //비밀번호
String sql = "select d.department_name, a.total, d.department_id\r\n"
+ "from departments d\r\n"
+ "inner join (select department_id, count(*) as total\r\n"
+ " from employees e\r\n"
+ " group by department_id) a\r\n"
+ "on d.department_id = a.department_id\r\n"
+ "where total > ?";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null; //select결과를 반환받을 객체
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
conn = DriverManager.getConnection(url, uid, upw);
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, c); //물음표의 내용을 적어줌
//sql
rs = pstmt.executeQuery();
while(rs.next()) { //한줄이면 한번, 여러줄이면 여러번 실행
String department_name = rs.getString("department_name");
int total = rs.getInt("total");
int department_id = rs.getInt("department_id");
System.out.println("부서명:" + department_name + ", 사원수:" + total + ",부서아이디:" + department_id);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try { //객체 계속 쌓여서 close 필수로 해줌
conn.close();
pstmt.close();
} catch (Exception e2) {
System.out.println("close 에러");
}
} //end try ~ catch ~ finally
} //end main
}
select count(*) from employees ;
select department_id, count(*) total
from employees e
group by department_id;
select d.department_name, a.total, d.department_id
from departments d
inner join (select department_id, count(*) as total
from employees e
group by department_id) a -- null이 안나오면 좋겠어서 inner join
on d.department_id = a.department_id
where total > 1;
Connection객체 - prepareStatement객체 - 특정 조건(?물음표에 대한) 설정 가능, set메서드 사용 - executeQuery() 쿼리문 실행(데이터 가져오기) - next(), get()으로 한 행에 대한 처리
update
package jdbc.ex;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.Scanner;
public class JDBCUpdate {
public static void main(String[] args) {
Scanner scan = new Scanner(System.in);
System.out.println("auth_id 입력>");
String tmp = scan.nextLine();
int auth_id = Integer.parseInt(tmp);
System.out.println("name 입력>");
String name = scan.nextLine();
System.out.println("job 입력>");
String job = scan.nextLine();
//변수선언
String url = "jdbc:oracle:thin:@localhost:1521:xe"; //주소, @작성해야함
String uid = "hr"; //계정 아이디
String upw = "hr"; //비밀번호
//스캐너로 auth_id, name, job을 입력받아서 해당 auth_id의 name, job을 업데이트 하는 구문.
String sql = "update auth set name = ?, job = ? where auth_id = ?";
Connection conn = null;
PreparedStatement pstmt = null;
try {
//드라이버 로드
Class.forName("oracle.jdbc.driver.OracleDriver");
//connection
conn = DriverManager.getConnection(url, uid, upw);
//statement 객체
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, name); //str
pstmt.setString(2, job); //str
pstmt.setInt(3, auth_id); //number
//sql 실행
int result = pstmt.executeUpdate(); // 1 or 0
if(result == 1) {
System.out.println("성공");
} else {
System.out.println("실패");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try { //객체 계속 쌓여서 close 필수로 해줌
conn.close();
pstmt.close();
scan.close();
} catch (Exception e2) {
System.out.println("close 에러");
}
} //end try ~ catch ~ finally
} //end main
}
