나무바다

<설명>

파라미터가 없는 default 생성자를 생성해주는 어노테이션

<예제>

package com.bootbatch.main;

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

@Getter
@Setter
@NoArgsConstructor
public class UserVO {
private int count;


public UserVO(int count) {
this.count = count;
}
}

<설명>

스프링의 @Configuration 어노테이션은 이 클래스가 구성 클래스임을 스프링에 알린다.

스프링은 @Configuration이 달린 클래스를 보면 일단 그 안에서 빈 인스턴스 정의부, 즉 @Bean을 붙인(빈 인스턴스를 생성해 반환하는) 자바 메서드를 찾는다.

아래 <예제1>에서 dataSource method를 보자 @Bean처리된 것을 확인할 수 있다.

<예제2>를 보면 private final로 dataSource 변수에 DI(Dependency Injection)가 된 것을 확인할 수 있다.

<설명>

@ComponentScan 어노테이션은 @Component 어노테이션 및 streotype(@Service, @Repository, @Controller) 어노테이션이 부여된 Class들을 자동으로 Scan하여 Bean으로 등록해주는 역할을 하는 어노테이션이다.

<설명>

Property 파일을 Environment로 로딩할 수 있다.

<설명>

@EnableBatchProcessing 어노테이션은 다른 스프링의 Enable**과 비슷하게 동작하며 배치 Job을 구성하는 기본 설정을 제공한다.

<예제1>

@Configuration
@ComponentScan("com.bootbatch")
@PropertySource("classpath:/database.properties")
@EnableBatchProcessing
public class BatchConfiguration {

    @Autowired
    private Environment env;

    @Bean
    public DataSource dataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setUrl(env.getRequiredProperty("jdbc.url"));
        dataSource.setUsername(env.getProperty("jdbc.username"));
        dataSource.setPassword(env.getProperty("jdbc.password"));
        return dataSource;
    }

    @Bean
    public DataSourceInitializer databasePopulator() {
        ResourceDatabasePopulator populator = new ResourceDatabasePopulator();
        populator.addScript(new ClassPathResource("org/springframework/batch/core/schema-oracle10g.sql"));
        populator.addScript(new ClassPathResource("total_count.sql"));
        populator.setContinueOnError(true);
        populator.setIgnoreFailedDrops(true);

        DataSourceInitializer initializer = new DataSourceInitializer();
        initializer.setDatabasePopulator(populator);
        initializer.setDataSource(dataSource());
        return initializer;
    }

}

<예제2>

package com.bootbatch.job;

import javax.sql.DataSource;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider;
import org.springframework.batch.item.database.JdbcBatchItemWriter;
import org.springframework.batch.item.database.JdbcCursorItemReader;
import org.springframework.batch.item.database.builder.JdbcCursorItemReaderBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import com.bootbatch.main.BatchVO;

import lombok.RequiredArgsConstructor;


@Configuration
@RequiredArgsConstructor
public class BatchJob {
private final JobBuilderFactory jobBuilderFactory;
    private final StepBuilderFactory stepBuilderFactoy;
    
    @Autowired
    private DataSource dataSource;
    
    @Autowired
    private ThreadPoolTaskExecutor taskExecutor;


    @Bean
    public Job jdbcCursorItemReaderJob() {
     return jobBuilderFactory.get("jdbcCursorItemReaderJob")
     .start(jdbcCursorItemReaderStep())
     .build();
    }

    @Bean
    public Step jdbcCursorItemReaderStep() {
     return stepBuilderFactoy.get("jdbcCursorItemReaderStep")
     .<BatchVO, BatchVO>chunk(10)
     //reader에서 받아서
     .reader(jdbcCursorItemReader())
     //writer에 넣는다.
     .writer(jdbcCursorItemWriter())
     .build();
    }


    @Bean
    JdbcBatchItemWriter jdbcCursorItemWriter(){
     JdbcBatchItemWriter itemWriter = new JdbcBatchItemWriter();
     itemWriter.setDataSource(dataSource);
     itemWriter.setSql("insert into insert_count values(:count)");
     itemWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider());
     return itemWriter;
    }
    
    @Bean
    public JdbcCursorItemReader jdbcCursorItemReader(){
     System.out.println("===>jdbcCursorItemReader 접속!!");
     return new JdbcCursorItemReaderBuilder()
     .fetchSize(10)
     .dataSource(dataSource)
     .rowMapper(new BeanPropertyRowMapper<>(BatchVO.class))
     .sql("SELECT COUNT FROM TOTAL_COUNT")
     .name("jdbcCursorItemWriter")
     .build();
 
    }
}

@Entity

@Entity

- JPA를 사용해서 테이블과 매핑할 클래스는 @Entity 어노테이션을 필수로 붙여야 합니다.
- @Entity가 붙은 클래스는 JPA가 관리하고, 엔티티라 부릅니다.
- @Entity 적용 시 주의사항
- 기본 생성자가 필수(파라미터가 없는 public 또는 protected 생성자)
- final 클래스, enum, interface, inner 클래스에는 사용 불가
- 저장할 필드에 final 사용 불가