MySQL go连接MySQL

1. 引言

MySQL是一个开源的关系型数据库管理系统，被广泛应用于各种Web应用和数据存储需求中。而Go是一门开源的编程语言，具有并发性能强、静态类型检查、垃圾回收等特点，被越来越多的开发者选用。本文将详细介绍如何使用Go连接MySQL数据库，包括安装依赖、连接数据库、执行SQL语句等操作。

2. 安装依赖

在开始之前，我们需要安装Go语言和MySQL驱动程序。使用以下命令可以安装Go语言：

$ sudo apt-get install golang

然后，我们需要安装MySQL驱动程序。在Go语言中，go-sql-driver是最流行的MySQL驱动，可以使用以下命令进行安装：

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

3. 连接数据库

接下来，我们需要在Go代码中导入database/sql和github.com/go-sql-driver/mysql两个包，用于连接和操作MySQL数据库。

package main

import (
    "database/sql"
    "fmt"

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

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

    err = db.Ping()
    if err != nil {
        panic(err.Error())
    }

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

在上述示例代码中，我们通过调用sql.Open()函数来连接MySQL数据库。其中，第一个参数为驱动名称，第二个参数为数据库连接字符串，格式为用户名:密码@tcp(主机:端口)/数据库名。在连接成功后，我们使用db.Ping()函数来测试与数据库的连接是否正常，如果不正常会抛出异常。

4. 执行SQL语句

连接数据库成功后，我们就可以执行各种SQL语句（如查询、插入、更新、删除等）。下面是一些常用的示例代码：

查询数据

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

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

err = rows.Err()
if err != nil {
    panic(err.Error())
}

在以上示例中，我们执行了一个简单的SELECT查询语句，并通过循环遍历返回的结果集。使用rows.Scan()函数将结果集中的每一行数据分别赋值给变量。

插入数据

stmt, err := db.Prepare("INSERT INTO users(name) VALUES(?)")
if err != nil {
    panic(err.Error())
}
defer stmt.Close()

result, err := stmt.Exec("Alice")
if err != nil {
    panic(err.Error())
}

affectedRows, _ := result.RowsAffected()
lastInsertID, _ := result.LastInsertId()

fmt.Println("受影响的行数:", affectedRows)
fmt.Println("最后插入的ID:", lastInsertID)

在以上示例中，我们使用db.Prepare()函数准备一个INSERT语句，并将参数占位符?用于插入数据。然后，使用stmt.Exec()函数执行准备好的语句，并获得执行结果。通过result.RowsAffected()可以获取受影响的行数，通过result.LastInsertId()可以获取最后插入的ID。

更新数据

stmt, err := db.Prepare("UPDATE users SET name=? WHERE id=?")
if err != nil {
    panic(err.Error())
}
defer stmt.Close()

result, err := stmt.Exec("Bob", 1)
if err != nil {
    panic(err.Error())
}

affectedRows, _ := result.RowsAffected()

fmt.Println("受影响的行数:", affectedRows)

在以上示例中，我们使用db.Prepare()函数准备一个UPDATE语句，将?占位符用于更新数据。然后，通过stmt.Exec()函数执行准备好的语句，并获得执行结果。使用result.RowsAffected()可以获取受影响的行数。