Go语言ORM框架:快捷查询函数的使用

KeLongRen
• 阅读 1595

快捷查询函数

大多数情况下您都是在使用worm支提供的Model方式(持结构体字段映射)来访问数据库,但有些时候使用Model方式显然有些笨重。例如您可能只需要查询一个记录的一个字段的值,这种情况下若使用Model方式则比较繁琐。worm提供了一些快捷查询函数来应对这种需求,例如DbTable的GetString()函数,该函数克用于查询一个记录的一个字符串类型的字段。这些快捷查询函数可以用于原生SQL以及SQLBuilder模式,这些快捷函数的用法以上两种模式下的用法基本上是一致的,本文中使用SQLBuilder模式来说明这些快捷函数的使用方法。

main函数

package main
import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
    log "github.com/haming123/wego/dlog"
    "github.com/haming123/wego/worm"
)
func mysql_open(cnnstr string) (*sql.DB, error) {
    db, err := sql.Open("mysql", cnnstr)
    if err != nil {
        return nil, err
    }
    err = db.Ping()
    if err != nil {
        return nil, err
    }
    return db, nil
}
func main() {
    //创建数据连接池
    cnnstr := "user:passwd@tcp(127.0.0.1:3306)/dbname?charset=utf8&parseTime=True"
    db_cnn, err := mysql_open(cnnstr)
    if err != nil {
        log.Error(err)
        return
    }
    //初始化ORM
    worm.InitMysql(db_cnn)
    //显示SQL语句log
    worm.ShowSqlLog(true)
}

说明:

  • worm代码的下载
    go get github.com/haming123/wego
  • worm.ShowSqlLog
    worm.ShowSqlLog用于控制sql日志的显示,建议测试环境下打开sql日志的显示的开关,这样可以看到每个数据库操作的sql语句以及执行时间,方便快速定位问题。
  • 数据库的支持
    目前worm支持的数据库有:mysql、postgres、sqlite、sqlserver, 本文的例子中采用了mysql数据库。

数据库表

//建表语句
CREATE TABLE `user` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `name` varchar(30) DEFAULT NULL,
  `age` int(11) DEFAULT NULL,
  `passwd` varchar(32) DEFAULT NULL,
  `created` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
);

查询某个记录是否存在

有些情况下您不需要获取一个记录的数据,而是只需要查询数据库中是否存在某个记录,这种情况下可以使用Exist()函数:

func SQLBuilderExist() {
    has, err := worm.Table("user").ID(1).Exist()
    if err != nil {
        log.Error(err)
        return
    }
    //select * from user where id=? limit 1
}

查询一个记录的指定字段

有些情况下您可能只需要获取一条记录的某几个字段,这种情况在没必要定义一个struct,然后通过Model方式来获取字段的数据。您可以使用DbTable的Get函数:

func SQLBuilderGetValue() {
    name := ""; age := 0
    _, err := worm.Table("user").Select("name,age").ID(1).Get(&name, &age)
    if err != nil {
        log.Error(err)
        return
    }
    //select name,age from user where id=? limit 1
}

说明:

  • Get函数的参数是可变长参数,参数的数量与类型必须与Select()中的字段一一对应。
  • Get函数的第一个返回值是一个bool类型,用于表示是否存在该记录。

查询一个记录的一个字符串字段

GetString()函数用于查询一个记录的一个字符串字段

func SQLBuilderGetValue() {
    val, err := worm.Table("user").Select("name").ID(1).GetString()
    if err != nil {
        log.Error(err)
        return
    }
    //select name from user where id=? limit 1
}

说明:

  • Select()中必须只有一个字段,并且字段的类型为字符串。
  • GetString()的第一个返回值为sql.NullString类型,其中的Valid变量用于说明是否是一个有效的值。

查询一个记录的一个整形字段

GetInt()函数用于查询一个记录的一个整形字段

func SQLBuilderGetInt() {
    val, err := worm.Table("user").Select("age").ID(1).GetInt()
    if err != nil {
        log.Error(err)
        return
    }
    //select age from user where id=? limit 1
}

说明:

  • Select()中必须只有一个字段,并且字段的类型为整形。
  • GetInt()的第一个返回值为sql.NullInt64类型,其中的Valid变量用于说明是否是一个有效的值。

查询一个记录的一个浮点型字段

GetFloat()函数用于查询一个记录的一个浮点型字段

func SQLBuilderGetFloat() {
    val, err := worm.Table("user").Select("weight").ID(1).GetFloat()
    if err != nil {
        log.Error(err)
        return
    }
    //select weight from user where id=? limit 1
}

说明:

  • Select()中必须只有一个字段,并且字段的类型为浮点型。
  • GetFloat()的第一个返回值为sql.NullFloat64类型,其中的Valid变量用于说明是否是一个有效的值。

查询一个记录

GetFloat()函数用于查询一个记录的一个浮点型字段

func SQLBuilderGetFloat() {
    val, err := worm.Table("user").Select("weight").ID(1).GetFloat()
    if err != nil {
        log.Error(err)
        return
    }
    //select weight from user where id=? limit 1
}

说明:

  • Select()中必须只有一个字段,并且字段的类型为浮点型。
  • GetFloat()的第一个返回值为sql.NullFloat64类型,其中的Valid变量用于说明是否是一个有效的值。

查询满足条件的记录数

Count()函数用于查询查询满足条件的记录数

func SQLBuilderCount() {
    val, err := worm.Table("user").Where("id>?", 0).Count()
    if err != nil {
        log.Error(err)
        return
    }
    //select count(1) from user where id>?
}

说明:

  • Count()若没有参数,则使用count(1)的计数, 若需要您也可以指定字段名称来计数:

    func SQLBuilderCount() {
      val, err := worm.Table("user").Where("id>?", 0).Count("name")
      if err != nil {
          log.Error(err)
          return
      }
      //select count(name) from user where id>?
    }

count_distinct查询

DistinctCount()函数用于统计满足条件的字段的排重后的数量:

func SQLBuilderDistinctCount() {
    val, err := worm.Table("user").Where("id>?", 0).DistinctCount("name")
    if err != nil {
        log.Error(err)
        return
    }
    //select count(distinct name) from user where id>?
}

查询字符串字段到数组

FindString()函数用于查询满足条件的记录,并将字符串字段的值添加到字符串数组:

func SQLBuilderFindString() {
    val, err := worm.Table("user").Select("name").Where("id>?", 0).FindString()
    if err != nil {
        log.Error(err)
        return
    }
    // select name from user where id>?
}

说明:

  • Select()中必须只有一个字段,并且字段的类型为字符串。

查询整形字段到数组

FindInt()函数用于查询满足条件的记录,并将整形字段的值添加到整形数组:

func SQLBuilderFindInt() {
    val, err := worm.Table("user").Select("age").Where("id>?", 0).FindInt()
    if err != nil {
        log.Error(err)
        return
    }
    log.Debug(val)
    // select age from user where id>?
}

说明:

  • Select()中必须只有一个字段,并且字段的类型为整形。

查询浮点型字段到数组

FindInt()函数用于查询满足条件的记录,并将浮点型字段的值添加到浮点型数组:

func SQLBuilderFindFloat() {
    val, err := worm.Table("user").Select("weight").Where("id>?", 0).FindFloat()
    if err != nil {
        log.Error(err)
        return
    }
    // select weight from user where id>?
}

说明:

  • Select()中必须只有一个字段,并且字段的类型为浮点型。
点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
Easter79 Easter79
3年前
sql注入
反引号是个比较特别的字符,下面记录下怎么利用0x00SQL注入反引号可利用在分隔符及注释作用,不过使用范围只于表名、数据库名、字段名、起别名这些场景,下面具体说下1)表名payload:select\from\users\whereuser\_id1limit0,1;!(https://o
Jacquelyn38 Jacquelyn38
4年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Easter79 Easter79
3年前
Twitter的分布式自增ID算法snowflake (Java版)
概述分布式系统中,有一些需要使用全局唯一ID的场景,这种时候为了防止ID冲突可以使用36位的UUID,但是UUID有一些缺点,首先他相对比较长,另外UUID一般是无序的。有些时候我们希望能使用一种简单一些的ID,并且希望ID能够按照时间有序生成。而twitter的snowflake解决了这种需求,最初Twitter把存储系统从MySQL迁移
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
3年前
mysql中的几种判断语句
在使用mysql过程中,经常会有根据某个字段的不同值显示语义化的名称的需求,例如一张用户表,有个sex字段存放的是用户性别,一般不会直接存男,女,未知这种字符串,而是存的0,1,2这种整型,整型的好处是查询效率高于字符串,查询出结果要显示成男,女这种,通常做法是查询出结果,在结果里if判断再赋值成字符串。其实mysql提供了类似判断的语法可以直接查出语义化的
Wesley13 Wesley13
3年前
F查询和Q查询,事务及其他
F查询和Q查询F查询在上面所有的例子中,我们构造的过滤器都只是将字段值与某个我们自己设定的常量做比较。如果我们要对两个字段的值做比较,那该怎么做呢?Django提供F()来做这样的比较。F()的实例可以在查询中引用字段,来比较同一个model实例中两个不同字段的值。示例1:查询出卖出数大于库存数的商品
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
为什么mysql不推荐使用雪花ID作为主键
作者:毛辰飞背景在mysql中设计表的时候,mysql官方推荐不要使用uuid或者不连续不重复的雪花id(long形且唯一),而是推荐连续自增的主键id,官方的推荐是auto_increment,那么为什么不建议采用uuid,使用uuid究
美凌格栋栋酱 美凌格栋栋酱
5个月前
Oracle 分组与拼接字符串同时使用
SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(