内容简介:需要填坑的是:这里面我使用事务一直实现不了回滚,再次细致阅读文档才发现,而关于innodb的设置方法,这里有一个很好的教程;
简单的用法
package main import ( _ "github.com/go-sql-driver/mysql" "github.com/go-xorm/xorm" "log" ) //定义结构体(xorm支持双向映射) type User struct { User_id int64 `xorm:"pk autoincr"` //指定主键并自增 Name string `xorm:"unique"` //唯一的 Balance float64 Time int64 `xorm:"updated"` //修改后自动更新时间 Creat_time int64 `xorm:"created"` //创建时间 //Version int `xorm:"version"` //乐观锁 } //定义orm引擎 var x *xorm.Engine //创建orm引擎 func init() { var err error x, err = xorm.NewEngine("mysql", "root:root@tcp(127.0.0.1:3306)/xorm?charset=utf8") if err != nil { log.Fatal("数据库连接失败:", err) } if err := x.Sync(new(User)); err != nil { log.Fatal("数据表同步失败:", err) } } //增 func Insert(name string, balance float64) (int64, bool) { user := new(User) user.Name = name user.Balance = balance affected, err := x.Insert(user) if err != nil { return affected, false } return affected, true } //删 func Del(id int64) { user := new(User) x.Id(id).Delete(user) } //改 func update(id int64, user *User) bool { affected, err := x.ID(id).Update(user) if err != nil { log.Fatal("错误:", err) } if affected == 0 { return false } return true } //查 func getinfo(id int64) *User { user := &User{User_id: id} is, _ := x.Get(user) if !is { log.Fatal("搜索结果不存在!") } return user }
在gin中的用法
package main import ( "github.com/gin-gonic/gin" "./models" "strconv" ) //添加操作 func insert(c *gin.Context) { name := c.Query("name") if name == "" { c.JSON(200, gin.H{"msg": "name不得为空!"}) return } money := c.Query("money") if money == "" { c.JSON(200, gin.H{"msg": "money不得为空!"}) return } Balance, _ := strconv.ParseFloat(money, 64) //添加 user := models.User{} user.Name = name user.Balance = Balance rel, err := models.X.Insert(user) if rel == 0 || err != nil { c.JSON(200, gin.H{"msg": "添加错误", "err": err, "rel": rel}) } else { c.JSON(200, gin.H{"msg": "添加成功"}) } } //查询单个操作 func get(c *gin.Context) { id := c.Query("id") if id == "" { c.JSON(200, gin.H{"msg": "id不得为空!"}) return } //string转int64 ids, _ := strconv.ParseInt(id, 10, 64) //查询1 //user := &User{User_id: ids} //rel, err := models.X.Get(user) //查询2 user := ⊧.User{} rel, err := models.X.Where("user_id = ?", ids).Get(user) if !rel || err != nil { c.JSON(200, gin.H{"msg": "查询错误"}) } else { c.JSON(200, gin.H{"user": user}) } } //查询多条操作 func find(c *gin.Context) { users := make(map[int64]models.User) err := models.X.Find(&users) if err != nil { c.JSON(200, gin.H{"msg": err}) } c.JSON(200, gin.H{"msg": users}) } //修改操作 func updates(c *gin.Context) { id := c.Query("id") if id == "" { c.JSON(200, gin.H{"msg": "id1不得为空!", "id": id}) return } ids, _ := strconv.ParseInt(id, 10, 64) name := c.Query("name") if name == "" { c.JSON(200, gin.H{"msg": "name不得为空!"}) return } balance := c.Query("balance") if balance == "" { c.JSON(200, gin.H{"msg": "balance不得为空!"}) return } money, _ := strconv.ParseFloat(balance, 64) //修改 user := models.User{} user.Name = name user.Balance = money rel, err := models.X.Id(ids).Update(user) if rel == 0 || err != nil { c.JSON(200, gin.H{"msg": "修改错误!", "rel": rel, "err": err, "user": user}) } else { c.JSON(200, gin.H{"mag": "修改成功"}) } } //删除操作 func delte(c *gin.Context) { id := c.Query("id") if id == "" { c.JSON(200, gin.H{"msg": "id1不得为空!", "id": id}) return } //string转化int64 ids, _ := strconv.ParseInt(id, 10, 64) //删除 user := models.User{} rel, err := models.X.Id(ids).Delete(user) if rel == 0 || err != nil { c.JSON(200, gin.H{"msg": "删除错误!", "rel": rel, "err": err, "user": user}) } else { c.JSON(200, gin.H{"mag": "删除成功"}) } } //事务的提交以及回滚 func gun(c *gin.Context) { //创建session session := models.X.NewSession() defer session.Close() //创建事务 err := session.Begin() if err != nil { c.JSON(200, gin.H{"err": err}) return } //操作事务,失败并回滚(模拟购物车结算情景) car_id := c.Query("car_id") if car_id == "" { c.JSON(200, gin.H{"msg": "car_id1不得为空!", "car_id": car_id}) return } //查找购物车中的商品id ids, _ := strconv.ParseInt(car_id, 10, 64) car := ⊧.Car{Car_id: ids} models.X.Get(car) /** * goods表库存减去销量 */ //查询商品 goods := ⊧.Goods{Goods_id: car.Goods_id} models.X.Get(goods) //更新库存 good := models.Goods{} good.Stock = goods.Stock - car.Num rel4, err4 := session.ID(car.Goods_id).Update(good) if rel4 == 0 || err4 != nil { session.Rollback() c.JSON(200, gin.H{"err4": err4, "rel4": rel4, "carid": car.Goods_id, "goodsid": goods.Goods_id, "Stock": good.Stock}) return } /** * 用户扣费 */ //查询用户 user := ⊧.User{User_id: car.User_id} models.X.Get(user) //更新价格 user_up := models.User{} user_up.Balance = user.Balance - car.Total_price rel1, err1 := session.ID(car.User_id).Update(user_up) if err1 != nil || rel1 == 0 { session.Rollback() c.JSON(200, gin.H{"err1": err1, "rel1": rel1}) return } /** * 删除用户的购物车信息 */ rel2, err2 := session.Delete(car) if err2 != nil || rel2 == 0 { session.Rollback() c.JSON(200, gin.H{"err2": err2, "rel2": rel2}) return } if user_up.Balance <= 0 { session.Rollback() c.JSON(200, gin.H{"msg": "余额不足"}) return } err3 := session.Commit() if err3 != nil { c.JSON(200, gin.H{"err3": err3}) return } c.JSON(200, gin.H{"msg": "用户扣费成功"}) } func update_goods(c *gin.Context) { id := c.Query("id") if id == "" { c.JSON(200, gin.H{"msg": "id1不得为空!", "id": id}) return } //string转换int64 ids, err := strconv.ParseInt(id, 10, 64) goods_name := c.Query("goods_name") if goods_name == "" { c.JSON(200, gin.H{"msg": "goods_name不得为空!", "goods_name": goods_name}) return } price := c.Query("price") if price == "" { c.JSON(200, gin.H{"msg": "price不得为空!", "price": price}) return } prices, _ := strconv.ParseFloat(price, 64) stock := c.Query("stock") if stock == "" { c.JSON(200, gin.H{"msg": "stock不得为空!", "stock": stock}) return } stocks, _ := strconv.ParseInt(stock, 10, 64) //修改 goods := models.Goods{} goods.Stock = stocks goods.Goods_name = goods_name goods.Price = prices rel, err := models.X.ID(ids).Update(goods) if rel == 0 || err != nil { c.JSON(200, gin.H{"msg": "修改失败", "err": err, "stocks": stocks, "goods_name": goods_name, "prices": prices, "id": id}) } else { c.JSON(200, gin.H{"msg": "修改成功"}) } } func shiwu(c *gin.Context) { session := models.X.NewSession() defer session.Close() err := session.Begin() user1 := models.User{Name: "xiaoxiao1", Balance: 100} _, err = session.Insert(&user1) if err != nil { return } session.Rollback() data := make(map[string]interface{}) data["msg"] = "错误" c.JSON(200, session) c.JSON(200, data) return //提交 err = session.Commit() if err != nil { return } } func main() { r := gin.Default() r.GET("/insert", insert) r.GET("/get", get) r.GET("/find", find) r.GET("/updates", updates) r.GET("/delte", delte) r.GET("/update_goods", update_goods) r.GET("/gun", gun) r.GET("/shiwu", shiwu) r.Run(":88") }
需要填坑的是:这里面我使用事务一直实现不了回滚,再次细致阅读文档才发现,
而关于innodb的设置方法,这里有一个很好的教程; https://blog.csdn.net/leejianjun/article/details/72467983
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- RecyclerView使用指南(一)—— 基本使用
- 如何使用Meteorjs使用URL参数
- 使用 defer 还是不使用 defer?
- 使用 Typescript 加强 Vuex 使用体验
- [译] 何时使用 Rust?何时使用 Go?
- UDP协议的正确使用场合(谨慎使用)
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
数据结构与算法:python语言实现
迈克尔.·T·古德里奇、罗伯托·塔玛西亚、迈克尔·H·戈德瓦瑟 / 张晓、赵晓南 / 机械工业出版社 / 2018-9 / 109.00元
本书采用Python语言讨论数据结构和算法,详细讲解其设计、分析与实现过程,是一本内容全面且特色鲜明的教材。书中将面向对象视角贯穿始终,充分利用Python语言优美而简洁的特点,强调代码的健壮性和可重用性,关注各种抽象数据类型以及不同算法实现策略的权衡。一起来看看 《数据结构与算法:python语言实现》 这本书的介绍吧!