Golang学习笔记之Golang与Mysql交互

一、打开数据库

//第⼀步：打开数据库,格式是 ⽤户名：密码@/数据库名称？编码⽅式
    db, err := sql.Open("mysql", "root:123@/mydb?charset=utf8")
    if err != nil {
        fmt.Println(err)
    }
    //关闭数据库
    defer db.Close()

二、查询数据

var id int
    var name string
    var price float64
    //查询数据，指定字段名，返回sql.Rows结果集
    rows, err := db.Query("select id,name,price from product")
    if err != nil {
        fmt.Println(err)
    }
    for rows.Next() {
        rows.Scan(&id, &name, &price)
        fmt.Println(id, name, price)
    }
    defer rows.Close()

• rows.Next() 迭代查询数据.

• rows.Scan() 读取每一行的值

• rows.Close() 关闭查询

三、查询一行数据

//查询⼀⾏数据可以使用and（与）限定多个条件,或者使用or（或）
    rows3 := db.QueryRow("SELECT id,name FROM product WHERE id = ? or price like ?", 1,1.11)
    // rows3 := db.QueryRow("select id,name from product where id = 1")
    rows3.Scan(&id, &name)
    fmt.Println(id, name)

四、插入一行数据

//插⼊⼀⾏数据
    ret, _ := db.Exec("insert into product(id,name,price) values(15,'dog',30)")
    //LastInsertId返回一个数据库生成的回应命令的整数。
    //返回插入的ID
    insID, _ := ret.LastInsertId()
    fmt.Println(insID)

• ret.LastInsertId()插入的ID

• ret.RowsAffected()受影响的行数

五、修改数据

//更新数据，修改id>1的行的name
    ret2, _ := db.Exec("update product set name= '000' where id > ?", 1)
    //获取影响⾏数
    aff_nums, _ := ret2.RowsAffected()
    fmt.Println(aff_nums)

六、删除数据

//删除数据,删除id=3的行
    ret3, _ := db.Exec("delete from product where id = ?",3)
    delNums, _ := ret3.RowsAffected()
    fmt.Println(delNums)

七、预处理

//预处理
    stmt, _ := db.Prepare("select id,name from product where id=? or name=?")
    //查找id为3或者name为000的人
    row4, _ := stmt.Query(3, "000")
    //注意这⾥需要Next()下，不然下⾯取不到值
    for row4.Next() {
        row4.Scan(&id, &name)
        fmt.Println(id, name)
    }
    //预处理插入数据
    stmt2, _ := db.Prepare("insert into product(name,id,price) values(?,?,null)")
    //name为lisi，id为22
    rows5, _ := stmt2.Exec("lisi", 22)
    fmt.Println(rows5.RowsAffected())

八、事务处理

//开启事务
    tx, _ := db.Begin()
    //id为1的price+1，id为2的price-1
    ret4, _ := tx.Exec("update product set price = price + 1 where id = ?", 1)
    ret5, _ := tx.Exec("update product set price = price - 1 where id = ?", 2)

    //如果id不存在,受影响行数则为0
    //接收影响行数，为0则失败
    updNums1, _ := ret4.RowsAffected()
    updNums2, _ := ret5.RowsAffected()
    if updNums1 > 0 && updNums2 > 0 { //只有两条更新同时成功，那么才提交
        tx.Commit() //提交事务
        fmt.Println("Success")
    } else { //否则回滚
        tx.Rollback() //回退事务
        fmt.Println("Fail")
    }

• tx.Commit() 提交事务

• tx.Rollback() 回退事务

demo

package main
import (
    "database/sql"
    "fmt"

    _ "github.com/go-sql-driver/mysql"
)
type dbWorker struct {
    dsn      string
    db       *sql.DB
    userInfo usertb
}
type usertb struct {
    id int
    //NullString代表一个可为NULL的字符串。
    name sql.NullString
    //NullInt64代表一个可为NULL的Float64值。
    price sql.NullFloat64
}
func main() {
    var err error
    //初始化结构体，保存数据库参数
    dbw := dbWorker{
        dsn: "root:123@/mydb?charset=utf8",
    }
    //打开数据库,并保存给结构体内db
    dbw.db, err = sql.Open("mysql", dbw.dsn)
    //如果打开失败，panic退出
    if err != nil {
        panic(err)
    }
    //关闭数据库
    defer dbw.db.Close()
    //插入数据
    dbw.insertData()
    //获取数据
    dbw.querData()
}

//创建方法，插入数据
func (dbw *dbWorker) insertData() {
    //预处理,插入数据
    stmt, _ := dbw.db.Prepare(`INSERT INTO product(name,id,price) VALUES(?,null,?)`)
    //函数执行完毕，关闭
    defer stmt.Close()
    //插入数据
    ret, err := stmt.Exec("hz", 29)
    if err != nil {
        fmt.Println(err)
        return
    }
    //获取id，执行成功，打印
    if LastInsertId, err := ret.LastInsertId(); err == nil {
        fmt.Println("LastInsertId:", LastInsertId)
    }
    //获取行号，执行成功，打印
    if RowsAffected, err := ret.RowsAffected(); err == nil {
        fmt.Println("RowsAffected:", RowsAffected)
    }
}

//初始化userInfo
func (dbw *dbWorker) querDataPre() {
    dbw.userInfo = usertb{}
}
func (dbw *dbWorker) querData() {

    //预处理,查询数据
    stmt, _ := dbw.db.Prepare(`SELECT * From product where price >= ? AND price < ?`)

    defer stmt.Close()

    dbw.querDataPre()
    //取price20到30之间的数据
    rows, err := stmt.Query(20, 30)
    defer rows.Close()
    if err != nil {
        fmt.Println(err)
        return
    }
    for rows.Next(){
        //取出数据库数据
        rows.Scan(&dbw.userInfo.id,&dbw.userInfo.name,&dbw.userInfo.price)
        if err != nil {
            fmt.Println(err.Error())
            continue
        }
        //如果取出的数据为null,则赋一个0值
        if !dbw.userInfo.name.Valid{
            dbw.userInfo.name.String = ""
        }
        if !dbw.userInfo.price.Valid{
            dbw.userInfo.price.Float64 = 0.00
        }
        fmt.Println("get data,id:",dbw.userInfo.id,"name:",dbw.userInfo.name.String,"price",float64(dbw.userInfo.price.Float64))
    }
    err = rows.Err()
    if err != nil{
        fmt.Printf(err.Error())
    }
}