MySQL go语言操作mysql数据库

MySQL是一种流行的关系型数据库管理系统，而Go语言作为一种高效、并发、简洁的编程语言，也提供了丰富的库来操作MySQL数据库。本文将详细介绍如何使用Go语言来连接、查询、插入、更新和删除MySQL数据库。具体内容将围绕以下几个主题展开：

准备工作
连接数据库
查询数据
插入数据
更新数据
删除数据

1. 准备工作

在使用Go语言操作MySQL数据库之前，我们首先需要安装并配置MySQL服务器。选择适合您操作系统的MySQL版本并完成安装。安装完成后，我们还需要创建一个数据库和一张表，以便后续的操作。

以MySQL 8.0为例，我们可以使用以下SQL语句来创建一个数据库和一张表：

CREATE DATABASE mydb;
USE mydb;
CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(255),
    age INT
);

2. 连接数据库

连接数据库是使用Go语言操作MySQL的第一步。可以使用database/sql包提供的Open函数来创建一个数据库连接。示例代码如下：

package main

import (
    "database/sql"
    "fmt"
    "log"

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

func main() {
    // 创建数据库连接
    db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/mydb")

    // 检查连接错误
    if err != nil {
        log.Fatal(err)
    }

    // 尝试连接数据库
    err = db.Ping()
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("数据库连接成功")

    // 关闭数据库连接
    defer db.Close()
}

运行以上代码，如果能打印出”数据库连接成功”，则表示连接成功。

3. 查询数据

一旦连接成功，我们就可以执行SQL查询语句来获取数据库中的数据。下面是一个简单的例子，展示如何查询用户表中的所有数据，并将结果打印到控制台。

func queryData(db *sql.DB) {
    // 执行查询语句
    rows, err := db.Query("SELECT * FROM users")
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()

    // 遍历结果集
    for rows.Next() {
        var id int
        var name string
        var age int
        err := rows.Scan(&id, &name, &age)
        if err != nil {
            log.Fatal(err)
        }
        fmt.Printf("ID: %d, Name: %s, Age: %d\n", id, name, age)
    }

    err = rows.Err()
    if err != nil {
        log.Fatal(err)
    }
}

func main() {
    // 创建数据库连接
    // ...

    // 查询数据
    queryData(db)

    // 关闭数据库连接
    // ...
}

运行以上代码，将会输出用户表中的所有数据。

4. 插入数据

除了查询数据，我们还可以通过执行SQL语句来插入新的数据。以下是一个示例代码，演示如何向用户表中插入一条新的数据。

func insertData(db *sql.DB) {
    // 准备插入语句
    stmt, err := db.Prepare("INSERT INTO users (name, age) VALUES (?, ?)")
    if err != nil {
        log.Fatal(err)
    }
    defer stmt.Close()

    // 执行插入语句
    result, err := stmt.Exec("Alice", 25)
    if err != nil {
        log.Fatal(err)
    }

    // 获取插入成功的记录数
    rowsAffected, err := result.RowsAffected()
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("插入成功", rowsAffected, "条记录")
}

func main() {
    // 创建数据库连接
    // ...

    // 插入数据
    insertData(db)

    // 关闭数据库连接
    // ...
}

运行以上代码后，将会在用户表中插入一条新的数据。

5. 更新数据

如果需要更新数据库中的数据，可以使用Exec函数执行UPDATE语句。以下是一个示例代码，演示如何更新用户表中特定用户的年龄。

func updateData(db *sql.DB) {
    // 准备更新语句
    stmt, err := db.Prepare("UPDATE users SET age = ? WHERE id = ?")
    if err != nil {
        log.Fatal(err)
    }
    defer stmt.Close()

    // 执行更新语句
    result, err := stmt.Exec(26, 1)
    if err != nil {
        log.Fatal(err)
    }

    // 获取更新成功的记录数
    rowsAffected, err := result.RowsAffected()
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("更新成功", rowsAffected, "条记录")
}

func main() {
    // 创建数据库连接
    // ...

    // 更新数据
    updateData(db)

    // 关闭数据库连接
    // ...
}

运行以上代码，将会更新用户表中ID为1的用户的年龄。

6. 删除数据

如果需要删除数据库中的数据，可以使用Exec函数执行DELETE语句。以下是一个示例代码，演示如何删除用户表中特定用户。

func deleteData(db *sql.DB) {
    // 准备删除语句
    stmt, err := db.Prepare("DELETE FROM users WHERE id = ?")
    if err != nil {
        log.Fatal(err)
    }
    defer stmt.Close()

    // 执行删除语句
    result, err := stmt.Exec(1)
    if err != nil {
        log.Fatal(err)
    }

    // 获取删除成功的记录数
    rowsAffected, err := result.RowsAffected()
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("删除成功", rowsAffected, "条记录")
}

func main() {
    // 创建数据库连接
    // ...

    // 删除数据
    deleteData(db)

    // 关闭数据库连接
    // ...
}

运行以上代码，将会删除用户表中ID为1的用户。