자바(Java) - JDBC(Oracle) : EMP 테이블을 Java와 연결하여 터미널에서 조회하기 (1)

Common

• 프로젝트 내에서 공통으로 사용할 메소드 구현

package com.kh.jdbc.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class Common {
    final static String ORACLE_URL = "jdbc:oracle:thin:@localhost:1521:xe";
    final static String ORACLE_ID = "SCOTT";
    final static String ORACLE_PWD = "TIGER";
    final static String ORACLE_DRV = "oracle.jdbc.driver.OracleDriver";

    public static Connection getConnection() {
        Connection conn = null; // Connection은 반드시 예외처리 해줘야 함
        try {
            Class.forName(ORACLE_DRV); // 오라클 연결하기 위해 드라이브 로딩
            conn = DriverManager.getConnection(ORACLE_URL, ORACLE_ID, ORACLE_PWD); // 자바-오라클 연결 얻기
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conn;
    }
    public static void close(Connection conn) {
        try {
            if(conn != null && !conn.isClosed()) {
                conn.close();
                System.out.println("Connection 해제 성공");
            }
        } catch(Exception e) {
            e.printStackTrace();
        }
    }
    public static void close(Statement stmt) {
        try {
            if(stmt != null && !stmt.isClosed()) {
                stmt.close();
                System.out.println("Connection 해제 성공");
            }
        } catch(Exception e) {
            e.printStackTrace();
        }
    }
    public static void close(ResultSet rSet) {
        try {
            if(rSet != null && !rSet.isClosed()) {
                rSet.close();
                System.out.println("Connection 해제 성공");
            }
        } catch(Exception e) {
            e.printStackTrace();
        }
    }
}

EmpDAO

• 각 쿼리문 실행시킬 메소드 구현

package com.kh.jdbc.dao;
import com.kh.jdbc.util.Common;
import com.kh.jdbc.vo.EmpVO;
import java.sql.Connection;
import java.sql.Date;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

public class EmpDAO {
    Connection conn = null; // 자바와 오라클에 대한 연결 설정
    Statement stmt = null; // sql문을 수행하기 위한 객체
    ResultSet rs = null; // statement 동작에 대한 결과로 전달되는 DB의 내용..!
    Scanner sc = new Scanner(System.in);

    public List<EmpVO> empSelect() {
        List<EmpVO> list = new ArrayList<>(); // 반환할 리스트를 위해 list 객체 생성
        try {
            conn = Common.getConnection();
            stmt = conn.createStatement();
            String sql = "SELECT * FROM EMP";
            rs = stmt.executeQuery(sql); // SELECT 문과 같이 여러 개의 레코드(행)로 결과가 반환 될 때 사용

            while (rs.next()) { // 읽을 행이 있으면 참
                int no = rs.getInt("EMPNO");
                String name = rs.getString("ENAME");
                String job = rs.getString("JOB");
                int mgr = rs.getInt("MGR");
                Date date = rs.getDate("HIREDATE");
                double sal = rs.getDouble("SAL");
                double comm = rs.getDouble("COMM");
                int deptNo = rs.getInt("DEPTNO");
                EmpVO vo = new EmpVO(no, name, job, mgr, date, sal, comm, deptNo); // 하나의 행에 대한 정보 저장을 위한 객체 생성
                list.add(vo);
            }
            // 연결과 역순으로 해제
            Common.close(rs);
            Common.close(stmt);
            Common.close(conn);

        } catch (Exception e) {
            e.printStackTrace(); // 넘어오는게 없을 때를 대비해 예외처리 넣어줄 수도 있음
        }
        return list;
    }

    public void empSelectPrint(List<EmpVO> list) {
        for(EmpVO e : list) {
            System.out.println("사원번호 : " + e.getNo());
            System.out.println("이름 : " + e.getName());
            System.out.println("직책 : " + e.getJob());
            System.out.println("매니저 : " + e.getMgr());
            System.out.println("입사일 : " + e.getDate());
            System.out.println("급여 : " + e.getSal());
            System.out.println("보너스 : " + e.getComm());
            System.out.println("부서번호 : " + e.getDeptNo());
            System.out.println("-----------------------------");
        }
    }

    public void empInsert() {
        System.out.println("사원 정보를 입력하세요.");
        System.out.print("사원번호(4자리) : ");
        int no = sc.nextInt();
        System.out.print("이름 : ");
        String name = sc.next();
        System.out.print("직책 : ");
        String job = sc.next();
        System.out.print("매니저(4자리) : ");
        int mgr = sc.nextInt();
        System.out.print("입사일 : ");
        String date = sc.next();
        System.out.print("급여 : ");
        double sal = sc.nextDouble();
        System.out.print("보너스 : ");
        double comm = sc.nextDouble();
        System.out.print("부서번호 : ");
        int deptNo = sc.nextInt();
        // INSERT INTO EMP VALUES(23,'ENAME', 'JOB',MGR,'HIREDATE',SAL,COMM,DEPTNO);
        String sql = "INSERT INTO EMP(EMPNO, ENAME, JOB, MGR, HIREDATE, SAL, COMM, DEPTNO) VALUES(" +
                no + ", " + "'" + name + "'" + ", " + "'" + job + "'" + ", " + mgr + ", " + "'" + date + "'" +
                 ", " + sal + ", " + comm + ", " + deptNo + ")";

        try {
            conn = Common.getConnection();
            stmt = conn.createStatement();
            int ret = stmt.executeUpdate(sql); // 영향받은 행이 몇 개냐
            System.out.println("Return : " + ret);
        } catch(Exception e) {
            e.printStackTrace();
        }
        Common.close(stmt);
        Common.close(conn);
    }
}

EmpVO

• 테이블 객체 생성

package com.kh.jdbc.vo;
import java.sql.Date; // sql에 있는 데이터를 주고 받을거라 sql date import 해야함.
// DB에 있는 정보를 퍼와서 객체에 담는 용도
public class EmpVO {
    private int no;
    private String name;
    private String job;
    private int mgr;
    private Date date;
    private double sal;
    private double comm;
    private int deptNo;

    public EmpVO(int no, String name, String job, int mgr, Date date, double sal, double comm, int deptNo) {
        this.no = no;
        this.name = name;
        this.job = job;
        this.mgr = mgr;
        this.date = date;
        this.sal = sal;
        this.comm = comm;
        this.deptNo = deptNo;
    }

    public int getNo() {
        return no;
    }

    public void setNo(int no) {
        this.no = no;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getJob() {
        return job;
    }

    public void setJob(String job) {
        this.job = job;
    }

    public int getMgr() {
        return mgr;
    }

    public void setMgr(int mgr) {
        this.mgr = mgr;
    }

    public Date getDate() {
        return date;
    }

    public void setDate(Date date) {
        this.date = date;
    }

    public double getSal() {
        return sal;
    }

    public void setSal(double sal) {
        this.sal = sal;
    }

    public double getComm() {
        return comm;
    }

    public void setComm(double comm) {
        this.comm = comm;
    }

    public int getDeptNo() {
        return deptNo;
    }

    public void setDeptNo(int deptNo) {
        this.deptNo = deptNo;
    }
}

JDBCMain

package com.kh.jdbc;
import com.kh.jdbc.dao.EmpDAO;
import com.kh.jdbc.vo.EmpVO;

import java.util.List;
import java.util.Scanner;

public class JdbcMain {
    public static void main(String[] args) {
        Scanner sc = new Scanner(System.in);
        EmpDAO dao = new EmpDAO();
        while (true) {
            System.out.println("[EMP TABLE COMMAND]");
            System.out.println("메뉴를 선택하세요.");
            System.out.print("[1]SELECT [2]INSERT [3]UPDATE [4]DELETE [5]EXIT : ");
            int sel = sc.nextInt();
            switch(sel) {
                case 1 :
                    List<EmpVO> list = dao.empSelect();
                    dao.empSelectPrint(list);
                    break;
                case 2 :
                    dao.empInsert();
                    break;
                case 3 :
                    break;
                case 4 :
                    break;
                case 5 :
                    System.out.println("종료합니다.");
                    return;
            }
        }
    }
}