Go语言连接外部MySQL数据库：DSN配置与GetAddrInfoW错误排查

import (
  "database/sql"
  _ "github.com/go-sql-driver/mysql" // 匿名导入MySQL驱动
  "fmt"
  "log" // 引入log包用于更专业的错误处理
)

const (
  DB_HOST = "tcp(http://thedburl.com)" // 错误：主机地址包含http协议，且多余tcp()包装
  DB_NAME = "nameofdatabase"
  DB_USER = "username"
  DB_PW   = "password"
)

func main() {
  dsn := DB_USER + ":" + DB_PW + "@" + DB_HOST + "/" + DB_NAME + "?charset=uf8" // 错误：charset拼写错误
  // ...
}

const (
  DB_HOST = "thedburl.com:3306" // 正确：直接指定主机和端口
  // 或者 DB_HOST = "127.0.0.1:3306" 如果是IP地址
  DB_NAME = "nameofdatabase"
  DB_USER = "username"
  DB_PW   = "password"
)

func main() {
  // 构建DSN，注意charset参数的正确拼写
  dsn := fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8mb4&parseTime=true&loc=Local",
                     DB_USER, DB_PW, DB_HOST, DB_NAME)
  // ...
}

db, err := sql.Open("mysql", dsn)
if err != nil {
  log.Fatalf("数据库连接初始化失败: %v", err) // 使用log.Fatalf在严重错误时退出程序
}

err = db.Ping()
if err != nil {
  log.Fatalf("无法连接到数据库: %v", err)
}
fmt.Println("成功连接到MySQL数据库！")

defer db.Close() // 确保在函数退出前关闭数据库连接

var forumTitle string
q := "SELECT title FROM forums WHERE id = ?" // 使用占位符防止SQL注入
row := db.QueryRow(q, 1) // 传入参数

err = row.Scan(&forumTitle)
if err != nil {
  if err == sql.ErrNoRows {
    fmt.Println("未找到匹配的论坛记录。")
  } else {
    log.Fatalf("查询单行数据失败: %v", err)
  }
} else {
  fmt.Printf("查询到的论坛标题: %s\n", forumTitle)
}

package main

import (
  "database/sql"
  _ "github.com/go-sql-driver/mysql"
  "fmt"
  "log"
)

const (
  // 请替换为您的实际数据库连接信息
  DB_HOST = "your_db_url.com:3306" // 正确格式：主机名或IP:端口
  // 如果数据库在本地，可以是 "127.0.0.1:3306"
  DB_NAME = "nameofdatabase"
  DB_USER = "username"
  DB_PW   = "password"
)

func main() {
  // 构建DSN字符串
  // 注意：tcp() 是协议和地址的包装，如果DB_HOST已包含端口，则格式为 tcp(host:port)
  // charSet=utf8mb4 是推荐的字符集
  // parseTime=true 允许将MySQL的DATETIME/TIMESTAMP类型解析为Go的time.Time类型
  // loc=Local 设置时区为本地时区
  dsn := fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8mb4&parseTime=true&loc=Local",
                     DB_USER, DB_PW, DB_HOST, DB_NAME)

  db, err := sql.Open("mysql", dsn)
  if err != nil {
    log.Fatalf("数据库连接初始化失败: %v", err)
  }
  defer db.Close() // 确保在main函数退出前关闭数据库连接

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

  // 示例：查询并打印一条数据
  var forumTitle string
  // 假设forums表有title字段，且id为1的记录存在
  q := "SELECT title FROM forums WHERE id = ?"
  row := db.QueryRow(q, 1) // 使用占位符传递参数

  err = row.Scan(&forumTitle)
  if err != nil {
    if err == sql.ErrNoRows {
      fmt.Println("未找到ID为1的论坛记录。")
    } else {
      log.Fatalf("查询数据失败: %v", err)
    }
  } else {
    fmt.Printf("查询到的论坛标题: %s\n", forumTitle)
  }

  // 另一个查询示例：获取所有论坛的标题（如果需要）
  // rows, err := db.Query("SELECT title FROM forums")
  // if err != nil {
  //     log.Fatalf("查询所有论坛失败: %v", err)
  // }
  // defer rows.Close()
  //
  // for rows.Next() {
  //     var title string
  //     if err := rows.Scan(&title); err != nil {
  //         log.Printf("扫描行失败: %v", err)
  //         continue
  //     }
  //     fmt.Printf("论坛标题: %s\n", title)
  // }
  // if err := rows.Err(); err != nil {
  //     log.Fatalf("遍历行时发生错误: %v", err)
  // }
}