2024.06.18 JDBC 실습 예제 (같이 만들어보기)

 

💡 학습 목표 

 JDBC를 사용하여  학생 관리 시스템을 구축해 보자.

- 학생의 정보를 데이터베이스에 저장하고 관리하는 간단한 시스템을 구축합니다.
- 학생 정보를 추가, 조회, 수정, 삭제할 수 있는 기능을 구현합니다.

 

1. 기능 요구사항
   • 학생 정보 추가
   • 학생 정보 조회
   • 학생 정보 수정
   • 학생 정보 삭제
2. 비기능 요구사항
   • 사용자 친화적인 콘솔 인터페이스 제공
   • 적절한 예외 처리 및 로그 기록
   • 데이터베이스 연결 풀 사용(HikariCP)

 

>> 프로젝트 설계 <<

1. 데이터베이스 설계 및 테이블 생성
2. 테이블 - tbstudent 컬럼 - id, name, age, email

create database studentdb;

CREATE TABLE students (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    age INT NOT NULL,
    email VARCHAR(100) NOT NULL UNIQUE
);

 

만들어 보기

 

DBConnectionManager

package ver2;

import java.sql.Connection;
import java.sql.SQLException;

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

/*
 * 싱글톤 패턴 - 단 하난의 객체만 필요함을 보장해야 한다면
 * 싱글톤 패턴으로 설계 할 수 있다.
 */
public class DBConnectionManager {
	
	// 자기 자신의 참조 주소값을 담을 변수 생성 단, private
	private static DBConnectionManager instance;
	private HikariDataSource dataSource;
	
	// 생성자를 <--- 외부에서 생성자를 호출 못 하게 막아야 한다.
	private DBConnectionManager() {
		HikariConfig config = new HikariConfig(); // 객체생성
		config.setJdbcUrl(" jdbc:mysql://localhost:3306/studentdb?serverTimezone=Asia/Seoul ");
		config.setUsername("root");
		config.setPassword("asd123");
		config.setMaximumPoolSize(10);
		dataSource = new HikariDataSource(config);
	} // end of DBConnectionManager()
	
	// 외부에서 클래스이름.getxxx 메서드를 만들어 주면 된다.
	// 한번에 하나의 스레드만 접근하도록 동기화 적용 
	public synchronized DBConnectionManager getInstance() {
		if (instance == null) {
			instance = new DBConnectionManager();
		}
		return instance;
	} // end of getInstance()
	
	// Connection 객체를 반환 (구현체 - HikariCP 이다.)
	public Connection getConnection() throws SQLException{
		return dataSource.getConnection();
	} // end of getConnection()
	
} // end of class

 

 StudentDTO 

package ver2.model;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

// DTO의 기능은 단지 데이터만 담는 역할을 하는것은 아니다.
// 기능도 추가 가능하다.

@Data  // getter setter 동시에 사용할수 있다.
@NoArgsConstructor
@AllArgsConstructor
@Builder
@ToString
public class StudentDTO {
	
	private int id;
	private String name;
	private int age;
	private String email;

} // end of class

 

StudentDAO

package ver2;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import ver2.model.StudentDTO;

// 물론 기능 설계는 인터페이스를 먼저 작성하고 구현 클래스를 만드는 것이 좋다.
public class StudentDAO {
	
	// 학생 정보 추가 가능 만들기
	public void addStudent(StudentDTO dto) throws SQLException {
		String query = " INSERT INTO students (name, age, email) values(?, ?, ?) ";
		try(
				Connection conn = DBConnectionManager.getInstance().getConnection()
				) {
			PreparedStatement pstmt = conn.prepareStatement(query);
			pstmt.setString(1, dto.getName());
			pstmt.setInt(2, dto.getAge());
			pstmt.setString(3, dto.getEmail());
			pstmt.executeUpdate();
		} 
	}
	
	// 학생의 아이디로 조회하는 기능 만들기 (id 또는 이름으로 많이 한다.)
	public StudentDTO getStudentbyId(int id) throws SQLException {
		
		String query = " SELECT * FROM students WHERE id = ? ";
		
		try(
				Connection conn = DBConnectionManager.getInstance().getConnection()
				) {
			PreparedStatement pstmt = conn.prepareStatement(query);
			pstmt.setInt(1, id);
			
			try(ResultSet rs = pstmt.executeQuery()) {
				if (rs.next()) {
					return new StudentDTO(rs.getInt("id"), rs.getString("name"), rs.getInt("age"), rs.getString("email"));
				}
				
			}
			
		} 
		
		// todo 수정하기
		return null;
	}
	
	// 학생 전체 조회 기능
	public List<StudentDTO> getAllStudents() throws SQLException{
		// tip - 리스트라면 무조건 리스트를 생성하고 코드 작성하기
		List<StudentDTO> list = new ArrayList<>();
		String query = " SELECT * FROM students ";
		
		try(
				Connection conn = DBConnectionManager.getInstance().getConnection()
				) {
			PreparedStatement pstmt = conn.prepareStatement(query);
			ResultSet rs = pstmt.executeQuery();
			
			while (rs.next()) {
				// 메서드 체이닝 기법
			 	StudentDTO dto = new StudentDTO().builder()
				.id(rs.getInt("id"))
				.name(rs.getString("name"))
				.age(rs.getInt("age"))
				.email(rs.getString("email"))
				.build();
			 list.add(dto);
			}
		} 
		// todo 수정하기
		return list;
	}
	
	// 학생 정보 수정하기
	public void updateStudent(String name, StudentDTO dto) throws SQLException {
		String query = " UPDATE SET name = ?, age = ?, email = ? WHERE name = ? ";
		try(
				Connection conn = DBConnectionManager.getInstance().getConnection();
				) {
			PreparedStatement pstmt = conn.prepareStatement(query);
			pstmt.setString(1, dto.getName());
			pstmt.setInt(2, dto.getAge());
			pstmt.setString(3, dto.getEmail());
			pstmt.setString(4, name); // 조건값 셋팅
			pstmt.executeUpdate();
			
		} catch (Exception e) {
			// TODO: handle exception
		}
		
	}
	
	// 학생 정보 삭제하기
	public void deleteStudent(int id) throws SQLException {
		String query = " DELETE FROM students WHERE id = ? ";
		try(
				Connection conn = DBConnectionManager.getInstance().getConnection();
				) {
			PreparedStatement pstmt = conn.prepareStatement(query);
			pstmt.setInt(1, id);
			pstmt.executeUpdate();
			
		} catch (Exception e) {
			// TODO: handle exception
		}
	}
	
} // end of class

 

 

StudentManagementSystem

package ver2;

import java.sql.SQLException;
import java.util.List;

import ver2.model.StudentDTO;

public class StudentManagementSystem {
	
	private static final StudentDAO studentDAO = new StudentDAO();
	
	public static void main(String[] args) {
		
		// 사용자에게 보여주는 부분 꾸며 줘도 된다.
		
		try {
			List<StudentDTO> list =  studentDAO.getAllStudents();
			System.out.println(list.size());
			System.out.println(list.toString());
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		
		
	} // end of main

} // end of class