sharding-sphere 3.1.0 的簡單使用

最開始倒騰sharding-sphere的時候，在網上找了半天，下了源碼看了半天（想用@Configuration 注解的方式，而不是去寫配置文件，我覺得配置文件太多了，弄的晃眼），也沒有弄明白個所以然。

后面直接在官網找到了比較齊全的答案，我最開始還以為必須要配置配置文件啥的，其實完全不需要。

這個是官網地址：https://shardingsphere.apache.org/document/current/cn/manual/sharding-jdbc/configuration/config-java/

下面這個是我們系統的一些配置:由於我們系統小，所以只用到了分表，沒有用到分庫和分片和主從，但是配置這些也很容易。

import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;

import javax.sql.DataSource;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import com.oftoo.datasource.config.DynamicDataSource;
import com.oftoo.datasource.database.IPKeyGenerator;
import com.oftoo.datasource.database.TimeShardingTableAlgorithm;

import io.shardingsphere.api.config.rule.ShardingRuleConfiguration;
import io.shardingsphere.api.config.rule.TableRuleConfiguration;
import io.shardingsphere.api.config.strategy.StandardShardingStrategyConfiguration;
import io.shardingsphere.shardingjdbc.api.ShardingDataSourceFactory;

@Configuration
public class DataSourceConfig {

    @Autowired
    DynamicDataSource datasource;

    @Bean(name = "shardingDataSource")
    @Primary
    DataSource getShardingDataSource() throws SQLException {
        ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();
        shardingRuleConfig.getTableRuleConfigs().add(getTestTableRuleConfiguration()); // 如果有多個表，可以用逗號“,”分隔 ，比如user_info,
        //shardingRuleConfig.getTableRuleConfigs().add(getTerminalRecordTableRuleConfiguration());
        shardingRuleConfig.getBindingTableGroups().add("tb_user,t_terminal_record");
        // 設置分片策略，自定義算法來實現分片規則 //shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new
        // StandardShardingStrategyConfiguration("user_id", new DemoDatabaseShardingAlgorithm()));
        shardingRuleConfig.setDefaultTableShardingStrategyConfig(//
                new StandardShardingStrategyConfiguration("user_id", new TimeShardingTableAlgorithm()));

        return ShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, //
                new ConcurrentHashMap(), new Properties());
    }

    /**
     * 配置表規則
     * 
     * @return
     */
    TableRuleConfiguration getTestTableRuleConfiguration() {
        TableRuleConfiguration test = new TableRuleConfiguration(); // 配置表名
        test.setLogicTable("tb_user"); // 配置真實的數據節點，即數據庫中真實存在的節點，由數據源名 + 表名組成
        test.setActualDataNodes("ds_0.tb_user_${0..1}");// user_${0..1}分庫，user_info_${0..1}分表
        // 主鍵生成列，默認的主鍵生成算法是snowflake
        test.setKeyGeneratorColumnName("user_id");
        IPKeyGenerator.initWorkerId();
        return test;
    }

    /**
     * 創建數據源
     * 
     * @return
     */
    private Map<String, DataSource> createDataSourceMap() {
        Map<String, DataSource> result = new HashMap<>();
        result.put("ds_0", datasource);
        return result;
    }


}

maven：

        <dependency>
            <groupId>io.shardingsphere</groupId>
            <artifactId>sharding-jdbc-core</artifactId>
            <version>3.1.0</version>
        </dependency>

TimeShardingTableAlgorithm這個類我復制的另外一個人寫的，

ParaseShardingKeyTool.getYearAndMonth(shardingValue.getValue())這個只是獲取到了日期如：201808（這個就是表名）

import java.util.Collection;

import com.oftoo.common.utils.ParaseShardingKeyTool;

import io.shardingsphere.api.algorithm.sharding.PreciseShardingValue;
import io.shardingsphere.api.algorithm.sharding.standard.PreciseShardingAlgorithm;

public class TimeShardingTableAlgorithm implements PreciseShardingAlgorithm<Long> {
    @Override
    public String doSharding(Collection<String> availableTargetNames, PreciseShardingValue<Long> shardingValue) {
        StringBuffer tableName = new StringBuffer();
        tableName.append(shardingValue.getLogicTableName()).append("_").append(ParaseShardingKeyTool.getYearAndMonth(shardingValue.getValue()));

        return tableName.toString();
    }
}

這個是我數據庫的表名，里面的字段很簡單，就一個user_id 和name，我們這邊用的是spring +mybatis 。