直接上硬货： 项目是 maven 的 spring mvc + mybaties 项目，数据库 mysql
maven pom.xml 中添加 sharding 依赖
<!-- 引入sharding-jdbc核心模块 -->
<dependency>
<groupId>io.shardingjdbc</groupId>
<artifactId>sharding-jdbc-core</artifactId>
<version>2.0.3</version>
</dependency>
<dependency>
<groupId>io.shardingjdbc</groupId>
<artifactId>sharding-jdbc-core-spring-namespace</artifactId>
<version>2.0.3</version>
</dependency>
applicationContext.xml 中 sharding 配置如下
<!--分表策略，sharding-column 这里根据 id (这列属性不能是String,只能是整型)分表，AdminSingleKeyTableShardingAlgorithm 分表算法-->
<sharding:standard-strategy id="tableShardingStrategy" sharding-column="id"
precise-algorithm-class="com.study.algorithm.AdminSingleKeyTableShardingAlgorithm"/>
<sharding:data-source id="shardingDataSource">
<!--因为我只有一张表。所以就只需要配置一个dataSource-->
<sharding:sharding-rule data-source-names="dataSource" default-data-source-name="dataSource">
<sharding:table-rules>
<!--logic-tables逻辑表名: 逻辑表名 其实就是 sql 中 写的表名称-->
<!--actual-data-nodes真实表名-->
<sharding:table-rule logic-table="t_manager"
actual-data-nodes="dataSource.t_manager_0,dataSource.t_manager_1"
table-strategy-ref="tableShardingStrategy"/>
</sharding:table-rules>
<sharding:binding-table-rules>
<!--logic-tables逻辑表名-->
<sharding:binding-table-rule logic-tables="t_manager"/>
</sharding:binding-table-rules>
</sharding:sharding-rule>
</sharding:data-source>
全部配置文件如下
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:sharding="http://shardingjdbc.io/schema/shardingjdbc/sharding"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://shardingjdbc.io/schema/shardingjdbc/sharding
http://shardingjdbc.io/schema/shardingjdbc/sharding/sharding.xsd
">
<context:component-scan base-package="com.study.service"/>
<context:property-placeholder location="classpath:jdbc.properties" ignore-unresolvable="true"/>
<!-- dbcp数据源 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init"
destroy-method="close">
<property name="driverClassName" value="${jdbc.driver}"/>
<property name="url" value="${jdbc.url}"/>
<property name="username" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
<!-- 连接池最大使用连接数 -->
<property name="maxActive" value="50"/>
<!-- 初始化连接大小 -->
<property name="initialSize" value="5"/>
<!-- 获取连接最大等待时间 -->
<property name="maxWait" value="30000"/>
<!-- 连接池最大空闲 -->
<property name="maxPoolPreparedStatementPerConnectionSize" value="20"/>
<!-- 连接池最小空闲 -->
<property name="minIdle" value="3"/>
<!-- 自动清除无用连接 -->
<property name="removeAbandoned" value="true"/>
<!-- 清除无用连接的等待时间 -->
<property name="removeAbandonedTimeout" value="180"/>
<!-- 连接属性 -->
<property name="connectionProperties" value="clientEncoding=UTF-8"/>
<property name="filters" value="stat"/>
</bean>
<!--分表策略，sharding-column 这里根据 id (这列属性不能是String,只能是整型)分表，AdminSingleKeyTableShardingAlgorithm 分表算法-->
<sharding:standard-strategy id="tableShardingStrategy" sharding-column="id"
precise-algorithm-class="com.study.algorithm.AdminSingleKeyTableShardingAlgorithm"/>
<sharding:data-source id="shardingDataSource">
<!--因为我只有一张表。所以就只需要配置一个dataSource-->
<sharding:sharding-rule data-source-names="dataSource" default-data-source-name="dataSource">
<sharding:table-rules>
<!--logic-tables逻辑表名: 逻辑表名 其实就是 sql 中 写的表名称-->
<!--actual-data-nodes真实表名-->
<sharding:table-rule logic-table="t_manager"
actual-data-nodes="dataSource.t_manager_0,dataSource.t_manager_1"
table-strategy-ref="tableShardingStrategy"/>
</sharding:table-rules>
<sharding:binding-table-rules>
<!--logic-tables逻辑表名-->
<sharding:binding-table-rule logic-tables="t_manager"/>
</sharding:binding-table-rules>
</sharding:sharding-rule>
</sharding:data-source>
<!-- mybatis的配置文件 -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="shardingDataSource"/>
<property name="mapperLocations" value="classpath*:com/study/dao/AdminDao.xml"/>
</bean>
<!-- spring与mybatis整合配置，扫描所有dao和所有mapper文件 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.study.dao"/>
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
</bean>
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="shardingDataSource"/>
</bean>
</beans>
分表逻辑 AdminSingleKeyTableShardingAlgorithm 代码如下：
package com.study.algorithm;
import io.shardingjdbc.core.api.algorithm.sharding.PreciseShardingValue;
import io.shardingjdbc.core.api.algorithm.sharding.standard.PreciseShardingAlgorithm;
import org.apache.log4j.Logger;
import java.util.Collection;
/**
* 根据id 进行分表
*/
public class AdminSingleKeyTableShardingAlgorithm implements PreciseShardingAlgorithm<Integer> {
private Logger logger = Logger.getLogger(getClass());
public String doSharding(final Collection<String> availableTargetNames, final PreciseShardingValue<Integer> shardingValue) {
String col = shardingValue.getColumnName(); // sharding 配置的 id 名称
for (String each : availableTargetNames) { //each 为t_manager_0 t_manager_1 配置的正式的表名
int value = shardingValue.getValue(); //value 为代码中 id 的真实数据，比如 插入，id 为7,则 value 为7
if (each.endsWith(value % 2 + "")) {
return each;
}
}
throw new UnsupportedOperationException();
}
}
表结果如下：
有 两个表 t_manager_0 t_manager_1
Test 如下：
testInsert 知会 insert t_manager_1 这个表中