beego框架之orm的使用

　 最近想專案接觸到了用go語言來操作資料庫msyql，用到了beego的orm，beego ORM（Object Relational Mapping） 是一個強大的 Go 語言 ORM 框架。它的靈感主要來自 Django ORM 和 SQLAlchemy。功能還是比較強大的。 
目前beego-orm支援的資料有: 
- MySQL：https://github.com/go-sql-driver/mysql 
- PostgreSQL：https://github.com/lib/pq

 
- Sqlite3：https://github.com/mattn/go-sqlite 
beego-orm的相關特性 
- 支援 Go 的所有型別儲存 
- 輕鬆上手，採用簡單的 CRUD 風格 
- 自動 Join 關聯表 
- 跨資料庫相容查詢 
- 允許直接使用 SQL 查詢／對映 
- 嚴格完整的測試保證 ORM 的穩定與健壯 
orm的使用 
- 匯入orm的依賴:go get github.com/astaxie/beego/orm. 
- 使用的步驟： 
1.往orm註冊預設資料庫（包括資料庫的連線的一些設定引數）,往orm註冊model。

def.go

/**
*實體定義
*/
type User struct {
    Id       int    `json:"id" pk:"auto" orm:"column(id)"`
    Username string `json:"username" orm:"column(username)"`
    Password string `json:"password" orm:"column(password)"`
    Sex      string `json:"sex" orm:"column(sex)"`
    Tel      string `json:"tel"
 
 orm:"column(tel)"`
}
/**
*資料相關配置
*/
type DBConfig struct {
    Host         string
    Port         string
    Database     string
    Username     string
    Password     string
    MaxIdleConns int   //最大空閒連線
    MaxOpenConns int   //最大連線數
}

usermanger.go

package service
import (
    "github.com/astaxie/beego/orm"
    "fmt"
    log "github.com/Sirupsen/logrus"
    _ "github.com/go-sql-driver/mysql"
)
/**
*CreatedBy:Hanyajun
*Time:2017 2017/10/28 14:34
*Project:Go_study
*Discription:使用orm操作mysql
*/
type UserManager struct {
    DBConf *DBConfig
}
  /*
  * usermanger構造器                         
  */                            
func NewUserManager(dbConf *DBConfig) *UserManager {
    mgr := &UserManager{
        DBConf: dbConf,
    }
    mgr.initDB()//初始化orm
    return mgr
}
/**
  初始化db，註冊預設資料庫，同時將實體模型也註冊上去
 */
func (mgr *UserManager) initDB() {
    orm.RegisterDriver("mysql", orm.DRMySQL)
　　　ds :=fmt.Sprintf("%s:%[email protected](%s:%s)/%s?　　　　　　　　charset=utf8", mgr.DBConf.Username, mgr.DBConf.Password, mgr.DBConf.Host, mgr.DBConf.Port, mgr.DBConf.Database)
    log.Infof("datasource=[%s]", ds)
　　err := orm.RegisterDataBase("default", "mysql", ds, 　　mgr.DBConf.MaxIdleConns, mgr.DBConf.MaxOpenConns)
    if err != nil {
        panic(err)
    }
    orm.RegisterModel(new(User))
}      

注意可以使用以下方式進行切換資料庫：

orm.RegisterDataBase("db1", "mysql", "root:[email protected]/orm_db2?charset=utf8")
orm.RegisterDataBase("db2", "sqlite3", "data.db")
o1 := orm.NewOrm()
o1.Using("db1")
o2 := orm.NewOrm()
o2.Using("db2")                     

2.操作資料庫

1. 對於要操作的資料庫如果你知道它的主鍵，則你可以用orm物件的crud方法進行資料庫的相關操作。

/**
 *通過orm物件來進行資料庫的操作，這種情況是必須要知道主鍵
 */
func (mgr *UserManager) OpreateUserWithOrmObjct(id int) () {
    orm.Debug = true
    o := orm.NewOrm()
    var users = new(User)//注意使用new來建立變數，否則就會報錯
    users.Id = id
    fmt.Print("******開始讀取資料庫*******")
    o.Read(users)
    fmt.Print(users)
    fmt.Print("******開始更新資料庫*******")
    users.Username = "123"
    o.Update(users)
    o.Read(users)
    fmt.Printf("更新後的資料庫為%v", users)
    o.Delete(users)       
      }   

1. 如果你不知道主鍵則可以通過orm的Querytable或者Raw執行原始的sql語句來操作資料庫。

/**
根據某些欄位來read 1：採用queryTable方法來查詢 2：採用Raw執行sql語句
 */
func (mgr *UserManager) GetUsersByIdWithQueryTable(id string) (*[]User, error) {
    orm.Debug = true
    o := orm.NewOrm()
    user := new([]User)
    _, err := o.QueryTable("user").Filter("Id", id).All(user)
    //err := o.QueryTable("user").Filter("id",key).One(user)
    //err:=o.Raw("select * from user where Id = ?",id).QueryRow(user)//使用sql語句進行查詢
    if err != nil {
        fmt.Println(err)
        return nil, err
    }
    return user, nil
}                      

３. 分頁查詢，可以使用limt方法來進行分頁（注意limt後面的引數，第一個表示的是分頁大小，第二個是指的偏移量，如同sql的offset）。

 /**
  * 分頁結構體                           
 */                            
 type Page struct {
    PageNo     int
    PageSize   int
    TotalPage  int
    TotalCount int
    FirstPage  bool
    LastPage   bool
    List       interface{}
}
func PageUtil(count int, pageNo int, pageSize int, list interface{}) Page {
    tp := count / pageSize
    if count % pageSize > 0 {
        tp = count / pageSize + 1
    }
    return Page{     
          PageNo: pageNo, 
          PageSize: pageSize, 
          TotalPage: tp, 
          TotalCount: count,
          FirstPage: pageNo == 1,
          LastPage: pageNo == tp,
          List: list
          }
}                             
func (mgr *UserManager) getUsrsWithPage(ps int, pageSize int) (page Page ) {
    o := orm.NewOrm()
    user:=new([]User)
    o.QueryTable("user").Limit(pageSize,(ps-1)*pageSize).All(user)
    TotalCount,_:=o.QueryTable("user").Count()
    page.TotalCount=int(TotalCount)
    page.PageSize=pageSize
    page.List=user
    fmt.Println(user)
    return  page
}

• 除了以上方法操作資料庫， QueryBuilder 提供了一個簡便，流暢的 SQL 查詢構造器。在不影響程式碼可讀性的前提下用來快速的建立 SQL 語句,QueryBuilder 在功能上與 ORM 重合， 但是各有利弊。ORM 更適用於簡單的 CRUD 操作，而 QueryBuilder 則更適用於複雜的查詢，例如查詢中包含子查詢和多重聯結。使用方法如下:

// User 包裝了下面的查詢結果
type User struct {
    Name string
    Age  int
}
var users []User
// 獲取 QueryBuilder 物件. 需要指定資料庫驅動引數。
// 第二個返回值是錯誤物件，在這裡略過
qb, _ := orm.NewQueryBuilder("mysql")
// 構建查詢物件
qb.Select("user.name",
    "profile.age").
    From("user").
    InnerJoin("profile").On("user.id_user = profile.fk_user").
    Where("age > ?").
    OrderBy("name").Desc().
    Limit(10).Offset(0)
// 匯出 SQL 語句
sql := qb.String()
// 執行 SQL 語句
o := orm.NewOrm()
o.Raw(sql, 20).QueryRows(&users)                            

• 當然資料庫操作必然離不開事物，orm支援簡單的orm事物操作：

 o := NewOrm()
err := o.Begin()
// 事務處理過程
...
...
// 此過程中的所有使用 o Ormer 物件的查詢都在事務處理範圍內
if SomeError {
    err = o.Rollback()
} else {
    err = o.Commit()
}                

• 本文為博主原創文章，未經博主允許不得轉載。 https://blog.csdn.net/hanyajun0123/article/details/78378207