在Golang中高效执行MySQL跨数据库JOIN操作

SELECT
    db1.users.username
FROM
    db1.users
JOIN
    db2.comments
    ON db1.users.id = db2.comments.username_id;

package main

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

    _ "github.com/go-sql-driver/mysql" // 导入MySQL驱动
)

func main() {
    // 数据库连接字符串
    // 假设MySQL服务器运行在localhost:3306，用户名为root，密码为password
    // 并且服务器上有db1和db2两个数据库
    // 注意：连接字符串中通常不需要指定具体的数据库名，因为我们将通过SQL语句指定
    dsn := "root:password@tcp(127.0.0.1:3306)/?charset=utf8mb4&parseTime=True&loc=Local"

    // 建立数据库连接
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    defer db.Close() // 确保在函数结束时关闭数据库连接

    // 验证数据库连接
    err = db.Ping()
    if err != nil {
        log.Fatalf("数据库连接失败: %v", err)
    }
    fmt.Println("成功连接到MySQL服务器！")

    // 假设我们要查询的用户ID
    targetUserID := 123

    // 声明用于存储查询结果的变量
    var username string
    var commentContent string // 假设我们也要获取评论内容

    // 构建跨数据库的JOIN查询语句
    // 注意：这里使用了db1.users和db2.comments来指定表所在的数据库
    query := `
        SELECT
            db1.users.username,
            db2.comments.content -- 假设comments表有一个content字段
        FROM
            db1.users
        JOIN
            db2.comments
            ON db1.users.id = db2.comments.username_id
        WHERE
            db1.users.id = ?` // 使用占位符防止SQL注入

    // 执行查询
    err = db.QueryRow(query, targetUserID).Scan(&username, &commentContent)

    switch {
    case err == sql.ErrNoRows:
        log.Printf("未找到ID为 %d 的用户或其相关评论。", targetUserID)
    case err != nil:
        log.Fatalf("查询执行失败: %v", err)
    default:
        fmt.Printf("用户ID: %d, 用户名: %s, 最新评论: %s\n", targetUserID, username, commentContent)
    }

    // 示例：如果需要查询多行结果
    fmt.Println("\n--- 查询所有用户及其评论 ---")
    rows, err := db.Query(`
        SELECT
            db1.users.id,
            db1.users.username,
            db2.comments.content
        FROM
            db1.users
        JOIN
            db2.comments
            ON db1.users.id = db2.comments.username_id
    `)
    if err != nil {
        log.Fatalf("查询所有用户评论失败: %v", err)
    }
    defer rows.Close()

    for rows.Next() {
        var userID int
        var user string
        var comment string
        if err := rows.Scan(&userID, &user, &comment); err != nil {
            log.Printf("扫描行失败: %v", err)
            continue
        }
        fmt.Printf("用户ID: %d, 用户名: %s, 评论: %s\n", userID, user, comment)
    }
    if err = rows.Err(); err != nil {
        log.Fatalf("迭代行时发生错误: %v", err)
    }
}