9일차.

 

 

 

 

for (타입 변수 : 배열 또는 컬렉션) { // 반복 실행할 코드 }

• 타입 변수 → 반복하면서 꺼낼 값의 타입과 임시 저장할 변수
• 배열 또는 컬렉션 → 반복할 대상
• : (콜론) → “~에서 하나씩 꺼낸다” 라는 의미

 

 

 

---

컨트롤러-서비스-레포지토리로 연결

@Controller

public class UserController {

    private final UserService userService;

    public UserController(UserService userService){

        this.userService = userService;

    }

}

 

 

ctrl+c , v해서 service에 넣고 커서에게 시키기

@UserService.java 여기에 @UserRepository.java와 파이프라인으로 연결하는 코드 짜줘

 

 

@Service

public class UserService {

    private final UserRepository userRepository;

    public UserService(UserRepository userRepository) {

        this.userRepository = userRepository;

    }

}

 

 

 

@train.csv 여기에서 스키마를 필드로 하는 코드를 작성해줘

 

 

 

 

롬복을 사용하는 이유

 

DTO 는 @Data

VO는 @Getter

 

 

 

**롬복(Lombok)**은 스프링 프로젝트에서 자바의 반복적인 코드를 자동으로 만들어주는 생산성 향상 도구입니다. 핵심은 가독성 향상 + 코드 간결화 + 유지보수성 개선입니다.

 

 

 

 

register에서 가져와서 저부분만 바꿔줌

 

 

 

 

 

passenger을 다 user 로 바꾸기

 

 

 

 

messenger에 담아서 보냄

 

 

 

이 부분은 수동으로 고쳐줘야함

                int count = 0;

                for (CSVRecord record : records) {

                    UserDTO user = new UserDTO();

                    user.setPassengerId(record.get("PassengerId"));

                    user.setName(record.get("Name"));

                    user.setGender(record.get("Sex"));

                    user.setAge(record.get("Age"));

                    user.setPclass(record.get("Pclass"));

                    user.setSurvived(record.get("Survived"));

                    user.setSibSp(record.get("SibSp"));

                    user.setParch(record.get("Parch"));

                    user.setTicket(record.get("Ticket"));

                    user.setFare(record.get("Fare"));

                    user.setCabin(record.get("Cabin"));

                    user.setEmbarked(record.get("Embarked"));

                    user.add(user);

 

 

package com.seoeunjin.api.user.controller;

import java.io.FileReader;

import java.io.InputStreamReader;

import java.io.Reader;

import java.util.ArrayList;

import java.util.List;

import org.apache.commons.csv.CSVFormat;

import org.apache.commons.csv.CSVParser;

import org.apache.commons.csv.CSVRecord;

import org.springframework.boot.autoconfigure.security.SecurityProperties.User;

import org.springframework.core.io.ClassPathResource;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.GetMapping;

import com.seoeunjin.api.common.domain.Messenger;

import com.seoeunjin.api.user.domain.UserDTO;

import com.seoeunjin.api.user.service.UserService;

import lombok.RequiredArgsConstructor;

@Controller

@RequiredArgsConstructor

public class UserController {

    private final UserService userService;

    @GetMapping("/train/top5")

    public Messenger printTop5Passengers() {

        try {

            String csvFilePath = "src/main/resources/static/csv/train.csv";

            // CSV 파일 읽기

            FileReader reader = new FileReader(csvFilePath);

            CSVParser parser = new CSVParser(reader, CSVFormat.DEFAULT.withFirstRecordAsHeader());

            List<UserDTO> users = new ArrayList<>();

            int count = 0;

           

            // 처음 5명의 데이터만 읽기

            for (CSVRecord record : parser) {

                if (count >= 5)

                break;

                    UserDTO user = new UserDTO();

                    user.setUserId(record.get("PassengerId"));

                    user.setName(record.get("Name"));

                    user.setGender(record.get("Sex"));

                    user.setAge(record.get("Age"));

                    user.setPclass(record.get("Pclass"));

                    user.setSurvived(record.get("Survived"));

                    user.setSibSp(record.get("SibSp"));

                    user.setParch(record.get("Parch"));

                    user.setTicket(record.get("Ticket"));

                    user.setFare(record.get("Fare"));

                    user.setCabin(record.get("Cabin"));

                    user.setEmbarked(record.get("Embarked"));

                    users.add(user);

                    count++;

                }

               

                parser.close();

                reader.close();

            Messenger messenger = new Messenger();

            return messenger;

        } catch (Exception e) {

            Messenger messenger = new Messenger();

            messenger.setCode(500);

            messenger.setMessage("csv 파일을 읽는 중 오류가 발생했습니다.");

            return messenger;

        }

}}

 

이렇게 완성이 되었습니당.