1.JDBC 기본 구조

2. MySQL 연동

StudentDAO.java -getStudent()

• StudentDAO.java는 MySQL과 Student.java 클래스를 이용하여 데이터를 처리하는 클래스 입니다.

JDBC 드라이버 로딩

• JDBC API 사용을 위해서 Class.forName 메서드를 이용하여 JDBC 드라이버 로딩
• DB 마다 클래스 이름이 다르므로 해당 DB 이름을 정확하게 넣어야 합니다.

Class.forName("com.mysql.cj.jdbc.Driver");

데이터 베이스 연결

    private static String dbUrl="jdbc:mysql://localhost:3306/bookex?serverTimezone=Asia/Seoul&useSSL=false";
    private static String dbUser="codeJ";
    private static String dbPasswd="yjy^^";

• dbUrl : 접속url, MySQL의 기본 포트번호는 3306!
• dbUser : 사용할 유저 아이디
• dbPasswd : 유저 비밀번호

데이터 베이스 연결 설정

//드라이버 로딩
Class.forName("com.mysql.cj.jdbc.Driver");
//커넥션 객체
conn = DriverManager.getConnection(dbUrl, dbUser, dbPasswd);

SQL문 작성

String sql = "SELECT * FROM STUDENT WEHRE stu_no = ?";
            ps = conn.prepareStatement(sql);
            ps.setInt(1,stuNo); //? 파라미터 값에 setInt를 이용하여 stuNo 매핑
            rs = ps.executeQuery();//명령어 실행

• PreparedStatement 에서는 필요한 변수를 ?로 표시하여 사용합니다.
• ? 파라미터 값에 setInt를 이용하여 StuNo를 매핑합니다.

  if(rs.next()){
                int stuNum = rs.getInt(1);
                String id = rs.getString("id");
                String passwd = rs.getString("passwd");
                String email = rs.getString("email");
                String phoneNum = rs.getString("5");
                student = new Student(stuNum,id,passwd,email,phoneNum);

• rs.next() : 데이터 존재 여부 확인
  • 결과값이 있다면 첫번째 레코드에서 true를 리턴
  • 결과값이 없다면 false를 리턴
• 컬럼의 데이터 타입에 맞춰 컬럼 순서 or 컬럼명을 입력합니다.

SQL문 처리명령

• 1.executeQuery
  • select 명령문에서 사용
  • 반환값 : ResultSet 클래스의 인스턴스로 반환
• 2.executeUpdate
  • insert,update,delte 명령문에서 사용
  • 반환값 :int

연결 해제

rs.close();
ps.close();
conn.close();

• 역순으로 연결을 해제 해줍니다.

Student.java

package codeJ.referenceRoom.Lab.jdbc;

import lombok.Getter;
import lombok.Setter;
import lombok.ToString;

@Getter
@ToString
@Setter
public class Student {

    private Integer stu_no;
    private String id;
    private String passwd;
    private String email;
    private String phoneNum;

    public Student(Integer stuNo, String id, String passwd, String email, String phoneNum) {
        super();
        this.stu_no = stuNo;
        this.id = id;
        this.passwd = passwd;
        this.email = email;
        this.phoneNum = phoneNum;
    }

}

StudentDAO.java

package codeJ.referenceRoom.Lab.jdbc;


import lombok.extern.log4j.Log4j2;

import java.sql.*;

@Log4j2
public class StudentDAO {




    private static String dbUrl="jdbc:mysql://localhost:3306/bookex?serverTimezone=Asia/Seoul&useSSL=false";
    private static String dbUser="codeJ";
    private static String dbPasswd="yjy^^";

    public Student getStudent(Integer stuNo){
        Student student = null;
        Connection conn = null; //DB와 연결을 위한 객체                     (연결을 맺을 객체)
        PreparedStatement ps = null;    //SQL 문을 DB에 보내기 위한 객체     (명령을 선언할 객체)
        ResultSet rs = null;    //SQL 질의에 생성된 테이블을 저장하는 객체      (결과값을 담아낼 객체)

        //executeQuery : SELECT 문
        //반환값 : ResultSet 클래스의 인스턴스로 반환

        //executeUpdate : INSERT,DELETE,UPDATE 문
        //반환값 : int

        try{
            Class.forName("com.mysql.cj.jdbc.Driver");  //JDBC 드라이버 로딩
            conn = DriverManager.getConnection(dbUrl, dbUser, dbPasswd);


            String sql = "SELECT * FROM STUDENT WEHRE stu_no = ?";
            ps = conn.prepareStatement(sql);
            ps.setInt(1,stuNo); //? 파라미터 값에 setInt를 이용하여 stuNo 매핑
            rs = ps.executeQuery();//명령어 실행

            if(rs.next()){
                int stuNum = rs.getInt(1);
                String id = rs.getString("id");
                String passwd = rs.getString("passwd");
                String email = rs.getString("email");
                String phoneNum = rs.getString("5");
                student = new Student(stuNum,id,passwd,email,phoneNum);
                log.info(stuNum+" "+id+" "+passwd+" "+email+" "+phoneNum);
            }

        }catch (SQLException e) {
            e.printStackTrace();
        }catch (ClassNotFoundException e){
            e.printStackTrace();
        }finally {
            //사용순서와 반대로 close 합니다.
            if(rs != null){
                try{
                    rs.close();
                }catch (SQLException e){
                    e.printStackTrace();
                }
            }
            if(ps != null){
                try{
                    ps.close();
                }catch (SQLException e){
                    e.printStackTrace();
                }
            }
            if(conn != null){
                try{
                    conn.close();
                }catch (SQLException e){
                    e.printStackTrace();
                }
            }
        }//연결한 부분 닫아주기 finally는 반드시 수행합니다.
        return student;
}
}

결과 출력

package codeJ.referenceRoom.Lab.jdbc;


public class JDBCExercise1 {
    public static void main(String[] args) {
        StudentDAO dao = new StudentDAO();
        Student student = dao.getStudent(1);
        System.out.println(student);


    }
}

• 원하는 결과 값이 잘 나온 것을 볼 수 있습니다.