Пример Пакета Spring – CSV-Файл В Базу Данных MySQL

Автор оригинала: mkyong.

В этом руководстве мы покажем вам, как настроить пакетное задание Spring для чтения данных из CSV-файла в базу данных.

Используемые инструменты и библиотеки:

Мавен 3
Затмение 4.2
JDK 1.6
Пружинный сердечник 3.2.2.ВЫСВОБОЖДЕНИЕ
Весенняя партия 2.2.0.ВЫПУСК
Драйвер MySQL Java 5.1.25

1. Проект Java

Создайте проект Java с помощью Maven

$ mvn archetype:generate -DgroupId=com.mkyong -DartifactId=SpringBatchExample 
  -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false

Преобразуйте в проект Eclipse и импортируйте его в среду разработки Eclipse.

$ cd SpringBatchExample/
$ mvn eclipse:eclipse

2. Зависимости проекта

Объявляет все зависимости проекта в pom.xml .


	4.0.0
	com.mkyong
	SpringBatchExample
	jar
	1.0-SNAPSHOT
	SpringBatchExample
	http://maven.apache.org

	
		1.6
		3.2.2.RELEASE
		2.2.0.RELEASE
		5.1.25
	

	

		
		
			org.springframework
			spring-core
			${spring.version}
		
		
		
		
			org.springframework
			spring-jdbc
			${spring.version}
		

		
		
			org.springframework.batch
			spring-batch-core
			${spring.batch.version}
		
		
			org.springframework.batch
			spring-batch-infrastructure
			${spring.batch.version}
		

		
		
			mysql
			mysql-connector-java
			${mysql.driver.version}
		

	
	
		spring-batch
		
		  
			org.apache.maven.plugins
			maven-eclipse-plugin
			2.9
			
				true
				false
			
		  
		  
			org.apache.maven.plugins
			maven-compiler-plugin
			2.3.2
			
				${jdk.version}
				${jdk.version}

3. Структура каталогов проектов

Просмотрите окончательную структуру проекта.

4. CSV-файл

Это csv-файл в папке ресурсов.

Date,Impressions,Clicks,Earning
6/1/13,"139,237",37,227.21
6/2/13,"149,582",55,234.71
6/3/13,"457,425",132,211.48
6/4/13,"466,870",141,298.40
6/5/13,"472,385",194,281.35
......

5. База данных MySQL

Определяет компонент “Источник данных” для базы данных MySQL. jdbc:инициализировать-база данных используется для автоматического создания таблиц метаданных, пакет Spring нужен для хранения сведений о задании.

6. Установка Сердечника Пружинной партии

Определяет Вакансию и Безработный .

7. Весенние пакетные Задания

Это основной xml-файл для настройки пакетного задания Spring. Это job-report.xml файл определяет задание для чтения файл report.csv , сопоставьте его с отчетом обычным pojo и запишите данные в базу данных MySQL.

Прочитайте комментарий, он должен быть понятным. Кстати, не забудьте создать таблицу ” RAW_REPORT ” вручную.

package com.mkyong.model;

public class Report {

	private String Date;
	private String Impressions;
	private String Clicks;
	private String Earning;
	
	//getter and setter methods

	
}

8. Запустите Его

Загружает все и запускает JobLauncher . Это самый простой способ запустить и протестировать его, но в реальной жизни вам может потребоваться запустить его с помощью планировщиков, таких как Spring task, Quartz или системный планировщик, такой как команда “cron” (я покажу вам в следующих уроках).

package com.mkyong;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class App {
  public static void main(String[] args) {

	String[] springConfig  = 
		{	"spring/batch/config/database.xml", 
			"spring/batch/config/context.xml",
			"spring/batch/jobs/job-report.xml" 
		};
		
	ApplicationContext context = 
		new ClassPathXmlApplicationContext(springConfig);
		
	JobLauncher jobLauncher = (JobLauncher) context.getBean("jobLauncher");
	Job job = (Job) context.getBean("reportJob");

	try {

		JobExecution execution = jobLauncher.run(job, new JobParameters());
		System.out.println("Exit Status : " + execution.getStatus());

	} catch (Exception e) {
		e.printStackTrace();
	}

	System.out.println("Done");

  }
}

Выход. Создаются таблицы метаданных пакета Spring, и содержимое report.cvs вставляется в таблицу базы данных ” RAW_REPORT “.

Сделано.