DishJi
commented
3 years ago sharding algorithm code
`public class UserRecordShardingAlgorithm implements StandardShardingAlgorithm
private UserService userService = null;
private static final String REFER = "2019-01-02";
private boolean allowRangeQuery;
private Properties props = new Properties();
private boolean isAllowRangeQuery() {
return Boolean.parseBoolean(this.props.getOrDefault("allow-range-query-with-record-sharding", Boolean.FALSE.toString()).toString());
}
@Override
public Collection<String> doSharding(Collection<String> collection, RangeShardingValue<Integer> rangeShardingValue) {
if (this.allowRangeQuery) {
return collection;
} else {
throw new UnsupportedOperationException("Since the property of `allow-range-query-with-user_record-sharding` is false, inline sharding algorithm can not tackle with range query.");
}
}
@SneakyThrows
@Override
public String doSharding(Collection<String> collection, PreciseShardingValue<Integer> preciseShardingValue){
//collection:["t_order_1","t_order_2"],preciseShardingValue:{"logicTableName":"t_order","columnName":"order_id","value":396416249350848512}
//name为两张订单表 t_order_1 和 t_order_2
if(null == userService){
synchronized (UserRecordShardingAlgorithm.class){
if(null == userService){
userService = (UserService) SpringTools.getBeanByClass(UserServiceImpl.class);
}
}
}
String tableName = preciseShardingValue.getLogicTableName();
int userId = preciseShardingValue.getValue();
User user = userService.queryById(userId);
Date loginTime = user.getLogintime();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
//参考时间
Date referTime = sdf.parse(REFER);
if (loginTime.after(referTime)) {
Calendar loginCal = Calendar.getInstance();
//设置登陆时间
loginCal.setTime(loginTime);
//获取登陆年份
int year = loginCal.get(Calendar.YEAR);
StringBuilder sb = new StringBuilder(tableName);
sb.append("_");
sb.append(year);
return sb.toString();
}
return tableName;
}
@Override
public void init() {
this.allowRangeQuery = this.isAllowRangeQuery();
}
@Override
public String getType() {
return "UserRecordShardingAlgorithm";
}
@Override
public Properties getProps() {
return props;
}
@Override
public void setProps(Properties props) {
this.props = props;
}}`
terrymanu
luckleemon
yu199195
Question Caused by: org.springframework.boot.context.properties.source.InvalidConfigurationPropertyNameException: Configuration property name 'spring.shardingsphere.rules.sharding.sharding-algorithms.user_record_standard.props' is not valid
Version Springboot2.2.9 | mybatis-plus| shardingsphere-jdbc-core-spring-boot-starter 5.0.0-alpha
Config
Exception