인프런 커뮤니티 질문&답변

학습하는 분들께 도움이 되고, 더 좋은 답변을 드릴 수 있도록 질문전에 다음을 꼭 확인해주세요.

1. 강의 내용과 관련된 질문을 남겨주세요.
2. 인프런의 질문 게시판과 자주 하는 질문(링크)을 먼저 확인해주세요.
(자주 하는 질문 링크: https://bit.ly/3fX6ygx)
3. 질문 잘하기 메뉴얼(링크)을 먼저 읽어주세요.
(질문 잘하기 메뉴얼 링크: https://bit.ly/2UfeqCG)

질문 시에는 위 내용은 삭제하고 다음 내용을 남겨주세요.
=========================================
[질문 템플릿]
1. 강의 내용과 관련된 질문인가요? 예
2. 인프런의 질문 게시판과 자주 하는 질문에 없는 내용인가요? 예
3. 질문 잘하기 메뉴얼을 읽어보셨나요? 예

[질문 내용]

리포지토리인 Dto 클래스에 private final DataSource dataSource시

Could not autowire. No beans of 'DataSource' type found.

라는 오류가 뜨면서 빌드가 안 됩니다! 서비스에서 트랜잭션을 쓰지는 않지만 DataSource를 적용해보고 싶었는데 안 되네요 ㅠㅠ

package com.spring.dto;

import com.spring.dao.member.Member;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Repository;

import javax.sql.DataSource;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.NoSuchElementException;
import java.util.Optional;


@Repository
@RequiredArgsConstructor
public class JDBCMemberDto implements MemberDto{

    private final DataSource dataSource;

    // 테이블 열
    private static final String TABLE_NAME = "USERS";
    private static final String ID_COLUMN = "ID";
    private static final String USERID_COLUMN = "USERID";
    private static final String PASSWORD_COLUMN = "PASSWORD";
    private static final String NAME_COLUMN = "NAME";

    @Override
    public Member save(Member member) {
        String query = "INSERT INTO " + TABLE_NAME + " (" + ID_COLUMN + ", " + USERID_COLUMN + ", " + PASSWORD_COLUMN + ", " + NAME_COLUMN + ") VALUES (SEQ_USER.NEXTVAL, ?, ?, ?)";

        try (Connection conn = getConnection();
             PreparedStatement pstmt = conn.prepareStatement(query)){
            pstmt.setString(1, member.getUserId());
            pstmt.setString(2, member.getPassword());
            pstmt.setString(3, member.getName());
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }

        return findByUserId(member.getUserId()).get();
    }

    @Override
    public Member findById(Long id) {
        Member member = new Member();
        String query = "SELECT * FROM USERS WHERE id = ?";

        try (Connection conn = getConnection();
             PreparedStatement pstmt = conn.prepareStatement(query)){
            pstmt.setLong(1, id);
            ResultSet rs = pstmt.executeQuery();
            if(rs.next()) {
                member.setId(rs.getLong(ID_COLUMN));
                member.setUserId(rs.getString(USERID_COLUMN));
                member.setPassword(rs.getString(PASSWORD_COLUMN));
                member.setName(rs.getString(NAME_COLUMN));
            } else {
                throw new NoSuchElementException("유저를 찾을 수 없습니다. memberId=" + id);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return member;
    }

    @Override
    public Optional<Member> findByUserId(String userid) {
        return findAll().stream()
                .filter(member -> member.getUserId().equals(userid))
                .findFirst();
    }

    @Override
    public List<Member> findAll() {

        List<Member> list = new ArrayList<>();

        String query = "SELECT * FROM USERS";
        try (Connection conn = getConnection();
             PreparedStatement pstmt = conn.prepareStatement(query)){
            pstmt.executeUpdate();
            ResultSet rs = pstmt.executeQuery();
            while(rs.next()) {
                Member member = new Member();
                member.setId(rs.getLong(ID_COLUMN));
                member.setUserId(rs.getString(USERID_COLUMN));
                member.setPassword(rs.getString(PASSWORD_COLUMN));
                member.setName(rs.getString(NAME_COLUMN));
                list.add(member);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return list;
    }

    private Connection getConnection() throws SQLException {
        Connection connection = dataSource.getConnection();
        return connection;
    }

}