Java 实现数据库读写分离竟如此简单？

1、介绍

2、ShardingJDBC

3、入门案例

4、测试

4.1 增加

4.2 删除

4.3 修改

4.4 查询

1、介绍

面对日益增加的系统访问量,数据库的吞吐量面临着巨大的瓶颈，可能有些服务器性能好，有些服务器的性能不好，我们就可以将数据库拆分为主库和从库，教程在这里:

(1条消息) MySQL 主从复制_一切总会归于平淡的博客-CSDN博客

主库负责处理事务性的增删改操作，从库负责处理查询操作，从而实现读写分离的操作。

通过读写分离,就可以降低单台数据库的访问压力, 提高访问效率，也可以避免单机故障。

介绍完读写分离，那我们就要想，在项目中，如何通过Java 代码来完成读写分离呢，如何在执行SELECT的时候查询从库，而在执行INSERT、UPDATE、DELETE的时候，操作主库呢？这个时候，我们就需要介绍一个新的技术 ShardingJDBC。

2、ShardingJDBC

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

Sharding-JDBC具有以下几个特点：

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

pom 依赖：

代码语言：javascript复制

<dependency>
  <groupId>org.apache.shardingsphere</groupId>
  <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
  <version>4.0.0-RC1</version>
</dependency>

接下来我们就做一个小案例，首先我们要把我们MySQL主从复制配置，教程在开篇已经提供给各位了。

3、入门案例

首先我们要在项目pom 文件中引入依赖。

代码语言：javascript复制

<dependency>
  <groupId>org.apache.shardingsphere</groupId>
  <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
  <version>4.0.0-RC1</version>
</dependency>

然后在yml 文件中配置数据源。

代码语言：javascript复制

server:
  port: 8080
spring:
  shardingsphere:
    datasource:
      names:
        master,slave # 数据源的名称master，slave是可以随意定义的，不是固定的
      # 主数据源
      master:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://192.168.231.134:3306/rw?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
        username: root
        password: root
      # 从数据源
      sla ve:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://192.168.231.134:3306/rw?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
        username: root
        password: root
    masterslave:
      # 读写分离配置
      load-balance-algorithm-type: round_robin #轮询 如果有多个从库，从库的负载均衡策略
      # 最终的数据源名称
      name: dataSource
      # 主库数据源名称
      master-data-source-name: master #主库数据库名称
      # 从库数据源名称列表，多个逗号分隔
      slave-data-source-names: slave #从库数据库名称
    props:
      sql:
        show: true #开启SQL显示，默认false
  main:
    allow-bean-definition-overriding: true # 允许如果当前项目中存在同名的bean,后定义的bean会覆盖先定义的
mybatis-plus:
  configuration:
    #在映射实体或者属性时，将数据库中表名和字段名中的下划线去掉，按照驼峰命名法映射
    map-underscore-to-camel-case: true
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  global-config:
    db-config:
      id-type: ASSIGN_ID