Beego数据库操作及路由控制

一拳打死你 · · 1086 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

beego入门体验
通过beego自带bee工具bee run 创建完一个项目以后。那么便可以在这么目录结构上完成我的项目。其中,少不了数据库操作和路由。
我们在原有的基础上新建一个数据库article的数据库表。结构如下:

CREATE TABLE IF NOT EXISTS `article` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(200) NOT NULL,
  `client` varchar(200) NOT NULL,
  `url` varchar(200) NOT NULL,
  `notes` text NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=MyISAM  DEFAULT CHARSET=gbk AUTO_INCREMENT=9 ;

建完数据库以后,需要有一个想对应的模型,在models的目录下的models.go的文件下加入如下代码:

import (
    "github.com/astaxie/beego/orm"
    _ "github.com/go-sql-driver/mysql"
)

type Article struct {
    Id int `form:"-"`
    Name string `form:"name,text,name:" valid:"MinSize(5);MaxSize(20)"`
    Client string `form:"client,text,client:"`
    Url string `form:"url,text,url:"`
    Notes string `form:"url,text,notes:"`
}

func init() {
    orm.RegisterDriver("mysql", orm.DR_MySQL)
    orm.RegisterDataBase("default", "mysql", "root:123456789@/beego_learn?charset=utf8")
    orm.RegisterModel(new(Article))
}

model中定义我们的数据库结构,并且完成数据库的初始化连接。
创建完成以后,默认有一个default.go的控制器。那么我们在创建一个测试的控制器,于是,我们新建一个test.go的控制器文件。test.go的实现大概如下:

package controllers

import (
    "fmt"
    "github.com/astaxie/beego"
    "github.com/astaxie/beego/orm"
    "reflect"
    //"strconv"
    models "wanghuixin/models"
)

type TtController struct {
    beego.Controller
}

func (c *TtController) Get() {
    orm.Debug = true
    o := orm.NewOrm()
    o.Using("default") // 默认使用 default,你可以指定为其他数据库
    var maps []orm.Params
    var Article models.Article
    //res, err := o.QueryTable("Article").Filter("id", "name").All(&Article)
    num, err := o.QueryTable("Article").Values(&maps, "id", "name", "client", "url", "notes")
    if err == orm.ErrNoRows {
        fmt.Println("查询不到")
    } else if err == orm.ErrMissPK {
        fmt.Println("找不到主键")
    } else {
        fmt.Println(Article.Id, Article.Name)
        fmt.Println("res是:", reflect.TypeOf(maps))
        fmt.Println(num)
        for _, v := range maps {
            fmt.Println(v)
        }
        c.Data["m"] = maps
    }
    c.TplNames = "index.tpl"
}

func (c *MainController) Read() {
    orm.Debug = true
    o := orm.NewOrm()
    o.Using("default")
    //var Article models.Article
    //err := o.QueryTable("Article").Filter("name").One(&Article)
    id := c.Ctx.Input.Param(":ids")
    intid, err := strconv.Atoi(id)
    user := models.Article{Id: intid}
    err = o.Read(&user)
    if err == orm.ErrMultiRows {
        // 多条的时候报错
        fmt.Printf("Returned Multi Rows Not One")
    }
    if err == orm.ErrNoRows {
        // 没有找到记录
        fmt.Printf("Not row found")
    }
    fmt.Println("id 是", id)
    c.Data["m"] = user
    c.TplNames = "read.tpl"
}
Get方法是默认获取数据表全部数据,Read是根据ID获取一条数据。然后,我们需要一个路由。
我们在routers目录下新建一个tt.go。tt.go代码如下:
package routers

import (
    "github.com/astaxie/beego"
    "quantou/controllers"
)

func init() {
    beego.Router("/read", &controllers.TtController{}, "*:Get")
    beego.Router("/read/:ids([0-9]+)", &controllers.TtController{}, "*:Read")
}

这样,就可以将相应的访问地址分配到相应的系统方法里了。也可以将上面代码追加到默认的models.go文件。只是分开更方便管理。
当然,还可以在路由中对相应的控制器进行自动注册,那样,就不再需要为每个方法分别配置。方法如下:

func init() {
   beego.AutoRouter(&controllers.ObjectController{})
}

那么 beego 就会通过反射获取该结构体中所有的实现方法,你就可以通过如下的方式访问到对应的方法中:

/object/login 调用 ObjectController 中的 Login 方法
/object/logout 调用 ObjectController 中的 Logout 方法

除了前缀两个/:controller/:method的匹配之外,剩下的 url beego会帮你自动化解析为参数,保存在 this.Ctx.Input.Params 当中:

/object/blog/2013/09/12 调用 ObjectController 中的 Blog 方法,参数如下:map[0:2013 1:09 2:12]


有疑问加站长微信联系(非本文作者)

本文来自:Segmentfault

感谢作者:一拳打死你

查看原文:Beego数据库操作及路由控制

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1086 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传