热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

xorm-Update,乐观锁,更新时间updated,NoAutoTime()

更新数据使用Update方法Update方法的第一个参数为需要更新的内容,可以为一个结构体指针或者一个Map[string]interface{}类型。当传入的为结构体指
  • 更新数据使用Update方法

  • Update方法的第一个参数为需要更新的内容,可以为一个结构体指针或者一个Map[string]interface{}类型。
    • 当传入的为结构体指针时,只有非nil和非0的field才会被作为更新的字段,也就是说结构体至少要有一个字段被赋予非0值
    • 当传入的为Map类型时,key为数据库Column的名字,value为要更新的内容。
  • Update方法将返回两个参数:
    • 第一个为更新的记录数,需要注意的是 SQLITE 数据库返回的是根据更新条件查询的记录数而不是真正受更新的记录数。
  • 如果需要更新一个值为0,有两种选择:
    • 通过添加Cols函数指定需要更新结构体中的哪些值,未指定的将不更新,指定了的即使为0也会更新。
    • 通过传入map[string]interface{}来进行更新,但这时需要额外指定更新到哪个表,因为通过map是无法自动检测更新哪个表的。
package main

import (
  "fmt"
  _ "github.com/go-sql-driver/mysql"
  "github.com/go-xorm/xorm"
  "log"
  "time"
)

var engine *xorm.Engine

type User struct {
  Name      string    `xorm:"varchar(25) 'name'"`
  Id        int       `xorm:"pk 'id' autoincr"`
  Money     int       `xorm:" 'money' "`
  Age       int       `xorm:"age"`
  CreatedAt time.Time `xorm:"created"`
}

func main() {
  var err error
  engine, err = xorm.NewEngine("mysql", "root:123456@/test")
  if err != nil {
      log.Fatal(err)
      return
  }
  //创建表和插入数据
/*    err = engine.CreateTables(User{})
  if err != nil {
      log.Fatal(err)
      return
  }

  u := make([]User, 3)
  u[0].Name = "u0"
  u[0].MOney= 1
  u[0].Age = 1
  u[1].Name = "u1"
  u[1].MOney= 2
  u[1].Age = 1
  u[2].Name = "u2"
  u[2].MOney= 3
  u[2].Age = 1

  _, err = engine.Insert(u)
  if err != nil {
      log.Fatal(err)
      return
  }*/


  u1 := new(User)
  u1.MOney= 2
  affected, err := engine.Id(1).Update(u1)
  if err != nil {
      log.Fatal(err)
  }
  fmt.Println("第一个参数为结构体指针,结构体中更新的数据不是0值时,受影响的行数:", affected)


  u2 := new(User)
  u2.MOney= 0
  affected, err = engine.Id(1).Cols("money").Update(u2)
  if err != nil {
      log.Fatal(err)
  }
  fmt.Println("第一个参数为结构体指针,结构体中更新的数据是0值,Cols函数指定需要更新结构体中的哪些值时,受影响的行数:", affected)

  affected, err = engine.Table(new(User)).Id(2).Update(map[string]interface{}{"age":0})
  fmt.Println("第一个参数为map,0值,受影响的行数:", affected)

  u3 := new(User)
  u3.MOney= 0
  affected, err = engine.Id(1).Update(u3)
  if err != nil {
      log.Fatal(err)
  }
  fmt.Println("第一个参数为结构体指针,结构体中更新的数据是0值时,受影响的行数:", affected)


/*
    如果传入的数据和数据库原有的数据相同时上面第一个方法受影响的行数就是0行,不同时上面第一个方法受影响的行数就是1行,输出:
      第一个参数为结构体指针,结构体中更新的数据不是0值时,受影响的行数: 1
      第一个参数为结构体指针,结构体中更新的数据是0值,Cols函数指定需要更新结构体中的哪些值时,受影响的行数: 1
    第一个参数为map,0值,受影响的行数: 1
      2019/05/28 11:51:35 No content found to be updated
*/

}
  • 乐观锁/更新时间update/不自动更新时间NoAutoTime()

    package main
    
    import (
      "fmt"
      _ "github.com/go-sql-driver/mysql"
      "github.com/go-xorm/xorm"
      "log"
      "time"
    )
    
    var engine *xorm.Engine
    
    type User struct {
      Name      string    `xorm:"varchar(25) 'name'"`
      Id        int       `xorm:"pk 'id' autoincr"`
      Version   int       `xorm:"version"`
      UpdatedAt time.Time `xorm:"updated"`
    }
    
    func main() {
      var err error
      engine, err = xorm.NewEngine("mysql", "root:123456@/test")
      if err != nil {
          log.Fatal(err)
          return
      }
      //创建表和插入数据
    /*    err = engine.CreateTables(User{})
      if err != nil {
          log.Fatal(err)
          return
      }
    
      u := make([]User, 3)
      u[0].Name = "u0"
      u[1].Name = "u1"
      u[2].Name = "u2"
    
      _, err = engine.Insert(u)
      if err != nil {
          log.Fatal(err)
          return
      }*/
    
      /*
          要使用乐观锁,需要使用version标记
          在Insert时,version标记的字段将会被设置为1,在Update时,Update的内容必须包含version原来的值。
      */
    
          var user User
          has, err := engine.Id(1).Get(&user)
          if err != nil {
              log.Fatal(err)
              return
          }
          if has {
              fmt.Println("乐观锁,初始的userName:", user.Name, "  初始的version:", user.Version, "更新时间:", user.UpdatedAt)
          }
    
          user.Name = "version2Name"
          affected, err := engine.Id(1).Update(&user)
          if err != nil {
              log.Fatal(err)
              return
          }
          fmt.Println("乐观锁,改变了的数据库记录数:", affected, "  改变后的userName:", user.Name,
              "  改变后的version:", user.Version, "更新时间:", user.UpdatedAt)
    
          /*
        更新时间Updated可以让您在记录插入或每次记录更新时自动更新数据库中的标记字段为当前时间,
          需要在xorm标记中使用updated标记,对应的字段可以为time.Time或者自定义的time.Time或者int,int64等int类型。
          在Insert(), InsertOne(), Update()方法被调用时,updated标记的字段将会被自动更新为当前时间
          */
    
          var user1 User
          has, err = engine.Id(2).Get(&user1)
          if err != nil {
              log.Fatal(err)
              return
          }
          if has {
              fmt.Println("更新时间Updated,初始的userName:", user1.Name, "  初始的version:", user1.Version, "更新时间:", user1.UpdatedAt)
          }
          affected, err = engine.Id(2).Update(&user1)
          if err != nil {
              log.Fatal(err)
              return
          }
          fmt.Println("更新时间Updated,改变了的数据库记录数:", affected, "  改变后的userName:", user1.Name,
              "  改变后的version:", user1.Version, "更新时间:", user1.UpdatedAt)
    
    
      /*  如果你希望临时不自动插入时间,则可以组合NoAutoTime()方法:
          engine.NoAutoTime().Insert(&user)
          这个在从一张表拷贝字段到另一张表时比较有用。
      */
    
          var user2 User
          has, err = engine.Id(3).Get(&user2)
          if err != nil {
              log.Fatal(err)
              return
          }
          if has {
              fmt.Println("临时不自动插入时间,初始的userName:", user2.Name, "  初始的version:", user2.Version, "更新时间:", user2.UpdatedAt)
          }
          affected, err = engine.Id(3).NoAutoTime().Update(&user2)
          if err != nil {
              log.Fatal(err)
              return
          }
          fmt.Println("临时不自动插入时间,改变了的数据库记录数:", affected, "  改变后的userName:", user2.Name,
              "  改变后的version:", user2.Version, "更新时间:", user2.UpdatedAt)
    
    
    /*输出:
      乐观锁,初始的userName: version2Name   初始的version: 2 更新时间: 2019-05-28 14:41:24 +0800 CST
      乐观锁,改变了的数据库记录数: 1   改变后的userName: version2Name   改变后的version: 3 更新时间: 2019-05-28 14:44:02.386965 +0800 CST
      更新时间Updated,初始的userName: u1   初始的version: 2 更新时间: 2019-05-28 14:41:24 +0800 CST
      更新时间Updated,改变了的数据库记录数: 1   改变后的userName: u1   改变后的version: 3 更新时间: 2019-05-28 14:44:02.395314 +0800 CST
      临时不自动插入时间,初始的userName: u2   初始的version: 2 更新时间: 2019-05-28 14:41:24 +0800 CST
      临时不自动插入时间,改变了的数据库记录数: 1   改变后的userName: u2   改变后的version: 3 更新时间: 2019-05-28 14:41:24 +0800 CST
    */
    
    }

推荐阅读
  • 优化ListView性能
    本文深入探讨了如何通过多种技术手段优化ListView的性能,包括视图复用、ViewHolder模式、分批加载数据、图片优化及内存管理等。这些方法能够显著提升应用的响应速度和用户体验。 ... [详细]
  • 本文将介绍如何编写一些有趣的VBScript脚本,这些脚本可以在朋友之间进行无害的恶作剧。通过简单的代码示例,帮助您了解VBScript的基本语法和功能。 ... [详细]
  • 本文详细介绍如何使用Python进行配置文件的读写操作,涵盖常见的配置文件格式(如INI、JSON、TOML和YAML),并提供具体的代码示例。 ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • 题目描述:给定n个半开区间[a, b),要求使用两个互不重叠的记录器,求最多可以记录多少个区间。解决方案采用贪心算法,通过排序和遍历实现最优解。 ... [详细]
  • 数据库内核开发入门 | 搭建研发环境的初步指南
    本课程将带你从零开始,逐步掌握数据库内核开发的基础知识和实践技能,重点介绍如何搭建OceanBase的开发环境。 ... [详细]
  • 本文深入探讨 MyBatis 中动态 SQL 的使用方法,包括 if/where、trim 自定义字符串截取规则、choose 分支选择、封装查询和修改条件的 where/set 标签、批量处理的 foreach 标签以及内置参数和 bind 的用法。 ... [详细]
  • 使用 Azure Service Principal 和 Microsoft Graph API 获取 AAD 用户列表
    本文介绍了一段通用代码示例,该代码不仅能够操作 Azure Active Directory (AAD),还可以通过 Azure Service Principal 的授权访问和管理 Azure 订阅资源。Azure 的架构可以分为两个层级:AAD 和 Subscription。 ... [详细]
  • 本文详细介绍了Java中org.neo4j.helpers.collection.Iterators.single()方法的功能、使用场景及代码示例,帮助开发者更好地理解和应用该方法。 ... [详细]
  • 本文介绍如何使用Objective-C结合dispatch库进行并发编程,以提高素数计数任务的效率。通过对比纯C代码与引入并发机制后的代码,展示dispatch库的强大功能。 ... [详细]
  • 技术分享:从动态网站提取站点密钥的解决方案
    本文探讨了如何从动态网站中提取站点密钥,特别是针对验证码(reCAPTCHA)的处理方法。通过结合Selenium和requests库,提供了详细的代码示例和优化建议。 ... [详细]
  • 主要用了2个类来实现的,话不多说,直接看运行结果,然后在奉上源代码1.Index.javaimportjava.awt.Color;im ... [详细]
  • 深入理解 SQL 视图、存储过程与事务
    本文详细介绍了SQL中的视图、存储过程和事务的概念及应用。视图为用户提供了一种灵活的数据查询方式,存储过程则封装了复杂的SQL逻辑,而事务确保了数据库操作的完整性和一致性。 ... [详细]
  • 本文详细介绍了Java中org.eclipse.ui.forms.widgets.ExpandableComposite类的addExpansionListener()方法,并提供了多个实际代码示例,帮助开发者更好地理解和使用该方法。这些示例来源于多个知名开源项目,具有很高的参考价值。 ... [详细]
  • 深入解析Spring Cloud Ribbon负载均衡机制
    本文详细介绍了Spring Cloud中的Ribbon组件如何实现服务调用的负载均衡。通过分析其工作原理、源码结构及配置方式,帮助读者理解Ribbon在分布式系统中的重要作用。 ... [详细]
author-avatar
手机用户2502934541
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有