golang如何查询mysql，高效查询MySQL的Golang实践

Golang如何高效查询MySQL数据库：从基础到实践
在Golang中查询MySQL数据库，主要通过标准库database/sql配合MySQL驱动（如github.com/go-sql-driver/mysql）实现，核心步骤包括连接数据库、执行SQL语句、处理结果集，以下是具体操作指南：

1. 安装驱动与导入包
   首先使用go get安装MySQL驱动：

   

   go get -u github.com/go-sql-driver/mysql

   在代码中导入必要包：

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

2. 建立数据库连接
   使用sql.Open()初始化连接池，需传入数据源名称（DSN），格式为"用户名:密码@协议(地址:端口)/数据库名"：

   db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
   if err != nil {
       panic(err.Error())
   }
   defer db.Close()

   注意：sql.Open()不会立即验证连接，实际连接在首次查询时建立。

3. 执行查询语句

   • 查询多行数据：使用db.Query()，通过rows.Next()遍历结果：

     rows, err := db.Query("SELECT id, name FROM users WHERE age > ?", 18)
     if err != nil {
         log.Fatal(err)
     }
     defer rows.Close()
     for rows.Next() {
         var id int
         var name string
         err = rows.Scan(&id, &name)
         // 处理数据
     }

   • 查询单行数据：使用db.QueryRow()直接获取结果：

     var name string
     err := db.QueryRow("SELECT name FROM users WHERE id = ?", 1).Scan(&name)

   • 执行非查询操作（如INSERT/UPDATE）：使用db.Exec()：

     result, err := db.Exec("INSERT INTO users(name) VALUES (?)", "John")

4. 关键注意事项

   • 参数化查询：务必使用占位符传递参数，避免SQL注入风险。
   • 连接管理：合理配置连接池参数（如SetMaxOpenConns()），以提升高并发性能。
   • 错误处理：每次操作后检查错误，并确保及时释放资源（如调用rows.Close()）。
   • 结果解析：Scan()方法需按查询列顺序传入对应变量指针，类型需匹配。

5. 进阶实践
   结合ORM库（如GORM）可简化复杂查询：

   // 使用GORM示例
   var users []User
   db.Where("age > ?", 18).Find(&users)

通过以上步骤,开发者可以灵活运用Golang实现安全高效的MySQL数据查询。重点在于规范使用连接池、坚持参数化查询，并合理处理资源释放，以确保应用的稳定性和性能。