关注JEECG发展历程 关注最新动态和版本, 记录JEECG成长点滴 更新日志 - 技术支持 - 招聘英才

JEECG最新版本下载 JEECG智能开发平台 - 显著提高开发效率 常见问题 - 入门视频 - 参与开源团队

商务QQ: 69893005、3102411850 商务热线(5*8小时): 010-64808099 官方邮箱: jeecgos@163.com

查看: 3528|回复: 1

JeecgBoot集成Sharding-JDBC

[复制链接]
发表于 2021-12-25 21:58:21 | 显示全部楼层 |阅读模式
1. 环境描述
本次测试基于JeecgBoot 2.4.6,测试代码在Jeecg-boot-module-system中编写。

2. 引入坐标
  1. <dependency>
  2.     <groupId>org.apache.shardingsphere</groupId>
  3.     <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
  4.     <version>4.1.1</version>
  5. </dependency>
复制代码

3. 配置yml文件
  1. datasource:
  2.     druid:
  3.       stat-view-servlet:
  4.         enabled: true
  5.         loginUsername: admin
  6.         loginPassword: 123456
  7.         allow:
  8.       web-stat-filter:
  9.         enabled: true
  10.     dynamic:
  11.       druid: # 全局druid参数,绝大部分值和默认保持一致。(现已支持的参数如下,不清楚含义不要乱设置)
  12.         # 连接池的配置信息
  13.         # 初始化大小,最小,最大
  14.         initial-size: 5
  15.         min-idle: 5
  16.         maxActive: 20
  17.         # 配置获取连接等待超时的时间
  18.         maxWait: 60000
  19.         # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
  20.         timeBetweenEvictionRunsMillis: 60000
  21.         # 配置一个连接在池中最小生存的时间,单位是毫秒
  22.         minEvictableIdleTimeMillis: 300000
  23.         validationQuery: SELECT 1
  24.         testWhileIdle: true
  25.         testOnBorrow: false
  26.         testOnReturn: false
  27.         # 打开PSCache,并且指定每个连接上PSCache的大小
  28.         poolPreparedStatements: true
  29.         maxPoolPreparedStatementPerConnectionSize: 20
  30.         # 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
  31.         filters: stat,wall,slf4j
  32.         # 通过connectProperties属性来打开mergeSql功能;慢SQL记录
  33.         connectionProperties: druid.stat.mergeSql\=true;druid.stat.slowSqlMillis\=5000
  34.       primary: master # 设置默认的数据源或者数据源组,默认值即为master
  35.       strict: false   # 严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
  36.       datasource:
  37.         master:
  38.           url: jdbc:mysql://127.0.0.1:3306/jeecg-boot?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai
  39.           username: root
  40.           password: root
  41.           driver-class-name: com.mysql.cj.jdbc.Driver
  42.           # 多数据源配置
  43.           #multi-datasource1:
  44.           #url: jdbc:mysql://localhost:3306/jeecg-boot2?useUnicode=true&characterEncoding=utf8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai
  45.           #username: root
  46.           #password: root
  47.           #driver-class-name: com.mysql.cj.jdbc.Driver
  48.             # 指定默认数据源名称
  49.   shardingsphere:
  50.     props:
  51.       sql:
  52.         show: true
  53.     dataSource:
  54.       names: ds0
  55.       ds0:
  56.         type: com.alibaba.druid.pool.DruidDataSource
  57.         driverClassName: com.mysql.cj.jdbc.Driver
  58.         url: jdbc:mysql://127.0.0.1:3306/jeecg-boot?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai
  59.         username: root
  60.         password: root
  61.     sharding:
  62.       tables:
  63.         sys_log:
  64.           logicTable: sys_log
  65.           actualDataNodes: ds0.sys_log$->{1..2}
  66.           tableStrategy:
  67.             inline:
  68.               shardingColumn: id
  69.               algorithmExpression: sys_log$->{id % 2 + 1}
  70.           keyGenerator:
  71.             type: SNOWFLAKE
  72.             column: id
  73.             worker:
  74.             id: 1
复制代码

注意:在jeecgboot原有数据源的基础上,增加了primary节点,用来设置默认的数据源。

4. 建立数据表
在jeecgboot默认的数据库中,将sys_log表复制两份,分别命名为sys_log1和sys_log2

5. 添加配置类
在config目录下,添加配置类DataSourceConfiguration和DataSourceHealthConfig
其中DataSourceConfiguration.java配置类代码如下:
  1. package org.jeecg.config;
  2. import com.baomidou.dynamic.datasource.DynamicRoutingDataSource;
  3. import com.baomidou.dynamic.datasource.provider.AbstractDataSourceProvider;
  4. import com.baomidou.dynamic.datasource.provider.DynamicDataSourceProvider;
  5. import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DataSourceProperty;
  6. import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DynamicDataSourceAutoConfiguration;
  7. import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DynamicDataSourceProperties;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.boot.SpringBootConfiguration;
  10. import org.springframework.boot.autoconfigure.AutoConfigureBefore;
  11. import org.springframework.context.annotation.Bean;
  12. import org.springframework.context.annotation.Configuration;
  13. import org.springframework.context.annotation.Lazy;
  14. import org.springframework.context.annotation.Primary;
  15. import javax.annotation.Resource;
  16. import javax.sql.DataSource;
  17. import java.util.Map;

  18. @Configuration
  19. @AutoConfigureBefore({DynamicDataSourceAutoConfiguration.class, SpringBootConfiguration.class})

  20. public class DataSourceConfiguration {
  21.     /**
  22.      * 分表数据源名称
  23.      */
  24.     public static final String SHARDING_DATA_SOURCE_NAME = "sharding";
  25.     /**
  26.      * 动态数据源配置项
  27.      */
  28.     @Autowired
  29.     private DynamicDataSourceProperties dynamicDataSourceProperties;

  30.     @Lazy
  31.     @Resource
  32.     DataSource shardingDataSource;

  33.     /**
  34.      * 将shardingDataSource放到了多数据源(dataSourceMap)中
  35.      * 注意有个版本的bug,3.1.1版本 不会进入loadDataSources 方法,这样就一直造成数据源注册失败
  36.      */
  37.     @Bean
  38.     public DynamicDataSourceProvider dynamicDataSourceProvider() {
  39.         Map<String, DataSourceProperty> datasourceMap = dynamicDataSourceProperties.getDatasource();
  40.         return new AbstractDataSourceProvider() {
  41.             @Override
  42.             public Map<String, DataSource> loadDataSources() {
  43.                 Map<String, DataSource> dataSourceMap = createDataSourceMap(datasourceMap);
  44.                 // 将 shardingjdbc 管理的数据源也交给动态数据源管理
  45.                 dataSourceMap.put(SHARDING_DATA_SOURCE_NAME, shardingDataSource);
  46.                 return dataSourceMap;
  47.             }
  48.         };
  49.     }

  50.     /**
  51.      * 将动态数据源设置为首选的
  52.      * 当spring存在多个数据源时, 自动注入的是首选的对象
  53.      * 设置为主要的数据源之后,就可以支持shardingjdbc原生的配置方式了
  54.      *
  55.      * @return
  56.      */
  57.     @Primary
  58.     @Bean
  59.     public DataSource dataSource(DynamicDataSourceProvider dynamicDataSourceProvider) {
  60.         DynamicRoutingDataSource dataSource = new DynamicRoutingDataSource();
  61.         dataSource.setPrimary(dynamicDataSourceProperties.getPrimary());
  62.         dataSource.setStrict(dynamicDataSourceProperties.getStrict());
  63.         dataSource.setStrategy(dynamicDataSourceProperties.getStrategy());
  64.         dataSource.setProvider(dynamicDataSourceProvider);
  65.         dataSource.setP6spy(dynamicDataSourceProperties.getP6spy());
  66.         dataSource.setSeata(dynamicDataSourceProperties.getSeata());
  67.         return dataSource;
  68.     }
  69. }
复制代码
DataSourceHealthConfig.java配置类代码如下:
  1. package org.jeecg.config;

  2. import org.springframework.beans.factory.ObjectProvider;
  3. import org.springframework.beans.factory.annotation.Value;
  4. import org.springframework.boot.actuate.autoconfigure.jdbc.DataSourceHealthContributorAutoConfiguration;
  5. import org.springframework.boot.actuate.health.AbstractHealthIndicator;
  6. import org.springframework.boot.actuate.jdbc.DataSourceHealthIndicator;
  7. import org.springframework.boot.jdbc.metadata.DataSourcePoolMetadataProvider;
  8. import org.springframework.context.annotation.Configuration;
  9. import org.springframework.util.StringUtils;
  10. import javax.sql.DataSource;
  11. import java.util.Map;

  12. @Configuration
  13. public class DataSourceHealthConfig extends DataSourceHealthContributorAutoConfiguration {

  14.     @Value("${spring.datasource.dbcp2.validation-query:select 1}")
  15.     private String defaultQuery;


  16.     public DataSourceHealthConfig(Map<String, DataSource> dataSources, ObjectProvider<DataSourcePoolMetadataProvider> metadataProviders) {
  17.         super(dataSources, metadataProviders);
  18.     }

  19.     @Override
  20.     protected AbstractHealthIndicator createIndicator(DataSource source) {
  21.         DataSourceHealthIndicator indicator = (DataSourceHealthIndicator) super.createIndicator(source);
  22.         if (!StringUtils.hasText(indicator.getQuery())) {
  23.             indicator.setQuery(defaultQuery);
  24.         }
  25.         return indicator;
  26.     }
  27. }
复制代码

6. 接口编写
Mapper
  1. package org.jeecg.modules.shardingjdbc.mapper;

  2. import com.baomidou.dynamic.datasource.annotation.DS;
  3. import org.apache.ibatis.annotations.Insert;
  4. import org.apache.ibatis.annotations.Mapper;
  5. import org.apache.ibatis.annotations.Param;
  6. import org.apache.ibatis.annotations.Select;
  7. import org.springframework.stereotype.Repository;

  8. import java.util.List;
  9. import java.util.Map;

  10. /**
  11. * Created by sunh.
  12. */
  13. @Mapper
  14. @Repository
  15. public interface SysLogShardingMapper {

  16.     /**
  17.      * 插入日志
  18.      * @param type
  19.      * @param content
  20.      * @param operateType
  21.      * @return
  22.      */

  23.     @Insert("insert into sys_log(log_type,log_content,operate_type)values( #{type},#{content},#{operateType})")
  24.     int insertLog( @Param("type") int type, @Param("content") String content, @Param("operateType") int operateType);

  25. }
复制代码
Service
  1. package org.jeecg.modules.shardingjdbc.service;

  2. public interface SysLogShardingService {
  3.     int insertLog( int type, String content, int operateType);
  4. }
复制代码
ServiceImpl
  1. package org.jeecg.modules.shardingjdbc.service.Impl;

  2. import com.baomidou.dynamic.datasource.annotation.DS;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.jeecg.config.DataSourceConfiguration;
  5. import org.jeecg.modules.shardingjdbc.mapper.SysLogShardingDao;
  6. import org.jeecg.modules.shardingjdbc.service.SysLogShardingService;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.stereotype.Service;

  9. @Slf4j
  10. @Service
  11. @DS(DataSourceConfiguration.SHARDING_DATA_SOURCE_NAME)
  12. public class SysLogShardingServiceImpl implements SysLogShardingService {
  13.     @Autowired
  14.     private SysLogShardingDao sysLogShardingDao;

  15.     @Override
  16.     public int insertLog(int type, String content, int operateType) {
  17.         int affectedRows = sysLogShardingDao.insertLog( type,content, operateType);
  18.         return affectedRows;
  19.     }
  20. }
复制代码

7. 测试用例
  1. package org.jeecg.modules.shardingjdbc.controller;
  2. import org.jeecg.common.api.vo.Result;
  3. import org.jeecg.modules.shardingjdbc.mapper.SysLogShardingDao;
  4. import org.jeecg.modules.shardingjdbc.service.SysLogShardingService;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;

  9. /**
  10. * 测试sharding-jdbc
  11. */
  12. @RestController
  13. @RequestMapping("/sys_log")
  14. public class SysLogShardingController {
  15.     @Autowired
  16.     private SysLogShardingService sysLogShardingService;
  17.     @GetMapping("/test1")
  18.     public Result<?> TestMongoDb(){
  19.         for(int i=1;i<20;i++){
  20.             sysLogShardingService.insertLog( i,"jeecgboot",i);
  21.         }
  22.         return Result.OK("存入成功");
  23.     }
  24. }
复制代码

8. 测试结果

发表于 2022-11-25 15:17:46 | 显示全部楼层
使用高质量的现代远摄增距镜所损失的幸运飞艇直播澳洲幸运20走势图福彩双色球结果影像质量已经比过去小得多了。所以,你可以根据价格和便利方面的优点,决定是否在可接受的影像质量方面作出有限的让步

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

快速回复 返回顶部 返回列表