Package me.ahoo.cosid.jdbc

Class JdbcIdSegmentDistributor

java.lang.Object

me.ahoo.cosid.segment.AbstractIdSegmentDistributor

me.ahoo.cosid.jdbc.JdbcIdSegmentDistributor

All Implemented Interfaces:

Grouped, IdSegmentDistributor

public class JdbcIdSegmentDistributor
extends AbstractIdSegmentDistributor

Jdbc IdSegment Distributor.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FETCH_MAX_ID_SQL
static final String	INCREMENT_MAX_ID_SQL

Fields inherited from interface me.ahoo.cosid.segment.IdSegmentDistributor

DEFAULT_OFFSET, DEFAULT_SEGMENTS, DEFAULT_STEP

Constructor Summary

Constructors

Constructor	Description
JdbcIdSegmentDistributor(String namespace, String name, long step, String incrementMaxIdSql, String fetchMaxIdSql, DataSource dataSource)
JdbcIdSegmentDistributor(String namespace, String name, long step, String incrementMaxIdSql, String fetchMaxIdSql, DataSource dataSource, Duration queryTimeout)	Create a JDBC segment distributor.
JdbcIdSegmentDistributor(String namespace, String name, long step, DataSource dataSource)

Method Summary

Modifier and Type	Method	Description
protected long	doNextMaxId(long step)	Ask the store for the next max id, step after the previous one.

Methods inherited from class me.ahoo.cosid.segment.AbstractIdSegmentDistributor

getLastMaxId, getName, getNamespace, getStep, nextMaxId

Methods inherited from class java.lang.Object

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

Methods inherited from interface me.ahoo.cosid.segment.grouped.Grouped

group

Methods inherited from interface me.ahoo.cosid.segment.IdSegmentDistributor

allowReset, getNamespacedName, getStep, nextIdSegment, nextIdSegment, nextIdSegment, nextIdSegmentChain, nextIdSegmentChain, nextMaxId

Field Details

INCREMENT_MAX_ID_SQL

public static final String INCREMENT_MAX_ID_SQL

See Also:

• Constant Field Values

FETCH_MAX_ID_SQL

public static final String FETCH_MAX_ID_SQL

See Also:

• Constant Field Values

Constructor Details

JdbcIdSegmentDistributor

public JdbcIdSegmentDistributor(String namespace,
 String name,
 long step,
 DataSource dataSource)

JdbcIdSegmentDistributor

public JdbcIdSegmentDistributor(String namespace,
 String name,
 long step,
 String incrementMaxIdSql,
 String fetchMaxIdSql,
 DataSource dataSource)

JdbcIdSegmentDistributor

public JdbcIdSegmentDistributor(String namespace,
 String name,
 long step,
 String incrementMaxIdSql,
 String fetchMaxIdSql,
 DataSource dataSource,
 Duration queryTimeout)

Create a JDBC segment distributor.

Parameters:

queryTimeout - timeout applied to each statement, null or zero means no timeout

Method Details

doNextMaxId

protected long doNextMaxId(long step)

Description copied from class: AbstractIdSegmentDistributor

Ask the store for the next max id, step after the previous one.

Specified by:

doNextMaxId in class AbstractIdSegmentDistributor

Parameters:

step - the step, already validated

Returns:

the new max id