SpringBoot 如何使用sharding jdbc进行分库分表

< sharding-sphere.version >4.0.0-RC1</ sharding-sphere.version >

<!-- 分库分表-->

         < dependency >

             < groupId >org.apache.shardingsphere</ groupId >

             < artifactId >sharding-jdbc-spring-boot-starter</ artifactId >

             < version >${sharding-sphere.version}</ version >

         </ dependency >

         < dependency >

             < groupId >org.apache.shardingsphere</ groupId >

             < artifactId >sharding-core-common</ artifactId >

             < version >${sharding-sphere.version}</ version >

         </ dependency >

         <!-- 分库分表 end-->

         < dependency >

             < groupId >org.springframework.boot</ groupId >

             < artifactId >spring-boot-starter-data-jpa</ artifactId >

         </ dependency >

spring:

   application:

     name: t3cc

   profiles:

     active: sharding-databases-tables

#  datasource:

#    primary:

#        jdbc-url: jdbc:mysql://${MYSQL_HOST:localhost}:${MYSQL_PORT:3306}/${DB_NAME:dmp_t3cc}?useUnicode=true&characterEncoding=UTF8&serverTimezone=Hongkong

#        username: ${MYSQL_USER:root}

#        password: ${MYSQL_PASS:root}

#    secondary:

#        jdbc-url: jdbc:mysql://xxxxxxxxxxxxx/xxxxxx?useUnicode=true&characterEncoding=UTF8&serverTimezone=Hongkong

#        username: xxxxx

#        password: xxxxxxx

   jpa:

     database: mysql

     database-platform: org.hibernate.dialect.MySQL5InnoDBDialect  #不加这句则默认为myisam引擎

     hibernate:

       ddl-auto: none

       naming:

         physical-strategy: org.springframework.boot.orm.jpa.hibernate.SpringPhysicalNamingStrategy

     open-in-view: true

     properties:

         enable_lazy_load_no_trans: true

     show-sql: true

db:

   one: primary

   two: secondary

spring:

   shardingsphere:

     datasource:

       names: ${db.one},${db.two}

       primary:

         type: com.zaxxer.hikari.HikariDataSource

         jdbc-url: jdbc:mysql://${MYSQL_HOST:localhost}:${MYSQL_PORT:3306}/${DB_NAME:dmp_t3cc}?useUnicode=true&characterEncoding=UTF8&serverTimezone=Hongkong

         username: ${MYSQL_USER:root}

         password: ${MYSQL_USER:root}

         max-active: 16

       secondary:

         type: com.zaxxer.hikari.HikariDataSource

         jdbc-url: jdbc:mysql://xxxxxxx:3306/t3cc?useUnicode=true&characterEncoding=UTF8&serverTimezone=Hongkong

         username: xxx

         password: xxxxxx

         max-active: 16

     sharding:

       tables:

         pt_call_info:

            actual-data-nodes: ${db.one}.pt_call_info_$->{1..14}

            table-strategy:

               inline:

                 sharding-column: today

                 algorithm-expression: pt_call_info_$->{today}

            key-generator:

               column: id

               type: SNOWFLAKE

         pre_cc_project:

            actual-data-nodes: ${db.two}.pre_cc_project

         pre_cc_biztrack:

            actual-data-nodes: ${db.two}.pre_cc_biztrack

@RunWith (SpringRunner. class )

@SpringBootTest

public class T3ccApplicationTests {

     @Resource

     private ProjectManager projectManager;

     @Resource

     private PtCallInfoManager ptCallInfoManager;

     @Test

     public void contextLoads() {

         List<PreCcProject> preCcProjectList = projectManager.findAll();

         System.out.println(preCcProjectList.size());

         for ( int i = 1 ; i <= 14 ; i++) {

             PtCallInfo ptCallInfo = new PtCallInfo();

             ptCallInfo.setId((Long) new SnowflakeShardingKeyGenerator().generateKey());

             ptCallInfo.setToday(i);

             ptCallInfoManager.add(ptCallInfo);

         }

     }

}