点击查看【bilibili】

目标

本章节以尽量短的时间，演示 PIG 框架如何整合 Apache ShardingSphere 完成分表操作 。

:::success 实现效果: 日志表根据 请求方法的不同 拆分为 GET、POST、PUT、DELETE 数据库 :::

image.png

快速上手

1. 添加 maven 依赖

  1. <dependency>
  2.   <groupId>org.apache.shardingsphere</groupId>
  3.   <artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId>
  4.   <version>5.1.2</version>
  5. </dependency>

2. 添加四张测试表

  1. CREATE TABLE `sys_log_GET` (
  2.                            `id` bigint NOT NULL AUTO_INCREMENT COMMENT '编号',
  3.                            `type` char(1) DEFAULT '1' COMMENT '日志类型',
  4.                            `title` varchar(255) DEFAULT '' COMMENT '日志标题',
  5.                            `service_id` varchar(32) DEFAULT NULL COMMENT '服务ID',
  6.                            `remote_addr` varchar(255) DEFAULT NULL COMMENT '操作IP地址',
  7.                            `user_agent` varchar(1000) DEFAULT NULL COMMENT '用户代理',
  8.                            `request_uri` varchar(255) DEFAULT NULL COMMENT '请求URI',
  9.                            `method` varchar(10) DEFAULT NULL COMMENT '操作方式',
  10.                            `params` text COMMENT '操作提交的数据',
  11.                            `time` mediumtext COMMENT '执行时间',
  12.                            `del_flag` char(1) DEFAULT '0' COMMENT '删除标记',
  13.                            `exception` text COMMENT '异常信息',
  14.                            `create_time` datetime DEFAULT NULL COMMENT '创建时间',
  15.                            `update_time` datetime DEFAULT NULL COMMENT '更新时间',
  16.                            `create_by` varchar(64) DEFAULT NULL COMMENT '创建人',
  17.                            `update_by` varchar(64) DEFAULT NULL COMMENT '更新人',
  18.                            PRIMARY KEY (`id`),
  19.                            KEY `sys_log_create_by` (`create_by`),
  20.                            KEY `sys_log_request_uri` (`request_uri`),
  21.                            KEY `sys_log_type` (`type`),
  22.                            KEY `sys_log_create_date` (`create_time`)
  23. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC COMMENT='日志表';
  25. CREATE TABLE `sys_log_POST` (
  26.                            `id` bigint NOT NULL AUTO_INCREMENT COMMENT '编号',
  27.                            `type` char(1) DEFAULT '1' COMMENT '日志类型',
  28.                            `title` varchar(255) DEFAULT '' COMMENT '日志标题',
  29.                            `service_id` varchar(32) DEFAULT NULL COMMENT '服务ID',
  30.                            `remote_addr` varchar(255) DEFAULT NULL COMMENT '操作IP地址',
  31.                            `user_agent` varchar(1000) DEFAULT NULL COMMENT '用户代理',
  32.                            `request_uri` varchar(255) DEFAULT NULL COMMENT '请求URI',
  33.                            `method` varchar(10) DEFAULT NULL COMMENT '操作方式',
  34.                            `params` text COMMENT '操作提交的数据',
  35.                            `time` mediumtext COMMENT '执行时间',
  36.                            `del_flag` char(1) DEFAULT '0' COMMENT '删除标记',
  37.                            `exception` text COMMENT '异常信息',
  38.                            `create_time` datetime DEFAULT NULL COMMENT '创建时间',
  39.                            `update_time` datetime DEFAULT NULL COMMENT '更新时间',
  40.                            `create_by` varchar(64) DEFAULT NULL COMMENT '创建人',
  41.                            `update_by` varchar(64) DEFAULT NULL COMMENT '更新人',
  42.                            PRIMARY KEY (`id`),
  43.                            KEY `sys_log_create_by` (`create_by`),
  44.                            KEY `sys_log_request_uri` (`request_uri`),
  45.                            KEY `sys_log_type` (`type`),
  46.                            KEY `sys_log_create_date` (`create_time`)
  47. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC COMMENT='日志表';
  50. CREATE TABLE `sys_log_PUT` (
  51.                            `id` bigint NOT NULL AUTO_INCREMENT COMMENT '编号',
  52.                            `type` char(1) DEFAULT '1' COMMENT '日志类型',
  53.                            `title` varchar(255) DEFAULT '' COMMENT '日志标题',
  54.                            `service_id` varchar(32) DEFAULT NULL COMMENT '服务ID',
  55.                            `remote_addr` varchar(255) DEFAULT NULL COMMENT '操作IP地址',
  56.                            `user_agent` varchar(1000) DEFAULT NULL COMMENT '用户代理',
  57.                            `request_uri` varchar(255) DEFAULT NULL COMMENT '请求URI',
  58.                            `method` varchar(10) DEFAULT NULL COMMENT '操作方式',
  59.                            `params` text COMMENT '操作提交的数据',
  60.                            `time` mediumtext COMMENT '执行时间',
  61.                            `del_flag` char(1) DEFAULT '0' COMMENT '删除标记',
  62.                            `exception` text COMMENT '异常信息',
  63.                            `create_time` datetime DEFAULT NULL COMMENT '创建时间',
  64.                            `update_time` datetime DEFAULT NULL COMMENT '更新时间',
  65.                            `create_by` varchar(64) DEFAULT NULL COMMENT '创建人',
  66.                            `update_by` varchar(64) DEFAULT NULL COMMENT '更新人',
  67.                            PRIMARY KEY (`id`),
  68.                            KEY `sys_log_create_by` (`create_by`),
  69.                            KEY `sys_log_request_uri` (`request_uri`),
  70.                            KEY `sys_log_type` (`type`),
  71.                            KEY `sys_log_create_date` (`create_time`)
  72. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC COMMENT='日志表';
  74. CREATE TABLE `sys_log_DELETE` (
  75.                            `id` bigint NOT NULL AUTO_INCREMENT COMMENT '编号',
  76.                            `type` char(1) DEFAULT '1' COMMENT '日志类型',
  77.                            `title` varchar(255) DEFAULT '' COMMENT '日志标题',
  78.                            `service_id` varchar(32) DEFAULT NULL COMMENT '服务ID',
  79.                            `remote_addr` varchar(255) DEFAULT NULL COMMENT '操作IP地址',
  80.                            `user_agent` varchar(1000) DEFAULT NULL COMMENT '用户代理',
  81.                            `request_uri` varchar(255) DEFAULT NULL COMMENT '请求URI',
  82.                            `method` varchar(10) DEFAULT NULL COMMENT '操作方式',
  83.                            `params` text COMMENT '操作提交的数据',
  84.                            `time` mediumtext COMMENT '执行时间',
  85.                            `del_flag` char(1) DEFAULT '0' COMMENT '删除标记',
  86.                            `exception` text COMMENT '异常信息',
  87.                            `create_time` datetime DEFAULT NULL COMMENT '创建时间',
  88.                            `update_time` datetime DEFAULT NULL COMMENT '更新时间',
  89.                            `create_by` varchar(64) DEFAULT NULL COMMENT '创建人',
  90.                            `update_by` varchar(64) DEFAULT NULL COMMENT '更新人',
  91.                            PRIMARY KEY (`id`),
  92.                            KEY `sys_log_create_by` (`create_by`),
  93.                            KEY `sys_log_request_uri` (`request_uri`),
  94.                            KEY `sys_log_type` (`type`),
  95.                            KEY `sys_log_create_date` (`create_time`)
  96. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC COMMENT='日志表';

3. nacos/pig-upms-biz-dev.yml 添加配置

  1. spring:
  2.   shardingsphere:
  3.     datasource:
  4.       ds0:
  5.         driver-class-name: com.mysql.cj.jdbc.Driver
  6.         type: com.zaxxer.hikari.HikariDataSource
  7.         username: root
  8.         password: root
  9.         jdbc-url: jdbc:mysql://pig-mysql:3306/pig?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowMultiQueries=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&nullCatalogMeansCurrent=true&allowPublicKeyRetrieval=true
  10.       names: ds0
  11.     props:
  12.       sql-show: true
  13.     rules:
  14.       sharding:
  15.         sharding-algorithms:
  16.           table-inline:
  17.             props:
  18.               algorithm-expression: sys_log_$->{method}
  19.             type: INLINE
  20.         tables:
  21.           sys_log:
  22.             actual-data-nodes: ds0.sys_log_GET,ds0.sys_log_POST,ds0.sys_log_PUT,ds0.sys_log_DELETE
  23.             table-strategy:
  24.               standard:
  25.                 sharding-algorithm-name: table-inline
  26.                 sharding-column: method

4. 业务测试

:::warning 编辑角色、新增角色 查看数据库中日志表记录 :::

❤ 问题咨询

手势点击蓝字求关注简约风动态引导关注__2022-09-07+23_18_38.gif