1.创建数据库表
2.插入数据
func (c *MysqlController) ShowMysql() {
conn, error := sql.Open("mysql","root:12345678@tcp(127.0.0.1:3306)/class1?charset=utf8")
if error!=nil{
beego.Info("连接错误",error)
return
}
////2.操作数据库
//_ , err := conn.Exec("create table userInfo(id int ,name varchar(11))")
//if err!=nil {
// beego.Info("创建表错误", err)
// return
//}
//插入数据
_,err :=conn.Exec("insert userInfo(id,name )value (?,?)",1,"lilei")
if err!=nil {
beego.Info("插入数据错误",err)
return
}
//3.关闭数据库
defer conn.Close()
c.Ctx.WriteString("插入数据成功")
}
2.数据库查询
func (c *MysqlController) ShowMysql() {
conn, error := sql.Open("mysql","root:12345678@tcp(127.0.0.1:3306)/class1?charset=utf8")
if error!=nil{
beego.Info("连接错误",error)
return
}
////2.操作数据库
//_ , err := conn.Exec("create table userInfo(id int ,name varchar(11))")
//if err!=nil {
// beego.Info("创建表错误", err)
// return
//}
//插入数据
//_,err :=conn.Exec("insert userInfo(id,name )value (?,?)",1,"lilei")
//if err!=nil {
// beego.Info("插入数据错误",err)
// return
//}
//查询
rows, err := conn.Query("select id from userInfo")
var id int
if err!=nil{
beego.Info("数据库查询错误",err)
return
}
for rows.Next() {
rows.Scan(&id)
beego.Info(id)
}
//3.关闭数据库
defer conn.Close()
c.Ctx.WriteString("查询数据成功")
}