GoFrame第五天

GoFrame day5

前言

有了客户端与服务端的请求和处理之后,我们还需要完成一些其他的功能,比如数据库交互,国际化服务,资源管理,分页管理…

今天就来学习一下重要的数据库交互相关内容,说到底大多数服务也只是对数据库进行增删改查.在GoFramev2.1之后数据库驱动都需要手动引入,相关的操作可以去看看这里https://github.com/gogf/gf/tree/master/contrib/drivers

ORM

GoFrame的ORM功能使用gdb模块实现,采用了链接池设计所以会自动关闭不再需要手动关闭.

使用配置

首先连接数据库需要设置数据库类型,数据库名,数据库链接(用户名,密码…),和之前的配置文件类似,同样可以在config.yaml中设置这些参数

增删改查相关

一般常用的数据库操作可以使用GoFrame支持的ORM链式操作,但是默认情况下gdb都不是链式安全的,也就是说每一个方法都会对当前的Model进行修改,不能重复使用.我们也可以手动调用Clone来克隆当前的模型,创建一个新的模型来实现链式安全.也可以设置Safe设置当前为链式安全的,不过每一次操作都需要使用变量赋值来覆盖原始模型.

对于较为复杂不好组合的查询或者操作,则可以选择使用原生的数据库操作来实现.下面就来看看一些例子(以插入insert为例)

package main

import (
	"fmt"

	"github.com/gogf/gf/v2/os/gctx"

	"github.com/gogf/gf/v2/frame/g"
)

type User struct {
    
	Uid  int    `orm:"uid"`
	Name string `orm:"name"`
	Site string `orm:"site"`
}

func main() {
    
	user := &User{
    
		Uid:  1,
		Name: "john",
		Site: "https://goframe.org",
	}
	db := g.DB()
	var ctx = gctx.New()
	g.Model("user").Data(user).Insert()

	_, err := db.Insert(ctx, "user", g.Map{
    
		"name": "bbb",
	})
	if err != nil {
    
		println(err)
	}

	g.Model("user").Data(g.Map{
    
		"name": "ccc",
	}).Insert()

	g.Model("user").Data(g.Map{
    
		"name": "ddd",
	}).Insert()

	//数量
	count, err := g.DB().Model("user").Where("uid", 10001).Count()
	if err != nil {
    
		panic(err)
	}
	fmt.Println("count:", count)
	//获取单个值
	v, err := g.DB().Model("user").Where("uid", 10000).Fields("name").Value()
	if err != nil {
    
		panic(err)
	}
	fmt.Println("name:", v.String())
	// 查询对象
	r, err := g.DB().Model("user").Where("uid", 10001).One()
	if err != nil {
    
		panic(err)
	}
	fmt.Println("name:", r.Map()["name"])
	// 查询对象
	//l, err := g.DB().Model("user").As("t").Where("t.uid > ?", 10000).All()
	// 也可以简写为 select * from user as t where t.uid > 10000
	l, err := g.DB().Model("user").As("t").All("t.uid > ?", 10000)
	if err != nil {
    
		panic(err)
	}
	for index, value := range l {
    
		fmt.Println(index, value["uid"], value["name"])
	}
	//g.DB().Model("user").Where("uid", 10001).Delete()
	//g.DB().Model("user").Where("uid", 10002).Delete()
}

对于简单的操作,可以使用g.Model()调用链式方法,默认Model使用的是config.yaml中default的设置,我的配置如下:

debug可以让我们看到每一行语句是否成功,dryrun: 0不会让我们只读不写,其他设置都是数据库连接相关,当然也可以添加log方便以后检查.

从代码看我们添加数据有好几种方式:

• 链式添加一个实体对象
• 链式添加一个g.Map{}封装的数据
• 原生方式添加一个数据

其他操作,如查询删除等等都可以仿照这份代码里的操作进行

事务与闭包

常规的事务操作方法为Begin/Commit/Rollback,先用Begin开启事务返回一个事务的操作对象;然后对操作对象进行后续数据库操作,利用Commit提交事务,如果存在错误就使用Callback回滚.但是开启事务之后一定要记得进行事务的提交或者回滚,否则会导致goroutine不断增长,导致后续事务超时.

为了防止我们忘记提交或者回滚,所以建议使用闭包操作处理事务.当给定的闭包方法没有错误的时候会自动执行提交事务,反之则会回滚事务.