配置默认数据库

Author: yulichao

sharding-sphere/pom.xml

@@ -33,15 +33,15 @@
         </dependency>
 
         <!-- ShardingSphere 注册配置中心 begin （直接配置文件配置的话不需要引入）-->
-        <dependency>
-            <groupId>org.apache.shardingsphere</groupId>
-            <artifactId>sharding-orchestration-reg-nacos</artifactId>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.apache.shardingsphere</groupId>-->
+<!--            <artifactId>sharding-orchestration-reg-nacos</artifactId>-->
+<!--        </dependency>-->
 
-        <dependency>
-            <groupId>com.alibaba.nacos</groupId>
-            <artifactId>nacos-client</artifactId>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>com.alibaba.nacos</groupId>-->
+<!--            <artifactId>nacos-client</artifactId>-->
+<!--        </dependency>-->
         <!-- ShardingSphere 注册配置中心 end -->
 
         <dependency>

sharding-sphere/src/main/java/org/ylc/note/shardingsphere/controller/UserController.java

@@ -0,0 +1,35 @@
+package org.ylc.note.shardingsphere.controller;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.ylc.note.shardingsphere.entity.User;
+import org.ylc.note.shardingsphere.mapper.UserMapper;
+
+/**
+ * 代码千万行，注释第一行，
+ * 注释不规范，同事泪两行。
+ *
+ * @author Yulc
+ * @date 2020/7/29
+ */
+@Slf4j
+@RequestMapping("/user")
+@RestController
+public class UserController {
+
+    private final UserMapper userMapper;
+
+    public UserController(UserMapper userMapper) {
+        this.userMapper = userMapper;
+    }
+
+    @GetMapping("/search")
+    public ResponseEntity<User> searchUser(@RequestParam(value = "username") String username) {
+        User user = userMapper.searchUser(username);
+        return ResponseEntity.ok(user);
+    }
+}

sharding-sphere/src/main/java/org/ylc/note/shardingsphere/entity/User.java

@@ -0,0 +1,33 @@
+package org.ylc.note.shardingsphere.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+import java.time.LocalDateTime;
+
+/**
+ * 代码千万行，注释第一行，
+ * 注释不规范，同事泪两行。
+ *
+ * @author Yulc
+ * @date 2020/7/29
+ */
+@Getter
+@Setter
+@ToString
+public class User {
+
+    private Long id;
+
+    private String name;
+
+    private String username;
+
+    private String password;
+
+    private String status;
+
+    private LocalDateTime createTime;
+
+}

sharding-sphere/src/main/java/org/ylc/note/shardingsphere/mapper/UserMapper.java

@@ -0,0 +1,18 @@
+package org.ylc.note.shardingsphere.mapper;
+
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Component;
+import org.ylc.note.shardingsphere.entity.User;
+
+/**
+ * 代码千万行，注释第一行，
+ * 注释不规范，同事泪两行。
+ *
+ * @author Yulc
+ * @date 2020/7/29
+ */
+@Component
+public interface UserMapper {
+
+    User searchUser(@Param("username") String username);
+}

sharding-sphere/src/main/resources/application.yml

@@ -1,12 +1,12 @@
 spring:
   shardingsphere:
     datasource:
-      names: dcmi, sharding0, sharding1
-      dcmi:
+      names: sharding, sharding0, sharding1
+      sharding:
         #type: com.alibaba.druid.pool.DruidDataSource
         type: com.zaxxer.hikari.HikariDataSource
         driver-class: com.mysql.jdbc.Driver
-        jdbc-url: jdbc:mysql://localhost:3306/dcmi?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8&autoReconnect=true
+        jdbc-url: jdbc:mysql://localhost:3306/sharding?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8&autoReconnect=true
         username: root
         password: root2019!
       sharding0:
@@ -23,7 +23,7 @@ spring:
         password: root2019!
     sharding:
       # 默认数据源，不分片数据存放
-      default-data-source-name: dcmi
+      default-data-source-name: sharding
       # 默认分库策略
       default-database-strategy:
         # 行表达式
@@ -36,7 +36,11 @@ spring:
       tables:
         sys_log:
           # 真实的数据节点，数据源+表名的形式（临时数据，这里需要通过配置中心来实现动态配置）
-          actual-data-nodes: sharding$->{0..1}.sys_log_20200$->{7..9}
+          actual-data-nodes: sharding$->{0..1}.sys_log_$->{[202007, 202008, 202009, 202010]}
+          database-strategy:
+            inline:
+              sharding-column: operation_id
+              algorithm-expression: sharding$->{operation_id % 2}
           table-strategy:
             standard:
               sharding-column: create_time

sharding-sphere/src/main/resources/db/schemas.sql

@@ -1,12 +1,26 @@
+-- 默认数据库
+CREATE SCHEMA `sharding` DEFAULT CHARACTER SET utf8 ;
+
+create table t_user(
+	id int primary key auto_increment,
+    name varchar(20) not null,
+    username varchar(20) not null,
+    password varchar(32) not null,
+    status char(1) not null,
+    create_time datetime
+)
+
+-- 分库0
 CREATE SCHEMA `sharding0` DEFAULT CHARACTER SET utf8 ;
 
-
+-- 分库1
 CREATE SCHEMA `sharding1` DEFAULT CHARACTER SET utf8 ;
 
-
+-- 分库下的分表，每个分库都有
 CREATE TABLE `sys_log_202007` (
   `id` int NOT NULL AUTO_INCREMENT,
   `value` int NOT NULL,
+  `operation_id` int NOT NULL,
   `create_time` datetime DEFAULT NULL,
   PRIMARY KEY (`id`)
 );
@@ -15,6 +29,7 @@ CREATE TABLE `sys_log_202007` (
 CREATE TABLE `sys_log_202008` (
   `id` int NOT NULL AUTO_INCREMENT,
   `value` int NOT NULL,
+  `operation_id` int NOT NULL,
   `create_time` datetime DEFAULT NULL,
   PRIMARY KEY (`id`)
 );
@@ -23,6 +38,7 @@ CREATE TABLE `sys_log_202008` (
 CREATE TABLE `sys_log_202009` (
   `id` int NOT NULL AUTO_INCREMENT,
   `value` int NOT NULL,
+  `operation_id` int NOT NULL,
   `create_time` datetime DEFAULT NULL,
   PRIMARY KEY (`id`)
 );
@@ -31,6 +47,7 @@ CREATE TABLE `sys_log_202009` (
 CREATE TABLE `sys_log_202010` (
   `id` int NOT NULL AUTO_INCREMENT,
   `value` int NOT NULL,
+  `operation_id` int NOT NULL,
   `create_time` datetime DEFAULT NULL,
   PRIMARY KEY (`id`)
 );

sharding-sphere/src/main/resources/mapper/UserMapper.xml

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.ylc.note.shardingsphere.mapper.UserMapper">
+
+    <resultMap id="BaseResultMap" type="org.ylc.note.shardingsphere.entity.User">
+        <id column="id" jdbcType="INTEGER" property="id"/>
+        <result column="name" jdbcType="VARCHAR" property="name"/>
+        <result column="username" jdbcType="VARCHAR" property="username"/>
+        <result column="password" jdbcType="VARCHAR" property="password"/>
+        <result column="status" jdbcType="VARCHAR" property="status"/>
+        <result column="create_time" jdbcType="TIMESTAMP" property="createTime"/>
+    </resultMap>
+
+    <select id="searchUser" resultMap="BaseResultMap">
+        SELECT * FROM t_user WHERE username = #{username}
+    </select>
+
+
+</mapper>