beego原生mysql查询_Beego基础学习（五）Golang原生sql操作Mysql数据库增删改查（基于Beego下测试）...
//控制器文件
package controllers
import ("fmt"
"github.com/astaxie/beego"
"mypro/models"
"strings")
type GetMovieInfoControllerstruct{
beego.Controller
}
type MovieInfostruct{
Id int64
Movie_namestringMovie_directorstring}
type JsonpDatastruct{
CodeintMsgstring}//獲取列表數(shù)據(jù)展示
func (c *GetMovieInfoController) Get() {
ids := []string{"11", "9", "10"}
db :=models.ConnectDb();
defer db.Close()
idStr := strings.Join(ids, "','")
sqlText := "select id,movie_name,movie_director from movie_info where id in ('%s')"sqlText=fmt.Sprintf(sqlText, idStr)
rows,err :=db.Query(sqlText)
item :=MovieInfo{}
list :=[]MovieInfo{}forrows.Next(){varmid int64var movie_name, movie_director stringerr= rows.Scan(&mid,&movie_name,&movie_director)if err !=nil {
panic(err.Error())
}
item.Id=mid
item.Movie_name=movie_name
item.Movie_director=movie_director
list=append(list,item)
}
c.Data["List"] =list
c.Data["Title"] = "電影列表"c.TplName= "get.tpl"}//編輯查看數(shù)據(jù)地址
func (c *GetMovieInfoController) Edit() {
movie_id := c.GetString(":id")
db :=models.ConnectDb();
defer db.Close()varInfo MovieInfo
err := db.QueryRow("select id,movie_name,movie_director from movie_info where id = ?",movie_id).Scan(&Info.Id, &Info.Movie_name, &Info.Movie_director)if err !=nil {
panic(err.Error())
}
c.Data["info"] =Info
c.TplName= "Edit.tpl"}//編輯提交地址
func (c *GetMovieInfoController ) EditPost() {
Movie_name:=c.GetString("name")
Movie_director:=c.GetString("director")
Id:=c.GetString("id")
db :=models.ConnectDb();
defer db.Close()
res,_ := db.Exec("update movie_info set movie_name =?,movie_director = ? where id = ?",Movie_name,Movie_director,Id)
num, _ := res.RowsAffected() //影響行數(shù)
if num >0{
c.Redirect("/editmovieinfo/"+Id,301)
}else{
c.Redirect("http://www.baidu.com",301)
}
}//刪除動(dòng)作提交
func (c *GetMovieInfoController ) Delete() {
Id:=c.GetString(":id")
db :=models.ConnectDb();
defer db.Close()
res,err := db.Exec("delete from movie_info where id = ?",Id)if err !=nil {
panic(err.Error())
}
num, _ := res.RowsAffected() //影響行數(shù)
if num >0{
c.Redirect("/getmovieinfo",301)
}else{
c.Redirect("http://www.baidu.com",301)
}
}//增加視圖
func (c *GetMovieInfoController ) AddView() {
c.TplName="add.tpl"}//增加提交操作地址
func (c *GetMovieInfoController ) Add() {
Movie_name:=c.GetString("name")
Movie_director:=c.GetString("director")
db :=models.ConnectDb();
defer db.Close()
res,err := db.Exec("insert into movie_info ( movie_name ,movie_director) values (?,?)",Movie_name,Movie_director)if err !=nil {
panic(err.Error())
}
num, _ := res.RowsAffected() //影響行數(shù)
if num >0{
c.Redirect("/getmovieinfo",301)
}else{
c.Redirect("http://www.baidu.com",301)
}
}
總結(jié)
以上是生活随笔為你收集整理的beego原生mysql查询_Beego基础学习（五）Golang原生sql操作Mysql数据库增删改查（基于Beego下测试）...的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： python跑一亿次循环_python爬
- 下一篇： linux cmake编译源码,linu