1. Delete操作

  1. package main
  3. import (
  4.     "fmt"
  6.     _ "github.com/go-sql-driver/mysql"
  7.     "github.com/jmoiron/sqlx"
  8. )
  10. type Person struct {
  11.     UserId   int    `db:"user_id"`
  12.     Username string `db:"username"`
  13.     Sex      string `db:"sex"`
  14.     Email    string `db:"email"`
  15. }
  17. type Place struct {
  18.     Country string `db:"country"`
  19.     City    string `db:"city"`
  20.     TelCode int    `db:"telcode"`
  21. }
  23. var Db *sqlx.DB
  25. func init() {
  27.     database, err := sqlx.Open("mysql", "root:root@tcp(127.0.0.1:3306)/test")
  28.     if err != nil {
  29.         fmt.Println("open mysql failed,", err)
  30.         return
  31.     }
  33.     Db = database
  34. }
  36. func main() {
  38.     /*
  39.     _, err := Db.Exec("delete from person where user_id=?", 1)
  40.     if err != nil {
  41.         fmt.Println("exec failed, ", err)
  42.         return
  43.     }
  44.     */
  46.     res, err := Db.Exec("delete from person where user_id=?", 1)
  47.     if err != nil {
  48.         fmt.Println("exec failed, ", err)
  49.         return
  50.     }
  52.     row,err := res.RowsAffected()
  53.     if err != nil {
  54.         fmt.Println("rows failed, ",err)
  55.     }
  57.     fmt.Println("delete succ: ",row)
  58. }

运行结果：

第一次运行：

  1.     delete succ: 1
  2.     #受影响的行数 1

第二次运行：

  1.     delete succ: 0
  2.     #受影响的行数 0