Go语言连接MySQL数据库：权限配置与常见问题解决指南

Error 1045: Access denied for user 'bankadmin'@'localhost' (using password: YES)

id    : 0
name  :
email :

mysql -u root -p

SELECT user, host FROM mysql.user;
SHOW GRANTS FOR 'bankadmin'@'localhost';
SHOW GRANTS FOR 'bankadmin'@'127.0.0.1';
SHOW GRANTS FOR 'bankadmin'@'%';

-- 授予 bankadmin 用户从 'localhost' 连接到 bankdata 数据库的所有权限
-- 注意：'localhost' 和 '127.0.0.1' 在某些MySQL配置中可能被视为不同。
-- 建议同时为 '127.0.0.1' 授予权限，以确保通过TCP连接时不会被拒绝。
GRANT ALL PRIVILEGES ON bankdata.* TO 'bankadmin'@'localhost' IDENTIFIED BY '1234';
GRANT ALL PRIVILEGES ON bankdata.* TO 'bankadmin'@'127.0.0.1' IDENTIFIED BY '1234';

-- 授予 bankadmin 用户从任何主机 ('%') 连接到 bankdata 数据库的所有权限
GRANT ALL PRIVILEGES ON bankdata.* TO 'bankadmin'@'%' IDENTIFIED BY '1234';

FLUSH PRIVILEGES;

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql" // 导入MySQL驱动，下划线表示只导入包进行初始化，不直接使用其导出标识符
    "log"
)

const (
    DB_HOST = "127.0.0.1:3306" // 直接指定IP和端口，无需"tcp()"
    DB_NAME = "bankdata"
    DB_USER = "bankadmin"
    DB_PASS = "1234"
)

type Account struct {
    ID       int
    Username string
    Email    sql.NullString // 使用sql.NullString处理可空字段
    Facebook sql.NullString
    Twitter  sql.NullString
}

func main() {
    // 构建DSN (Data Source Name)
    // 格式：username:password@tcp(host:port)/dbname?charset=utf8
    dsn := fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8", DB_USER, DB_PASS, DB_HOST, DB_NAME)

    // 打开数据库连接
    // sql.Open 不会立即建立连接，它只是验证参数并返回一个DB对象。
    // 实际连接会在第一次需要时建立（如执行Query或Exec）。
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatalf("无法打开数据库连接: %v", err) // 使用Fatalf在错误发生时退出程序
    }
    defer db.Close() // 确保在函数退出时关闭数据库连接

    // 尝试ping数据库以验证连接是否成功
    err = db.Ping()
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    fmt.Println("成功连接到MySQL数据库！")

    // 查询单个用户数据
    var user Account
    query := "SELECT id, username, email, facebook, twitter FROM accounts WHERE id = ?"
    row := db.QueryRow(query, 1) // 使用占位符防止SQL注入

    // 扫描结果到结构体
    err = row.Scan(&user.ID, &user.Username, &user.Email, &user.Facebook, &user.Twitter)
    if err != nil {
        if err == sql.ErrNoRows {
            log.Printf("ID为1的用户未找到")
        } else {
            log.Fatalf("扫描查询结果失败: %v", err)
        }
    } else {
        fmt.Printf("查询结果：\n")
        fmt.Printf("ID: %d\n", user.ID)
        fmt.Printf("用户名: %s\n", user.Username)
        fmt.Printf("邮箱: %s\n", user.Email.String) // 访问NullString的String字段
        fmt.Printf("Facebook: %s\n", user.Facebook.String)
        fmt.Printf("Twitter: %s\n", user.Twitter.String)
    }

    // 针对 mymysql 驱动的空结果问题：
    // 如果 `mymysql` 驱动仍然返回空结果，除了权限问题外，还需检查：
    // 1. `Scan` 方法的参数数量和类型是否与 `SELECT` 语句中的列完全匹配。
    //    原始 `UserById` 函数中 `SELECT id, username, email` 却 `Scan` 了四个字段，会导致错误。
    //    确保 `row.Scan(&user.Id, &user.Username, &user.Email, &user.Facebook)` 与 `SELECT id, username, email, facebook` 对应。
    // 2. 查询条件是否正确，例如 `WHERE id=2` 是否能匹配到数据。
    // 3. 确认数据库连接字符串格式是否正确，`mymysql` 的格式是 `dbname/user/password`。
    //    例如：`sql.Open("mymysql", "bankdata/bankadmin/1234")`
}