一. 修改注意点

  • 修改和新增类似,只是不需要获取LastInsertId()和SQL语句是修改语句
  • 在Golang中要求:如果修改前和修改后的值相同,RowsAffected()返回0

二.代码实现

  1. package main
  3. import (
  4.    "fmt"
  5.    //驱动已经放入到标准库文件夹,由于不使用所以需要空导入,在前面添加_
  6.    _ "github.com/go-sql-driver/mysql"
  7.    //Golang中数据库操作包
  8.    "database/sql"
  9. )
  11. func main() {
  12.    /*
  13.    第一个参数:连接什么数据库
  14.    第二个参数:连接字符串
  15.    语法:数据库登录用户名:密码@tcp(mysql主机ip:端口)/database名称
  16.     */
  17.    db,err:=sql.Open("mysql","root:root@tcp(localhost:3306)/first")
  18.    db.Ping()
  19.    //Error处理
  20.    if err!=nil{
  21.       fmt.Println("数据库连接失败")
  22.    }
  23.    //关闭连接
  24.    defer func() {
  25.       if db!=nil{
  26.          db.Close()
  27.          fmt.Println("关闭连接")
  28.       }
  29.    }()
  30.    /*
  31.       准备处理SQL语句
  32.       支持占位符,防止SQL注入
  33.     */
  34.    stmt,err:=db.Prepare("update people set name=?,address=? where id=?")
  35.    //错误处理
  36.    if err!=nil{
  37.       fmt.Println("预处理失败",err)
  38.    }
  39.    //关闭对象
  40.    defer func() {
  41.       if stmt!=nil{
  42.          stmt.Close()
  43.          fmt.Println("stmt关闭")
  44.       }
  45.    }()
  46.    /*
  47.    Exec() 参数为不定项参数,对应占位符?个数
  48.     */
  49.    res,err:=stmt.Exec("李四","朝阳",1)
  50.    //错误处理
  51.    if err!=nil{
  52.       fmt.Println("执行SQL出现错误")
  53.    }
  54.    //受影响行数
  55.    count,err:=res.RowsAffected()
  56.    if err!=nil{
  57.       fmt.Println("获取结果失败",err)
  58.    }
  59.    if count>0{
  60.       fmt.Println("修改成功")
  61.    }else{
  62.       fmt.Println("修改失败")
  63.    }
  64. }