package main
​
import (
    "fmt"
    //并不需要使用其API，只需要執(zhí)行該包的init方法（加載MySQL是驅(qū)動(dòng)程序）
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
)

//執(zhí)行insert操作
func main()  {
    //連接數(shù)據(jù)庫(kù)
    //driverName:mysql,表示驅(qū)動(dòng)器的名稱是mysql也就上面"github.com/go-sql-driver/mysql"導(dǎo)入的驅(qū)動(dòng)器。
    //dataSourceName：root:123456@tcp(localhost:3306)/mydb 賬戶名:密碼@tcp(ip:端口)/數(shù)據(jù)庫(kù)名稱
    //sqlx.Open返回一個(gè)*sqlx.DB和錯(cuò)誤。
    db, _ := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
    defer db.Close()
    //執(zhí)行增刪改
    //query里面是sql語(yǔ)句。
    result, e := db.Exec("insert into person(name,age,rmb,gender,brithday) values(?,?,?,?,?);", "小揚(yáng)", 21, 8888, true, 20000101)
    if e!=nil{
        fmt.Println("err=",e)
        return
    }
    // RowsAffected returns the number of rows affected by an
    // update, insert, or delete. Not every database or database
    // driver may support this.
    rowsAffected, _ := result.RowsAffected()
    // LastInsertId returns the integer generated by the database
    // in response to a command. Typically this will be from an
    // "auto increment" column when inserting a new row. Not all
    // databases support this feature, and the syntax of such
    // statements varies.
    lastInsertId, _ := result.LastInsertId()
    fmt.Println("受影響的行數(shù)=",rowsAffected)
    fmt.Println("最后一行的ID=",lastInsertId)
}

result, e := db.Exec("insert into person(name,age,rmb,gender,brithday) values(?,?,?,?,?);", "小揚(yáng)", 21, 8888, true, 20000101)

rowsAffected, _ := result.RowsAffected()
lastInsertId, _ := result.LastInsertId()

result, e := db.Exec("delete from person where name not like ?;", "%揚(yáng)")

result, e := db.Exec("update person set name = ? where id = ?;", "大揚(yáng)", 1)

package main
​
import (
    "fmt"
    //并不需要使用其API，只需要執(zhí)行該包的init方法（加載MySQL是驅(qū)動(dòng)程序）
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
)
​
type Person struct {
    // 對(duì)應(yīng)name表字段
    Name string `db:"name"`
    // 對(duì)應(yīng)age表字段
    Age int `db:"age"`
    // 對(duì)應(yīng)rmb表字段
    Money float64 `db:"rmb"`
}
​
func main()  {
    db, _ := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
    defer db.Close()
​
    //預(yù)定義Person切片用于接收查詢結(jié)果
    var ps []Person
    //執(zhí)行查詢，得到Perosn對(duì)象的集合，丟入預(yù)定義的ps地址
    e := db.Select(ps, "select name,age,rmb from person where name like ?;", "%揚(yáng)")
    if e != nil{
        fmt.Println("err=",e)
    }
    fmt.Println("查詢成功",ps)
}

Age int `db:"age"`

type Person struct {
 // 對(duì)應(yīng)name表字段
 Name string `db:"name"`
 // 對(duì)應(yīng)age表字段
 Age int `db:"age"`
 // 對(duì)應(yīng)rmb表字段
 Money float64 `db:"rmb"`
}

var ps []Person

e := db.Select(ps, "select name,age,rmb from person where name like ?;", "%揚(yáng)")