//控制器文件

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}//获取列表数据展示

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"}//编辑查看数据地址

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() //影响行数

if num >0{

c.Redirect("/editmovieinfo/"+Id,301)

}else{

c.Redirect("http://www.baidu.com",301)

}

}//删除动作提交

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() //影响行数

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() //影响行数

if num >0{

c.Redirect("/getmovieinfo",301)

}else{

c.Redirect("http://www.baidu.com",301)

}

}