go ssh连接mysql

package main

import (
    "database/sql"
    "fmt"
    "log"

    "golang.org/x/crypto/ssh"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    // SSH连接配置
    config := &ssh.ClientConfig{
        User: "your-username",
        Auth: []ssh.AuthMethod{
            ssh.Password("your-password"),
        },
        HostKeyCallback: ssh.InsecureIgnoreHostKey(),
    }

    // 连接到SSH服务器
    sshConn, err := ssh.Dial("tcp", "your-ssh-server:22", config)
    if err != nil {
        log.Fatalf("Failed to dial: %s", err)
    }
    defer sshConn.Close()

    // MySQL连接配置
    mysqlDSN := "your-username:your-password@tcp(your-mysql-server:3306)/your-database"

    // 通过SSH隧道连接到MySQL
    sshConn, err = ssh.NewClientConn("localhost", 3306, sshConn)
    if err != nil {
        log.Fatalf("Failed to create SSH client conn: %s", err)
    }
    defer sshConn.Close()

    // 连接到MySQL数据库
    db, err := sql.Open("mysql", mysqlDSN)
    if err != nil {
        log.Fatalf("Failed to open MySQL connection: %s", err)
    }
    defer db.Close()

    // 测试数据库连接
    err = db.Ping()
    if err != nil {
        log.Fatalf("Failed to ping MySQL: %s", err)
    }

    fmt.Println("Successfully connected to MySQL via SSH!")
}