orm 原生数据操作

package main
import (
    "fmt"
    "github.com/astaxie/beego"
    "github.com/astaxie/beego/logs"
        "os"
    "log"
    "strings"
        _ "github.com/go-sql-driver/mysql"
    _"cms/beegodb/models"
    "github.com/astaxie/beego/orm"
    "bufio"
    "cms/beegodb/models"
    "encoding/json"

    "strconv"
)

var ConsoleLogs *logs.BeeLogger
var FileLogs *logs.BeeLogger
func init(){
    ConsoleLogs = logs.NewLogger(1000)
    ConsoleLogs.SetLogger("console")
    FileLogs = logs.NewLogger(1000)
    FileLogs.SetLogger("file",`{"filename":”logs/log.log"}`)
}
func logmsg(str string)  {
    log := logs.NewLogger()
    log.Alert(str)
    log.SetLogger(logs.AdapterConsole)
    log.Debug("this is a debug message")
    r := bufio.NewReader(os.Stdin)
    for {
        fmt.Print("Command> ")
        b, _, _ := r.ReadLine()
        line := string(b)
        tokens := strings.Split(line, " ")
        fmt.Println("Command:", tokens[0])
    }
}

//多表查询
func GetQuerList()  {
     var maps []orm.Params
     orm1 := orm.NewOrm()
     var sqlstr  string
     sqlstr ="SELECT us.id,us.name,us.pwd,us.pwd,";
     sqlstr+="ua.user_id,ua.id,ua.article_id,";
     sqlstr+="ar.article_type_id,ar.id,ar.arti_name,arts.id,arts.tname";
     sqlstr+=" from ";
     sqlstr+="user as us,user_articles as ua,article as ar,article_type as arts"
     sqlstr+=" WHERE us.id=ua.user_id and ar.article_type_id=arts.id"
     sql:=sqlstr;
     rs,err:=orm1.Raw(sql).Values(&maps)
     if err == nil {
        fmt.Printf("Result Nums: %d
",rs)
        for _, m := range maps {
            fmt.Println("用户:",m["name"],"密码:",m["pwd"],m["arti_name"],m["tname"])
        }
    }
    jsonData, err := json.Marshal(maps)
    fmt.Println("多条数据查询结果", maps," 
",jsonData)
    checkErr(err)
}
func QuerySqlAdd() {
    orm := orm.NewOrm()
    var sqlstr string
    var us models.User
    us.Name="dqh"
    us.Pwd="dqh"
    sqlstr = "insert into user (id,name,pwd) values(null, '"+us.Name+"','"+us.Pwd+"')";
    fmt.Println(sqlstr)
    res, err := orm.Raw(sqlstr).Exec()
    if err == nil {
        ins_id,_ := res.LastInsertId();
        fmt.Println("添加一行: ", ins_id)
    }
}
//删除数据
func QuerySqldel() {
    orm := orm.NewOrm()
    var sqlstr string
    var us models.User
    us.Id = 109
    sqlstr = "delete from user where id =" + strconv.Itoa(us.Id)
    fmt.Println(sqlstr)
    res, err := orm.Raw(sqlstr).Exec()
    if err == nil {
        num, _ := res.RowsAffected()
        fmt.Println("mysql row affected nums: ", num)
    }
}
//更新数据
func QuerySqlUp(){
    orm := orm.NewOrm()
    var sqlstr string
    var us models.User
    us.Name="44"
    us.Pwd="67"
    us.Id=115
    sqlstr ="update user set name="+us.Name+",pwd="+us.Pwd+" where id="+strconv.Itoa(us.Id)+""
    fmt.Println(sqlstr)
    res, err := orm.Raw(sqlstr).Exec()
    if err == nil {
        num, _ := res.RowsAffected()
        fmt.Println("mysql row affected nums: ", num)
    }
}
func GetQueryVlue()  {
    var lists []orm.ParamsList
    orm := orm.NewOrm()
    num, err := orm.Raw("SELECT * FROM user").ValuesList(&lists)
    if err == nil && num > 0 {
        fmt.Println(lists[7][0]) // slene
    }
}
//orm sql1行数据查询
func GetQueryRow() {
    //1.创建user对象
    var user models.User
    //2.创建orm
    orm := orm.NewOrm()
    user.Id=118
    //3.通过sql语句查询
    err := orm.Raw("select * from user where id = ?",user.Id).QueryRow(&user)
    //4.处理错误
    if err != nil {
        fmt.Println("err = ", err)
        beego.Info("查询出错!")
        return
    }
    //5.打印结果
    fmt.Println("输出", user.Name)
    beego.Info("查询成功!")

}
func SelectById(id int)  models.User {
    var us models.User
    o:=orm.NewOrm()
    id=122
    us.Id=id
    _ = o.Raw("select * from user where id=?", id).QueryRow(&us)
    return us
}
func main()  {
    //insertorm()
    GetQueryRow()
    GetQuerList()
    GetQueryVlue()
    QuerySqlAdd()
    QuerySqlUp()
    QuerySqldel()
    updateorm()
    chercorm()
    delorm()
    beego.Run()
}
//orm更新
func updateorm(){
    o := orm.NewOrm()
    //2.查询要更新的结构体对象
    user := models.User{}
    //3.查询需要更新的数据
    user.Id = 118
    err := o.Read(&user)
    if err == nil {
        user.Name = "999"
        //5.更新
        _, err := o.Update(&user)
        if err != nil {
            logmsg("更新失败")
            fmt.Println("gxsb")
            return
        }
        logmsg("更新成功")
    }
}
//orm添加
func insertorm()  {
    FileLogs.Alert("进入插入orm")
    o := orm.NewOrm()
    user :=models.User{}
    user.Name="admin"
    user.Pwd="admin"
    _,err := o.Insert(&user) //一定是地址
    checkErr(err)
    logmsg("插入成功")
}
//orm查询
func chercorm()  {
    o := orm.NewOrm()
    user := models.User{}
    user.Name = "admin"
    user.Id = 114
    err := o.Read(&user, "Name", "Id")
    if err != nil {
        beego.Info("查询失败", err)
        logmsg("查询失败")
        return
    }
    logmsg("查询成功")
}
//orm删除
func delorm(){
    o := orm.NewOrm()
    user:=models.User{}
    user.Id=114
    _,err:=o.Delete(&user,"Id")
    if err != nil {
        logmsg("删除失败")
        return
    }
    logmsg("删除成功")
}
func checkErr(err error){
    if err != nil {
        //panic(err)
        log.Fatal(err)
    }
}