图片.png

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("查询数据成功")
}