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)

  // }

}