微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

springboot2集成sharding-jdbc分库分表

分类：JDBC作者：编程之家原文地址AI导航网

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。

Sharding-JDBC Architecture

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 {

  @Autowired
  private UserService userService;

  @RequestMapping("/user/save")
  @ResponseBody
  public 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}")
  @ResponseBody
  public 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 {
  @Autowired
  private AddressService addressService;

  @RequestMapping("/address/save")
  @ResponseBody
  public 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}")
  @ResponseBody
  public 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 {
  @Autowired
  UserMapper 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 {
  @Autowired
  private AddressMapper addressMapper;//这里会报错，但是并不会影响
  /**
   * 保存
   */
  @Override
  public void save(Address address){
    addressMapper.save(address);
  }

  /**
   * 查询
   * @param id
   * @return
   */
  @Override
  public 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,ds1

sharding.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=MysqL1234

sharding.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

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

讲解JDBC
连接数据库的方式：第一种方式：ODBC：开放数据库连接是微软公司开放服务结构中有关数据库的一个组成部分，是数据库访问接口标准。ODBC是基于C语言实现的。提供了语言和数据库进行交互的一致性的接口，便于语言和数据库通信以及语言对数据库的各种操作。第二种方式：JDBC（本章重点）在Java中，
Jmeter 数据库请求
JDBCRequest 使用VariableNamesmysql：数据库连接池对象variousname：设置的变量名称 如何使用该变量a_#、b_#、c_#、d_#：代表行数a_1：第1行、第1列b_2：第2行、第2列
抽取基本JDBC中的基本操作与数据连接池
 1.JDBCDBC(JavaDataBaseConnectivity)：Java数据库连接技术：具体讲就是通过Java连接广泛的数据库，并对表中数据执行增、删、改、查等操作的技术。JDBC是数据库与Java代码的桥梁。JDBC中定义了操作数据库的各种接口和类型：增删改基本操作：（1）获取连接：Connectionconnection=
JDBC操作流程
1.需要jar包的支持：java.sqljavax.sqlmysql-conneter-java...连接驱动（必须要导入）<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.46</version></depend
Activiti可视化流程管理器
1.简介Activiti是一个业务流程管理(BPM)框架,它是覆盖了业务流程管理，工作流，服务协作等领域的一个开源，灵活的，易扩展的可执行流程语言框架。在Java工作流引擎中可谓是主流，我们的项目也是使用的这个框架进行流程相关的开发。与流程息息相关的就是我们的流程定义BPMN文件，包含有一系列
0811JDBC随笔
1.JDBC体系系统一组规范：接口JDBC接口（API）包括两个层次：面向应用的API：JavaAPI，抽象接口，供应用开发人员使用（连接数据库，执行SQL语句，获得结果）面向数据库的API：JavaDriverAPI，供开发商开发数据库驱动程序JDBC是sun公司提供一套用于数据库操作的接口，java程序员只需要面向这套接
JDBC的基本概念
原文链接JDBC一般指Java数据库连接（JavaDatabaseConnectivity）api应用程序接口（API）：可以调用或者使用类/接口/方法等去完成某个目标。API制定的类/方法可以做什么。API由开发人员调用。spi服务提供接口（SPI）：需要继承或实现某些类/接口/方法等去完成某个目标。SPI告诉你
Shardingsphere-ShardingSphere-JDBC-Spring Boot配置-分片规则
spring.shardingsphere.datasource.names=#省略数据源配置，请参考用法#标准分表配置spring.shardingsphere.rules.sharding.tables.<table-name>.actual-data-nodes=#描述数据源名称和实际表，分隔符为点，多个数据节点用逗号分隔，支持内联表达式。Absent表示仅对数据库进行分片
20220814 idea_springboot_启动 Cannot load driver class: com.mysql.cj.jdbc.Driver
1问题Cannotloaddriverclass:com.mysql.cj.jdbc.Driver 2解决方案2.1已解决2.1.1首先，去查看项目中MySQL的版本如果找不到，说明可能还没有jdbc驱动，需要配置或者引入       （1）如果是直接引用的jar包，就去lib文件夹中查看，后缀是版
JDBC
JDBC一、JDBC概述什么是JDBC？JDBC是使用Java语言操作关系型数据库的一套API。这套API是交由不同的数据库厂商实现的。我们利用JDBC编写操作数据库的代码，真正执行的是各个数据库的实现类（驱动）。全称：（JavaDataBaseConnectivity）Java数据库连接。JDBC的好处面向接口编
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native