MysqlBatchController.java

package com.sangchu.preprocess.etl.controller;

import com.sangchu.preprocess.scheduler.PreProcessScheduler;
import lombok.RequiredArgsConstructor;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.JobParametersInvalidException;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
import org.springframework.batch.core.repository.JobRestartException;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/test")
@RequiredArgsConstructor
public class MysqlBatchController {

    private final JobLauncher jobLauncher;
    private final Job mysqlJob;
    private final PreProcessScheduler preProcessScheduler;

    @PostMapping("/import/mysql")
    public String runImportMysqlJob() throws JobInstanceAlreadyCompleteException, JobExecutionAlreadyRunningException, JobParametersInvalidException, JobRestartException {
        JobParameters jobParameters = new JobParametersBuilder()
                .addLong("time", System.currentTimeMillis())
                .toJobParameters();

        jobLauncher.run(mysqlJob, jobParameters);

        return "csv -> mysql 작업";
    }

    @PostMapping("/scheduler")
    public void runScheduler() throws Exception {
        preProcessScheduler.scheduler();
    }
}