gaolove opened a new issue, #28994:
URL: https://github.com/apache/shardingsphere/issues/28994
## Bug Report
### Which version of ShardingSphere did you use?
```
<groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-jdbc-core</artifactId>
<version>5.4.1</version>
```
### Which project did you use? ShardingSphere-JDBC or ShardingSphere-Proxy?
ShardingSphere-JDBC
### Expected behavior
Correct routing to the correct shard table
### Actual behavior
Occasionally the wrong routing rule is used, most of the time it's normal
```
2023-11-09 17:03:05,188 [WARN ] [SqlExceptionHelper.java:145]
[http-nio-8004-exec-2] SQL Error: 20081, SQLState: HY000
2023-11-09 17:03:05,193 [ERROR] [SqlExceptionHelper.java:150]
[http-nio-8004-exec-2] Routed target `zta_execution_detail_19` does not exist,
available targets are `[zta_execution_0, ..., zta_execution_127]`.
```
### Reason analyze (If you can)
### Steps to reproduce the behavior, such as: SQL to execute, sharding rule
configuration, when exception occur etc.
This is my configuration class.
```java
@Configuration
@Order(Ordered.HIGHEST_PRECEDENCE)
public class ShardingsphereConfig {
@Value("${spring.shardingsphere.datasource.testing-platform.jdbc-url}")
private String jdbcUrl;
@Value("${spring.shardingsphere.datasource.testing-platform.username}")
private String userName;
@Value("${spring.shardingsphere.datasource.testing-platform.password}")
private String password;
@Bean
@Primary
public DataSource dataSource() throws SQLException,
NoSuchFieldException, IllegalAccessException {
return
ShardingSphereDataSourceFactory.createDataSource(createModeConfiguration(),
createDataSourceMap(), createRuleConfiguration(), createProperties());
}
private ModeConfiguration createModeConfiguration() {
return new ModeConfiguration("Standalone", new
StandalonePersistRepositoryConfiguration("JDBC", new Properties()));
}
private Map<String, DataSource> createDataSourceMap() {
Map<String, DataSource> result = new LinkedHashMap<>();
result.put("testing_platform", createDataSource());
return result;
}
private DataSource createDataSource() {
HikariDataSource dataSource = new HikariDataSource();
dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
dataSource.setJdbcUrl(jdbcUrl);
dataSource.setUsername(userName);
dataSource.setPassword(password);
dataSource.setMaximumPoolSize(10);
dataSource.setConnectionTimeout(300000);
return dataSource;
}
private Collection<RuleConfiguration> createRuleConfiguration() {
Collection<RuleConfiguration> result = new LinkedList<>();
result.add(createShardingRuleConfiguration());
result.add(createSingleRuleConfiguration());
return result;
}
private ShardingRuleConfiguration createShardingRuleConfiguration() {
ShardingRuleConfiguration result = new ShardingRuleConfiguration();
result.getTables().add(getExecutionTableRuleConfiguration());
result.getTables().add(getDetailTableRuleConfiguration());
result.setDefaultDatabaseShardingStrategy(new
NoneShardingStrategyConfiguration());
result.getKeyGenerators().put("snowflake", new
AlgorithmConfiguration("SNOWFLAKE", new Properties()));
Properties executionProps = new Properties();
executionProps.setProperty("algorithm-expression",
"zta_execution_$->{job_id % 128}");
result.getShardingAlgorithms().put("execution-inline", new
AlgorithmConfiguration("INLINE", executionProps));
Properties detailProps = new Properties();
detailProps.setProperty("algorithm-expression",
"zta_execution_detail_$->{job_id % 512}");
result.getShardingAlgorithms().put("detail-inline", new
AlgorithmConfiguration("INLINE", detailProps));
return result;
}
private SingleRuleConfiguration createSingleRuleConfiguration() {
return new SingleRuleConfiguration(Collections.singleton("*.*"),
"testing_platform");
}
private ShardingTableRuleConfiguration
getExecutionTableRuleConfiguration() {
ShardingTableRuleConfiguration result = new
ShardingTableRuleConfiguration("zta_execution",
"testing_platform.zta_execution_$->{0..127}");
result.setKeyGenerateStrategy(new
KeyGenerateStrategyConfiguration("id", "snowflake"));
result.setTableShardingStrategy(new
StandardShardingStrategyConfiguration("job_id", "execution-inline"));
return result;
}
private ShardingTableRuleConfiguration getDetailTableRuleConfiguration()
{
ShardingTableRuleConfiguration result = new
ShardingTableRuleConfiguration("zta_execution_detail",
"testing_platform.zta_execution_detail_$->{0..511}");
result.setKeyGenerateStrategy(new
KeyGenerateStrategyConfiguration("id", "snowflake"));
result.setTableShardingStrategy(new
StandardShardingStrategyConfiguration("job_id", "detail-inline"));
return result;
}
private Properties createProperties() {
Properties result = new Properties();
return result;
}
}
```
Maybe it's related to concurrency? Or do I need to modify my configuration?
### Example codes for reproduce this issue (such as a github link).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
