org.jumpmind.symmetric.service.impl

Class SequenceService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.SequenceService

All Implemented Interfaces:

ISequenceService, IService

public class SequenceService
extends AbstractService
implements ISequenceService

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
SequenceService(IParameterService parameterService, ISymmetricDialect symmetricDialect)

Method Summary

Modifier and Type	Method and Description
void	create(Sequence sequence)
long	currVal(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name)
long	currVal(java.lang.String name)
protected Sequence	get(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name)
protected java.util.Map<java.lang.String,Sequence>	getAll()
protected Sequence	getSequenceDefinition(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name)
protected Sequence	getSequenceDefinition(java.lang.String name)
void	init()
long	nextRange(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name, long size) Obtain a contiguous range of sequence numbers.
long	nextRange(java.lang.String name, long size)
long	nextVal(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name)
long	nextVal(java.lang.String name)
protected long	nextValFromCache(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name)
protected long	nextValFromDatabase(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name, long size)
protected long	nextValFromDatabase(java.lang.String name, long size)
protected long	tryToGetNextVal(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name, long size)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceService

public SequenceService(IParameterService parameterService,
                       ISymmetricDialect symmetricDialect)

Method Detail

init

public void init()

Specified by:

init in interface ISequenceService

nextVal

public long nextVal(java.lang.String name)

Specified by:

nextVal in interface ISequenceService

nextVal

public long nextVal(org.jumpmind.db.sql.ISqlTransaction transaction,
                    java.lang.String name)

Specified by:

nextVal in interface ISequenceService

nextValFromCache

protected long nextValFromCache(org.jumpmind.db.sql.ISqlTransaction transaction,
                                java.lang.String name)

nextValFromDatabase

protected long nextValFromDatabase(java.lang.String name,
                                   long size)

nextValFromDatabase

protected long nextValFromDatabase(org.jumpmind.db.sql.ISqlTransaction transaction,
                                   java.lang.String name,
                                   long size)

tryToGetNextVal

protected long tryToGetNextVal(org.jumpmind.db.sql.ISqlTransaction transaction,
                               java.lang.String name,
                               long size)

nextRange

public long nextRange(org.jumpmind.db.sql.ISqlTransaction transaction,
                      java.lang.String name,
                      long size)

Obtain a contiguous range of sequence numbers. The initial load extract in background needs an uninterrupted range of batch numbers. As a bonus, it's more efficient to request the entire range in one call.

Specified by:

nextRange in interface ISequenceService

Parameters:

name - Sequence name to use

size - Number of sequence numbers to obtain

Returns:

Starting sequence number for the entire range that was obtained

nextRange

public long nextRange(java.lang.String name,
                      long size)

Specified by:

nextRange in interface ISequenceService

getSequenceDefinition

protected Sequence getSequenceDefinition(java.lang.String name)

getSequenceDefinition

protected Sequence getSequenceDefinition(org.jumpmind.db.sql.ISqlTransaction transaction,
                                         java.lang.String name)

currVal

public long currVal(org.jumpmind.db.sql.ISqlTransaction transaction,
                    java.lang.String name)

Specified by:

currVal in interface ISequenceService

currVal

public long currVal(java.lang.String name)

Specified by:

currVal in interface ISequenceService

create

public void create(Sequence sequence)

Specified by:

create in interface ISequenceService

get

protected Sequence get(org.jumpmind.db.sql.ISqlTransaction transaction,
                       java.lang.String name)

getAll

protected java.util.Map<java.lang.String,Sequence> getAll()