如何访问 MySQL-MGR 实例

访问 MySQL-MGR 实例时，从业务应用连接到实例有多种方式。本节介绍如何选择连接地址访问 MySQL-MGR 实例，并提供示例进行演示。

适用场景

访问方式	适用场景
集群内访问	在单主或多主模式下，集群内应用通过 SVC 暴露的端口访问 MGR 实例。
集群外访问	在单主或多主模式下，集群外应用通过 NodePort 端口访问 MGR 实例。

常用客户端程序

示例演示了使用 JDBC 和 GORM 客户端的程序，其他客户端请参考对应框架文档。

使用代码时，请将相关变量修改为实际值。变量说明如下：

变量	说明
host	对应访问方式的主机 IP 或 SVC 名称
port	对应访问方式的端口号
user	MySQL-MGR 的用户名
password	MySQL-MGR 用户的实际密码
database	访问的数据库名称

JDBC

集群内访问

import java.sql.*;
public class Main {
    static final String DB_URL = "jdbc:mysql://mgr-0:3306,mgr-1:3306,mgr-2:3306/mysql";
    static final String USER = "root";
    static final String PASS = "123456";
    public static void main(String[] args) {
        try {
            Connection conn = DriverManager.getConnection(DB_URL,USER,PASS);
            Statement statement = conn.createStatement();
        }catch(SQLException se){
            se.printStackTrace();
        }
    }
}

集群外访问 - 通过 NodePort

import java.sql.*;
public class Main {
    static final String DB_URL = "jdbc:mysql://192.168.1.100:32630,192.168.1.101:32630,192.168.1.102:32630/mysql";
    static final String USER = "root";
    static final String PASS = "123456";
    public static void main(String[] args) {
        try {
            Connection conn = DriverManager.getConnection(DB_URL,USER,PASS);
            Statement statement = conn.createStatement();
        }catch(SQLException e){
            e.printStackTrace();
        }
    }
}

GORM

集群内访问

import (
    "gorm.io/driver/mysql"
    "gorm.io/gorm"
    "gorm.io/plugin/dbresolver"
)

func main() {
    writeDSN:="root:123456@tcp(mgr-read-write:32631)/mysql"
    readDSN := "root:123456@tcp(mgr-read-only:32630)/mysql"
    db, err := gorm.Open(mysql.Open(writeDSN), &gorm.Config{})
    if err != nil {
        panic(err)
    }
    err = db.Use(dbresolver.Register(dbresolver.Config{
        Replicas:          []gorm.Dialector{mysql.Open(readDSN)},
        Policy:            dbresolver.RandomPolicy{},
        TraceResolverMode: true,
    }))
    if err != nil {
        panic(err)
    }
}

集群外访问 - 通过 NodePort

package main

import (
    "gorm.io/driver/mysql"
    "gorm.io/gorm"
    "gorm.io/plugin/dbresolver"
)

func main() {
    writeDSNs := []string{
        "root:123456@tcp(192.168.18.130:32631)/mysql",
        "root:123456@tcp(192.168.18.131:32631)/mysql",
        "root:123456@tcp(192.168.18.132:32631)/mysql",
    }
    readDSNs := []string{
        "root:123456@tcp(192.168.18.131:32630)/mysql",
        "root:123456@tcp(192.168.18.132:32630)/mysql",
        "root:123456@tcp(192.168.18.133:32630)/mysql",
    }
    db, err := gorm.Open(mysql.Open(writeDSNs[0]), &gorm.Config{})
    if err != nil {
        panic(err)
    }
    sources := make([]gorm.Dialector, 0)
    replicas := make([]gorm.Dialector, 0)
    for _, dsn := range writeDSNs {
        sources = append(sources, mysql.Open(dsn))
    }
    for _, dsn := range readDSNs {
        replicas = append(replicas, mysql.Open(dsn))
    }
    err = db.Use(dbresolver.Register(dbresolver.Config{
        Sources:           sources,
        Replicas:          replicas,
        Policy:            dbresolver.RandomPolicy{},
        TraceResolverMode: true,
    }))
    if err != nil {
        panic(err)
    }
}

#如何访问 MySQL-MGR 实例

#目录

#适用场景

#常用客户端程序

#JDBC

#GORM

如何访问 MySQL-MGR 实例

目录

适用场景

常用客户端程序

JDBC

GORM