ShardingSphere-JDBC是ShardingSphere提供的一个组件，用于实现数据库的读写分离功能。
详细实现步骤如下：
1. 添加ShardingSphere-JDBC的依赖
在项目的pom.xml文件中添加ShardingSphere-JDBC的依赖。
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>sharding-jdbc-core</artifactId>
<version>5.0.0</version>
</dependency>
2. 配置数据源和分片规则
在项目中配置数据源和分片规则，指定主库和从库的信息，以及读写分离的策略。
spring:
sharding:
jdbc:
datasource:
names: ds_master, ds_slave
ds_master:
url: jdbc:mysql://localhost:3306/master
username: root
password: root
ds_slave:
url: jdbc:mysql://localhost:3306/slave
username: root
password: root
config:
masterslave:
name: ms
load-balance-algorithm-type: round_robin
master-data-source-name: ds_master
slave-data-source-names: ds_slave
3. 编写业务代码
在业务代码中使用ShardingSphere-JDBC的数据源来操作数据库，ShardingSphere会根据配置的规则自动路由读写操作到主库或从库。
@Repository
public class UserRepository {
@Autowired
private DataSource dataSource;
public User findById(Long id) {
try (Connection connection = dataSource.getConnection();
PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM user WHERE id = ?")) {
preparedStatement.setLong(1, id);
try (ResultSet resultSet = preparedStatement.executeQuery()) {
if (resultSet.next()) {
return new User(resultSet.getLong("id"), resultSet.getString("name"));
}
}
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
}
通过以上步骤，可以实现使用ShardingSphere-JDBC实现数据库的读写分离功能。在业务代码中无需关心具体的数据源和分片规则，ShardingSphere会根据配置自动进行读写操作的路由。
原文链接: https://blog.csdn.net/2401_82884096/article/details/138488690