Sharding-Proxy简单应用

Sharding-Proxy简介

Sharding-Proxy是ShardingSphere的第二个产品，定位为透明化的数据库代理端，提供封装了数据库二进制协议的服务端版本，用于完成对异构语言的支持。目前先提供MySQL版本，它可以使用任何兼容MySQL协议的访问客户端(如：MySQL Command Client, MySQL Workbench等操作数据，对DBA更加友好。

向应用程序完全透明，可直接当做MySQL使用
适用于任何兼容MySQL协议的客户端

Sharding-Proxy的优势在于对异构语言的支持，以及为DBA提供可操作入口。

Sharding-Proxy使用过程：

注意事项：Sharding-Proxy 需要在JDK8的环境下使用，我在配置过程中使用JDK11启动会报错

下载Sharding-Proxy的最新发行版；
下载地址：https://archive.apache.org/dist/shardingsphere/4.1.1/apache-shardingsphere-4.1.1-sharding-proxy-bin.tar.gz

解压缩后修改conf/server.yaml和以config-前缀开头的文件，进行分片规则、读写分离规则配置
编辑%SHARDING_PROXY_HOME%\conf\config-sharding.yaml

schemaName: sharding_db
#
dataSources:
  ds_0:
    url: jdbc:mysql://localhost:3306/sharding1?serverTimezone=UTC&useSSL=false
    username: root
    password: 123456
    connectionTimeoutMilliseconds: 30000
    idleTimeoutMilliseconds: 60000
    maxLifetimeMilliseconds: 1800000
    maxPoolSize: 50
  ds_1:
    url: jdbc:mysql://localhost:3306/sharding2?serverTimezone=UTC&useSSL=false
    username: root
    password: 123456
    connectionTimeoutMilliseconds: 30000
    idleTimeoutMilliseconds: 60000
    maxLifetimeMilliseconds: 1800000
    maxPoolSize: 50

shardingRule:
  tables:
    position:
      actualDataNodes: ds_${
     0..1}.position
      databaseStrategy:
        inline:
          shardingColumn: id
          algorithmExpression: ds_${
     id % 2}
      keyGenerator:
        type: SNOWFLAKE
        column: id

编辑%SHARDING_PROXY_HOME%\conf\server.yaml

引入依赖jar
如果后端连接MySQL数据库，需要下载MySQL驱动，解压缩后将mysql-connector-java-5.1.49.jar拷贝到${sharding-proxy}\lib目录。
如果后端连接PostgreSQL数据库，不需要引入额外依赖。
Linux操作系统请运行bin/start.sh，Windows操作系统请运行bin/start.bat启动Sharding-Proxy。
使用默认配置启动：${sharding-proxy}\bin\start.sh

配置端口启动： ${sharding-proxy}\\bin\\start.sh$ {port}
使用客户端工具连接。如: mysql -h 127.0.0.1 -P 3307 -u root -p root

结合springboot使用

创建工程
基于之前使用的工程，新建一个子工程sharding-proxy-example

改破pom文件

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>

    </dependencies>

yaml配置文件

spring:
  datasource:
    url: jdbc:mysql://192.168.137.144:3307/sharding_db?useSSL=false&amp;characterEncoding=UTF-8
    password: root
    username: root
    driver-class-name: com.mysql.jdbc.Driver

实体类

@Entity
@Table(name = "position")
public class Position {
     
    @Id
    @Column(name = "id")
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(name = "name")
    private String name;

    @Column(name = "city")
    private String city;

    @Column(name = "salary")
    private Integer salary;

    public Long getId() {
     
        return id;
    }

    public void setId(Long id) {
     
        this.id = id;
    }

    public String getName() {
     
        return name;
    }

    public void setName(String name) {
     
        this.name = name;
    }

    public String getCity() {
     
        return city;
    }

    public void setCity(String city) {
     
        this.city = city;
    }

    public Integer getSalary() {
     
        return salary;
    }

    public void setSalary(Integer salary) {
     
        this.salary = salary;
    }
}

repository资源类

public interface PositionRepository extends JpaRepository<Position, Long> {
     
}

启动类

@SpringBootApplication()
public class RunBoot {
     
}

测试类

import com.elvis.pojo.Position;
import com.elvis.repository.PositionRepository;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

import javax.annotation.Resource;
import java.util.List;

/**
 * @program: shardingsphere-study
 * @Description
 * @author Elvis
 * @date 2021-07-28 7:31    
 */
@SpringBootTest
public class TestProxy {
     
    @Resource
    private PositionRepository positionRepository;


    @Test
    public void test1() {
     
        List<Position> list = positionRepository.findAll();
        list.forEach(position -> {
     
            System.out.println(position.getId() + " " + position.getName() + " " + position.getSalary());
        });
    }

    @Test
    public void test2() {
     
        Position position = new Position();
        position.setName("tiger");
        position.setSalary(30000);
        position.setCity("shanghai");
        positionRepository.save(position);
    }

}

原文链接: https://blog.csdn.net/Kiven_ch/article/details/119155127

Sharding-Proxy简介

Sharding-Proxy使用过程：

结合springboot使用

目录