shardingsphere-jdbc 5.5 使用配置文件可以正常工作，但是使用API编程后报错：org.apache.shardingsphere.infra.exception.kernel.metadata.TableNotFoundException: Table or view 't_server' does not exist. #34286
Comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
配置文件
spring.datasource.driver-class-name=org.apache.shardingsphere.driver.ShardingSphereDriver
spring.datasource.url=jdbc:shardingsphere:classpath:sharding.yaml
##sharding.yaml
dataSources:
ds_11:
driverClassName: com.mysql.cj.jdbc.Driver
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
#jdbcUrl: jdbc:mysql://10.8.0.1:3381/db_assistant?useUnicode=true&charset=utf8mb4&serverTimezone=UTC&useSSL=false&useOldAliasMetadataBehavior=true
jdbcUrl: jdbc:mysql://10.8.0.1:3381/db_platform?useUnicode=true&charset=utf8mb4&useSSL=false&useOldAliasMetadataBehavior=true
username: root
password: qaz@123#PY
ds_21:
driverClassName: com.mysql.cj.jdbc.Driver
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
jdbcUrl: jdbc:mysql://10.8.0.9:3381/db_platform?useUnicode=true&charset=utf8mb4&useSSL=false&useOldAliasMetadataBehavior=true
username: root
password: qaz@123#PY
ds_31:
driverClassName: com.mysql.cj.jdbc.Driver
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
jdbcUrl: jdbc:mysql://10.8.0.13:3381/db_platform?useUnicode=true&charset=utf8mb4&useSSL=false&useOldAliasMetadataBehavior=true
username: root
password: qaz@123#PY
rules:
tables:
defaultDataSource: ds_11
dataSources:
readwrite_ds:
writeDataSourceName: ds_11
readDataSourceNames:
- ds_21
- ds_31
transactionalReadQueryStrategy: PRIMARY
loadBalancerName: random
loadBalancers:
random:
type: RANDOM
props:
sql-show: true
启动文件配置
@EntityScan(basePackages = {"com.ks.common.springboot.starter.server.entity"})
@EnableConfigurationProperties(KsDataSourceProperties.class)
@SpringBootApplication//(exclude = DataSourceAutoConfiguration.class)
public class PlatformServiceApplication {
public static void main(String[] args) {
SpringApplication.run(PlatformServiceApplication.class, args);
}
}
修改为代码方式
@component
public class DataSourceProvider {
public DataSource getDataSource() throws SQLException {
ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfig = new ReadwriteSplittingDataSourceRuleConfiguration(
"demo_read_query_ds", "demo_write_ds", Arrays.asList("demo_read_ds_0", "demo_read_ds_1"), "demo_weight_lb");
Properties algorithmProps = new Properties();
algorithmProps.setProperty("demo_read_ds_0", "2");
algorithmProps.setProperty("demo_read_ds_1", "1");
Map<String, AlgorithmConfiguration> algorithmConfigMap = new HashMap<>();
algorithmConfigMap.put("demo_weight_lb", new AlgorithmConfiguration("WEIGHT", algorithmProps));
ReadwriteSplittingRuleConfiguration ruleConfig = new ReadwriteSplittingRuleConfiguration(Collections.singleton(dataSourceConfig), algorithmConfigMap);
Properties props = new Properties();
props.setProperty("sql-show", Boolean.TRUE.toString());
return ShardingSphereDataSourceFactory.createDataSource(createDataSourceMap(), Collections.singleton(ruleConfig), props);
}
private Map<String, DataSource> createDataSourceMap() {
DataSource masterDataSource = DataSourceBuilder.create().url("jdbc:mysql://10.8.0.1:3381/db_platform").username("root").password("qaz@123#PY").build();
DataSource slaveDataSource1 = DataSourceBuilder.create().url("jdbc:mysql://10.8.0.9:3381/db_platform").username("root").password("qaz@123#PY").build();
DataSource slaveDataSource2 = DataSourceBuilder.create().url("jdbc:mysql://10.8.0.13:3381/db_platform").username("root").password("qaz@123#PY").build();
}
@configuration
public class ShardingSphereConfig {
private static final Logger logger = LoggerFactory.getLogger(ShardingSphereConfig.class);
}
同时修改启动文件
@EntityScan(basePackages = {"com.ks.common.springboot.starter.server.entity"})
@EnableConfigurationProperties(KsDataSourceProperties.class)
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
public class PlatformServiceApplication {
public static void main(String[] args) {
SpringApplication.run(PlatformServiceApplication.class, args);
}
}
测试报错
2025-01-08 23:32:28 DEBUG [main] org.hibernate.SQL select t1_0.id,t1_0.create_time,t1_0.create_user,t1_0.db,t1_0.driver_class_name,t1_0.
host,t1_0.key,t1_0.password,t1_0.port,t1_0.role,t1_0.service,t1_0.state,t1_0.type,t1_0.update_time,t1_0.update_user,t1_0.user,t1_0.version from t_server t1_0 where t1_0.id=?org.apache.shardingsphere.infra.exception.kernel.metadata.TableNotFoundException: Table or view 't_server' does not exist.
The text was updated successfully, but these errors were encountered: