Package io.jmix.dataimport.impl

Class DataImportExecutor

java.lang.Object

io.jmix.dataimport.impl.DataImportExecutor

@Component("datimp_DataImportExecutor")
@Scope("prototype")
public class DataImportExecutor
extends Object

Executes import for a given import configuration and ImportedData.

Field Summary

Fields

Modifier and Type	Field	Description
protected DuplicateEntityManager	duplicateEntityManager
protected EntityExtractor	entityExtractor
protected EntityImportExport	entityImportExport
protected EntityImportPlans	entityImportPlans
protected EntityPropertiesPopulator	entityPropertiesPopulator
protected EntityStates	entityStates
protected FetchPlans	fetchPlans
protected ImportConfiguration	importConfiguration
protected ImportedData	importedData
protected ImportResult	importResult
protected static final org.slf4j.Logger	log
protected Metadata	metadata
protected MetadataTools	metadataTools

Constructor Summary

Constructors

Constructor	Description
DataImportExecutor(ImportConfiguration importConfiguration, ImportedData importedData)

Method Summary

Modifier and Type	Method	Description
protected void	addReferencePropertyToImportPlan(EntityImportPlanBuilder ownerBuilder, String propertyName, MetaProperty property, EntityImportPlan propertyImportPlan)
protected void	applyEntityInitializer(List<Object> entitiesToImport)
protected boolean	checkEntityDuplicate(EntityExtractionResult extractionResult)
protected boolean	checkEntityDuplicate(EntityExtractionResult entityExtractionResult, List<EntityExtractionResult> processedResults)
protected boolean	checkExtractedEntity(EntityExtractionResult entityExtractionResult)
protected List<Object>	checkExtractionResults(List<EntityExtractionResult> extractionResults)
protected boolean	checkPreImportPredicate(EntityExtractionResult entityExtractionResult)
protected EntityImportError	createEntityImportErrorResult(EntityExtractionResult result, String errorMessage, EntityImportErrorType entityImportErrorType)
protected EntityImportPlan	createEntityImportPlan(Object entityToImport)
protected EntityImportPlanBuilder	createEntityImportPlanBuilder(MetaClass ownerEntityMetaClass, List<PropertyMapping> propertyMappings, Object ownerEntity)
protected EntityImportPlanBuilder	createEntityImportPlanForCollection(MetaProperty property, ReferenceMultiFieldPropertyMapping referenceMapping)
protected void	createErrorResult(Exception e, String errorMessage)
protected Object	getDuplicateEntity(Object extractedEntity, UniqueEntityConfiguration configuration, List<EntityExtractionResult> processedResults)
protected FetchPlanBuilder	getFetchPlanBuilder(EntityImportPlan plan)
protected void	importByBatches()
ImportResult	importData()
protected List<Object>	importEntities(List<Object> entitiesToImport)
protected void	importEntity(EntityExtractionResult entityExtractionResult)
protected void	importInMultipleTransactions()
protected void	importInOneTransaction()
protected void	processBatch(List<ImportedDataItem> importedDataItemsBatch)
protected boolean	processExistingEntity(EntityExtractionResult extractionResult, UniqueEntityConfiguration configuration, Object existingEntity)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

log

protected static final org.slf4j.Logger log

metadata

@Autowired
protected Metadata metadata

metadataTools

@Autowired
protected MetadataTools metadataTools

entityImportPlans

@Autowired
protected EntityImportPlans entityImportPlans

entityStates

@Autowired
protected EntityStates entityStates

entityImportExport

@Autowired
protected EntityImportExport entityImportExport

duplicateEntityManager

@Autowired
protected DuplicateEntityManager duplicateEntityManager

fetchPlans

@Autowired
protected FetchPlans fetchPlans

entityPropertiesPopulator

@Autowired
protected EntityPropertiesPopulator entityPropertiesPopulator

entityExtractor

@Autowired
protected EntityExtractor entityExtractor

importResult

protected ImportResult importResult

importConfiguration

protected ImportConfiguration importConfiguration

importedData

protected ImportedData importedData

Constructor Details

DataImportExecutor

public DataImportExecutor(ImportConfiguration importConfiguration,
 ImportedData importedData)

Method Details

importData

public ImportResult importData()

importInOneTransaction

protected void importInOneTransaction()

importByBatches

protected void importByBatches()

processBatch

protected void processBatch(List<ImportedDataItem> importedDataItemsBatch)

importInMultipleTransactions

protected void importInMultipleTransactions()

checkExtractionResults

protected List<Object> checkExtractionResults(List<EntityExtractionResult> extractionResults)

checkExtractedEntity

protected boolean checkExtractedEntity(EntityExtractionResult entityExtractionResult)

checkEntityDuplicate

protected boolean checkEntityDuplicate(EntityExtractionResult extractionResult)

processExistingEntity

protected boolean processExistingEntity(EntityExtractionResult extractionResult,
 UniqueEntityConfiguration configuration,
 Object existingEntity)

checkEntityDuplicate

protected boolean checkEntityDuplicate(EntityExtractionResult entityExtractionResult,
 List<EntityExtractionResult> processedResults)

getDuplicateEntity

@Nullable
protected Object getDuplicateEntity(Object extractedEntity,
 UniqueEntityConfiguration configuration,
 @Nullable
 List<EntityExtractionResult> processedResults)

checkPreImportPredicate

protected boolean checkPreImportPredicate(EntityExtractionResult entityExtractionResult)

applyEntityInitializer

protected void applyEntityInitializer(List<Object> entitiesToImport)

importEntity

protected void importEntity(EntityExtractionResult entityExtractionResult)

importEntities

protected List<Object> importEntities(List<Object> entitiesToImport)

createEntityImportErrorResult

protected EntityImportError createEntityImportErrorResult(EntityExtractionResult result,
 String errorMessage,
 EntityImportErrorType entityImportErrorType)

createErrorResult

protected void createErrorResult(Exception e,
 String errorMessage)

getFetchPlanBuilder

protected FetchPlanBuilder getFetchPlanBuilder(EntityImportPlan plan)

createEntityImportPlan

protected EntityImportPlan createEntityImportPlan(Object entityToImport)

createEntityImportPlanBuilder

protected EntityImportPlanBuilder createEntityImportPlanBuilder(MetaClass ownerEntityMetaClass,
 List<PropertyMapping> propertyMappings,
 Object ownerEntity)

createEntityImportPlanForCollection

protected EntityImportPlanBuilder createEntityImportPlanForCollection(MetaProperty property,
 ReferenceMultiFieldPropertyMapping referenceMapping)

addReferencePropertyToImportPlan

protected void addReferencePropertyToImportPlan(EntityImportPlanBuilder ownerBuilder,
 String propertyName,
 MetaProperty property,
 EntityImportPlan propertyImportPlan)