当前位置：首页 > news >正文

Go 语言中，golang结合 PostgreSQL 、MySQL驱动开启数据库事务

news 2025/6/29 3:36:54

Go 语言中，golang结合 PostgreSQL 、MySQL驱动开启数据库事务

PostgreSQL
- - 代码说明：
MySQL
- - 代码说明：

PostgreSQL

在 Go 语言中，使用 database/sql 包结合 PostgreSQL 驱动（如 github.com/lib/pq）可以方便地开启和管理数据库事务。
以下是一个示例，展示了如何在 PostgreSQL 中开启一个事务、执行一些操作，并在最后提交或回滚事务。

package mainimport ("database/sql""fmt""log"_ "github.com/lib/pq" // 使用 PostgreSQL 驱动
)func main() {// 连接到数据库connStr := "user=username dbname=mydb password=mypassword host=localhost sslmode=disable"db, err := sql.Open("postgres", connStr)if err != nil {log.Fatal(err)}defer db.Close()// 开始一个事务tx, err := db.Begin()if err != nil {log.Fatal(err)}// 执行一些数据库操作_, err = tx.Exec("INSERT INTO users (name) VALUES ($1)", "x302")if err != nil {// 如果出错，回滚事务tx.Rollback()log.Fatal(err)}_, err = tx.Exec("INSERT INTO users (name) VALUES ($1)", "nw10999")if err != nil {// 如果出错，回滚事务tx.Rollback()log.Fatal(err)}// 提交事务err = tx.Commit()if err != nil {log.Fatal(err)}fmt.Println("事务已成功提交")
}

代码说明：

连接数据库：使用 sql.Open 连接到 PostgreSQL 数据库，连接字符串中包含用户名、数据库名、密码和主机信息。
开启事务：调用 db.Begin() 开始一个新的事务。
执行操作：使用 tx.Exec 执行 SQL 语句，注意使用 $1 作为参数占位符。
错误处理：如果在执行过程中发生错误，调用 tx.Rollback() 回滚事务。
提交事务：如果所有操作成功，调用 tx.Commit() 提交事务。

确保在使用前安装 PostgreSQL 驱动，例如 github.com/lib/pq。

MySQL

在 Go 语言中，使用 database/sql 包可以很方便地开启和管理MySQL数据库事务。
以下是一个简单的示例，展示了如何开启一个数据库事务、执行一些操作，并在最后提交或回滚事务。

package mainimport ("database/sql""fmt""log"_ "github.com/go-sql-driver/mysql" // 使用 MySQL 驱动
)func main() {// 连接到数据库db, err := sql.Open("mysql", "user:password@/dbname")if err != nil {log.Fatal(err)}defer db.Close()// 开始一个事务tx, err := db.Begin()if err != nil {log.Fatal(err)}// 执行一些数据库操作_, err = tx.Exec("INSERT INTO users (name) VALUES (?)", "X302")if err != nil {// 如果出错，回滚事务tx.Rollback()log.Fatal(err)}_, err = tx.Exec("INSERT INTO users (name) VALUES (?)", "nw10999")if err != nil {// 如果出错，回滚事务tx.Rollback()log.Fatal(err)}// 提交事务err = tx.Commit()if err != nil {log.Fatal(err)}fmt.Println("事务已成功提交")
}