提交 26ef442c 编写于 作者: G gkdgkdgkdgkd

Update Spring Boot 2.7.0 and Kotlin 1.6.21

上级 d40447ee
# 内容
`ShardingSphereJDBC`分库分表 + 读写分离。
# 环境
- `MySQL 8.0.29``Docker`
- `MyBatis Plus 3.5.1`
- `MyBatis Plus Generator 3.5.2`
- `Druid 1.2.10`
- `ShardingSphereJDBC 5.1.1`
- `Yitter 1.0.6`
# 博客
[地址](https://blog.csdn.net/qq_27525611/article/details/118528939)
# MySQL 配置文件
# `MySQL` 配置文件
- `master.cnf`是主节点的配置文件
- `slave.cnf`是从节点的配置文件
......
import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
plugins {
id("org.springframework.boot") version "2.5.2"
id("org.springframework.boot") version "2.7.0"
id("io.spring.dependency-management") version "1.0.11.RELEASE"
kotlin("jvm") version "1.5.20"
kotlin("plugin.spring") version "1.5.20"
kotlin("jvm") version "1.6.21"
kotlin("plugin.spring") version "1.6.21"
}
group = "com.example"
version = "0.0.1-SNAPSHOT"
java.sourceCompatibility = JavaVersion.VERSION_11
java.sourceCompatibility = JavaVersion.VERSION_17
configurations {
compileOnly {
......@@ -30,18 +30,19 @@ dependencies {
runtimeOnly("mysql:mysql-connector-java")
annotationProcessor("org.springframework.boot:spring-boot-configuration-processor")
testImplementation("org.springframework.boot:spring-boot-starter-test")
implementation("com.baomidou:mybatis-plus-boot-starter:3.4.3.1")
implementation("org.apache.velocity:velocity-engine-core:2.3")
implementation("org.realityforge.org.jetbrains.annotations:org.jetbrains.annotations:1.7.0")
implementation("com.alibaba:druid:1.2.6")
implementation("org.apache.shardingsphere:sharding-jdbc-spring-boot-starter:4.1.1")
implementation("com.alibaba:druid:1.2.10")
implementation("com.baomidou:mybatis-plus-generator:3.5.2")
implementation("com.baomidou:mybatis-plus-boot-starter:3.5.1")
implementation("org.freemarker:freemarker:2.3.31")
implementation("org.apache.shardingsphere:shardingsphere-jdbc-core-spring-boot-starter:5.1.1")
implementation("com.github.yitter:yitter-idgenerator:1.0.6")
}
tasks.withType<KotlinCompile> {
kotlinOptions {
freeCompilerArgs = listOf("-Xjsr305=strict")
jvmTarget = "11"
jvmTarget = "17"
}
}
......
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-7.0.2-bin.zip
distributionUrl=https\://services.gradle.org/distributions/gradle-7.4.1-bin.zip
zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists
#!/bin/sh
#
# Copyright © 2015-2021 the original authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
##############################################################################
#
# Gradle start up script for POSIX generated by Gradle.
#
# Important for running:
#
# (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
# noncompliant, but you have some other compliant shell such as ksh or
# bash, then to run this script, type that shell name before the whole
# command line, like:
#
# ksh Gradle
#
# Busybox and similar reduced shells will NOT work, because this script
# requires all of these POSIX shell features:
# * functions;
# * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
# «${var#prefix}», «${var%suffix}», and «$( cmd )»;
# * compound commands having a testable exit status, especially «case»;
# * various built-in commands including «command», «set», and «ulimit».
#
# Important for patching:
#
# (2) This script targets any POSIX shell, so it avoids extensions provided
# by Bash, Ksh, etc; in particular arrays are avoided.
#
# The "traditional" practice of packing multiple parameters into a
# space-separated string is a well documented source of bugs and security
# problems, so this is (mostly) avoided, by progressively accumulating
# options in "$@", and eventually passing that to Java.
#
# Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
# and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
# see the in-line comments for details.
#
# There are tweaks for specific operating systems such as AIX, CygWin,
# Darwin, MinGW, and NonStop.
#
# (3) This script is generated from the Groovy template
# https://github.com/gradle/gradle/blob/master/subprojects/plugins/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
# within the Gradle project.
#
# You can find Gradle at https://github.com/gradle/gradle/.
#
##############################################################################
# Attempt to set APP_HOME
# Resolve links: $0 may be a link
app_path=$0
# Need this for daisy-chained symlinks.
while
APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path
[ -h "$app_path" ]
do
ls=$( ls -ld "$app_path" )
link=${ls#*' -> '}
case $link in #(
/*) app_path=$link ;; #(
*) app_path=$APP_HOME$link ;;
esac
done
APP_HOME=$( cd "${APP_HOME:-./}" && pwd -P ) || exit
APP_NAME="Gradle"
APP_BASE_NAME=${0##*/}
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
# Use the maximum available, or set MAX_FD != -1 to use that value.
MAX_FD=maximum
warn () {
echo "$*"
} >&2
die () {
echo
echo "$*"
echo
exit 1
} >&2
# OS specific support (must be 'true' or 'false').
cygwin=false
msys=false
darwin=false
nonstop=false
case "$( uname )" in #(
CYGWIN* ) cygwin=true ;; #(
Darwin* ) darwin=true ;; #(
MSYS* | MINGW* ) msys=true ;; #(
NONSTOP* ) nonstop=true ;;
esac
CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
# Determine the Java command to use to start the JVM.
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD=$JAVA_HOME/jre/sh/java
else
JAVACMD=$JAVA_HOME/bin/java
fi
if [ ! -x "$JAVACMD" ] ; then
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
else
JAVACMD=java
which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
# Increase the maximum file descriptors if we can.
if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
case $MAX_FD in #(
max*)
MAX_FD=$( ulimit -H -n ) ||
warn "Could not query maximum file descriptor limit"
esac
case $MAX_FD in #(
'' | soft) :;; #(
*)
ulimit -n "$MAX_FD" ||
warn "Could not set maximum file descriptor limit to $MAX_FD"
esac
fi
# Collect all arguments for the java command, stacking in reverse order:
# * args from the command line
# * the main class name
# * -classpath
# * -D...appname settings
# * --module-path (only if needed)
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
# For Cygwin or MSYS, switch paths to Windows format before running java
if "$cygwin" || "$msys" ; then
APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
JAVACMD=$( cygpath --unix "$JAVACMD" )
# Now convert the arguments - kludge to limit ourselves to /bin/sh
for arg do
if
case $arg in #(
-*) false ;; # don't mess with options #(
/?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath
[ -e "$t" ] ;; #(
*) false ;;
esac
then
arg=$( cygpath --path --ignore --mixed "$arg" )
fi
# Roll the args list around exactly as many times as the number of
# args, so each arg winds up back in the position where it started, but
# possibly modified.
#
# NB: a `for` loop captures its iteration list before it begins, so
# changing the positional parameters here affects neither the number of
# iterations, nor the values presented in `arg`.
shift # remove old arg
set -- "$@" "$arg" # push replacement arg
done
fi
# Collect all arguments for the java command;
# * $DEFAULT_JVM_OPTS, $JAVA_OPTS, and $GRADLE_OPTS can contain fragments of
# shell script including quotes and variable substitutions, so put them in
# double quotes to make sure that they get re-expanded; and
# * put everything else in single quotes, so that it's not re-expanded.
set -- \
"-Dorg.gradle.appname=$APP_BASE_NAME" \
-classpath "$CLASSPATH" \
org.gradle.wrapper.GradleWrapperMain \
"$@"
# Use "xargs" to parse quoted args.
#
# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
#
# In Bash we could simply go:
#
# readarray ARGS < <( xargs -n1 <<<"$var" ) &&
# set -- "${ARGS[@]}" "$@"
#
# but POSIX shell has neither arrays nor command substitution, so instead we
# post-process each arg (as a line of input to sed) to backslash-escape any
# character that might be a shell metacharacter, then use eval to reverse
# that process (while maintaining the separation between arguments), and wrap
# the whole thing up as a single "set" statement.
#
# This will of course break if any of these variables contains a newline or
# an unmatched quote.
#
eval "set -- $(
printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
xargs -n1 |
sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
tr '\n' ' '
)" '"$@"'
exec "$JAVACMD" "$@"
package com.example.demo.generator
import com.baomidou.mybatisplus.annotation.IdType
import com.baomidou.mybatisplus.generator.FastAutoGenerator
import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine
fun main(args: Array<String>) {
val userTableName = "User"
FastAutoGenerator.create("jdbc:mysql://localhost:3306/test0", "root", "123456")
.globalConfig { builder ->
builder.author("author").outputDir(System.getProperty("user.dir") + "/src/main/kotlin").enableKotlin()
.build()
}.packageConfig { builder ->
builder.parent("com.example.demo").moduleName("user").build()
}.strategyConfig { builder ->
builder.addInclude("user0")
.entityBuilder().idType(IdType.ASSIGN_ID).convertFileName { userTableName }
.mapperBuilder().enableMapperAnnotation().convertMapperFileName { userTableName + "Mapper" }
.convertXmlFileName { userTableName + "Mapper" }
.serviceBuilder().convertServiceFileName { "I" + userTableName + "Service" }
.convertServiceImplFileName { userTableName + "Service" }
.controllerBuilder().enableRestStyle().convertFileName { userTableName + "Controller" }
}.templateEngine(FreemarkerTemplateEngine()).execute()
}
\ No newline at end of file
package com.example.demo.generator
import com.baomidou.mybatisplus.core.incrementer.IdentifierGenerator
import com.github.yitter.idgen.YitIdHelper
import org.springframework.context.annotation.Bean
class IdGenerator {
@Bean
fun identifierGenerator() = IdentifierGenerator { YitIdHelper.nextId() }
}
\ No newline at end of file
package com.example.demo.user.controller;
import com.example.demo.user.entity.User
import com.example.demo.user.service.IUserService
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.web.bind.annotation.GetMapping
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* <p>
* 前端控制器
* </p>
*
* @author author
* @since 2022-06-01
*/
@RestController
@RequestMapping("/user")
class UserController{
@Autowired
lateinit var userService: IUserService
@GetMapping("/insert")
fun insert() = userService.save(User().apply {
age = (1..100).random()
name = "name"
})
@GetMapping("/select")
fun select(): List<User>? = userService.list()
}
package com.example.demo.user.entity
import com.baomidou.mybatisplus.annotation.IdType
import com.baomidou.mybatisplus.annotation.TableId
import com.baomidou.mybatisplus.annotation.TableName
import java.io.Serializable
/**
* <p>
*
* </p>
*
* @author author
* @since 2022-06-01
*/
class User : Serializable {
@TableId(type = IdType.ASSIGN_ID)
var id: Long? = null
var name: String? = ""
var age: Int? = 20
override fun toString(): String {
return "User{" +
"id=" + id +
", name=" + name +
", age=" + age +
"}"
}
}
package com.example.demo.user.mapper;
import com.example.demo.user.entity.User;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* Mapper 接口
* </p>
*
* @author author
* @since 2022-06-01
*/
@Mapper
interface UserMapper : BaseMapper<User>
<?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="com.example.demo.user.mapper.UserMapper">
</mapper>
package com.example.demo.user.service;
import com.example.demo.user.entity.User;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* <p>
* 服务类
* </p>
*
* @author author
* @since 2022-06-01
*/
interface IUserService : IService<User>
package com.example.demo.user.service.impl;
import com.example.demo.user.entity.User;
import com.example.demo.user.mapper.UserMapper;
import com.example.demo.user.service.IUserService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
/**
* <p>
* 服务实现类
* </p>
*
* @author author
* @since 2022-06-01
*/
@Service
open class UserService : ServiceImpl<UserMapper, User>(), IUserService {
}
spring:
shardingsphere:
mode:
type: Memory # 内存模式,元数据保存在当前进程中
datasource:
names: master-test$->{0..1},slave-test$->{0..1}
master-test0: # 跟上面的数据源对应
type: com.alibaba.druid.pool.DruidDataSource # 连接池
url: jdbc:mysql://127.0.0.1:3306/test0 # 连接url
username: root
password: 123456
master-test1: # 跟上面的数据源对应
type: com.alibaba.druid.pool.DruidDataSource
url: jdbc:mysql://127.0.0.1:3306/test1
username: root
password: 123456
slave-test0: # 跟上面的数据源对应
type: com.alibaba.druid.pool.DruidDataSource
url: jdbc:mysql://127.0.0.1:3307/test0
username: root
password: 123456
slave-test1: # 跟上面的数据源对应
type: com.alibaba.druid.pool.DruidDataSource
url: jdbc:mysql://127.0.0.1:3307/test1
username: root
password: 123456
rules: # 配置分库分表以及读写分离的规则
sharding: # 配置分库分表规则
tables:
user: # 这个可以随便取,问题不大
actual-data-nodes: master-test$->{0..1}.user$->{0..2} # 实际节点名称,格式为 库名$->{0..n1}.表名$->{0..n2}
# 其中n1、n2分别为库数量-1和表数量-1
# 也可以使用${0..n1}的形式,但是会与Spring属性文件占位符冲突
# 所以使用$->{0..n1}的形式
database-strategy: # 分库策略
standard: # 标准分库策略
sharding-column: age # 分库列名
sharding-algorithm-name: age-mod # 分库算法名字
table-strategy: # 分表策略
standard: # 标准分表策略
sharding-column: id # 分表列名
sharding-algorithm-name: id-mod # 分表算法名字
sharding-algorithms: # 配置分库和分表的算法
age-mod: # 分库算法名字
type: MOD # 算法类型为取模
props: # 算法配置的键名,所有算法配置都需要在props下
sharding-count: 2 # 分片数量
id-mod: # 分表算法名字
type: MOD # 算法类型为取模
props: # 算法配置的键名,所有算法配置都需要在props下
sharding-count: 3 # 分片数量
readwrite-splitting: # 配置读写分离规则
data-sources: # 数据源
master-test0: # 这个可以随便取,带有区分意义即可,比如这里表示的是主库test0的规则
type: Static # 静态类型
load-balancer-name: round_robin # 负载均衡算法名字
props: # 具体读写数据源需要配置在props下
write-data-source-name: master-test0 # 写数据源
read-data-source-names: slave-test0 # 读数据源
master-test1:
type: Static # 静态类型
load-balancer-name: round_robin # 负载均衡算法名字
props: # 具体读写数据源需要配置在props下
write-data-source-name: master-test1 # 写数据源
read-data-source-names: slave-test1 # 读数据源
load-balancers: # 负载均衡配置
round_robin: # 跟上面负载均衡算法的名字对应
type: ROUND_ROBIN # 负载均衡算法
props:
sql-show: true # 打印SQL
\ No newline at end of file
# mysqldump 导出文件
# `mysqldump` 导出文件
使用时直接使用`mysqldump`导入即可。
首先创建好两个库:
```mysql
create database test0;
create database test1;
```
接着导入:
在主库执行:
```bash
mysqldump -u root -p < master.db
```
在从库执行:
```bash
mysqldump -u root -p < slave.db
```
-- MySQL dump 10.13 Distrib 8.0.25, for Linux (x86_64)
-- MySQL dump 10.13 Distrib 8.0.29, for Linux (x86_64)
--
-- Host: localhost Database: test0
-- ------------------------------------------------------
-- Server version 8.0.25
-- Server version 8.0.29
/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
......@@ -19,35 +19,10 @@
-- Current Database: `test0`
--
CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test0` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_520_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;
CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test0` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;
USE `test0`;
--
-- Table structure for table `user`
--
DROP TABLE IF EXISTS `user`;
/*!40101 SET @saved_cs_client = @@character_set_client */;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
-- Dumping data for table `user`
--
LOCK TABLES `user` WRITE;
/*!40000 ALTER TABLE `user` DISABLE KEYS */;
/*!40000 ALTER TABLE `user` ENABLE KEYS */;
UNLOCK TABLES;
--
-- Table structure for table `user0`
--
......@@ -57,11 +32,10 @@ DROP TABLE IF EXISTS `user0`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user0` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -70,7 +44,6 @@ CREATE TABLE `user0` (
LOCK TABLES `user0` WRITE;
/*!40000 ALTER TABLE `user0` DISABLE KEYS */;
INSERT INTO `user0` VALUES (177937894588485,'test name',34,'test@test.com'),(177937911459909,'test name',54,'test@test.com'),(177937933234245,'test name',62,'test@test.com'),(177986645717061,'test name',22,'test@test.com'),(178192082350149,'name',36,'test@test.com'),(178192109875269,'name',82,'test@test.com');
/*!40000 ALTER TABLE `user0` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -83,11 +56,10 @@ DROP TABLE IF EXISTS `user1`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user1` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -96,7 +68,6 @@ CREATE TABLE `user1` (
LOCK TABLES `user1` WRITE;
/*!40000 ALTER TABLE `user1` DISABLE KEYS */;
INSERT INTO `user1` VALUES (177937813430341,'test name',58,'test@test.com'),(177938001510469,'test name',52,'test@test.com'),(177938100994117,'test name',58,'test@test.com'),(177985635291205,'test name',86,'test@test.com'),(177986677755973,'test name',34,'test@test.com');
/*!40000 ALTER TABLE `user1` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -109,11 +80,10 @@ DROP TABLE IF EXISTS `user2`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user2` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -122,7 +92,6 @@ CREATE TABLE `user2` (
LOCK TABLES `user2` WRITE;
/*!40000 ALTER TABLE `user2` DISABLE KEYS */;
INSERT INTO `user2` VALUES (177937737605189,'test name',86,'test@test.com'),(177937771569221,'test name',20,'test@test.com'),(177937949585477,'test name',52,'test@test.com'),(177937980035141,'test name',40,'test@test.com'),(177938027675717,'test name',30,'test@test.com'),(177986626347077,'test name',62,'test@test.com');
/*!40000 ALTER TABLE `user2` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -130,7 +99,7 @@ UNLOCK TABLES;
-- Current Database: `test1`
--
CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test1` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_520_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;
CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test1` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;
USE `test1`;
......@@ -143,11 +112,10 @@ DROP TABLE IF EXISTS `user0`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user0` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -156,7 +124,6 @@ CREATE TABLE `user0` (
LOCK TABLES `user0` WRITE;
/*!40000 ALTER TABLE `user0` DISABLE KEYS */;
INSERT INTO `user0` VALUES (177938057982021,'test name',53,'test@test.com'),(177986656321605,'test name',27,'test@test.com');
/*!40000 ALTER TABLE `user0` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -169,11 +136,10 @@ DROP TABLE IF EXISTS `user1`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user1` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -182,7 +148,6 @@ CREATE TABLE `user1` (
LOCK TABLES `user1` WRITE;
/*!40000 ALTER TABLE `user1` DISABLE KEYS */;
INSERT INTO `user1` VALUES (178192100921413,'name',77,'test@test.com');
/*!40000 ALTER TABLE `user1` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -195,11 +160,10 @@ DROP TABLE IF EXISTS `user2`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user2` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -208,7 +172,6 @@ CREATE TABLE `user2` (
LOCK TABLES `user2` WRITE;
/*!40000 ALTER TABLE `user2` DISABLE KEYS */;
INSERT INTO `user2` VALUES (177985650556997,'test name',85,'test@test.com');
/*!40000 ALTER TABLE `user2` ENABLE KEYS */;
UNLOCK TABLES;
/*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */;
......@@ -221,4 +184,4 @@ UNLOCK TABLES;
/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;
/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;
-- Dump completed on 2021-07-07 6:52:40
-- Dump completed on 2022-06-01 12:02:34
-- MySQL dump 10.13 Distrib 8.0.25, for Linux (x86_64)
-- MySQL dump 10.13 Distrib 8.0.29, for Linux (x86_64)
--
-- Host: localhost Database: test0
-- ------------------------------------------------------
-- Server version 8.0.25
-- Server version 8.0.29
/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
......@@ -19,7 +19,7 @@
-- Current Database: `test0`
--
CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test0` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_520_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;
CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test0` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;
USE `test0`;
......@@ -32,11 +32,10 @@ DROP TABLE IF EXISTS `user0`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user0` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -45,7 +44,6 @@ CREATE TABLE `user0` (
LOCK TABLES `user0` WRITE;
/*!40000 ALTER TABLE `user0` DISABLE KEYS */;
INSERT INTO `user0` VALUES (177937894588485,'test name',34,'test@test.com'),(177937911459909,'test name',54,'test@test.com'),(177937933234245,'test name',62,'test@test.com'),(177986645717061,'test name',22,'test@test.com'),(178192082350149,'name',36,'test@test.com'),(178192109875269,'name',82,'test@test.com');
/*!40000 ALTER TABLE `user0` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -58,11 +56,10 @@ DROP TABLE IF EXISTS `user1`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user1` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -71,7 +68,6 @@ CREATE TABLE `user1` (
LOCK TABLES `user1` WRITE;
/*!40000 ALTER TABLE `user1` DISABLE KEYS */;
INSERT INTO `user1` VALUES (177937813430341,'test name',58,'test@test.com'),(177938001510469,'test name',52,'test@test.com'),(177938100994117,'test name',58,'test@test.com'),(177985635291205,'test name',86,'test@test.com'),(177986677755973,'test name',34,'test@test.com');
/*!40000 ALTER TABLE `user1` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -84,11 +80,10 @@ DROP TABLE IF EXISTS `user2`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user2` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -97,7 +92,6 @@ CREATE TABLE `user2` (
LOCK TABLES `user2` WRITE;
/*!40000 ALTER TABLE `user2` DISABLE KEYS */;
INSERT INTO `user2` VALUES (177937737605189,'test name',86,'test@test.com'),(177937771569221,'test name',20,'test@test.com'),(177937949585477,'test name',52,'test@test.com'),(177937980035141,'test name',40,'test@test.com'),(177938027675717,'test name',30,'test@test.com'),(177986626347077,'test name',62,'test@test.com');
/*!40000 ALTER TABLE `user2` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -105,7 +99,7 @@ UNLOCK TABLES;
-- Current Database: `test1`
--
CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test1` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_520_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;
CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test1` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;
USE `test1`;
......@@ -118,11 +112,10 @@ DROP TABLE IF EXISTS `user0`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user0` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -131,7 +124,6 @@ CREATE TABLE `user0` (
LOCK TABLES `user0` WRITE;
/*!40000 ALTER TABLE `user0` DISABLE KEYS */;
INSERT INTO `user0` VALUES (177938057982021,'test name',53,'test@test.com'),(177986656321605,'test name',27,'test@test.com');
/*!40000 ALTER TABLE `user0` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -144,11 +136,10 @@ DROP TABLE IF EXISTS `user1`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user1` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -157,7 +148,6 @@ CREATE TABLE `user1` (
LOCK TABLES `user1` WRITE;
/*!40000 ALTER TABLE `user1` DISABLE KEYS */;
INSERT INTO `user1` VALUES (178192100921413,'name',77,'test@test.com');
/*!40000 ALTER TABLE `user1` ENABLE KEYS */;
UNLOCK TABLES;
......@@ -170,11 +160,10 @@ DROP TABLE IF EXISTS `user2`;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user2` (
`id` bigint NOT NULL,
`name` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`age` int NOT NULL,
`email` varchar(45) COLLATE utf8mb4_unicode_520_ci NOT NULL,
`name` varchar(30) NOT NULL,
`age` int NOT NULL DEFAULT '20',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_520_ci;
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
/*!40101 SET character_set_client = @saved_cs_client */;
--
......@@ -183,7 +172,6 @@ CREATE TABLE `user2` (
LOCK TABLES `user2` WRITE;
/*!40000 ALTER TABLE `user2` DISABLE KEYS */;
INSERT INTO `user2` VALUES (177985650556997,'test name',85,'test@test.com');
/*!40000 ALTER TABLE `user2` ENABLE KEYS */;
UNLOCK TABLES;
/*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */;
......@@ -196,4 +184,4 @@ UNLOCK TABLES;
/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;
/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;
-- Dump completed on 2021-07-07 6:53:51
-- Dump completed on 2022-06-01 12:03:44
# ShardingSphere 分库分表 + 读写分离
详细教程可以参考[博客](https://blog.csdn.net/qq_27525611/article/details/118528939)
#!/usr/bin/env sh
#
# Copyright 2015 the original author or authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
##############################################################################
##
## Gradle start up script for UN*X
##
##############################################################################
# Attempt to set APP_HOME
# Resolve links: $0 may be a link
PRG="$0"
# Need this for relative symlinks.
while [ -h "$PRG" ] ; do
ls=`ls -ld "$PRG"`
link=`expr "$ls" : '.*-> \(.*\)$'`
if expr "$link" : '/.*' > /dev/null; then
PRG="$link"
else
PRG=`dirname "$PRG"`"/$link"
fi
done
SAVED="`pwd`"
cd "`dirname \"$PRG\"`/" >/dev/null
APP_HOME="`pwd -P`"
cd "$SAVED" >/dev/null
APP_NAME="Gradle"
APP_BASE_NAME=`basename "$0"`
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
# Use the maximum available, or set MAX_FD != -1 to use that value.
MAX_FD="maximum"
warn () {
echo "$*"
}
die () {
echo
echo "$*"
echo
exit 1
}
# OS specific support (must be 'true' or 'false').
cygwin=false
msys=false
darwin=false
nonstop=false
case "`uname`" in
CYGWIN* )
cygwin=true
;;
Darwin* )
darwin=true
;;
MINGW* )
msys=true
;;
NONSTOP* )
nonstop=true
;;
esac
CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
# Determine the Java command to use to start the JVM.
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD="$JAVA_HOME/jre/sh/java"
else
JAVACMD="$JAVA_HOME/bin/java"
fi
if [ ! -x "$JAVACMD" ] ; then
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
else
JAVACMD="java"
which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
# Increase the maximum file descriptors if we can.
if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
MAX_FD_LIMIT=`ulimit -H -n`
if [ $? -eq 0 ] ; then
if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
MAX_FD="$MAX_FD_LIMIT"
fi
ulimit -n $MAX_FD
if [ $? -ne 0 ] ; then
warn "Could not set maximum file descriptor limit: $MAX_FD"
fi
else
warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
fi
fi
# For Darwin, add options to specify how the application appears in the dock
if $darwin; then
GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
fi
# For Cygwin or MSYS, switch paths to Windows format before running java
if [ "$cygwin" = "true" -o "$msys" = "true" ] ; then
APP_HOME=`cygpath --path --mixed "$APP_HOME"`
CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
JAVACMD=`cygpath --unix "$JAVACMD"`
# We build the pattern for arguments to be converted via cygpath
ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
SEP=""
for dir in $ROOTDIRSRAW ; do
ROOTDIRS="$ROOTDIRS$SEP$dir"
SEP="|"
done
OURCYGPATTERN="(^($ROOTDIRS))"
# Add a user-defined pattern to the cygpath arguments
if [ "$GRADLE_CYGPATTERN" != "" ] ; then
OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
fi
# Now convert the arguments - kludge to limit ourselves to /bin/sh
i=0
for arg in "$@" ; do
CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option
if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition
eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
else
eval `echo args$i`="\"$arg\""
fi
i=`expr $i + 1`
done
case $i in
0) set -- ;;
1) set -- "$args0" ;;
2) set -- "$args0" "$args1" ;;
3) set -- "$args0" "$args1" "$args2" ;;
4) set -- "$args0" "$args1" "$args2" "$args3" ;;
5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
esac
fi
# Escape application args
save () {
for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
echo " "
}
APP_ARGS=`save "$@"`
# Collect all arguments for the java command, following the shell quoting and substitution rules
eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
exec "$JAVACMD" "$@"
package com.example.demo
import com.baomidou.mybatisplus.core.incrementer.IdentifierGenerator
import com.github.yitter.contract.IdGeneratorOptions
import com.github.yitter.idgen.YitIdHelper
import org.springframework.stereotype.Component
import javax.annotation.PostConstruct
@Component
class IdGenerator:IdentifierGenerator {
val options = IdGeneratorOptions(1)
@PostConstruct
fun init(){
YitIdHelper.setIdGenerator(options)
}
override fun nextId(entity: Any?):Long?{
return YitIdHelper.nextId()
}
}
\ No newline at end of file
package com.example.demo.user
import com.baomidou.mybatisplus.annotation.IdType
import com.baomidou.mybatisplus.annotation.TableId
data class User(
@TableId(type = IdType.ASSIGN_ID)
var id: Long?,
var name: String,
var age: Int,
var email: String,
) {
constructor(name: String, age: Int, email: String) : this(null,name,age,email)
}
\ No newline at end of file
package com.example.demo.user
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.web.bind.annotation.GetMapping
import org.springframework.web.bind.annotation.RequestMapping
import org.springframework.web.bind.annotation.RestController
import java.util.*
@RestController
@RequestMapping("/user")
class UserController {
@Autowired
lateinit var userService: UserServiceImpl
companion object{
val random = Random()
}
@GetMapping("/insert")
fun insert() = userService.save(User("name", random.nextInt(80)+20,"test@test.com"))
@GetMapping("/select")
fun select() = userService.list()
}
\ No newline at end of file
package com.example.demo.user
import com.baomidou.mybatisplus.core.mapper.BaseMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface UserMapper:BaseMapper<User>
\ No newline at end of file
package com.example.demo.user
import com.baomidou.mybatisplus.extension.service.IService
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
import org.springframework.stereotype.Service
@Service
class UserServiceImpl:ServiceImpl<UserMapper, User>(),IService<User>
\ No newline at end of file
spring:
shardingsphere:
datasource:
names: master-test0,master-test1,slave-test0,slave-test1
master-test0:
type: com.alibaba.druid.pool.DruidDataSource
url: jdbc:mysql://127.0.0.1:3306/test0
username: root
password: 123456
master-test1:
type: com.alibaba.druid.pool.DruidDataSource
url: jdbc:mysql://127.0.0.1:3306/test1
username: root
password: 123456
slave-test0:
type: com.alibaba.druid.pool.DruidDataSource
url: jdbc:mysql://127.0.0.1:3307/test0
username: root
password: 123456
slave-test1:
type: com.alibaba.druid.pool.DruidDataSource
url: jdbc:mysql://127.0.0.1:3307/test1
username: root
password: 123456
sharding:
default-database-strategy:
inline:
sharding-column: age
algorithm-expression: master-test$->{age % 2}
tables:
user:
actual-data-nodes: master-test$->{0..1}.user$->{0..2}
table-strategy:
inline:
sharding-column: id
algorithm-expression: user$->{id%3}
master-slave-rules:
master-test0:
master-datasource-name: master-test0
slave-data-source-names: slave-test0
master-test1:
master-datasource-name: master-test1
slave-data-source-names: slave-test1
props:
sql:
show:
true
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册