合规国际互联网加速 OSASE为企业客户提供高速稳定SD-WAN国际加速解决方案。 广告
## Insert 插入 ```go // 一条数据 var data = map[string]interface{}{"age":17, "job":"it3"} // insert into user (age, job) values (17, 'it3') db.Table(&user).Data(data).Insert() // 多条数据 var multi_data = []map[string]interface{}{ {"age":17, "job":"it3"},{"age":17, "job":"it4"} } // insert into user (age, job) values (17, 'it3') (17, 'it4') db.Table("user").Data(multi_data).Insert() ``` ## InsertGetId 插入并返回插入id, 默认返回影响行数 ```go // 一条数据 var data = map[string]interface{}{"age":17, "job":"it3"} // insert into user (age, job) values (17, 'it3') db.Table(&user).Data(data).Insert() // 多条数据 var multi_data = []map[string]interface{}{ {"age":17, "job":"it3"},{"age":17, "job":"it4"} } // insert into user (age, job) values (17, 'it3') (17, 'it4') db.Table("user").Data(multi_data).InsertGetId() ``` ## Update 修改 ```go // update user set age=17, job='ite3' where (id=1) or (age>30) db.Table("user"). Data(map[string]interface{}{"age":17, "job":"it3"}). Where("id", 1). OrWhere("age",">",30). Update() ``` ## Delete 删除 ```go // delete from user where id=5 db.Table("user").Where("id", 5).Delete() ``` 除了 `InsertGetId` 返回插入id, 其他方法均返回 影响行数, 如果影响行数为0, 则操作也是不成功的 ## 事务 ```go var data = map[string]interface{}{"names": "fizz3", "age": 3} ``` - 标准事务 ```go db := connection.NewSession() // 开始事务 db.Begin() res,err := db.Table("user").Where("id", 1).Data(data).Update() if (res == 0 || err!=nil) { // 回滚事务 db.Rollback() } res2,err2 := db.Table("user").Data(data).Insert() if (res2 == 0 || err2!=nil) { // 回滚事务 db.Rollback() } // 提交事务 db.Commit() ``` - 一键事务: 简单用法, 用闭包实现, 自动开始,回滚和提交 事务 ```go err := db.Transaction(func() (error) { res1,err := db.Execute("delete from users where id=14") if err!=nil { return err } res2,err2 := db.Table("area").Data(data).Insert() if err2!=nil { return err2 } res3,err3 := db.Table("area").Data(data).Where("id",10).Update() if err3!=nil { return err3 } return nil }) ``` 内部闭包会在返回错误时自动回滚, 会在没有错误时自动提交事务