Skip to content
Snippets Groups Projects
Commit 66f9792a authored by Robert Goldmann's avatar Robert Goldmann
Browse files

#663 - migrator: added generic processor that does nothing

parent 2a64d0aa
No related branches found
No related tags found
No related merge requests found
......@@ -7,10 +7,9 @@ import de.deadlocker8.budgetmaster.databasemigrator.destination.image.Destinatio
import de.deadlocker8.budgetmaster.databasemigrator.listener.GenericChunkListener;
import de.deadlocker8.budgetmaster.databasemigrator.listener.GenericJobListener;
import de.deadlocker8.budgetmaster.databasemigrator.listener.GenericStepListener;
import de.deadlocker8.budgetmaster.databasemigrator.steps.GenericDoNothingProcessor;
import de.deadlocker8.budgetmaster.databasemigrator.steps.GenericWriter;
import de.deadlocker8.budgetmaster.databasemigrator.steps.category.CategoryProcessor;
import de.deadlocker8.budgetmaster.databasemigrator.steps.category.CategoryReader;
import de.deadlocker8.budgetmaster.databasemigrator.steps.image.ImageProcessor;
import de.deadlocker8.budgetmaster.databasemigrator.steps.image.ImageReader;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
......@@ -62,7 +61,7 @@ public class BatchConfiguration
return stepBuilderFactory.get("Migrate images")
.<DestinationImage, DestinationImage>chunk(1)
.reader(new ImageReader(primaryDataSource))
.processor(new ImageProcessor())
.processor(new GenericDoNothingProcessor<>())
.writer(new GenericWriter<>(destinationImageRepository))
.listener(new GenericChunkListener("image"))
.listener(new GenericStepListener("images"))
......@@ -75,7 +74,7 @@ public class BatchConfiguration
return stepBuilderFactory.get("Migrate categories")
.<DestinationCategory, DestinationCategory>chunk(1)
.reader(new CategoryReader(primaryDataSource))
.processor(new CategoryProcessor())
.processor(new GenericDoNothingProcessor<>())
.writer(new GenericWriter<>(destinationCategoryRepository))
.listener(new GenericChunkListener("category"))
.listener(new GenericStepListener("categories"))
......
package de.deadlocker8.budgetmaster.databasemigrator.steps;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.item.ItemProcessor;
public class GenericDoNothingProcessor<T> implements ItemProcessor<T, T>
{
private static final Logger LOGGER = LoggerFactory.getLogger(GenericDoNothingProcessor.class);
@Override
public T process(T item)
{
LOGGER.debug("GenericDoNothingProcessor: Processing item: {}", item);
return item;
}
}
package de.deadlocker8.budgetmaster.databasemigrator.steps.category;
import de.deadlocker8.budgetmaster.databasemigrator.destination.category.DestinationCategory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.item.ItemProcessor;
public class CategoryProcessor implements ItemProcessor<DestinationCategory, DestinationCategory>
{
private static final Logger LOGGER = LoggerFactory.getLogger(CategoryProcessor.class);
@Override
public DestinationCategory process(DestinationCategory category)
{
LOGGER.debug("CategoryProcessor: Processing category: {}", category);
return category;
}
}
package de.deadlocker8.budgetmaster.databasemigrator.steps.image;
import de.deadlocker8.budgetmaster.databasemigrator.destination.image.DestinationImage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.item.ItemProcessor;
public class ImageProcessor implements ItemProcessor<DestinationImage, DestinationImage>
{
private static final Logger LOGGER = LoggerFactory.getLogger(ImageProcessor.class);
@Override
public DestinationImage process(DestinationImage image)
{
LOGGER.debug("ImageProcessor: Processing image: {}", image);
return image;
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment