JDBC를 이용해서 MySQL 데이터 저장하기

• JDBC (Java Database Connectivity)
  • SQL Mapper의 한 종류
  • 자바와 DB를 연결해주는 애. 그 이상/이하도 아님
  • JDBC로 데이터 저장하기 url = jdbc:DB_VENDER://IP_ADDR:IP_PORT/INSTACNE 

1. build.gradle 파일에 jdbc, mysql 관련 라이브러리 추가.

implementation 'org.springframework.boot:spring-boot-starter-jdbc'
runtimeOnly 'com.mysql:mysql-connector-j' //버전 바뀜에 유의

 

2. SpringBoot 실행시키면 APPLICATION FAILED TO START 뜰 거임. → DB 접속 정보가 없기 때문

 

3. application.properties에 DB 접속 정보 저장.

spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3307/project?serverTimeZone=UTC&characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=

//1. 이 드라이버를 쓰겠다 의미
//2. 어떤 mySQL을 쓸 것인지. - localhost에 있는 것. port는 3307로 설정(3306은 마리아 db가 쓰고있음.)
//project는 mysql에서 사용할 DB명. 뒤에 시간 setting, 한글 인코딩에 적합한 UTF-8적용.
//3. user name    4. password
//복기해보면 DB접속에 필요한 5가지 ip,user(계정),password,인스턴스,포트번호

 

4. MySQL에 memo 테이블 만들기

create table memo(
	id INT not null primary key auto_increment,
  text VARCHAR(50) NOT NULL
 );

 

5. Memo 객체 만들기 (domain패키지 DB테이블 객체 Spring boot에 생성)

package zerobase.weather.domain;

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
public class Memo {
    private int id;
    private String text;
}

 

6. JdbcMemoRepository 만들기 JdbcTemplate

package zerobase.weather.repository;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Repository;
import zerobase.weather.domain.Memo;

import javax.sql.DataSource;
import java.util.List;
import java.util.Optional;

@Repository
public class JdbcMemoRepository {
    private final JdbcTemplate jdbcTemplate;

    @Autowired
    public JdbcMemoRepository(DataSource dataSource) { //여기의 DataSource는 application.properties에 적어둔 datasource 정보들
        jdbcTemplate = new JdbcTemplate(dataSource);
    }

    public Memo save(Memo memo) {
        String sql = "insert into memo values(?,?)";
        jdbcTemplate.update(sql, memo.getId(), memo.getText());
        return memo;
    }

    public List<Memo> findAll(){
        String sql = "select * from memo";
        return jdbcTemplate.query(sql, memoRowMapper());
    }

    public Optional<Memo> findById(int id) {
        String sql = "select * from memo where id = ?";
        return jdbcTemplate.query(sql, memoRowMapper(), id).stream().findFirst();
				//결과값이 하나인데 스프링부트는 모르니까 .stream().findFirst()로 해주고 반환형 optionmal<Memo>로 변경.
				//이 메소드의 결과값이 null이어도 Optional이라는 객체로 매핑해줘서 정상동작 가능.
    }

    private RowMapper<Memo> memoRowMapper() { //ResultSet을 스프링부트에 메모라는 클래스로 대입을 시켜야함 -> RowMapper
        //jdbc를 통해 db에서 가져온 값의 타입은 ResultSet
        //ResultSet의 형태 -> {id = 1, text = 'this is memo~'}
        return(rs,rowNum) -> new Memo(
                rs.getInt("id"),
                rs.getString("text")
        );
    }
}

 

7. 테스트 코드 작성

package zerobase.weather.repository;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.transaction.annotation.Transactional;
import zerobase.weather.domain.Memo;

import java.util.List;
import java.util.Optional;

import static org.junit.jupiter.api.Assertions.*;

@SpringBootTest
@Transactional
class JpaMemoRepositoryTest {

    @Autowired
    JpaMemoRepository jpaMemoRepository;

    @Test
    void insertMemoTest() {
        //given
        Memo newMemo = new Memo(2, "hi");

        //when
        jpaMemoRepository.save(newMemo);

        //then
        List<Memo> memoList = jpaMemoRepository.findAll();
        assertTrue(memoList.size() > 0);

     }

     @Test
     void findByIdTest() {
         //given
         Memo newMemo = new Memo(11, "jpa");

         //when
         Memo memo = jpaMemoRepository.save(newMemo);
         System.out.println(memo.getId());

         //then
         Optional<Memo> result = jpaMemoRepository.findById(memo.getId());
         assertEquals(result.get().getId(), memo.getId());
         assertEquals(result.get().getText(), "jpa");
     }
}