de.hybris.platform.impex.jalo.imp

Class DefaultImportProcessor

java.lang.Object

de.hybris.platform.impex.jalo.imp.DefaultImportProcessor

All Implemented Interfaces:

ImportProcessor

Direct Known Subclasses:

ImpExImportJob.MyImportProcessor, ImpExModifierTest.TestImportProcessor, MultiThreadedImportProcessor, TestImportProcessor

public class DefaultImportProcessor
extends Object
implements ImportProcessor

Constructor Summary

Constructors

Constructor and Description
DefaultImportProcessor()

Method Summary

Modifier and Type	Method and Description
protected void	adjustSessionSettings()
protected void	assertTargetTypePermitted(HeaderDescriptor header, ComposedType targetType, ValueLine valueLine)
protected ImpExImportCUDHandler	createCUDHandler(ImpExImportReader reader)
protected ExistingItemResolver	createExistingItemsResolver(HeaderDescriptor header, boolean useCache)
protected void	debug(String msg) Deprecated. use the logger Logger#debug(Object) method direct
protected void	enableLegacyFlagWhenLineIsUsingJaloOnlyFeatures(ValueLine line)
protected void	error(String msg) Deprecated. use the logger Logger#error(Object) method direct
protected SessionContext	getCreationContext(ComposedType targetType, Map<StandardColumnDescriptor,Object> attributeValueMappings, ValueLine valueLine)
protected ExistingItemResolver	getExistingItemResolver(ValueLine valueLine)
ImpExImportCUDHandler	getHandlerForLine(ValueLine line)
protected Language	getLanguage(StandardColumnDescriptor columnDescriptor)
ImpExImportReader	getReader()
protected String	getSavedValuesMessage(SavedValues savedValues, Item existingItem, ValueLine valueLine)
protected ValueLineTranslator	getValueLineTranslator(ValueLine valueLine)
protected void	handleExceptionDuringImport(ValueLine valueLine, Exception e, ImpExProcessModeEnum mode, String message)
protected boolean	hasUnresolvedMandatoryOrInitialColumns(Collection<StandardColumnDescriptor> columns, ValueLine valueLine)
protected void	info(String msg) Deprecated. use the logger Logger#info(Object) method direct
void	init(ImpExImportReader reader)
protected boolean	isDebugEnabled() Deprecated. use the logger Logger#isDebugEnabled() method direct
protected boolean	isInfoEnabled() Deprecated. use the logger Logger#isInfoEnabled() method direct
protected void	logExceptionDuringImport(Exception e, String message)
protected Item	processInsertLine(Collection<Item> existingItems, ValueLine valueLine, ComposedType targetType)
protected Item	processInsertLine(ValueLine valueLine, HeaderDescriptor header, ComposedType targetType)
protected Item	processInsertLineInternal(Collection<Item> existingItems, ValueLine valueLine, ComposedType targetType)
protected Item	processItemCreation(ComposedType targetType, Map<StandardColumnDescriptor,Object> attributeValueMappings, ValueLine valueLine)
Item	processItemData_Impl(ValueLine valueLine)
Item	processItemData_TX(ValueLine valueLine)
Item	processItemData(ValueLine valueLine)
protected void	processItemRemoval(Item toRemove, ValueLine valueLine)
protected void	processItemUpdate(Item toUpdate, Map<StandardColumnDescriptor,Object> attributeValueMappings, ValueLine valueLine)
protected Item	processRemoveLine(Collection<Item> existingItems, ValueLine valueLine)
protected void	processRemoveLine(Item item, ValueLine valueLine, HeaderDescriptor header)
protected void	processUpdateLine(Item item, ValueLine valueLine, HeaderDescriptor header, ComposedType targetType)
protected void	restoreSessionSettings()
protected boolean	shouldRetryAfterException(Exception exception, ImpExProcessModeEnum mode)
protected void	throwImpExOrRuntimeException(Exception e)
protected Map<String,Object>	translateValueMappings(Item existingItem, Map<StandardColumnDescriptor,Object> attributeValueMappings)
protected void	warn(String msg) Deprecated. use the logger Logger#warn(Object) method direct

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultImportProcessor

public DefaultImportProcessor()

Method Detail

init

public void init(ImpExImportReader reader)

Specified by:

init in interface ImportProcessor

createCUDHandler

protected ImpExImportCUDHandler createCUDHandler(ImpExImportReader reader)

getHandlerForLine

public ImpExImportCUDHandler getHandlerForLine(ValueLine line)

enableLegacyFlagWhenLineIsUsingJaloOnlyFeatures

protected void enableLegacyFlagWhenLineIsUsingJaloOnlyFeatures(ValueLine line)

getReader

public ImpExImportReader getReader()

adjustSessionSettings

protected void adjustSessionSettings()

restoreSessionSettings

protected void restoreSessionSettings()

processItemData

public Item processItemData(ValueLine valueLine)
                     throws ImpExException

Specified by:

processItemData in interface ImportProcessor

Throws:

ImpExException

processItemData_TX

public Item processItemData_TX(ValueLine valueLine)
                        throws ImpExException

Throws:

ImpExException

processItemData_Impl

public Item processItemData_Impl(ValueLine valueLine)
                          throws ImpExException

Throws:

ImpExException

assertTargetTypePermitted

protected void assertTargetTypePermitted(HeaderDescriptor header,
                                         ComposedType targetType,
                                         ValueLine valueLine)
                                  throws InsufficientDataException

Throws:

InsufficientDataException

processRemoveLine

protected Item processRemoveLine(Collection<Item> existingItems,
                                 ValueLine valueLine)
                          throws ImpExException

Throws:

ImpExException

processInsertLine

protected Item processInsertLine(Collection<Item> existingItems,
                                 ValueLine valueLine,
                                 ComposedType targetType)
                          throws ImpExException

Throws:

ImpExException

processInsertLineInternal

protected Item processInsertLineInternal(Collection<Item> existingItems,
                                         ValueLine valueLine,
                                         ComposedType targetType)
                                  throws ImpExException

Throws:

ImpExException

processInsertLine

protected Item processInsertLine(ValueLine valueLine,
                                 HeaderDescriptor header,
                                 ComposedType targetType)
                          throws ImpExException

Throws:

ImpExException

throwImpExOrRuntimeException

protected void throwImpExOrRuntimeException(Exception e)
                                     throws ImpExException

Throws:

ImpExException

handleExceptionDuringImport

protected void handleExceptionDuringImport(ValueLine valueLine,
                                           Exception e,
                                           ImpExProcessModeEnum mode,
                                           String message)
                                    throws ImpExException

Throws:

ImpExException

logExceptionDuringImport

protected void logExceptionDuringImport(Exception e,
                                        String message)

shouldRetryAfterException

protected boolean shouldRetryAfterException(Exception exception,
                                            ImpExProcessModeEnum mode)

processUpdateLine

protected void processUpdateLine(Item item,
                                 ValueLine valueLine,
                                 HeaderDescriptor header,
                                 ComposedType targetType)
                          throws InsufficientDataException,
                                 ImpExException

Throws:

InsufficientDataException

ImpExException

processRemoveLine

protected void processRemoveLine(Item item,
                                 ValueLine valueLine,
                                 HeaderDescriptor header)
                          throws ImpExException

Throws:

ImpExException

hasUnresolvedMandatoryOrInitialColumns

protected boolean hasUnresolvedMandatoryOrInitialColumns(Collection<StandardColumnDescriptor> columns,
                                                         ValueLine valueLine)

getSavedValuesMessage

protected String getSavedValuesMessage(SavedValues savedValues,
                                       Item existingItem,
                                       ValueLine valueLine)

processItemRemoval

protected void processItemRemoval(Item toRemove,
                                  ValueLine valueLine)
                           throws ConsistencyCheckException

Throws:

ConsistencyCheckException

processItemUpdate

protected void processItemUpdate(Item toUpdate,
                                 Map<StandardColumnDescriptor,Object> attributeValueMappings,
                                 ValueLine valueLine)
                          throws ImpExException

Throws:

ImpExException

getCreationContext

protected SessionContext getCreationContext(ComposedType targetType,
                                            Map<StandardColumnDescriptor,Object> attributeValueMappings,
                                            ValueLine valueLine)

processItemCreation

protected Item processItemCreation(ComposedType targetType,
                                   Map<StandardColumnDescriptor,Object> attributeValueMappings,
                                   ValueLine valueLine)
                            throws ImpExException

Throws:

ImpExException

translateValueMappings

protected Map<String,Object> translateValueMappings(Item existingItem,
                                                    Map<StandardColumnDescriptor,Object> attributeValueMappings)
                                             throws ImpExException

Throws:

ImpExException

isDebugEnabled

@Deprecated
protected boolean isDebugEnabled()

Deprecated. use the logger Logger#isDebugEnabled() method direct

Checks if the debug method of the reader is enabled or if no reader set the logger will be checked.

Returns:

is debug mode enabled?

debug

@Deprecated
protected void debug(String msg)

Deprecated. use the logger Logger#debug(Object) method direct

Debugs a message with the reader or the current logger instance.

Parameters:

msg - debug message

isInfoEnabled

@Deprecated
protected boolean isInfoEnabled()

Deprecated. use the logger Logger#isInfoEnabled() method direct

Checks if the info method of the reader is enabled or if no reader set the logger will be checked.

Returns:

is info mode enabled?

info

@Deprecated
protected void info(String msg)

Deprecated. use the logger Logger#info(Object) method direct

Logs an info message with the reader or the current logger instance.

Parameters:

msg - info message

warn

@Deprecated
protected void warn(String msg)

Deprecated. use the logger Logger#warn(Object) method direct

Logs an warn message with the reader or the current logger instance.

Parameters:

msg - warn message

error

@Deprecated
protected void error(String msg)

Deprecated. use the logger Logger#error(Object) method direct

Logs an error message with the reader or the current logger instance.

Parameters:

msg - error message

getLanguage

protected Language getLanguage(StandardColumnDescriptor columnDescriptor)
                        throws InsufficientDataException,
                               HeaderValidationException

Throws:

InsufficientDataException

HeaderValidationException

getValueLineTranslator

protected ValueLineTranslator getValueLineTranslator(ValueLine valueLine)

getExistingItemResolver

protected ExistingItemResolver getExistingItemResolver(ValueLine valueLine)
                                                throws HeaderValidationException

Throws:

HeaderValidationException

createExistingItemsResolver

protected ExistingItemResolver createExistingItemsResolver(HeaderDescriptor header,
                                                           boolean useCache)
                                                    throws HeaderValidationException

Throws:

HeaderValidationException