[6/28 TIL] SPRING(DataSource, JdbcTemplate)

🍃프로그래머스 백엔드 데브코스 4기 교육과정을 듣고 정리한 글입니다.🍃

DataSource

• 데이터 소스를 이용해서 커넥션 풀에 있는 커넥션을 가져와 사용하고, 반납함
• 데이터 소스가 커넥션 풀을 관리

DataBase Connection Pool(DBCP)

그림 출처

• 커넥션 풀은 여러 데이터베이스 연결(커넥션)을 미리 설정하고 재사용하여 오버헤드를 줄임
• 데이터베이스 작업을 처리한 후에는 연결을 닫지 않고 풀에 반환하여 이를 재사용

HikariCP

• Java 언어를 위한 커넥션 풀 라이브러리
• 별도 설정 없이 스프링 부트 JDBC API에 포함

JdbcTemplate

• 기존 JDBC API를 단순화하고 복잡한 반복 코드를 제거
• 예외 처리와 커넥션 리소스 관리를 자동으로 처리
• DataSource를 이용해서 커넥션을 사용

예시 코드

public class JDBCTemplateCrudExample {

    public static void main(String[] args) {
        // JDBC 드라이버 로드
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return;
        }

        // 데이터베이스 연결 설정
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setUrl("jdbc:mysql://localhost:3306/sampledb");
        dataSource.setUsername("username");
        dataSource.setPassword("password");

        // JdbcTemplate 생성
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

        // 데이터 삽입
        UUID id = UUID.randomUUID();
        String name = "유명한";
        int age = 25;
        insertData(jdbcTemplate, id, name, age);
        
        // 데이터 검색 (단일 행)
        UUID searchId = UUID.fromString("your-id");
        UserData userData = retrieveDataById(jdbcTemplate, searchId);
        if (userData != null) {
            System.out.println("Data Found:");
            System.out.println("ID: " + userData.getId() + ", Name: " + userData.getName() + ", Age: " + userData.getAge());
        } else {
            System.out.println("Data Not Found");
        }

        // 데이터 검색
        System.out.println("All Data:");
        retrieveData(jdbcTemplate);

        // 데이터 갱신
        String newName = "김명한";
        int newAge = 30;
        updateData(jdbcTemplate, id, newName, newAge);

        // 데이터 삭제
        deleteData(jdbcTemplate, id);

        // 최종 데이터 검색
        System.out.println("Updated Data:");
        retrieveData(jdbcTemplate);
    }

    // 데이터 삽입
    private static void insertData(JdbcTemplate jdbcTemplate, UUID id, String name, int age) {
        String sql = "INSERT INTO users (id, name, age) VALUES (?, ?, ?)";
        jdbcTemplate.update(sql, toBytes(id), name, age);
        System.out.println("Data inserted successfully.");
    }
    
    // 데이터 검색 (단일 행)
    private static UserData retrieveDataById(JdbcTemplate jdbcTemplate, UUID id) {
        String sql = "SELECT * FROM users WHERE id = ?";
        Object[] params = {toBytes(id)};
        UserData userData = jdbcTemplate.queryForObject(sql, params, (ResultSet rs, int rowNum) -> {
            UUID userId = toUUID(rs.getBytes("id"));
            String name = rs.getString("name");
            int age = rs.getInt("age");
            return new UserData(userId, name, age);
        });
        return userData;
    }

    // 데이터 검색
    private static void retrieveData(JdbcTemplate jdbcTemplate) {
        String sql = "SELECT * FROM users";
        jdbcTemplate.query(sql, (ResultSet rs) -> {
            while (rs.next()) {
                UUID id = toUUID(rs.getBytes("id"));
                String name = rs.getString("name");
                int age = rs.getInt("age");
                System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
            }
        });
    }

    // 데이터 갱신
    private static void updateData(JdbcTemplate jdbcTemplate, UUID id, String name, int age) {
        String sql = "UPDATE users SET name=?, age=? WHERE id=?";
        jdbcTemplate.update(sql, name, age, toBytes(id));
        System.out.println("Data updated successfully.");
    }

    // 데이터 삭제
    private static void deleteData(JdbcTemplate jdbcTemplate, UUID id) {
        String sql = "DELETE FROM users WHERE id=?";
        jdbcTemplate.update(sql, toBytes(id));
        System.out.println("Data deleted successfully.");
    }

    // byte[]을 UUID로 변환
    private static UUID toUUID(byte[] bytes) {
        ByteBuffer byteBuffer = ByteBuffer.wrap(bytes);
        return new UUID(byteBuffer.getLong(), byteBuffer.getLong());
    }

    // UUID를 byte[]로 변환
    private static byte[] toBytes(UUID uuid) {
        ByteBuffer byteBuffer = ByteBuffer.allocate(16);
        byteBuffer.putLong(uuid.getMostSignificantBits());
        byteBuffer.putLong(uuid.getLeastSignificantBits());
        return byteBuffer.array();
    }
}