Skip to end of metadata
Go to start of metadata

为安全性保证、防止误操作,UpdateDelete方法必须带有Where条件才能提交执行,否则将会错误返回,错误信息如:there should be WHERE condition statement for XXX operationgoframe是一款用于企业生产级别的框架,各个模块设计严谨,工程实践的细节处理得比较好。

Update更新方法

Update用于数据的更新,往往需要结合DataWhere方法共同使用。Data方法用于指定需要更新的数据,Where方法用于指定更新的条件范围。同时,Update方法也支持直接给定数据和条件参数。

使用示例:

// UPDATE `user` SET `name`='john guo' WHERE name='john'
db.Table("user").Data(g.Map{"name" : "john guo"}).Where("name", "john").Update()
db.Table("user").Data("name='john guo'").Where("name", "john").Update()
// UPDATE `user` SET `status`=1 ORDER BY `login_time` asc LIMIT 10
db.Table("user").Data("status", 1).Order("login_time asc").Limit(10).Update()

// UPDATE `user` SET `status`=1 WHERE 1
db.Table("user").Data("status=1").Where(1).Update()
db.Table("user").Data("status", 1).Where(1).Update()
db.Table("user").Data(g.Map{"status" : 1}).Where(1).Update()

也可以直接给Update方法传递datawhere参数:

// UPDATE `user` SET `name`='john guo' WHERE name='john'
db.Table("user").Update(g.Map{"name" : "john guo"}, "name", "john")
db.Table("user").Update("name='john guo'", "name", "john")

// UPDATE `user` SET `status`=1 WHERE 1
db.Table("user").Update("status=1", 1)
db.Table("user").Update(g.Map{"status" : 1}, 1)

Counter更新特性

可以使用Counter类型参数对特定的字段进行数值操作,例如:增加、减少操作。

Counter数据结构定义:

// Counter  is the type for update count.
type Counter struct {
	Field string
	Value float64
}

Counter使用示例,字段自增:

updateData := g.Map{
	"views": &gdb.Counter{ 
        Field: "views", 
        Value: 1,
    },
}
// UPDATE `article` SET `views`=`views`+1 WHERE `id`=1
result, err := db.Update("article", updateData, "id", 1)

Counter也可以实现非自身字段的自增,例如:

updateData := g.Map{
	"views": &gdb.Counter{ 
        Field: "clicks", 
        Value: 1,
    },
}
// UPDATE `article` SET `views`=`clicks`+1 WHERE `id`=1
result, err := db.Update("article", updateData, "id", 1)

Increment/Decrement自增/减

我们可以通过IncrementDecrement方法实现对指定字段的自增/自减常用操作。两个方法的定义如下:

// Increment increments a column's value by a given amount.
func (m *Model) Increment(column string, amount float64) (sql.Result, error)

// Decrement decrements a column's value by a given amount.
func (m *Model) Decrement(column string, amount float64) (sql.Result, error)

使用示例:

// UPDATE `article` SET `views`=`views`+10000 WHERE `id`=1
db.Model("article").Where("id", 1).Increment("views", 10000)
// UPDATE `article` SET `views`=`views`-10000 WHERE `id`=1
db.Model("article").Where("id", 1).Decrement("views", 10000)

RawSQL语句嵌入

gdb.Raw是字符串类型,该类型的参数将会直接作为SQL片段嵌入到提交到底层的SQL语句中,不会被自动转换为字符串参数类型、也不会被当做预处理参数。例如:

// UPDATE `user` SET login_count='login_count+1',update_time='now()' WHERE id=1
db.Model("user").Data(g.Map{
    "login_count": "login_count+1",
    "update_time": "now()",
}).Where("id", 1).Update()
// 执行报错:Error Code: 1136. Column count doesn't match value count at row 1

使用gdb.Raw改造后:

// UPDATE `user` SET login_count=login_count+1,update_time=now() WHERE id=1
db.Model("user").Data(g.Map{
    "login_count": gdb.Raw("login_count+1"),
    "update_time": gdb.Raw("now()"),
}).Where("id", 1).Update()

Delete删除方法

Delete方法用于数据的删除。

使用示例:

// DELETE FROM `user` WHERE uid=10
db.Table("user").Where("uid", 10).Delete()
// DELETE FROM `user` ORDER BY `login_time` asc LIMIT 10
db.Table("user").Order("login_time asc").Limit(10).Delete()

也可以直接给Delete方法传递where参数:

// DELETE FROM `user` WHERE `uid`=10
db.Table("user").Delete("uid", 10)
// DELETE FROM `user` WHERE `score`<60
db.Table("user").Delete("score < ", 60)

软删除特性

软删除特性请查看章节:ORM链式操作-时间维护








Content Menu

  • No labels

15 Comments

  1. gdbCounter := &gdb.Counter{
    	Field: "views",
    	Value: 1,
    }

    是不可以理解为 views 字段加 1, 如果想要 -1 则写成:

    gdbCounter := &gdb.Counter{ Field: "views", Value: -1 }
    1. 个人感觉挺麻烦的..做自减都要做一次负数转化.还是常规链式的Inc/Dec机制比较区分.

      1. 负数转化?

        1. 例如会员消费余额,前端传回来是个正数(消费多少),扣除余额的时候在Value之前就要对这个金额做一次转换使之变为负数(在前面加个减号).

  2. Counter使用示例

    能否加个 sql语句 这样容易理解

    1. 感谢建议,已更新。

  3. 能否实现类似LaravelUpdateOrCreate

    https://laravel.com/docs/8.x/eloquent#upserts

    如果存在就更新,否则插入数据

    每次都要重复写这些逻辑,或者是要在每个dao里面去拷贝代码,感觉不太优雅

    1. 哥,就是Save方法。😓

      1. 感觉不对,这个差异很大,比如表结构

        id, name, date, score, created_at, updated_at
        namedate是唯一索引

        dao.Score.Data(g.Map{
            dao.Score.Columns.Date:  "2021-01-18",
            dao.Score.Columns.Name:  "test",
            dao.Score.Columns.Score: 80,
        }).Save()

        此时会Insert一条新记录

        但是实际意图是:

        如果存在 name="test" and date="2021-01-18" 的记录,则更新其score80

        否则插入 name="test", date="2021-01-18", score=80

        func (r *ScoreDao) UpdateOrCreate(whereAndData ...g.Map) {}
        
        dao.Score.UpdateOrCreate(g.Map{
           dao.Score.Columns.Date:   "2021-01-18",
           dao.Score.Columns.Name: "test",
        }, g.Map{
           dao.Score.Columns.Score: 80,
        })




        1. 现在Save的逻辑就是这样啊,你把debug打开看看sql对不对:ORM链式操作-写入保存

          1. 谢谢💕,由于debug显示的SQL较长,没注意看后面的 ON DUPLICATE KEY UPDATE,只看到前面的 INSERT INTO

  4. xx

    有没有mysql更新json类型字段的例子?

  5. 请问一下,删除了以后怎样检查删除操作是否执行成功呢?谢谢了!

    1. 判断返回的Result结果,里面有RowsAffected方法。

      1. 明白了,感谢!