golang 数据库操作类

在现代软件开发中，数据库操作是必不可少的一部分。而对于Golang开发者来说，如何高效地操作数据库也是一项重要的技能。本文将介绍基于Golang的数据库操作类，帮助开发者更方便地完成与数据库的交互。

连接数据库

Golang提供了多种方式来连接数据库，最常用的是使用第三方库。其中，Golang官方推荐的库是database/sql。可以通过`Open`函数创建一个数据库连接对象，代码示例如下：

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

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

执行查询

数据库操作的核心之一就是执行查询语句。Golang提供了`Query`和`QueryRow`两个函数来执行查询，并且返回结果集或单行数据。以下是使用`Query`函数执行查询的示例代码：

rows, err := db.Query("SELECT * FROM users WHERE age > ?", 18)
if err != nil {
    panic(err.Error())
}
defer rows.Close()

for rows.Next() {
    var id int
    var name string
    var age int
    err := rows.Scan(&id, &name, &age)
    if err != nil {
        panic(err.Error())
    }
    fmt.Println(id, name, age)
}

上述代码中，首先使用`Query`函数执行查询语句，然后使用`Scan`方法将查询结果映射到变量中，最后通过循环遍历输出结果。

执行插入、更新和删除操作

除了查询操作，数据库操作还包括插入、更新和删除等操作。Golang的database/sql库提供了`Exec`函数来执行这些操作，示例如下：

// 插入操作
result, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)", "Alice", 20)
if err != nil {
    panic(err.Error())
}
affectedRows, err := result.RowsAffected()
if err != nil {
    panic(err.Error())
}
fmt.Println("插入成功，影响的行数：", affectedRows)

// 更新操作
result, err := db.Exec("UPDATE users SET age = ? WHERE id = ?", 21, 1)
if err != nil {
    panic(err.Error())
}
affectedRows, err := result.RowsAffected()
if err != nil {
    panic(err.Error())
}
fmt.Println("更新成功，影响的行数：", affectedRows)

// 删除操作
result, err := db.Exec("DELETE FROM users WHERE id = ?", 1)
if err != nil {
    panic(err.Error())
}
affectedRows, err := result.RowsAffected()
if err != nil {
    panic(err.Error())
}
fmt.Println("删除成功，影响的行数：", affectedRows)

上述代码中，分别使用`Exec`函数执行插入、更新和删除操作，并通过`RowsAffected`方法获取受影响的行数。

通过本文的介绍，你已经了解了基于Golang的数据库操作类的用法，包括连接数据库、执行查询以及执行插入、更新和删除操作。希望这些内容对你在Golang开发中的数据库操作有所帮助。