前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Go 语言操作 MySQL 之 事务操作

Go 语言操作 MySQL 之 事务操作

作者头像
Meng小羽
修改2020-07-04 15:34:36
1.3K0
修改2020-07-04 15:34:36
举报
文章被收录于专栏:Debug客栈

事务

数据库事务( transaction )是访问并可能操作各种数据项的一个数据库操作序列,这些操作要么全部执行,要么全部不执行,是一个不可分割的工作单位。 事务由事务开始与事务结束之间执行的全部数据库操作组成。

MySQL 存储引擎分类有 MyISAM、InnoDB、Memory、Merge等,但是其中最为常用的就是 MyISAM 和 InnoDB 两个引擎,这两个引擎中,支持事务的引擎就是 Innodb(MySQL 默认引擎),在创建数据库中要注意对应引擎。

这里可以看一下针对 MySQL 选择引擎的文章:

事务 ACID

通常事务必须满足4个条件( ACID ):原子性(Atomicity,或称不可分割性)、一致性(Consistency)、隔离性(Isolation,又称独立性)、持久性(Durability)。

条件

解释

原子性

一个事务(transaction)中的所有操作,要么全部完成,要么全部不完成,不会结束在中间某个环节。事务在执行过程中发生错误,会被回滚(Rollback)到事务开始前的状态,就像这个事务从来没有执行过一样。

一致性

在事务开始之前和事务结束以后,数据库的完整性没有被破坏。这表示写入的资料必须完全符合所有的预设规则,这包含资料的精确度、串联性以及后续数据库可以自发性地完成预定的工作。

隔离性

数据库允许多个并发事务同时对其数据进行读写和修改的能力,隔离性可以防止多个事务并发执行时由于交叉执行而导致数据的不一致。事务隔离分为不同级别,包括读未提交(Read uncommitted)、读提交(read committed)、可重复读(repeatable read)和串行化(Serializable)。

持久性

事务处理结束后,对数据的修改就是永久的,即便系统故障也不会丢失。

Go 操作 MySQL 使用事务

Go语言中使用以下三个方法实现MySQL中的事务操作:

代码语言:javascript
复制
// 开始事务
func (db *DB) Begin() (*Tx, error)
// 回滚事务
func (tx *Tx) Rollback() error
// 提交事务
func (tx *Tx) Commit() error

示例代码:

代码语言:javascript
复制
// 事务更新操作
func transActionUpdate() {
	tx, err := db.Begin()
	if err != nil {
		if tx != nil {
			_ = tx.Rollback()
		}
		fmt.Printf("begin trans action failed, err:%v\n", err)
		return
	}
	sqlStr1 := "UPDATE user SET age = ? WHERE id = ?"
	result1, err := tx.Exec(sqlStr1, 20, 1)
	if err != nil {
		_ = tx.Rollback()
		fmt.Printf("exec failed, err:%v\n", err)
		return
	}
	n1, err := result1.RowsAffected()
	if err != nil {
		_ = tx.Rollback()
		fmt.Printf("exec result1.RowsAffected() failed, err:%v\n", err)
		return
	}
	sqlStr2 := "UPDATE user SET age = ? WHERE id = ?"
	result2, err := tx.Exec(sqlStr2, 20, 6)
	if err != nil {
		_ = tx.Rollback()
		fmt.Printf("exec failed, err:%v\n", err)
		return
	}
	n2, err := result2.RowsAffected()
	if err != nil {
		_ = tx.Rollback()
		fmt.Printf("exec result1.RowsAffected() failed, err:%v\n", err)
		return
	}

	if n1 == 1 && n2 == 1 {
		_ = tx.Commit()
		fmt.Printf("transaction commit success\n")
	} else {
		_ = tx.Rollback()
		fmt.Printf("transaction commit error, rollback\n")
		return
	}
}

参考(学习)文章:Go语言操作MySQL – 李文周的个人博客

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 事务
  • 事务 ACID
  • Go 操作 MySQL 使用事务
相关产品与服务
云数据库 SQL Server
腾讯云数据库 SQL Server (TencentDB for SQL Server)是业界最常用的商用数据库之一,对基于 Windows 架构的应用程序具有完美的支持。TencentDB for SQL Server 拥有微软正版授权,可持续为用户提供最新的功能,避免未授权使用软件的风险。具有即开即用、稳定可靠、安全运行、弹性扩缩等特点。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档