org.tinygroup.sequence.impl

Class SequenceDataSourceHolder

java.lang.Object

org.tinygroup.sequence.impl.SequenceDataSourceHolder

public class SequenceDataSourceHolder
extends Object

高可用sequence 所使用的数据源的包装类, 可是实现对sequence故障数据源的踢出和恢复

Version:

$Id: SequenceDataSource.java, v 0.1 2011-12-22 下午04:46:44 zhaofeng.wang Exp $

Author:

zhaofeng.wang

Constructor Summary

Constructors

Constructor and Description
SequenceDataSourceHolder(DataSource ds) 构造函数

Method Summary

Modifier and Type	Method and Description
Map<String,Map<String,Object>>	getAllSequenceRecordName(String selectSql, String nameColumn, String minValueColumnName, String maxValueColumnName, String innerStepColumnName) 获取当前db里所有的sequence记录的指定字段值
DataSource	getDs()
Map<String,Map<String,Object>>	getSequenceRecordByName(String selectSql, String minValueColumnName, String maxValueColumnName, String innerStepColumnName, String sequenceName) 根据sequenceName 获取当前db里的指定sequence记录的各字段值
void	initSequenceRecord(int index, String sequenceName, int innerStep, int outStep, long minValue, long maxValue, String valueColumnName) 初始化sequence 记录，如果db里存在该记录就跳过；否则对此进行初始化
void	setParameters(String tableName, String selectSql, String updateSql, String insertSql, boolean adjust) 设置常用的参数
SequenceRange	tryOnAvailableDataSource(int index, String sequenceName, long minValue, long maxValue, int innerStep, int outStep, List<Integer> excludeIndexes) 在可用的数据源上获取sequence段，如果发生异常，则进行统计
SequenceRange	tryOnFailedDataSource(int index, String sequenceName, long minValue, long maxValue, int innerStep, int outStep, List<Integer> excludeIndexes) 在故障的数据源上进行单线程重试，每隔2s允许一个业务单线程进入重试状态, 如果访问成功则标记该数据源为可用，否则去寻找其他可用数据源。 采用的是非阻塞锁实现的并发控制。
SequenceRange	tryOnSelectedDataSource(int index, String sequenceName, long minValue, long maxValue, int innerStep, int outStep, List<Integer> excludeIndexes) 在随机选择的数据源上获取sequence段
boolean	tryToConnectDataBase(int dbIndex) 在单线程重试的时候，取到连接后真正和数据库建立连接；

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceDataSourceHolder

public SequenceDataSourceHolder(DataSource ds)

构造函数

Parameters:

ds -

Method Detail

setParameters

public void setParameters(String tableName,
                          String selectSql,
                          String updateSql,
                          String insertSql,
                          boolean adjust)

设置常用的参数

Parameters:

tableName - 表名

selectSql - select的sql语句

updateSql - 更新语句

insertSql - 插入语句

adjust - 是否开启自动调整开关

getDs

public DataSource getDs()

tryOnSelectedDataSource

public SequenceRange tryOnSelectedDataSource(int index,
                                             String sequenceName,
                                             long minValue,
                                             long maxValue,
                                             int innerStep,
                                             int outStep,
                                             List<Integer> excludeIndexes)
                                      throws SequenceException

在随机选择的数据源上获取sequence段

Parameters:

index - 数据源序列号

sequenceName - sequence名

minValue - 最小值

maxValue - 最大值

innerStep - 内步长

outStep - 外步长

excludeIndexes - 记录单次内已经故障的数据源

Returns:

可用的sequence段

Throws:

SequenceException

tryOnAvailableDataSource

public SequenceRange tryOnAvailableDataSource(int index,
                                              String sequenceName,
                                              long minValue,
                                              long maxValue,
                                              int innerStep,
                                              int outStep,
                                              List<Integer> excludeIndexes)
                                       throws SequenceException

在可用的数据源上获取sequence段，如果发生异常，则进行统计

Parameters:

index - 数据源序列号

sequenceName - sequence名称

minValue - 最小值

maxValue - 最大值

innerStep - 内步长

outStep - 外步长

excludeIndexes - 记录单次内已经故障的数据源

Returns:

sequence段

Throws:

SequenceException

getAllSequenceRecordName

public Map<String,Map<String,Object>> getAllSequenceRecordName(String selectSql,
                                                               String nameColumn,
                                                               String minValueColumnName,
                                                               String maxValueColumnName,
                                                               String innerStepColumnName)
                                                        throws SQLException

获取当前db里所有的sequence记录的指定字段值

Parameters:

selectSql - ：select name,min_value,max_value,step from table_name(default:sequence)

nameColumn - sequence列名

minValueColumnName - 最小值

maxValueColumnName - 最大值

innerStepColumnName - 内步长

Returns:

Map> 外层key标识sequence名字，内层key表示最小、最大值以及步长等；

Throws:

SQLException

getSequenceRecordByName

public Map<String,Map<String,Object>> getSequenceRecordByName(String selectSql,
                                                              String minValueColumnName,
                                                              String maxValueColumnName,
                                                              String innerStepColumnName,
                                                              String sequenceName)
                                                       throws SQLException,
                                                              SequenceException

根据sequenceName 获取当前db里的指定sequence记录的各字段值

Parameters:

selectSql - : select value,min_value,max_value,step from sequence where name=?

nameColumn - sequence列名

minValueColumnName - 最小值

maxValueColumnName - 最大值

innerStepColumnName - 内步长

Returns:

Throws:

SQLException

SequenceException

tryToConnectDataBase

public boolean tryToConnectDataBase(int dbIndex)

在单线程重试的时候，取到连接后真正和数据库建立连接；

Parameters:

dbIndex -

Returns:

tryOnFailedDataSource

public SequenceRange tryOnFailedDataSource(int index,
                                           String sequenceName,
                                           long minValue,
                                           long maxValue,
                                           int innerStep,
                                           int outStep,
                                           List<Integer> excludeIndexes)

在故障的数据源上进行单线程重试，每隔2s允许一个业务单线程进入重试状态, 如果访问成功则标记该数据源为可用，否则去寻找其他可用数据源。
采用的是非阻塞锁实现的并发控制。

Parameters:

index - 数据源标号

sequenceName - sequence名称

minValue - 最小值

maxValue - 最大值

innerStep - 内步长

outStep - 外步长

excludeIndexes - 单次查询db排除掉的故障数据源标识集合

Returns:

initSequenceRecord

public void initSequenceRecord(int index,
                               String sequenceName,
                               int innerStep,
                               int outStep,
                               long minValue,
                               long maxValue,
                               String valueColumnName)
                        throws SequenceException

初始化sequence 记录，如果db里存在该记录就跳过；否则对此进行初始化

Parameters:

index - db标识

sequenceName - sequence名称

innerStep - 内步长

outStep - 外步长

minValue - 最小值

maxValue - 最大值

valueColumnName - 值列名

Throws:

SequenceException