qinfengge

        <!-- druid -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.22</version>
        </dependency>
        <!--mysqlドライバ-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
            <version>8.0.23</version>
        </dependency>
        <!--mybatis-plus-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.3.1</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.3</version>
        </dependency>
        <!-- sharding-jdbc 分庫分表依存関係-->
        <dependency>
            <groupId>org.apache.shardingsphere</groupId>
            <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
            <version>4.1.1</version>
        </dependency>

#以下の設定を追加してbean名のオーバーライドを許可する必要があります。これは後のSQLのテーブル操作に主に使用されます。MybatisPlusはクラス名をテーブル名として使用します。
spring.main.allow-bean-definition-overriding=true

#シャーディング戦略、複数のデータソースはカンマで区切ります。例: ds0,ds1
spring.shardingsphere.datasource.names=ds0

#データソースの内容を設定します。以下のds0は上記で設定したものと同名である必要があります。
spring.shardingsphere.datasource.ds0.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.ds0.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.ds0.url=jdbc:mysql://localhost:3306/jk_test?useUnicode=true&characterEncoding=utf-8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&allowPublicKeyRetrieval=true&useSSL=false&serverTimezone=GMT%2B8
spring.shardingsphere.datasource.ds0.username=root
spring.shardingsphere.datasource.ds0.password=root

#テーブルの位置はどのデータソース（データベース）のどのテーブルにあるかです。以下のtables.inspection_resultのinspection_resultはテーブル名の接頭辞です。
#分表を指定するテーブルを設定します。ここではinspection_resultとinspection_result_homeの2つのテーブルを指定しました。
spring.shardingsphere.sharding.tables.inspection_result.actual-data-nodes=ds0.inspection_result, ds0.inspection_result_home

#inspection_resultテーブル内の主キーcidの生成戦略を指定します。SNOWFLAKEは雪花アルゴリズムです。
#spring.shardingsphere.sharding.tables.course.key-generator.column=cid
#spring.shardingsphere.sharding.tables.course.key-generator.type=SNOWFLAKE

#テーブルのシャーディング戦略
spring.shardingsphere.sharding.tables.inspection_result.table-strategy.standard.sharding-column=id
#ビジネスに基づく分表であり、ここではカスタムの分表戦略です。
spring.shardingsphere.sharding.tables.inspection_result.table-strategy.standard.precise-algorithm-class-name=com.jkkj.config.ResultPreciseShardingAlgorithm

#SQL出力ログを有効にします。
spring.shardingsphere.props.sql.show=true

public class ResultPreciseShardingAlgorithm implements PreciseShardingAlgorithm<Long> {
    @Override
    public String doSharding(Collection<String> collection, PreciseShardingValue<Long> preciseShardingValue) {
        Long id = preciseShardingValue.getValue();
        if (id < 8000000) {
            return "inspection_result";
        } else {
            return "inspection_result_home";
        }
    }
}

#テーブルのシャーディング戦略
spring.shardingsphere.sharding.tables.inspection_result.table-strategy.standard.sharding-column=id
#ビジネスに基づく分表であり、ここではカスタムの分表戦略です。
# standard.precise-algorithm 標準戦略下のシャーディングアルゴリズムには2つのprecise + rangeが含まれます。rangeはオプションですが、rangeを使用する場合はpreciseと一緒に使用する必要があります。
# 精密シャーディングアルゴリズムクラス名、=およびINに使用されます。
spring.shardingsphere.sharding.tables.inspection_result.table-strategy.standard.precise-algorithm-class-name=com.jkkj.config.ResultPreciseShardingAlgorithm
# 範囲シャーディングアルゴリズムクラス名、BETWEENに使用され、<、<=、>、>=をサポートします。
spring.shardingsphere.sharding.tables.inspection_result.table-strategy.standard.range-algorithm-class-name=com.jkkj.config.ResultPreciseShardingAlgorithm

public class ResultPreciseShardingAlgorithm implements PreciseShardingAlgorithm<Integer>, RangeShardingAlgorithm<Integer> {

    @Override
    public String doSharding(Collection<String> collection, PreciseShardingValue<Integer> preciseShardingValue) {
        try {
            Integer id = preciseShardingValue.getValue();
            if (id < 8000000) {
                return "inspection_result";
            } else {
                return "inspection_result_home";
            }
        } catch (NumberFormatException e) {
            log.error("分表時にid変換異常が発生しました");
            throw new RuntimeException(e);
        }
    }

    @Override
    public Collection<String> doSharding(Collection<String> collection, RangeShardingValue<Integer> rangeShardingValue) {
        Range<Integer> valueRange = rangeShardingValue.getValueRange();
//        Integer lowerEndpoint = valueRange.lowerEndpoint();
//        Integer upperEndpoint = valueRange.upperEndpoint();

        log.info("範囲 : {}", valueRange);

        Collection<String> tables = new ArrayList<>();

        if (Range.closed(0, 8000000).encloses(valueRange)) {
            tables.add("inspection_result");
        } else {
            tables.add("inspection_result_home");
        }
        log.info("テーブル: {}", tables);
        return collection;
    }
}