ShardingJDBC有哪些能力？如何使用的？

**ShardingJDBC** 是一款轻量级的分布式数据库中间件，提供分库分表、读写分离、分布式事务等功能，支持多种数据库（如 MySQL、PostgreSQL、Oracle 等）。ShardingJDBC 以 JDBC 驱动的形式接入应用程序，透明地实现分布式数据库能力。 ### **1. 分库分表** #### **功能** - 分库：将数据水平拆分到多个数据库实例中。 - 分表：将数据水平拆分到同一个数据库的多个表中。 - 动态路由：根据分片键将请求路由到正确的数据库和表。 #### **使用方式** 1. **配置分片规则** 在 `sharding-jdbc` 中通过配置 `ShardingRuleConfiguration` 来定义分库分表规则。 ```yaml sharding: tables: user: actual-data-nodes: ds$->{0..1}.user$->{0..1} table-strategy: inline: sharding-column: user_id algorithm-expression: user$->{user_id % 2} database-strategy: inline: sharding-column: user_id algorithm-expression: ds$->{user_id % 2} ``` 2. **SQL 示例** 使用原生 SQL，无需修改： ```sql SELECT * FROM user WHERE user_id = 123; INSERT INTO user (user_id, name) VALUES (123, 'Alice'); ``` 3. **自动路由** - 查询：`user_id = 123` 将路由到具体的库和表，例如 `ds0.user1`。 - 插入：数据根据分片规则写入正确的目标表。 ### **2. 读写分离** #### **功能** - 实现主从分离，将写操作路由到主库，读操作路由到从库，支持负载均衡。 #### **使用方式** 1. **配置读写分离规则** 在配置中指定主从数据源关系及负载均衡策略。 ```yaml master-slave: data-sources: ds: master-data-source-name: master_ds slave-data-source-names: slave_ds_0, slave_ds_1 load-balance-algorithm-type: round_robin ``` 2. **SQL 示例** - 写操作：`INSERT INTO user (user_id, name) VALUES (123, 'Alice');` 路由到主库。 - 读操作：`SELECT * FROM user WHERE user_id = 123;` 路由到从库，根据负载均衡策略分配具体的从库。 3. **负载均衡策略** - 支持多种策略，如轮询（`round_robin`）、随机（`random`）。 ### **3. 分布式事务** #### **功能** - 支持两阶段提交（XA事务）和最佳努力送达型事务，确保分布式数据库的事务一致性。 #### **使用方式** 1. **配置事务管理器** 引入 ShardingSphere 事务管理组件，支持以下事务类型： - XA 事务：强一致性事务。 - 柔性事务：最终一致性事务。 2. **XA 事务示例** ```java @Transactional public void transactionalOperation() { jdbcTemplate.update("INSERT INTO user (user_id, name) VALUES (?, ?)", 1, "Alice"); jdbcTemplate.update("INSERT INTO order (order_id, user_id) VALUES (?, ?)", 1, 1); } ``` 3. **最佳努力送达型事务** - 通过日志记录失败的事务重试，确保最终一致性。 ### **4. 数据脱敏** #### **功能** - 对特定字段（如身份证号、银行卡号）进行脱敏操作，保护敏感数据。 #### **使用方式** 1. **配置脱敏规则** ```yaml encrypt: encryptors: aes_encryptor: type: AES props: aes.key.value: 1234567890123456 tables: user: columns: phone: plainColumn: phone_plain cipherColumn: phone_cipher encryptor: aes_encryptor ``` 2. **SQL 示例** - 插入：`INSERT INTO user (phone_plain) VALUES ('13800138000');` - 查询：`SELECT phone_plain FROM user;` 3. **效果** - 数据库存储加密后的 `phone_cipher` 字段。 - 应用程序查询时自动解密。 ### **5. 数据分片算法** #### **功能** - 支持多种分片算法： - **标准分片算法**：按单一字段分片。 - **复合分片算法**：按多个字段分片。 - **Hint 分片算法**：通过程序指定分片策略。 #### **使用方式** 1. **标准分片算法** ```java public class ModuloShardingAlgorithm implements StandardShardingAlgorithm<Integer> { @Override public String doSharding(Collection<String> availableTargetNames, PreciseShardingValue<Integer> shardingValue) { int shard = shardingValue.getValue() % availableTargetNames.size(); return availableTargetNames.stream().skip(shard).findFirst().orElseThrow(); } } ``` 2. **配置自定义分片算法** ```yaml sharding: tables: user: actual-data-nodes: ds$->{0..1}.user$->{0..1} table-strategy: standard: sharding-column: user_id sharding-algorithm-name: custom_algorithm sharding-algorithms: custom_algorithm: type: CLASS_BASED props: strategy.class.name: com.example.ModuloShardingAlgorithm ``` ### **6. 异构数据库联合查询** #### **功能** - 支持多种数据库的联合查询（如 MySQL 与 PostgreSQL），实现跨库数据分析。 #### **使用方式** 1. **配置多数据源** ```yaml data-sources: ds_0: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/db0 username: root password: root ds_1: type: org.postgresql.ds.PGSimpleDataSource jdbc-url: jdbc:postgresql://localhost:5432/db1 username: root password: root ``` 2. **SQL 示例** ```sql SELECT a.id, b.name FROM db0.user a JOIN db1.department b ON a.department_id = b.id; ``` ### **总结** ShardingJDBC 提供以下核心能力及其适用场景： | **功能** | **描述** | **适用场景** | |-------------------|---------------------------------------------------------------------------------------------|--------------------------------------------------------------------------------------------------| | **分库分表** | 将数据拆分到多个数据库或表中，并自动路由请求到正确的目标库/表。 | 数据量大，需要通过水平拆分提高性能的场景。 | | **读写分离** | 实现主从分离，将读操作分配到从库，支持负载均衡。 | 写入压力较大，需通过主从复制分摊读压力的场景。 | | **分布式事务** | 支持强一致性（XA事务）和最终一致性事务。 | 需要分布式事务保障的数据一致性场景。 | | **数据脱敏** | 对敏感数据（如手机号、身份证号）加密，提供解密支持。 | 对数据隐私要求高的场景，如金融系统、用户数据管理等。 | | **分片算法支持** | 提供标准、自定义、复合和 Hint 分片算法，灵活支持多样化分片需求。 | 分片逻辑复杂，需要自定义分片逻辑的场景。 | | **异构数据库联合查询** | 支持不同数据库的联合查询，提供透明化访问。 | 数据分散在多个异构数据库中，需统一查询分析的场景。 | 通过配置 ShardingJDBC，可以在代码透明的情况下轻松实现分布式数据库的管理和优化。