关于mysql:使用wegoworm的智能选择字段功能访问数据库

1次阅读

共计 3517 个字符,预计需要花费 9 分钟才能阅读完成。

介绍

worm 是一款不便易用的 Go 语言 ORM 库,worm 具备应用简略,运行性能高,功能强大的特点。具体特色如下:

  • 通过 Struct 的 Tag 与数据库字段进行映射,让您免于常常拼写 SQL 的麻烦。
  • 反对 Struct 映射、原生 SQL 以及 SQLBuilder 三种模式来操作数据库,并且 Struct 映射、原生 SQL 以及 SQLBuilder 可混合应用。
  • Struct 映射、SQL builder 反对链式 API,可应用 Where, And, Or, ID, In, Limit, GroupBy, OrderBy, Having 等函数结构查问条件。
  • 可通过 Join、LeftJoin、RightJoin 来进行数据库表之间的关联查问。
  • 反对事务反对,可在会话中开启事务,在事务中能够混用 Struct 映射、原生 SQL 以及 SQL builder 来操作数据库。
  • 反对预编译模式拜访数据库,会话开启预编译模式后,任何 SQL 都会应用缓存的 Statement,能够晋升数据库拜访效率。
  • 反对应用数据库的读写拆散模式来拜访一组数据库。
  • 反对在 Insert,Update,Delete,Get, Find 操作中应用钩子办法。
  • 反对 SQL 日志的输入,并且可通过日志钩子自定义 SQL 日志的输入,日志钩子反对 Context。
  • 可依据数据库主动生成库表对应的 Model 构造体。

目前 worm 反对的数据库有:mysql、postgres、sqlite、sqlserver。

代码获取

go get github.com/haming123/wego/worm

应用 select 办法指定字段

应用 worm.Model().Update() 办法来更新数据库时,则 worm 缺省会更新实体类对应的全副字段。若只心愿更新指定的字段,能够应用若 Select 办法指定须要更新的字段:

func demoModelUpdate() {var user = User{Name:"name1", Age: 21, Created: time.Now()}
    _, err := worm.Model(&user).Select("name", "age").ID(1).Update()
    if err != nil{log.Println(err)
        return
    }
}
//update users set name=?,age=? where id=?

基于编辑状态来更新数据库

Select 办法尽管可能做到按需更新,然而若库表的字段比拟多,这种办法应用起来则比拟麻烦,也容易引起谬误(更新了不该更新的字段)。worm 提供了一种基于编辑状态来更新数据库的办法:

  • 首先创立实体类
  • 接着 Model 对象,并将实体类指针传递给 Model
  • 而后应用 SetValue 办法一一给字段赋值
  • 最初调用 Update()办法更新数据库

    func demoModelUpdateX() {var user = User{}
      md := worm.Model(&user)
      md.SetValue(&user.Name, "name2")
      md.SetValue(&user.Age, 22)
      _, err := md.ID(1).Update()
      if err != nil{log.Println(err)
          return
      }
    }
    //update users set name=?,age=? where id=?

    阐明:

  • 应用 SetValue 办法,第一个参数必须是实体对象的字段的指针,第二个对象的类型须要与字段类型统一。

通过 Vo 对象拜访数据库

更加无效的办法是通过 Vo 对象来拜访数据库。Vo 对象只蕴含了须要应用的数据库字段,因而应用 Vo 对象来拜访数据库能够缩小数据库拜访的负载,并可能缩小数据更新时的谬误(只更新必要字段)。例如:

type UserVo struct {
    Id          int64       
    Name        string      
    Age         int64       
}

阐明:

  • 通常 Vo 构造提的字段与 Model 构造体的字段保持一致,并且不须要字段标签(tag:db)
  • 若 Vo 构造提的字段与 Model 构造体的字段不统一,须要实现:VoLoader 接口或 VoSaver 接口

应用 Vo 增加数据库记录

有了 Vo 对象,您能够这样来查询数据库:

func insertUserVo() {var vo = UserVo{Age: 33, Name: "demo3"}
    id, err := worm.Model(&User{}).Insert(&vo)
    if err != nil{log.Error(err)
        return
    }
    log.Debug(id)
}
//insert into user set name=?,age=?

应用 Vo 更新数据库记录

func insertUserVo() {vo = UserVo{Age: 32, Name: "NameVo2"}
    _, err := worm.Model(&User{}).Update(&vo)
    if err != nil{log.Error(err)
        return
    }
}
//update user set name=?,age=? where id=?

应用查问单条记录到 Vo

func demoGetVo() {
    var vo UserVo
    _, err := dbs.Model(&User{}).Where("id=?", 1).Get(&vo)
    if err != nil{log.Error(err)
        return
    }
}
//select id,name,age from user where id=1 limit 1

应用查问多条记录到 Vo 数组

func demoFindUserVo() {var arrvo []UserVo
    err := worm.Model(&User{}).WhereIn("id>?", 0).Find(&arrvo)
    if err != nil{log.Error(err)
        return
    }
}
//select id,name,age from user where id>?

应用 VoLoader 接口定义 Vo 数据查问逻辑

worm 通过字段的名称 + 字段的类型把 Vo 对象与 Model 对象进行映射来抉择 Model 的字段。若 Vo 对象与 Model 对象的字段名称不雷同,您可为 Vo 对象实现 VoLoader 接口,VoLoader 接口用于定义 Vo 如何从 Model 对象获取数据。

type VoLoader interface {LoadFromModel(md *DbModel, mo interface{})()}

一个应用 VoLoader 接口的例子:

type UserVo struct {
    Id          int64
    UserName       string
    UserAge        int
}
func (vo *UserVo) LoadFromModel(md *worm.DbModel, mo_ptr interface{}) {if mo, ok := mo_ptr.(*User); ok {vo.Id = worm.GetInt64(md, &mo.Id)
        vo.UserName = worm.GetString(md, &mo.Name)
        vo.UserAge = worm.GetInt(md, &mo.Age)
    }
}
// 应用 UserVo 查询数据库
var arr []UserVo
err := worm.Model(&User{}).Where("id>?", 0).Find(&arr)
//select id,name,age from user where id>?

应用 VoSaver 接口定义 Vo 数据存储逻辑

同样,您可为 Vo 对象实现 VoSaver 接口,VoSaver 接口用于定义如何将 Vo 的值赋值给 Model 对象,并通过 Model 对象更新数据库。

type VoSaver interface {SaveToModel(md *DbModel, mo interface{})()}

一个应用 VoSaver 接口的例子:

func (vo *UserVo) SaveToModel(md *worm.DbModel, mo_ptr interface{}) {if mo, ok := mo_ptr.(*User); ok {worm.SetValue(md, &mo.DB_id, vo.DB_id)
        worm.SetValue(md, &mo.DB_name, vo.DB_name)
        worm.SetValue(md, &mo.Age, vo.Age)
    }
}
// 插入记录
vo := UserVo{UserAge: 31, UserName: "NameVo"}
id, err := worm.Model(&User{}).Insert(&vo)
//insert into user set name=?,age=?
// 更新记录
vo = UserVo{UserAge: 32, UserName: "NameVo2"}
_, err = worm.Model(&User{}).ID(id).Update(&vo)
//update user set name=?,age=? where id=?
正文完
 0