【初心者のspringboot】springboot初心者が開発現場で必要な知識をみにつけるまで！！

@Service
public class YokunaiService {

    // ❌ 危険：インスタンス変数（フィールド）を持たせている
    private int count = 0;

    public int increment() {
        // 複数スレッドから同時に呼ばれると、countの値がおかしくなる（スレッドセーフではない）
        count++; 
        return count;
    }
}

@Service
public class DamenaService {

    @Autowired // ❌ 非推奨になりつつある書き方
    private UserRepository userRepository;

    @Autowired
    private OrderRepository orderRepository;
}

@Service
public class YoiService {

    // ⭕ finalを付けて、値が途中で変わらない安全な設計にする
    private final UserRepository userRepository;
    private final OrderRepository orderRepository;

    // コンストラクタインジェクション
    public OrderService(UserRepository userRepository, OrderRepository orderRepository) {
        this.userRepository = userRepository;
        this.orderRepository = orderRepository;
    }
}

import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor // 👈 これを付けるだけ！
public class LombokwotukattaService {

    // final を付けたフィールドを自動で認識して、コンストラクタを裏で生成してくれる
    private final UserRepository userRepository;
    private final OrderRepository orderRepository;

    public void processOrder() {
        // 処理...
    }
}

import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.job.builder.JobBuilder;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.step.builder.StepBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;

@Configuration
public class BatchJobConfig {

    @Bean
    public Step userProcessStep(JobRepository jobRepository,
                                PlatformTransactionManager transactionManager,
                                JpaPagingItemReader<User> reader,
                                UserItemProcessor processor,
                                ItemWriter<UserDto> writer) {
        return new StepBuilder("userProcessStep", jobRepository)
                .<User, UserDto>chunk(10, transactionManager) // 👈 10件ごとにチャンク処理を実行
                .reader(reader)
                .processor(processor)
                .writer(writer)
                .build();
    }

    @Bean
    public Job userImportJob(JobRepository jobRepository, Step userProcessStep) {
        return new JobBuilder("userImportJob", jobRepository)
                .start(userProcessStep)
                .build();
    }
}

import org.springframework.batch.item.ItemProcessor;
import org.springframework.stereotype.Component;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Component
public class UserItemProcessor implements ItemProcessor<User, UserDto> {

    @Override
    public UserDto process(User user) throws Exception {
        log.info("Processing user: {}", user.getName());

        // 例: 特定の条件に合わないデータは null を返してスキップする
        if (user.getEmail() == null || user.getEmail().isEmpty()) {
            return null; // このデータはWriterへ渡されない
        }

        // 加工して新しいDTOに詰める
        UserDto dto = new UserDto();
        dto.setId(user.getId());
        dto.setName(user.getName().trim());
        dto.setEmail(user.getEmail().toLowerCase()); // メールアドレスを小文字化

        return dto;
    }
}

import org.springframework.batch.item.Chunk;
import org.springframework.batch.item.ItemWriter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import lombok.extern.slf4j.Slf4j;

@Configuration
public class BatchWriterConfig {

    @Bean
    public ItemWriter<UserDto> writer() {
        return new ItemWriter<UserDto>() {
            @Override
            public void write(Chunk<? extends UserDto> items) throws Exception {
                log.info("Writing {} items to database...", items.size());
                
                // items にはチャンクサイズ分のリストがまとめて入っている
                for (UserDto dto : items) {
                    // 実際の保存処理（例: Repositoryを呼ぶなど）
                    // userRepository.save(...)
                    log.info("Saved: {}", dto.getEmail());
                }
            }
        };
    }
}