zhyyu opened a new issue #8560:
URL: https://github.com/apache/shardingsphere/issues/8560
## Bug Report
### Which version of ShardingSphere did you use?
```
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>sharding-jdbc-core</artifactId>
<version>4.1.1</version>
</dependency>
```
### Which project did you use? ShardingSphere-JDBC or ShardingSphere-Proxy?
- ShardingSphere-JDBC
### Expected behavior
- get complete schema data (so can use keyGenerate)
- insert row using generated key
### Actual behavior
- schema tableMeta don't have generated key (when using mysql dataSource is
ok, but h2 database wrong)
- sql exception : org.springframework.dao.DataIntegrityViolationException:
PreparedStatementCallback; SQL [insert into test_snow_flake (name) values (?)];
NULL not allowed for column "ID"; SQL statement:
### Reason analyze (If you can)
### Steps to reproduce the behavior, such as: SQL to execute, sharding rule
configuration, when exception occur etc.
- /resouces/schema.sql
```
CREATE TABLE `test_snow_flake0`
(
`id` bigint,
`name` varchar(45) NOT NULL,
PRIMARY KEY (`id`)
);
CREATE TABLE `test_snow_flake1`
(
`id` bigint,
`name` varchar(45) NOT NULL,
PRIMARY KEY (`id`)
);
```
- dataSource config
```
@Bean
public DataSource shardingJdbcSnowFlakeDataSource() throws SQLException {
// 配置真实数据源
Map<String, DataSource> dataSourceMap = new HashMap<>();
// 配置第一个数据源
// HikariDataSource dataSource1 = getMysqlDataSource();
HikariDataSource dataSource1 = getH2DataSource();
dataSourceMap.put("test_schema_1", dataSource1);
// 配置 test_snow_flake 表规则
TableRuleConfiguration testTableTableRuleConfig = new
TableRuleConfiguration("test_snow_flake","test_schema_1.test_snow_flake${0..1}");
// 自定义分片规则
StandardShardingStrategyConfiguration
standardShardingStrategyConfiguration = new
StandardShardingStrategyConfiguration("name", new PreciseShardingAlgorithm() {
@Override
public String doSharding(Collection availableTargetNames,
PreciseShardingValue shardingValue) {
String name = (String) shardingValue.getValue();
if (StringUtils.isEmpty(name)) {
return (String)
availableTargetNames.stream().findFirst().get();
}
if (name.startsWith("a")) {
return "test_snow_flake0";
}
return "test_snow_flake1";
}
});
testTableTableRuleConfig.setTableShardingStrategyConfig(standardShardingStrategyConfiguration);
// 自定义分布式主键
testTableTableRuleConfig.setKeyGeneratorConfig(new
KeyGeneratorConfiguration("SNOWFLAKE", "id"));
// 配置分片规则
ShardingRuleConfiguration shardingRuleConfig = new
ShardingRuleConfiguration();
shardingRuleConfig.getTableRuleConfigs().add(testTableTableRuleConfig);
// 获取数据源对象
Properties properties = new Properties();
properties.setProperty("sql.show", "true");
DataSource dataSource =
ShardingDataSourceFactory.createDataSource(dataSourceMap, shardingRuleConfig,
properties);
return dataSource;
}
private HikariDataSource getMysqlDataSource() {
HikariDataSource dataSource1 = new HikariDataSource();
dataSource1.setDriverClassName("com.mysql.jdbc.Driver");
dataSource1.setJdbcUrl("jdbc:mysql://localhost:3306/test_schema_1");
dataSource1.setUsername("root");
dataSource1.setPassword("xxxx");
return dataSource1;
}
private HikariDataSource getH2DataSource() {
HikariDataSource dataSource1 = new HikariDataSource();
dataSource1.setDriverClassName("org.h2.Driver");
dataSource1.setJdbcUrl("jdbc:h2:mem:test_schema_1");
dataSource1.setUsername("sa");
return dataSource1;
}
```
### 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.
For queries about this service, please contact Infrastructure at:
[email protected]
