public class SequenceService extends AbstractService implements ISequenceService
log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
SequenceService(IParameterService parameterService,
ISymmetricDialect symmetricDialect) |
| 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) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdspublic SequenceService(IParameterService parameterService, ISymmetricDialect symmetricDialect)
public void init()
init in interface ISequenceServicepublic long nextVal(java.lang.String name)
nextVal in interface ISequenceServicepublic long nextVal(org.jumpmind.db.sql.ISqlTransaction transaction,
java.lang.String name)
nextVal in interface ISequenceServiceprotected long nextValFromCache(org.jumpmind.db.sql.ISqlTransaction transaction,
java.lang.String name)
protected long nextValFromDatabase(java.lang.String name,
long size)
protected long nextValFromDatabase(org.jumpmind.db.sql.ISqlTransaction transaction,
java.lang.String name,
long size)
protected long tryToGetNextVal(org.jumpmind.db.sql.ISqlTransaction transaction,
java.lang.String name,
long size)
public long nextRange(org.jumpmind.db.sql.ISqlTransaction transaction,
java.lang.String name,
long size)
nextRange in interface ISequenceServicename - Sequence name to usesize - Number of sequence numbers to obtainpublic long nextRange(java.lang.String name,
long size)
nextRange in interface ISequenceServiceprotected Sequence getSequenceDefinition(java.lang.String name)
protected Sequence getSequenceDefinition(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name)
public long currVal(org.jumpmind.db.sql.ISqlTransaction transaction,
java.lang.String name)
currVal in interface ISequenceServicepublic long currVal(java.lang.String name)
currVal in interface ISequenceServicepublic void create(Sequence sequence)
create in interface ISequenceServiceprotected Sequence get(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String name)
protected java.util.Map<java.lang.String,Sequence> getAll()