go连接mysql数据库的进阶使用指南

2023-11-17 12:13:00

连接MySQL数据库

Go中连接MySQL数据库非常简单，只需要导入"database/sql"包并使用"Open"函数即可。例如：

package main

import (
	"database/sql"
	"log"

	_ "github.com/go-sql-driver/mysql" //导入MySQL驱动
)

func main() {
	// 数据库连接字符串
	connectionString := "user:password@tcp(127.0.0.1:3306)/database"

	// 打开数据库连接
	db, err := sql.Open("mysql", connectionString)
	if err != nil {
		log.Fatal(err)
	}

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

	// 执行查询
	rows, err := db.Query("SELECT * FROM users")
	if err != nil {
		log.Fatal(err)
	}

	// 循环处理查询结果
	for rows.Next() {
		var id int
		var name string
		var email string

		// 扫描查询结果中的每一列
		err = rows.Scan(&id, &name, &email)
		if err != nil {
			log.Fatal(err)
		}

		// 打印查询结果
		log.Printf("ID: %d, Name: %s, Email: %s", id, name, email)
	}

	// 关闭查询结果集
	rows.Close()
}

执行查询

在Go中，可以使用"Query"函数执行SQL查询。例如，以下代码执行一个简单的查询来获取所有用户：

rows, err := db.Query("SELECT * FROM users")

查询结果存储在"rows"变量中，它是一个游标，可以逐行读取查询结果。可以使用"Next"方法来移动到下一行，并使用"Scan"方法来获取每一列的值。例如：

for rows.Next() {
	var id int
	var name string
	var email string

	err = rows.Scan(&id, &name, &email)

插入数据

可以使用"Exec"函数向数据库中插入数据。例如，以下代码插入一个新用户：

result, err := db.Exec("INSERT INTO users (name, email) VALUES (?, ?)", "John Doe", "john.doe@example.com")

"result"变量包含了插入操作影响的行数，"err"变量包含了任何错误信息。

更新数据

可以使用"Exec"函数更新数据库中的数据。例如，以下代码更新一个用户的电子邮件地址：

result, err := db.Exec("UPDATE users SET email = ? WHERE id = ?", "new.email@example.com", 1)

删除数据

可以使用"Exec"函数从数据库中删除数据。例如，以下代码删除一个用户：

result, err := db.Exec("DELETE FROM users WHERE id = ?", 1)

事务

事务可以确保一组数据库操作要么全部成功，要么全部失败。在Go中，可以使用"Begin"、"Commit"和"Rollback"函数来管理事务。例如：

// 开始事务
tx, err := db.Begin()
if err != nil {
	log.Fatal(err)
}

// 执行操作
_, err = tx.Exec("UPDATE users SET balance = balance + 100 WHERE id = ?", 1)
if err != nil {
	tx.Rollback() // 如果操作失败，回滚事务
	log.Fatal(err)
}

// 提交事务
err = tx.Commit() // 如果操作成功，提交事务
if err != nil {
	log.Fatal(err)
}