Package de.hybris.platform.persistence.numberseries

Class DefaultSerialNumberDAO

java.lang.Object

de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO

All Implemented Interfaces:

SerialNumberDAO

public class DefaultSerialNumberDAO
extends Object
implements SerialNumberDAO

Default persistence implementation of SerialNumberDAO. Use existing number series tables. Please make sure to call initPersistence() once at each tenant start. This will initialize database tables and patch old number series data if necessary.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONFIG_PARAM_MAX_RETRIES
static final String	CONFIG_PARAM_SYNCHRONIZE_NUMBERGENERATION

Constructor Summary

Constructors

Constructor	Description
DefaultSerialNumberDAO(Tenant t, HybrisDataSource initDataSource)

Method Summary

Modifier and Type	Method	Description
protected void	alterSeriesTable(Connection conn, DeploymentImpl deployments, ItemDeployment depl, de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo info)
protected String	calculateTableName(HybrisDataSource ds)
void	createSeries(String key, int type, long startValue)	Deprecated, for removal: This API element is subject to removal in a future version. since ages
void	createSeries(String key, int type, long startValue, String template)
protected void	createSeriesTable(Connection conn, DeploymentImpl deployments, ItemDeployment depl)
NumberSeries	fetchUniqueRange(String key, int count)
Collection<NumberSeries>	getAllCurrent()
protected Connection	getConnection(HybrisDataSource ds)
NumberSeries	getCurrent(String key)
protected HybrisDataSource	getDataSource()
protected de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo	getTableInfo(Connection conn, String expectedName)
void	initPersistence()
protected void	initTable(Connection conn, DeploymentImpl deployments, ItemDeployment depl, de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo info)
protected boolean	isOldNumerMigrationRequired(de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo info)
protected boolean	isSchemaInitOrUpdateRequired(de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo info)
void	removeSeries(String key)
void	resetSeries(String key, int type, long startValue)
protected void	tryToClose(Connection connection, Statement statement, ResultSet resultSet)
protected void	tryToClose(Statement statement, ResultSet resultSet)

Methods inherited from class java.lang.Object

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

Field Details

CONFIG_PARAM_SYNCHRONIZE_NUMBERGENERATION

public static final String CONFIG_PARAM_SYNCHRONIZE_NUMBERGENERATION

See Also:

• Constant Field Values

CONFIG_PARAM_MAX_RETRIES

public static final String CONFIG_PARAM_MAX_RETRIES

See Also:

• Constant Field Values

Constructor Details

DefaultSerialNumberDAO

public DefaultSerialNumberDAO(Tenant t,
 HybrisDataSource initDataSource)

Method Details

calculateTableName

protected String calculateTableName(HybrisDataSource ds)

getDataSource

protected HybrisDataSource getDataSource()

getConnection

protected Connection getConnection(HybrisDataSource ds)
                            throws SQLException

Throws:

SQLException

createSeries

public void createSeries(String key,
 int type,
 long startValue,
 String template)

Specified by:

createSeries in interface SerialNumberDAO

createSeries

@Deprecated(since="ages",
            forRemoval=true)
public void createSeries(String key,
 int type,
 long startValue)

Deprecated, for removal: This API element is subject to removal in a future version.

since ages

Specified by:

createSeries in interface SerialNumberDAO

fetchUniqueRange

public NumberSeries fetchUniqueRange(String key,
 int count)

Specified by:

fetchUniqueRange in interface SerialNumberDAO

removeSeries

public void removeSeries(String key)

Specified by:

removeSeries in interface SerialNumberDAO

resetSeries

public void resetSeries(String key,
 int type,
 long startValue)

Specified by:

resetSeries in interface SerialNumberDAO

getCurrent

public NumberSeries getCurrent(String key)

Specified by:

getCurrent in interface SerialNumberDAO

getAllCurrent

public Collection<NumberSeries> getAllCurrent()

Specified by:

getAllCurrent in interface SerialNumberDAO

initPersistence

public void initPersistence()

isOldNumerMigrationRequired

protected boolean isOldNumerMigrationRequired(de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo info)

isSchemaInitOrUpdateRequired

protected boolean isSchemaInitOrUpdateRequired(de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo info)

initTable

protected void initTable(Connection conn,
 DeploymentImpl deployments,
 ItemDeployment depl,
 de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo info)

alterSeriesTable

protected void alterSeriesTable(Connection conn,
 DeploymentImpl deployments,
 ItemDeployment depl,
 de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo info)

createSeriesTable

protected void createSeriesTable(Connection conn,
 DeploymentImpl deployments,
 ItemDeployment depl)

tryToClose

protected void tryToClose(Statement statement,
 ResultSet resultSet)

tryToClose

protected void tryToClose(Connection connection,
 Statement statement,
 ResultSet resultSet)

getTableInfo

protected de.hybris.platform.persistence.numberseries.DefaultSerialNumberDAO.TableInfo getTableInfo(Connection conn,
 String expectedName)