golang如何优雅的编写事务代码示例

2024-10-23 01:09:36

前言

新手程序员大概有如下特点

if嵌套经常超过3层、经常出现重复代码、单个函数代码特别长。
只会crud，对语言特性和语言的边界不了解。
不懂面向对象原则和设计模式，以为copy代码就算学会了，常见的是代码职责不明确或者写出万能类
不知道数据结构和算法的重要性，以为靠硬件能解决运行慢的问题
架构不懂，搭建框架不会，搭建环境不会，使用的软件底层原理一问三不知

其实吧，很多人干了很多年，看似是老手，平时工作看似很忙，其实做的都是最简单的活。
这就像去锻炼，有的人每天练的很积极，准时打卡，频繁发朋友圈，貌似是正能量，结果是几年下来体型还是那样，该减的肥肉没少，要增的肌肉没加，为什么会这样？因为从来都是挑最简单最轻松的练

貌似吐槽多了，下面演示一下如何将一坨烂事务代码重构得优雅

需求

执行一个事务，需要调用one、two、three、four、five几个方法，任意一个方法失败，都回滚事务
下面是这些方法的简单模拟，我们用尽可能少的代码模拟一个操作

//开启事务
func beginTransaction() {
 fmt.Println("beginTransaction")
}

//回滚事务
func rollback() {
 fmt.Println("rollback")
}

//提交事务
func commit() {
 fmt.Println("commit")
}

//执行one操作
func one() (err error) {
 fmt.Println("one ok")
 return nil
}

//执行two操作
func two() (err error) {
 fmt.Println("two ok")
 return nil
}

//执行three操作
func three() (err error) {
 fmt.Println("two ok")
 return nil
}

//执行four操作
func four() (err error) {
 fmt.Println("four ok")
 return nil
}

//执行five操作
func five() (err error) {
 err = errors.New("five panic")
 panic("five")
 return err
}

烂代码示例

下面演示开启一个事务，依次执行one、two、three、four、five 5个操作，前四个成功，第五个失败

这是新手程序员常见使用事务的代码风格，其实也不光是事务，所有的代码都可能长下边这样

func demo() (err error) {
 beginTransaction()
 defer func() {
 if e := recover(); e != nil {
  err = fmt.Errorf("%v", e)
  fmt.Printf("%v panic\n", e)
  rollback()
 }
 }()
 if err = one(); err == nil {
 if err = two(); err == nil {
  if err = three(); err == nil {
  if err = four(); err == nil {
   if err = five(); err == nil {
   commit()
   return nil
   } else {
   rollback()
   return err
   }
  } else {
   rollback()
   return err
  }
  } else {
  rollback()
  return err
  }
 } else {
  rollback()
  return err
 }
 } else {
 rollback()
 return err
 }
}

重构套路

一、提前return去除if嵌套

通过提前返回error，来去掉一些else代码，减少嵌套，如下

代码

func demo() (err error) {
 beginTransaction()
 defer func() {
 if e := recover(); e != nil {
  err = fmt.Errorf("%v", e)
  fmt.Printf("%v panic\n", e)
  rollback()
 }
 }()
 if err = one(); err != nil {
 rollback()
 return err
 }
 if err = two(); err != nil {
 rollback()
 return err
 }
 if err = three(); err != nil {
 rollback()
 return err
 }

 if err = four(); err != nil {
 rollback()
 return err
 }
 if err = five(); err != nil {
 rollback()
 return err
 }
 commit()
 return nil
}

先解决嵌套

二、goto+label提取重复代码

代码

func demo() (err error) {
 beginTransaction()
 defer func() {
 if e := recover(); e != nil {
  err = fmt.Errorf("%v", e)
  fmt.Printf("%v panic\n", e)
  rollback()
 }
 }()
 if err = one(); err != nil {
 goto ROLLBACK
 }
 if err = two(); err != nil {
 goto ROLLBACK
 }
 if err = three(); err != nil {
 goto ROLLBACK
 }
 if err = four(); err != nil {
 goto ROLLBACK
 }
 if err = five(); err != nil {
 goto ROLLBACK
 }
 commit()
 return nil
ROLLBACK:
 rollback()
 return err
}

三、封装try-catch统一捕获panic

上面的代码其实还有一点问题

defer里有rollback的代码
goto虽然好，但是不建议使用

我们可以对panic和defer进行封装，模拟一下try-catch，实现如下

可以看到，rollback只调用了一次，完美的进行了事务代码重构

try-catch.go代码

package exception

type Block struct {
 Try func()
 Catch func(interface{})
 Finally func()
}

func (t Block) Do() {
 if t.Finally != nil {
 defer t.Finally()
 }
 if t.Catch != nil {
 defer func() {
  if r := recover(); r != nil {
  t.Catch(r)
  }
 }()
 }
 t.Try()
}

使用代码

	exception.Block{
		Try: func() {
			beginTransaction()
			if err = one(); err != nil {
				panic(err)
			}
			if err = two(); err != nil {
				panic(err)
			}
			if err = three(); err != nil {
				panic(err)
			}
			if err = four(); err != nil {
				panic(err)
			}
			if err = five(); err != nil {
				panic(err)
			}
			err = nil
			commit()
		},
		Catch: func(e interface{}) {
			rollback()
			fmt.Printf("%v panic\n", e)
			err = fmt.Errorf("%v", e)
		},
	}.Do()
	return err
}

这样，我们就可以用非常少的代码实现事务，并且简单清晰好维护，以上为chenqionghe原创，light weight baby

到此这篇关于golang如何优雅的编写事务代码示例的文章就介绍到这了,更多相关golang 编写事务内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

ThinkPHP实现事务回滚示例代码

ThinkPHP的事务回滚示例如下: $m=D('YourModel');//或者是M(); $m2=D('YouModel2'); $m->startTrans();//在第一个模型里启用就可以了,或者第二个也行 $result=$m->where('删除条件')->delete(); $result2=m2->where('删除条件')->delete(); if($result && $result2){ $m->commit();//成功则提交
php中在PDO中使用事务(Transaction)

并且在执行的过程中, 如果其中的某条执行失败, 可以回滚所有已更改的操作. 如果执行成功, 那么这一系列操作都会永久有效. 事务很好的解决了在操作数据库的时候不同步的问题. 同时, 通过事务去执行大数据量的时候, 执行效率可以提高很多很多. 在 PDO 中, 事务已经显得非常简单. 下面一个基本的例子, 演示了向 SQLite 数据库插入 1000000 条数据, 并且在出错的时候回滚. 复制代码代码如下: try { $conn = new PDO('sqlite:Transactioion
Mysql中的事务是什么如何使用

什么是事务? 事务是逻辑上的一组操作,组成这组操作的各个单元,要不全都成功要不全都失败,这个特性就是事务注意:mysql数据支持事务,但是要求必须是innoDB存储引擎解决这个问题: mysql的事务解决这个问题,因为mysql的事务特性,要求这组操作,要不全都成功,要不全都失败,这样就避免了某个操作成功某个操作失败.利于数据的安全如何使用: (1)在执行sql语句之前,我们要开启事务 start transaction; (2)正常执行我们的sql语句 (3)当sql语句执行完毕,存在两
SpringMVC+MyBatis声明式事务管理

采用的基本搭建环境:SpringMVC.MyBatis.MySQL.tomcat Spring事务管理分解了传统的全局事务管理和本地事务管理的劣势,使得在任何环境中都可以使用统一的事务管理模型,你可以写一次代码,然后在不同的环境从你的代码里面配置不同的事务管理策略,Spring提供两种事务管理策略:一种是声明式事务管理策略,另一种是编程式事务管理策略,这里主要介绍声明式事务管理策略由于采用的是SpringMVC. MyBatis,故统一采用了标注来声明Service.Controller 由于
C#事务处理（Execute Transaction）实例解析

本文所述为C#事务处理(Execute Transaction)的一个实例,包含了创建SqlTransaction 对象并用SqlConnection对象的BeginTransaction()方法开始事务,创建保存SQL语句,将SqlCommand对象的CommandText属性设置为第一个INSERT语句,第一个INSERT语句在Customers表中增加一行,提交事务,使INSERT语句增加的两行在数据库中保存起来. 具体的实例代码如下: using System; using System
Spring中的事务管理实例详解

本文实例讲述了Spring中的事务管理.分享给大家供大家参考.具体分析如下: 事务简介: 事务管理是企业级应用程序开发中必不可少的技术,用来确保数据的完整性和一致性事务就是一系列的动作,它们被当作一个单独的工作单元.这些动作要么全部完成,要么全部不起作用事务的四个关键属性(ACID) ① 原子性(atomicity):事务室一个原子操作,有一系列动作组成.事务的原子性确保动作要么全部完成,要么完全不起作用 ② 一致性(consistency):一旦所有事务动作完成,事务就被提交.数据和资源就
SpringBoot 注解事务声明式事务的方式

springboot 对新人来说可能上手比springmvc要快,但是对于各位从springmvc转战到springboot的话,有些地方还需要适应下,尤其是xml配置.我个人是比较喜欢注解➕xml是因为看着方便,查找方便,清晰明了.但是xml完全可以使用注解代替,今天就扒一扒springboot中事务使用注解的玩法. springboot的事务也主要分为两大类,一是xml声明式事务,二是注解事务,注解事务也可以实现类似声明式事务的方法,关于注解声明式事务,目前网上搜索不到合适的资料,所以在这里
golang如何优雅的编写事务代码示例

前言新手程序员大概有如下特点 if嵌套经常超过3层.经常出现重复代码.单个函数代码特别长. 只会crud,对语言特性和语言的边界不了解. 不懂面向对象原则和设计模式,以为copy代码就算学会了,常见的是代码职责不明确或者写出万能类不知道数据结构和算法的重要性,以为靠硬件能解决运行慢的问题架构不懂,搭建框架不会,搭建环境不会,使用的软件底层原理一问三不知其实吧,很多人干了很多年,看似是老手,平时工作看似很忙,其实做的都是最简单的活. 这就像去锻炼,有的人每天练的很积极,准时打卡,频繁发朋友
golang之数据校验的实现代码示例

目前大都是使用 validator 安装 go get gopkg.in/go-playground/validator.v9 原理当然只能通过反射来实现了,之前写过一篇反射的文章 golang之反射和断言 ,里面有写到怎么通过反射获取struct tag. 读取struct tag之后就是对里面的标识符进行识别,然后进行验证了.具体可以去看源码. demo 简单使用: package main import ( "fmt" "gopkg.in/go-playground/
使用golang如何优雅的关机或重启操作示例

目录前言优雅地关机什么是优雅关机? 如何实现优雅关机? 优雅地重启总结前言我们编写的Web项目部署之后,经常会因为需要进行配置变更或功能迭代而重启服务,单纯的kill -9 pid的方式会强制关闭进程,这样就会导致服务端当前正在处理的请求失败,那有没有更优雅的方式来实现关机或重启呢? 阅读本文需要了解一些UNIX系统中信号的概念,请提前查阅资料预习. 优雅地关机什么是优雅关机? 优雅关机就是服务端关机命令发出后不是立即关机,而是等待当前还在处理的请求全部处理完毕后再退出程序,是一种
golang操作连接数据库实现mysql事务示例

目录 mysql驱动 posgre驱动连接postgres 连接mysql 初始化连接 SetMaxOpenConns SetMaxIdleConns CRUD 查询单行查询QueryRow 多行查询Query-rows 插入和更新和删除Exec 影响的行数插入更新删除 MySQL预处理为什么要预处理? Go实现MySQL预处理 SQL注入问题 Go实现MySQL事务什么是事务? 事务的ACID 事务相关方法事务示例 MySQL是业界常用的关系型数据库,本文介绍了database
Golang Map实现赋值和扩容的示例代码

golang map 操作,是map 实现中较复杂的逻辑.因为当赋值时,为了减少hash 冲突链的长度过长问题,会做map 的扩容以及数据的迁移.而map 的扩容以及数据的迁移也是关注的重点. 数据结构首先,我们需要重新学习下map实现的数据结构: type hmap struct { count int flags uint8 B uint8 noverflow uint16 hash0 uint32 buckets unsafe.Pointer oldbuckets unsafe.Poin
Python编写春联的示例代码(支持行书隶书楷书)

目录选择矢量字库选择一款喜欢的春联背景图案完整代码效果展示仅供学习编程技术之用,绝无侵犯字体权利人之权力的故意,特此声明. 选择矢量字库虽然有很多方法可以帮你呈现出系统支持的所有字体文件,我建议最直接的方式是去查看操作系统的字体目录.以Windows为例,我直接在C:\Windows\Fonts这个路径下找到了“华文隶书”这个字库文件,查看属性可知,该文件名为STLITI.TTF.找到了喜欢的字库文件,只需要将其全路径文件名替换到代码中的FONT_FILE常量即可,不需要做其他操作
Golang实现AES加密和解密的示例代码

目录对称加密 AES 算法加解密文件加密解密说明对称加密 AES 算法 (Advanced Encryption Standard ,AES) 优点算法公开.计算量小.加密速度快.加密效率高. 缺点发送方和接收方必须商定好密钥,然后使双方都能保存好密钥,密钥管理成为双方的负担. 应用场景相对大一点的数据量或关键数据的加密. 加解密 package helpers import ( "bytes" "crypto/aes" "crypto/c
Golang实现可重入锁的示例代码

目录什么是可重入锁具体实现项目中遇到了可重入锁的需求和实现,具体记录下. 什么是可重入锁我们平时说的分布式锁,一般指的是在不同服务器上的多个线程中,只有一个线程能抢到一个锁,从而执行一个任务.而我们使用锁就是保证一个任务只能由一个线程来完成.所以我们一般是使用这样的三段式逻辑: Lock();DoJob();Unlock(); 但是由于我们的系统都是分布式的,这个锁一般不会只放在某个进程中,我们会借用第三方存储,比如 Redis 来做这种分布式锁.但是一旦借助了第三方存储,我们就必须面对
Golang实现图片上传功能的示例代码

目录 1.前端代码 2.JS代码 3.后端代码该代码为使用beego实现前后端图片上传.话不多说,直接上代码. 1.前端代码 html代码: <div class="col-5 f-l text text-r">背景图(必须):</div> <div class="img-box"> <label> <span class="copy-btn Hui-iconfont"></s
golang NewRequest/gorequest实现http请求的示例代码

通过go语言实现http请求 http.Post import ( "net/http" "net/url" ) data := url.Values{"start":{"100"}, "hobby":{"xxxx"}} body := strings.NewReader(data.Encode()) resp, err := http.Post("127.0.

golang如何优雅的编写事务代码示例

相关推荐

随机推荐