连接Mysql操作

package main

import (
	"fmt"
	_ "github.com/go-sql-driver/mysql"
	"github.com/jmoiron/sqlx"
)

type Person struct {
	UserId   int    `db:"user_id"`
	Username string `db:"username"`
	Sex      string `db:"sex"`
	Email    string `db:"email"`
}

type Place struct {
	Country string `db:"country"`
	City    string `db:"city"`
	TelCode int    `db:"telcode"`
}

// 新增
func Insert(db *sqlx.DB) {
	r, err := db.Exec("insert into person(username, sex, email)values(?, ?, ?)", "stu002", "man", "stu01@qq.com")
	if err != nil {
		fmt.Println("exec failed, ", err)
		return
	}
	id, err := r.LastInsertId()
	if err != nil {
		fmt.Println("exec failed, ", err)
		return
	}
	fmt.Println("insert succ:", id)
}

// 查询
func Select(db *sqlx.DB) {
	var people []Person
	err := db.Select(&people, "select * from person where user_id > ?", 1)
	if err != nil {
		fmt.Println("select failed:", err)
		return
	}
	fmt.Println(people)
}

// 更新
func Update(db *sqlx.DB) {
	r, err := db.Exec("update person set username = ? where user_id = ?", "stu0022", 2)
	if err != nil {
		fmt.Println("update mysql failed,", err)
		return
	}
	num, err := r.RowsAffected()
	if err != nil {
		fmt.Println("update mysql failed,", err)
		return
	}
	fmt.Println("update success,", num)
}

// 删除
func Delete(db *sqlx.DB) {
	r, err := db.Exec("delete from person where user_id = ?", 2)
	if err != nil {
		fmt.Println("delete mysql failed,", err)
		return
	}
	num, err := r.RowsAffected()
	if err != nil {
		fmt.Println("delete mysql failed,", err)
		return
	}
	fmt.Println("delete success,", num)
}

func main() {
	Db, err := sqlx.Open("mysql", "root:root@tcp(127.0.0.1:3306)/test")
	if err != nil {
		fmt.Println("open mysql failed,", err)
		return
	}
	fmt.Println(Db.Ping())
	//Insert(Db)
	//Select(Db)
	//Update(Db)
	Delete(Db)
	Select(Db)
}