springboot2集成sharding-jdbc分库分表

sharding-jdbc简介：

定位为轻量级Java框架，在Java的JDBC层提供的额外服务。它使用客户端直连数据库，以jar包形式提供服务，无需额外部署和依赖，可理解为增强版的JDBC驱动，完全兼容JDBC和各种ORM框架。

适用于任何基于Java的ORM框架，如：JPA, Hibernate, Mybatis, Spring JDBC Template或直接使用JDBC。
基于任何第三方的数据库连接池，如：DBCP, C3P0, BoneCP, Druid, HikariCP等。
支持任意实现JDBC规范的数据库。目前支持MySQL，Oracle，SQLServer和PostgreSQL。

1、pom.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.7.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.mqm501</groupId><artifactId>springboot-sharding</artifactId><version>0.0.1-SNAPSHOT</version><name>springboot-sharding</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.1.0</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.1.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.1.0</version></dependency><dependency><groupId>io.shardingsphere</groupId><artifactId>sharding-jdbc-spring-boot-starter</artifactId><version>3.0.0</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

2、创建数据库语句：

CREATE TABLE `t_address` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`code` varchar(64) DEFAULT NULL COMMENT '编码',`name` varchar(64) DEFAULT NULL COMMENT '名称',`pid` varchar(64) NOT NULL DEFAULT '0' COMMENT '父id',`type` int(11) DEFAULT NULL COMMENT '1国家2省3市4县区',`lit` int(11) DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=21 DEFAULT CHARSET=utf8;CREATE TABLE `t_user0` (`id` bigint(20) NOT NULL,`name` varchar(64) DEFAULT NULL COMMENT '名称',`city_id` int(12) DEFAULT NULL COMMENT '城市',`sex` tinyint(1) DEFAULT NULL COMMENT '性别',`phone` varchar(32) DEFAULT NULL COMMENT '电话',`email` varchar(32) DEFAULT NULL COMMENT '邮箱',`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',`password` varchar(32) DEFAULT NULL COMMENT '密码',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;CREATE TABLE `t_user1` (`id` bigint(20) NOT NULL,`name` varchar(64) DEFAULT NULL COMMENT '名称',`city_id` int(12) DEFAULT NULL COMMENT '城市',`sex` tinyint(1) DEFAULT NULL COMMENT '性别',`phone` varchar(32) DEFAULT NULL COMMENT '电话',`email` varchar(32) DEFAULT NULL COMMENT '邮箱',`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',`password` varchar(32) DEFAULT NULL COMMENT '密码',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

3、实体类：

package com.mqm501.springbootsharding.sharding.model;import java.util.Date;
import lombok.Data;
import lombok.NoArgsConstructor;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.model* <p>Create Time: 2019年09月01日 16:19          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
@NoArgsConstructor
@Data
public class User {private Long id;private String name;private String phone;private String email;private String password;private Integer cityId;private Date createTime;private Integer sex;
}

package com.mqm501.springbootsharding.sharding.model;import lombok.Data;
import lombok.NoArgsConstructor;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.model* <p>Create Time: 2019年09月01日 16:19          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
@NoArgsConstructor
@Data
public class Address {private Long id;private String code;private String name;private String pid;private Integer type;private Integer lit;
}

4、创建Mapper

package com.mqm501.springbootsharding.sharding.mapper;import com.mqm501.springbootsharding.sharding.model.User;
import org.apache.ibatis.annotations.Mapper;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.mapper* <p>Create Time: 2019年09月01日 16:20          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
@Mapper
public interface UserMapper {/*** 保存*/void save(User user);/*** 查询* @param id* @return*/User get(Long id);
}

package com.mqm501.springbootsharding.sharding.mapper;import com.mqm501.springbootsharding.sharding.model.Address;
import org.apache.ibatis.annotations.Mapper;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.mapper* <p>Create Time: 2019年09月01日 16:45          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
@Mapper
public interface AddressMapper {/*** 保存*/void save(Address address);/*** 查询* @param id* @return*/Address get(Long id);
}

5、配置mapper.xml

<?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.mqm501.springbootsharding.sharding.mapper.UserMapper"><insert id="save" parameterType="User">INSERT INTO t_user(name,phone,email,city_id,sex,password)VALUES(#{name},#{phone},#{email},#{cityId},#{sex},#{password})</insert><select id="get" parameterType="long" resultType="User">select * from t_user where id = #{id}</select>
</mapper>

<?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.mqm501.springbootsharding.sharding.mapper.AddressMapper"><insert id="save" parameterType="Address">INSERT INTO t_address(code,name,pid,type,lit)VALUES(#{code},#{name},#{pid},#{type},#{lit})</insert><select id="get" parameterType="long" resultType="Address">select * from t_address where id = #{id}</select>
</mapper>

6、配置controller、service

package com.mqm501.springbootsharding.sharding.controller;import com.mqm501.springbootsharding.sharding.model.User;
import com.mqm501.springbootsharding.sharding.service.UserService;
import java.util.Date;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.controller* <p>Create Time: 2019年09月01日 16:18          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
@Controller
public class UserController {@Autowiredprivate UserService userService;@RequestMapping("/user/save")@ResponseBodypublic String save() {for (int i = 0; i <10 ; i++) {User user=new User();user.setName("test"+i);user.setCityId(i%2==0?1:2);user.setCreateTime(new Date());user.setSex(i%2==0?1:2);user.setPhone("11111111"+i);user.setEmail("xxxxx");user.setCreateTime(new Date());user.setPassword("eeeeeeeeeeee");userService.save(user);}return "success";}@RequestMapping("/user/get/{id}")@ResponseBodypublic User get(@PathVariable Long id) {User user =  userService.get(id);System.out.println(user.getId());return user;}
}

package com.mqm501.springbootsharding.sharding.controller;import com.mqm501.springbootsharding.sharding.model.Address;
import com.mqm501.springbootsharding.sharding.service.AddressService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.controller* <p>Create Time: 2019年09月01日 16:45          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
@Controller
public class AddressController {@Autowiredprivate AddressService addressService;@RequestMapping("/address/save")@ResponseBodypublic String save() {for (int i = 0; i <10 ; i++) {Address address=new Address();address.setCode("code_"+i);address.setName("name_"+i);address.setPid(i+"");address.setType(0);address.setLit(i%2==0?1:2);addressService.save(address);}return "success";}@RequestMapping("/address/get/{id}")@ResponseBodypublic Address get(@PathVariable Long id) {return addressService.get(id);}
}

package com.mqm501.springbootsharding.sharding.service;import com.mqm501.springbootsharding.sharding.model.User;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.service.impl* <p>Create Time: 2019年09月01日 16:20          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
public interface UserService {/*** 保存*/void save(User user);/*** 查询* @param id* @return*/User get(Long id);
}

package com.mqm501.springbootsharding.sharding.service;import com.mqm501.springbootsharding.sharding.model.Address;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.service* <p>Create Time: 2019年09月01日 16:44          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
public interface AddressService {void save(Address address);Address get(Long id);
}

package com.mqm501.springbootsharding.sharding.service.impl;import com.mqm501.springbootsharding.sharding.mapper.UserMapper;
import com.mqm501.springbootsharding.sharding.model.User;
import com.mqm501.springbootsharding.sharding.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.service.impl* <p>Create Time: 2019年09月01日 16:23          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
@Service("userService")
public class UserServiceImpl implements UserService {@AutowiredUserMapper userMapper;//这里会报错，但是并不会影响/*** 保存*/public void save(User user){userMapper.save(user);}/*** 查询* @param id* @return*/public User get(Long id){return userMapper.get(id);}
}

package com.mqm501.springbootsharding.sharding.service.impl;import com.mqm501.springbootsharding.sharding.mapper.AddressMapper;
import com.mqm501.springbootsharding.sharding.model.Address;
import com.mqm501.springbootsharding.sharding.service.AddressService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** Project: springboot-sharding Package: com.mqm501.springbootsharding.sharding.service.impl* <p>Create Time: 2019年09月01日 16:44          </p>* <p>@author: qingmei.meng               </p>* <p>Description:               </p>**/
@Service(value = "addressService")
public class AddressServiceImpl implements AddressService {@Autowiredprivate AddressMapper addressMapper;//这里会报错，但是并不会影响/*** 保存*/@Overridepublic void save(Address address){addressMapper.save(address);}/*** 查询* @param id* @return*/@Overridepublic Address get(Long id){return addressMapper.get(id);}
}

7、设置分片规则，分库分表事例：

#url相关配置，这里配置url的基本url
server.port=8081
### MYBATIS
mybatis.typeAliasesPackage=com.mqm501.springbootsharding.*.model
mybatis.mapperLocations=classpath:mapper/*.xml
mybatis.configuration.mapUnderscoreToCamelCase=true#sharding-jdbc
sharding.jdbc.datasource.names=ds0,ds1sharding.jdbc.datasource.ds0.type=com.alibaba.druid.pool.DruidDataSource
sharding.jdbc.datasource.ds0.driver-class-name=com.mysql.jdbc.Driver
sharding.jdbc.datasource.ds0.url=jdbc:mysql://localhost:3306/mytest?useAffectedRows=true&useUnicode=true&characterEncoding=utf-8&useSSL=false
sharding.jdbc.datasource.ds0.username=root
sharding.jdbc.datasource.ds0.password=mysql1234sharding.jdbc.datasource.ds1.type=com.alibaba.druid.pool.DruidDataSource
sharding.jdbc.datasource.ds1.driver-class-name=com.mysql.jdbc.Driver
sharding.jdbc.datasource.ds1.url=jdbc:mysql://localhost:3306/mytest2?useAffectedRows=true&useUnicode=true&characterEncoding=utf-8&useSSL=false
sharding.jdbc.datasource.ds1.username=root
sharding.jdbc.datasource.ds1.password=mysql1234#t_user 不分库分表
sharding.jdbc.config.sharding.tables.t_user.key-generator-column-name=id
sharding.jdbc.config.sharding.tables.t_user.actual-data-nodes=ds$->{0..1}.t_user$->{0..1}
sharding.jdbc.config.sharding.tables.t_user.database-strategy.inline.sharding-column=city_id
sharding.jdbc.config.sharding.tables.t_user.database-strategy.inline.algorithm-expression=ds$->{city_id % 2}
sharding.jdbc.config.sharding.tables.t_user.table-strategy.inline.sharding-column=sex
sharding.jdbc.config.sharding.tables.t_user.table-strategy.inline.algorithm-expression=t_user$->{sex % 2}
#t_user 不分库分表
sharding.jdbc.config.sharding.tables.t_address.key-generator-column-name=id
sharding.jdbc.config.sharding.tables.t_address.actual-data-nodes=ds$->{0..1}.t_address
sharding.jdbc.config.sharding.tables.t_address.database-strategy.inline.sharding-column=lit
sharding.jdbc.config.sharding.tables.t_address.database-strategy.inline.algorithm-expression=ds$->{lit % 2}sharding.jdbc.config.props.sql.show=true

8、官方文档：https://shardingsphere.apache.org/document/legacy/3.x/document/cn/overview/

9、源码地址：https://github.com/mqm501/keepup.git

springboot2集成sharding-jdbc分库分表相关推荐

Spring boot + Sharding JDBC 分库分表及分布式事务处理
Sharding JDBC 基础概念 Apache ShardingSphere 是一套开源的分布式数据库解决方案组成的生态圈,它由 JDBC.Proxy 和 Sidecar(规划中)这 3 款既能够 ...
SSM项目引入sharding JDBC进行分表
SSM项目引入sharding JDBC进行分表注意点: 本次集成sharing-jdbc 4.1.1,由于各个版本差别比较大,配置方式差别也特别大,请根据官方文档进行配置! 官方配置路径:http ...
视频教程-ShardingSphere:SpringBoot2+MybatisPlus+读写分离+分库分表-Java
ShardingSphere:SpringBoot2+MybatisPlus+读写分离+分库分表 10多年互联网一线实战经验,现就职于大型知名互联网企业,架构师, 有丰富实战经验和企业面试经验:曾就职 ...
Springboot2.x +JPA 集成 Apache ShardingSphere 分库分表
分库分表背景: 数据库性能瓶颈:主要分为按照业务来划分或者按照数据量来划分. 拆分方式: 水平拆分(每个表的结构都一样):订单表数据量大,我们可以水平拆分 ,分成order表1.order表2.ord ...
server sql 水平分表_springboot集成Shardingsphere进行分库分表
当公司业务量上去之后,单表支撑不了的时候,分库分表就是一个绕不开的话题,小弟最近新入职一家公司,发现这边公司在用ShardingSphere来进行分库分表,之前没接触过这方面,所以就写了个demo学习 ...
ShardingSphere JDBC 分库分表读写分离数据加密
简介在上篇文章中,在本地搭建了运行环境,本地来体验下ShardingSphere JDBC的三个功能:分库分表.读写分离.数据加密示例运行首先把概念先捋一捋,参考下面的文档: 数据分片读写分离 ...
使用sharding做分库分表，使用jpa，发生的save不报错，数据库缺插不进去数据的问题
先讲讲问题的诞生,我们项目起初没有引进 sharding分库,而是在项目上线前,才做的分库分表.也就是之前的业务都写好的,所以知道业务代码没有任何问题. 然后引入 sharding 的相关的依赖以后, ...
mysql sharding 方案_mysql sharding 方案分库分表(sharding)系列(4)
图1. Sharding实现层面与相关框架/产品在DAO层实现当团队决定自行实现sharding的时候,DAO层可能是嵌入sharding逻辑的首选位置,因为在这个层面上,每一个DAO的方法都明确 ...
MySQL数据库性能优化--数据分库分表
目录前言 1.什么时候需要分库分表? 1.1.第一次改造 1.2.分库分表的必要性 1.3.第二次改造 2.分库分表应该怎么分? 3.垂直分库会带来哪些问题? 3.1.跨库的关联查询 3.2.分布式 ...
sharding-jdbc4.1.1 分库分表后 mysql查询优化（count）
sharding jdbc分库分表之后查询优化背景需求研发历程 1.单线程(sharding jdbc 内置查询机制) 2.多线程(sharding jdbc 内置查询机制) 3.sql调整结 ...

springboot2集成sharding-jdbc分库分表

sharding-jdbc简介：

1、pom.xml配置

2、创建数据库语句：

3、实体类：

4、创建Mapper

5、配置mapper.xml

6、配置controller、service

7、设置分片规则，分库分表事例：

8、官方文档：https://shardingsphere.apache.org/document/legacy/3.x/document/cn/overview/

9、源码地址：https://github.com/mqm501/keepup.git

springboot2集成sharding-jdbc分库分表相关推荐

最新文章

热门文章