Package de.hybris.platform.jdbcwrapper.interceptor.recover

Class DefaultSQLRecoveryStrategy

java.lang.Object

de.hybris.platform.jdbcwrapper.interceptor.recover.DefaultSQLRecoveryStrategy

All Implemented Interfaces:

SQLRecoveryStrategy

public class DefaultSQLRecoveryStrategy
extends java.lang.Object
implements SQLRecoveryStrategy

Constructor Summary

Constructors

Constructor	Description
DefaultSQLRecoveryStrategy(ConfigIntf config)

Method Summary

Modifier and Type	Method	Description
java.time.Duration	calculateBackoffDuration(int numberOfIterations)
boolean	canRecover(JDBCInterceptorContext ctx)
protected double	getBackoffIncreaseFactor()
protected Config.DatabaseName	getDataBaseType()
protected int	getInitialBackoffSeconds()
protected int	getMaxBackoffSeconds()
boolean	isRecoverable(java.sql.SQLException e)
protected static java.util.Map<Config.DatabaseName,java.util.Set<java.lang.Integer>>	mergeDBSpecificWithCommonErrorCodes(ConfigIntf config, java.util.function.Function<Config.DatabaseName,java.lang.String> errorCodesKeyForDB)
protected static java.lang.String	nonRecoverableErrorCodesKey(Config.DatabaseName name)
protected static java.lang.String	recoverableErrorCodesKey(Config.DatabaseName name)
protected static java.util.Set<java.lang.Integer>	toSetOfInts(java.lang.String intsToSplit)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSQLRecoveryStrategy

public DefaultSQLRecoveryStrategy(ConfigIntf config)

Method Detail

calculateBackoffDuration

public java.time.Duration calculateBackoffDuration(int numberOfIterations)

Specified by:

calculateBackoffDuration in interface SQLRecoveryStrategy

isRecoverable

public boolean isRecoverable(java.sql.SQLException e)

Specified by:

isRecoverable in interface SQLRecoveryStrategy

canRecover

public boolean canRecover(JDBCInterceptorContext ctx)

Specified by:

canRecover in interface SQLRecoveryStrategy

getInitialBackoffSeconds

protected int getInitialBackoffSeconds()

getBackoffIncreaseFactor

protected double getBackoffIncreaseFactor()

getMaxBackoffSeconds

protected int getMaxBackoffSeconds()

getDataBaseType

protected Config.DatabaseName getDataBaseType()

mergeDBSpecificWithCommonErrorCodes

protected static java.util.Map<Config.DatabaseName,java.util.Set<java.lang.Integer>> mergeDBSpecificWithCommonErrorCodes(ConfigIntf config,
                                                                                                                               java.util.function.Function<Config.DatabaseName,java.lang.String> errorCodesKeyForDB)

recoverableErrorCodesKey

protected static final java.lang.String recoverableErrorCodesKey(Config.DatabaseName name)

nonRecoverableErrorCodesKey

protected static final java.lang.String nonRecoverableErrorCodesKey(Config.DatabaseName name)

toSetOfInts

protected static java.util.Set<java.lang.Integer> toSetOfInts(java.lang.String intsToSplit)