package db;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;
//scott.emp에 DML작업
//DML중에서는 시퀀스를 사용한 INSERT연습
public class DMLex02 {
//필드
String url = "jdbc:oracle:thin:@127.0.0.1:1521/xe";
String user = "scott";
String password = "tiger";
Connection conn=null;// static Statement stmt =null;
PreparedStatement pstmt=null;
ResultSet rs =null; //select 쿼리문의 실행결과 집합을 저장하기 위한 변수선언 및 초기화
//생성자 // [접근제한자] 클래스명(){}
public DMLex02() {} //기본생성자 - 매개변수가 없는 생성자
//메소드
//1. JDBC Driver등록 & 2. 연결 Connection 얻기// [접근제한자] [제어자] 리턴유형 메소드명(매개변수리스트) {}
// public Connection dbConnection() { //리턴 유형을 void에서 밑에 return = conn;을 선언해줘야하니 Connection으로 수정
public void dbConnection() { //리턴 유형을 void에서 밑에 return = conn;을 선언해줘야하니 Connection으로 수정
//1. JDBC Driver등록
try {
Class.forName("oracle.jdbc.OracleDriver");
System.out.println("1. JDBC Driver 등록 - 성공");
} catch (ClassNotFoundException e) {
System.out.println("ClassNotFoundException발생 e=");
e.printStackTrace();
}//문제가 왜 발생이 됐는지 원인에 대한 트레이스로 출력!!! 문제 파악하려는 것!!문제가 발생하면 캐치절로 !
//2. 연결 Connection 얻기
try {
conn = DriverManager.getConnection(url, user, password);
System.out.println("2. 연결 Connection 얻기 성공!");
} catch (SQLException e) {
System.out.println("SQLException 발생");
e.printStackTrace();
}// return conn;
}
public static void main(String[] args) {
//객체생성
DMLex02 obj = new DMLex02();
//1. JDBC Driver등록 & 2. 연결 Connection 얻기// Connection cn = obj.dbConnection(); ///--->>Connection cn = obj.conn; 같은말인데... 위에 dbconnection에 리턴값이 없으면 이렇게 써야한다.
obj.dbConnection();
//3. 객체 준비 & 4. 쿼리실행
//사원입사 -> 사원목록조회 -> 사원삭제 -> 사원목록 조회
System.out.println(); //빈줄
System.out.println("----------------------아래는 입사전 사원목록 조회------------------------- ----");
//사원목록조회
obj.selectEmpList();
System.out.println(); //빈줄
System.out.println("-----------------------아래는 사원입사 --------------------------------");
//사원입사
//obj.insertEmp(9010, "김민재", "사원", 2789, 1234);
obj.insertEmp("이강인", "개발", 4800, 1500);
System.out.println(); //빈줄
System.out.println("----------------------아래는 사원목록 조회------------------------- ----");
//사원목록조회
obj.selectEmpList();
//사원정보수정
//특정사원조회
System.out.println(); //빈줄
System.out.println("-----------------------아래는 사원삭제 --------------------------------");
//삭제
obj.deleteEmp(9010); //사번 9010인 사원 삭제
System.out.println();//빈줄
System.out.println("-------------------------아래는 사원목록조회----------------------------");
//사원목록조회
obj.selectEmpList();
//5. 자원반납// obj.close(pstmt);
// obj.close(cn); //obj.close(obj.conn); 리턴값과 메소드에 Connection타입 말고 void로 하면 이렇게 해줘야한다. 애매허다 ㅋㅋ
}//main 끝
//자원반납
//상위클래스명 참조변수 = new 하위클래스명();
//인터페이스명 참조변수 = new 구현클래스명();// [접근제한자] 제어자 리턴유형 메소드명(매개변수리스트)
//자원반납, 해제 Statement, PreparedStatement
public void close(Object pstmt){ //PreparedStatement 보다 상위 클래스 Statement 이기 때문에 더 상위클래스로 선언(다형성) Object...해도되지만 close 메소드를 못쓴다. 그래서 강제 형변환 진행
try {
if(pstmt!=null) {
if(pstmt instanceof Statement)
((Statement)pstmt).close();
}
if(pstmt instanceof PreparedStatement) {
((PreparedStatement)pstmt).close();
}
if(conn!=null) {
conn.close();
}
System.out.println("5. 자원반납 진행");
} catch (SQLException e) {
e.printStackTrace();
}
}//close 끝
//자원반납 Connection --메소드 오버로딩
public void close(Connection conn){
try {
if(conn!=null) {
conn.close();
}
System.out.println("5. 자원반납 진행");
} catch (SQLException e) {
e.printStackTrace();
}
}
//입력// public void insertEmp(int empNo, String ename, String job, int pay, int comm) {
public void insertEmp(String ename, String job, int pay, int comm) {
// System.out.println("insertEmp()진입 empNo = "+empNo+", ename = "+ename+", job = "+job+", pay = "+pay+", comm = "+comm);
System.out.println("insertEmp()진입 empNo = , ename = "+ename+", job = "+job+", pay = "+pay+", comm = "+comm);
// System.out.printf("insertEmp()진입 empNo : %d, ename : %s, job : %s, pay : %d, comm : %d\r", empNo, ename, job, pay, comm);
System.out.printf("insertEmp()진입 empNo : ename : %s, job : %s, pay : %d, comm : %d\r", ename, job, pay, comm);
String sql = "insert into emp(empno, ename, job, hiredate, sal, comm)" +
"values(emp_empno_seq.nextval, ?, ?, sysdate, ?, ?)";
//"values(?, ?, ?, sysdate, ?, ?)";
try {
pstmt = conn.prepareStatement(sql); //프리페어드스테이트먼트는 미리 값을 받아 처리 하기 때문에 sql을 해당 구문 전에 선언해야한다.// pstmt.setInt(1, empNo);
// pstmt.setString(2, ename);
// pstmt.setString(3, job);
// pstmt.setInt(4, pay);
// pstmt.setInt(5, comm);
pstmt.setString(1, ename);
pstmt.setString(2, job);
pstmt.setInt(3, pay);
pstmt.setInt(4, comm);
int resultCnt = pstmt.executeUpdate();
System.out.println("4. 쿼리문 실행결과로 받은 record 수 = "+resultCnt);
} catch (SQLException e1) {
System.out.println("executeUpdate()실행관련 에러");
e1.printStackTrace();
}
try {
if(pstmt!=null) {
pstmt.close();
}
System.out.println("5.insertEmp()의 pstmt 자원반납");
} catch (SQLException e) {
e.printStackTrace();
}
}
//수정// public static void updateEmp(int empNo, String ename, String job, int pay, int comm) {}
//삭제
public void deleteEmp(int empNo) {
System.out.println("deleteEmp()진입 empNo = "+empNo);
String sql = "delete from emp " +
"where empno= ?";
try {
pstmt = conn.prepareStatement(sql); //프리페어드스테이트먼트는 미리 값을 받아 처리 하기 때문에 sql을 해당 구문 전에 선언해야한다.
System.out.println("3. 객체 준비 완료!");
} catch (SQLException e1) {
e1.printStackTrace();
}
//4.쿼리실행
try {
pstmt.setInt(1, empNo);
int resultCnt = pstmt.executeUpdate();
System.out.println("4. 쿼리문 실행!!");
System.out.println("쿼리문 실행결과로 받은 record 수 = "+resultCnt);
} catch (SQLException e1) {
System.out.println("executeUpdate()실행관련 에러");
e1.printStackTrace();
} //실행결과가 몇행적용됐는지 행수가 리턴, create alter drop -->ddl 문이면 리턴 없음!
//5.자원해제
try {
pstmt.close();
System.out.println("5.deleteEmp()의 pstmt 자원반납");
} catch (SQLException e) {
e.printStackTrace();
}
}//deleteEmp()끝
//사원목록조회
public void selectEmpList() {
String sql = "select empno, ename, job, hiredate, sal "+
"from emp";
try {
//stmt = conn.createStatement();
pstmt = conn.prepareStatement(sql); //프리페어드스테이트먼트는 미리 값을 받아 처리 하기 때문에 sql을 해당 구문 전에 선언해야한다.
System.out.println("3. 객체 준비 완료!");
ResultSet rs = pstmt.executeQuery();
System.out.println("4. 쿼리문 실행 결과");
while(rs.next()) { //rs.next()는 다음행(new row)있으면 true리턴
//rs.get데이터타입(select 컬럼순서) 첫번째 컬럼은 1, 두번쨰 컬럼은 2
//rs.get데이터타입("컬럼명 또는 컬럼별칭")
int eno = rs.getInt(1);
String ename = rs.getString(2);
String job = rs.getString(3);
Date date = rs.getDate(4);
double sal = rs.getDouble(5); //--->실수형태로 바꿔도 된다.
// System.out.print(eno + " | ");
// System.out.print(ename + " | ");
// System.out.print(job + " | ");
// System.out.print(date + " | ");
// System.out.println(sal);
//%d : 숫자
//%s : 문자열
// \r\n : 줄바꿈
//한줄로 출력
System.out.printf("%10d | %15s | %15s | %15s | %15f", eno, ename, job, date, sal);
System.out.println(" ");//줄바꿈
}
} catch (SQLException e1) {
System.out.println("executeUpdate()실행관련 에러");
e1.printStackTrace();
} //실행결과가 몇행적용됐는지 행수가 리턴, create alter drop -->ddl 문이면 리턴 없음!
//5. 자원반납 --> 생략가능 하지만 사실 하면 안되는 개념 (제일 처음 객체를 생성 한 것을 제일 나중에 close)
try {
if(rs!=null) {
rs.close();
}
if(pstmt!=null) {
pstmt.close();
}
System.out.println("5.selectEmp()의 pstmt 자원반납");
} catch (SQLException e) {
e.printStackTrace();
}
}//selectEmpList 끝
//특정사원조회// public void selectEmp(매개변수) {}
}