package config; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing; import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; import org.springframework.batch.item.database.JdbcCursorItemReader; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import model.Order; import repository.OrderRepository; @Configuration @EnableBatchProcessing public class SpringBatchConfig_ { @Autowired private JobBuilderFactory jobBuilderFactory; @Autowired private StepBuilderFactory stepBuilderFactory; @Autowired private OrderRepository orderRepository; @Bean public JdbcCursorItemReader<Order> orderReader(@Value("#{jobParameters[fullPathFileName]}") String pathToFile) throws SQLException{ String msAccDB = "jdbc:ucanaccess://" + pathToFile; Connection conn = DriverManager.getConnection(msAccDB); JdbcCursorItemReader<Order> orderReader = new JdbcCursorItemReader<>(); //Fetching Orders Data from orders table in mdb file Statement orders = conn.createStatement(); ResultSet orderResult = orders.executeQuery("SELECT * FROM tblOrder"); List<Order> orderList = new ArrayList<>(); while(orderResult.next()) { Order orderData = new Order(); orderData.setOrderId(orderResult.getString(2)); orderData.setDescription(orderResult.getString(3)); orderData.setQuantity(orderResult.getString(4)); orderData.setOderDate(orderResult.getString(5)); orderData.setOrderStatus(orderResult.getString(6)); orderData.setOrderLocation(orderResult.getString(7)); orderList.add(orderData); } system.out.print(orderList); return orderReader ; } }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)