经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » Go语言 » 查看文章
xorm - Update,乐观锁,更新时间updated,NoAutoTime()
来源:cnblogs  作者:j_x_x  时间:2019/5/29 8:56:34  对本文有异议
  • 更新数据使用Update方法

  • Update方法的第一个参数为需要更新的内容,可以为一个结构体指针或者一个Map[string]interface{}类型。
    • 当传入的为结构体指针时,只有非nil和非0的field才会被作为更新的字段,也就是说结构体至少要有一个字段被赋予非0值
    • 当传入的为Map类型时,key为数据库Column的名字,value为要更新的内容。
  • Update方法将返回两个参数:
    • 第一个为更新的记录数,需要注意的是 SQLITE 数据库返回的是根据更新条件查询的记录数而不是真正受更新的记录数。
  • 如果需要更新一个值为0,有两种选择:
    • 通过添加Cols函数指定需要更新结构体中的哪些值,未指定的将不更新,指定了的即使为0也会更新。
    • 通过传入map[string]interface{}来进行更新,但这时需要额外指定更新到哪个表,因为通过map是无法自动检测更新哪个表的。
  1. package main
  2. import (
  3. "fmt"
  4. _ "github.com/go-sql-driver/mysql"
  5. "github.com/go-xorm/xorm"
  6. "log"
  7. "time"
  8. )
  9. var engine *xorm.Engine
  10. type User struct {
  11. Name string `xorm:"varchar(25) 'name'"`
  12. Id int `xorm:"pk 'id' autoincr"`
  13. Money int `xorm:" 'money' "`
  14. Age int `xorm:"age"`
  15. CreatedAt time.Time `xorm:"created"`
  16. }
  17. func main() {
  18. var err error
  19. engine, err = xorm.NewEngine("mysql", "root:123456@/test")
  20. if err != nil {
  21. log.Fatal(err)
  22. return
  23. }
  24. //创建表和插入数据
  25. /* err = engine.CreateTables(User{})
  26. if err != nil {
  27. log.Fatal(err)
  28. return
  29. }
  30. u := make([]User, 3)
  31. u[0].Name = "u0"
  32. u[0].Money = 1
  33. u[0].Age = 1
  34. u[1].Name = "u1"
  35. u[1].Money = 2
  36. u[1].Age = 1
  37. u[2].Name = "u2"
  38. u[2].Money = 3
  39. u[2].Age = 1
  40. _, err = engine.Insert(u)
  41. if err != nil {
  42. log.Fatal(err)
  43. return
  44. }*/
  45. u1 := new(User)
  46. u1.Money = 2
  47. affected, err := engine.Id(1).Update(u1)
  48. if err != nil {
  49. log.Fatal(err)
  50. }
  51. fmt.Println("第一个参数为结构体指针,结构体中更新的数据不是0值时,受影响的行数:", affected)
  52. u2 := new(User)
  53. u2.Money = 0
  54. affected, err = engine.Id(1).Cols("money").Update(u2)
  55. if err != nil {
  56. log.Fatal(err)
  57. }
  58. fmt.Println("第一个参数为结构体指针,结构体中更新的数据是0值,Cols函数指定需要更新结构体中的哪些值时,受影响的行数:", affected)
  59. affected, err = engine.Table(new(User)).Id(2).Update(map[string]interface{}{"age":0})
  60. fmt.Println("第一个参数为map,0值,受影响的行数:", affected)
  61. u3 := new(User)
  62. u3.Money = 0
  63. affected, err = engine.Id(1).Update(u3)
  64. if err != nil {
  65. log.Fatal(err)
  66. }
  67. fmt.Println("第一个参数为结构体指针,结构体中更新的数据是0值时,受影响的行数:", affected)
  68. /*
  69. 如果传入的数据和数据库原有的数据相同时上面第一个方法受影响的行数就是0行,不同时上面第一个方法受影响的行数就是1行,输出:
  70. 第一个参数为结构体指针,结构体中更新的数据不是0值时,受影响的行数: 1
  71. 第一个参数为结构体指针,结构体中更新的数据是0值,Cols函数指定需要更新结构体中的哪些值时,受影响的行数: 1
  72. 第一个参数为map,0值,受影响的行数: 1
  73. 2019/05/28 11:51:35 No content found to be updated
  74. */
  75. }
  • 乐观锁/更新时间update/不自动更新时间NoAutoTime()

    1. package main
    2. import (
    3. "fmt"
    4. _ "github.com/go-sql-driver/mysql"
    5. "github.com/go-xorm/xorm"
    6. "log"
    7. "time"
    8. )
    9. var engine *xorm.Engine
    10. type User struct {
    11. Name string `xorm:"varchar(25) 'name'"`
    12. Id int `xorm:"pk 'id' autoincr"`
    13. Version int `xorm:"version"`
    14. UpdatedAt time.Time `xorm:"updated"`
    15. }
    16. func main() {
    17. var err error
    18. engine, err = xorm.NewEngine("mysql", "root:123456@/test")
    19. if err != nil {
    20. log.Fatal(err)
    21. return
    22. }
    23. //创建表和插入数据
    24. /* err = engine.CreateTables(User{})
    25. if err != nil {
    26. log.Fatal(err)
    27. return
    28. }
    29. u := make([]User, 3)
    30. u[0].Name = "u0"
    31. u[1].Name = "u1"
    32. u[2].Name = "u2"
    33. _, err = engine.Insert(u)
    34. if err != nil {
    35. log.Fatal(err)
    36. return
    37. }*/
    38. /*
    39. 要使用乐观锁,需要使用version标记
    40. 在Insert时,version标记的字段将会被设置为1,在Update时,Update的内容必须包含version原来的值。
    41. */
    42. var user User
    43. has, err := engine.Id(1).Get(&user)
    44. if err != nil {
    45. log.Fatal(err)
    46. return
    47. }
    48. if has {
    49. fmt.Println("乐观锁,初始的userName:", user.Name, " 初始的version:", user.Version, "更新时间:", user.UpdatedAt)
    50. }
    51. user.Name = "version2Name"
    52. affected, err := engine.Id(1).Update(&user)
    53. if err != nil {
    54. log.Fatal(err)
    55. return
    56. }
    57. fmt.Println("乐观锁,改变了的数据库记录数:", affected, " 改变后的userName:", user.Name,
    58. " 改变后的version:", user.Version, "更新时间:", user.UpdatedAt)
    59. /*
    60. 更新时间Updated可以让您在记录插入或每次记录更新时自动更新数据库中的标记字段为当前时间,
    61. 需要在xorm标记中使用updated标记,对应的字段可以为time.Time或者自定义的time.Time或者int,int64等int类型。
    62. 在Insert(), InsertOne(), Update()方法被调用时,updated标记的字段将会被自动更新为当前时间
    63. */
    64. var user1 User
    65. has, err = engine.Id(2).Get(&user1)
    66. if err != nil {
    67. log.Fatal(err)
    68. return
    69. }
    70. if has {
    71. fmt.Println("更新时间Updated,初始的userName:", user1.Name, " 初始的version:", user1.Version, "更新时间:", user1.UpdatedAt)
    72. }
    73. affected, err = engine.Id(2).Update(&user1)
    74. if err != nil {
    75. log.Fatal(err)
    76. return
    77. }
    78. fmt.Println("更新时间Updated,改变了的数据库记录数:", affected, " 改变后的userName:", user1.Name,
    79. " 改变后的version:", user1.Version, "更新时间:", user1.UpdatedAt)
    80. /* 如果你希望临时不自动插入时间,则可以组合NoAutoTime()方法:
    81. engine.NoAutoTime().Insert(&user)
    82. 这个在从一张表拷贝字段到另一张表时比较有用。
    83. */
    84. var user2 User
    85. has, err = engine.Id(3).Get(&user2)
    86. if err != nil {
    87. log.Fatal(err)
    88. return
    89. }
    90. if has {
    91. fmt.Println("临时不自动插入时间,初始的userName:", user2.Name, " 初始的version:", user2.Version, "更新时间:", user2.UpdatedAt)
    92. }
    93. affected, err = engine.Id(3).NoAutoTime().Update(&user2)
    94. if err != nil {
    95. log.Fatal(err)
    96. return
    97. }
    98. fmt.Println("临时不自动插入时间,改变了的数据库记录数:", affected, " 改变后的userName:", user2.Name,
    99. " 改变后的version:", user2.Version, "更新时间:", user2.UpdatedAt)
    100. /*输出:
    101. 乐观锁,初始的userName: version2Name 初始的version: 2 更新时间: 2019-05-28 14:41:24 +0800 CST
    102. 乐观锁,改变了的数据库记录数: 1 改变后的userName: version2Name 改变后的version: 3 更新时间: 2019-05-28 14:44:02.386965 +0800 CST
    103. 更新时间Updated,初始的userName: u1 初始的version: 2 更新时间: 2019-05-28 14:41:24 +0800 CST
    104. 更新时间Updated,改变了的数据库记录数: 1 改变后的userName: u1 改变后的version: 3 更新时间: 2019-05-28 14:44:02.395314 +0800 CST
    105. 临时不自动插入时间,初始的userName: u2 初始的version: 2 更新时间: 2019-05-28 14:41:24 +0800 CST
    106. 临时不自动插入时间,改变了的数据库记录数: 1 改变后的userName: u2 改变后的version: 3 更新时间: 2019-05-28 14:41:24 +0800 CST
    107. */
    108. }

原文链接:http://www.cnblogs.com/jiangxiangxiang/p/10937385.html

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号