企业🤖AI Agent构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
# 对象的 CRUD 操作 如果已知主键的值,那么可以使用这些方法进行 CRUD 操作 对 object 操作的四个方法 Read / Insert / Update / Delete ~~~ o := orm.NewOrm() user := new(User) user.Name = "slene" fmt.Println(o.Insert(user)) user.Name = "Your" fmt.Println(o.Update(user)) fmt.Println(o.Read(user)) fmt.Println(o.Delete(user)) ~~~ 如果需要通过条件查询获取对象,请参见[高级查询](https://www.kancloud.cn/oldlei/beego/query.md#all) ## Read 只查询一条数据,如果出现多条数据,只显示第一条。 1、查询主键id ~~~ o := orm.NewOrm() user := User{Id: 1} err := o.Read(&user) if err == orm.ErrNoRows { fmt.Println("查询不到") } else if err == orm.ErrMissPK { fmt.Println("找不到主键") } else { fmt.Println(user.Id, user.Name) } ~~~ Read 默认通过查询主键赋值,但要查询其他字段,可以使用指定的字段进行查询,但必须是结构体上的字段名称 :如Name ~~~ o := orm.NewOrm() user := User{Name: "slene"} err = o.Read(&user, "Name") ~~~ 多个条件查询 ~~~ o := orm.NewOrm() user := User{Name: "slene",Age:20} err = o.Read(&user, "Name","Age") ~~~ ``` o := orm.NewOrm() 对象的其他字段值将会是对应类型的默认值 // 2.定义需要查询的对象 var user models.User // 3.指定需要查询的字段 //user.Name = "zq" user.Id = 1 // 4.利用ORM对象查询指定的对象 // 含义从表中找到name是我们指定name的那一条数据, 然后赋值给传入的user变量 // 第二个参数就相当于过去的where name=user.Name //if err := o.Read(&user, "name"); err ==nil{ //if err := o.Read(&user, "id"); err ==nil{ // 注意点: 如果查询的条件字段是ID, 那么可以省略 if err := o.Read(&user); err ==nil{ beego.Info("查询成功", user) }else{ beego.Error("查询失败", err) } ``` ``` ~~~ o := orm.NewOrm() qs:=QueryTable("user") var users [ ]models.User _,err:=qs.All(&user) return users ~~~ ``` 复杂的单个对象查询参见[One](https://www.kancloud.cn/oldlei/beego/query.md#one) ## ReadOrCreate 尝试从数据库读取,不存在的话就创建一个 默认必须传入一个参数作为条件字段,同时也支持多个参数多个条件字段 ~~~ o := orm.NewOrm() user := User{Name: "slene"} // 三个返回参数依次为:是否新创建的,对象 Id 值,错误 if created, id, err := o.ReadOrCreate(&user, "Name"); err == nil { if created { fmt.Println("New Insert an object. Id:", id) } else { fmt.Println("Get an object. Id:", id) } } ~~~ ## Insert 第一个返回值为自增健 Id 的值 ~~~ o := orm.NewOrm() var user User user.Name = "slene" user.IsActive = true id, err := o.Insert(&user) if err == nil { fmt.Println(id) } ~~~ ``` // 1.获取ORM对象 o := orm.NewOrm() // 2.创建需要插入的对象 var user models.User user.Name="zq" user.PassWorld="987654" // 3.通过ORM对象将创建的对象插入到数据库当中 if id, err := o.Insert(&user); err == nil{ beego.Info("插入数据成功, id是", id) }else{ beego.Error("插入数据失败", err) } ``` 创建后会自动对 auto 的 field 赋值 ## InsertMulti 同时插入多条数据,最多100条,结构体+切片或数组 类似sql语句 ~~~ insert into table (name, age) values("slene", 28),("astaxie", 30),("unknown", 20) ~~~ 第一个参数 bulk 为并列插入的数量,第二个为对象的slice 返回值为成功插入的数量 ~~~ users := []User{ {Name: "slene"}, {Name: "astaxie"}, {Name: "unknown"}, ... } successNums, err := o.InsertMulti(100, users) ~~~ 返回插入成功条数及错误信息。 bulk 为 1 时,将会顺序插入 slice 中的数据 ## Update 第一个返回值为影响的行数 ~~~ o := orm.NewOrm() user := User{Id: 1} if o.Read(&user) == nil { user.Name = "MyName" if num, err := o.Update(&user); err == nil { fmt.Println(num) } } ~~~ Update 默认更新所有的字段,可以更新指定的字段: ~~~ // 只更新 Name o.Update(&user, "Name") // 指定多个字段 // o.Update(&user, "Field1", "Field2", ...) ... ~~~ ``` // 1.定义需要更新的对象 var user models.User // 2.指定需要查询的字段 // 为了避免出错, 一般情况下更新之前需要先判断数据是否存在 user.Name = "lnj" // 注意点: 如果查询的条件字段是ID, 那么可以省略 if err := o.Read(&user, "name"); err ==nil{ beego.Info("查询成功", user) // 3.设置需要更新的数据 user.Name="it666" user.PassWorld="abcdefg" count, \_ :=o.Update(&user) beego.Info("count====", count) }else{ beego.Error("查询失败", err) } ``` 根据复杂条件更新字段值参见[Update](https://www.kancloud.cn/oldlei/beego/query.md#update) ## Delete 第一个返回值为影响的行数 ~~~ o := orm.NewOrm() if num, err := o.Delete(&User{Id: 1}); err == nil { fmt.Println(num) } ~~~ ``` // 1.定义需要删除的对象 var user models.User // 2.指定需要查询的字段 // 为了避免出错, 一般情况下更新之前需要先判断数据是否存在 user.Name = "zq" // 注意点: 如果查询的条件字段是ID, 那么可以省略 if err := o.Read(&user, "name"); err ==nil{ beego.Info("查询成功", user) // 3.删除指定的对象 count, \_ :=o.Delete(&user) beego.Info("count====", count) }else{ beego.Error("查询失败", err) } ``` Delete 操作会对反向关系进行操作,此例中 Post 拥有一个到 User 的外键。删除 User 的时候。如果 on\_delete 设置为默认的级联操作,将删除对应的 Post **Changed in 1.0.3**删除以后不会删除 auto field 的值 ``` //1.有ORM对象 o := orm.NewOrm() //2.有一个要插入数据的结构体对象 user := models.User{} //3.对结构体对象赋值 user.Name = "111" user.Pwd = "222" //4.插入 _,err := o.Insert(&user) if err!= nil { beego.Info("插入失败",err) return } ``` ``` /1.有ORM对象 o := orm.NewOrm() //2.查询的对象 user := models.User{} //3.指定查询对象字段值 user.Name = "111" user.Id = 3 //4.查询-只有Id是参数可以省略 //err := o.Read(&user) err := o.Read(&user, "Name", "Id") if err != nil { beego.Info("查询失败", err) return } ``` ``` ///1.有ORM对象 o := orm.NewOrm() //2.查询要更新的结构体对象 user := models.User{} //3.查询需要更新的数据 user.Id = 1 err := o.Read(&user) //4.给数据重新赋值 if err == nil { user.Name = "999" //5.更新 num, err := o.Update(&user) if err != nil { beego.Info("更新失败", err) return } beego.Info("更新成功,一共更新了:", num, "条") } ``` ``` //1.有orm对象 o := orm.NewOrm() //2.删除的对象 user := models.User{} //3.指定那一条对象删除 //user.Id = 2 //num, err := o.Delete(&user) //条件只有Id的话,不用加参数 user.Pwd = "222" //4.删除 num, err := o.Delete(&user, "Pwd") if err != nil { beego.Info("删除失败", err) return } beego.Info("删除成功,一共删除了:", num, "条") ```