• 欢迎大家分享资料!前往留言板评论即可!

go学习笔记(二) —— 操作MySQL

合宙 模组资料网 5个月前 (05-15) 76次浏览 已收录 0个评论 扫描二维码
database/sql

原生支持连接池,是并发安全的。

下载驱动
go get -u github.com/go-sql-driver/mysql
连接
dsn := "root:[email protected](127.0.0.1:3306)/go_test"
db, err = sql.Open("mysql", dsn)
if err != nil {
    return err
}
err = db.Ping()
if err != nil {
    return err
}

// 配置
// 最大连接数
db.SetMaxOpenConns(100)
// 最大闲置连接数
db.SetMaxIdleConns(10)
查询
  • 单条查询
func sel() {
    var u1 user
    sqlStr := `select i_d,user_name,password from s_user where i_d=1;`
    rowObj := db.QueryRow(sqlStr)
    fmt.Println(rowObj)
    rowObj.Scan(&u1.id, &u1.userName, &u1.password)
    fmt.Println(u1)
}
  • 多条查询
func selall() {
    sqlStr := `select i_d,user_name,password from s_user;`
    rows, err := db.Query(sqlStr)
    if err != nil {
        fmt.Println("error", err)
        return
    }
    defer rows.Close()
    for rows.Next() {
        u1 := user{}
        err := rows.Scan(&u1.id, &u1.userName, &u1.password)
        if err != nil {
            fmt.Println("scan error")
            return
        }
        fmt.Printf("%#v\n", u1)
    }
}
插入
func insert() {
    sqlStr := `insert into s_user (user_name,password) values("哈喽",20)`
    ret, err := db.Exec(sqlStr)
    if err != nil {
        fmt.Println("exec error:", err)
        return
    }
    id, err := ret.LastInsertId()
    if err != nil {
        fmt.Println("get last id error:", err)
        return
    }
    fmt.Println("id:", id)
}
更新
func update(password string, id int) {
    sqlStr := `update s_user set password=? where i_d=?`
    ret, err := db.Exec(sqlStr, password, id)
    if err != nil {
        fmt.Println("update error:", err)
        return
    }
    n, err := ret.RowsAffected()
    if err != nil {
        fmt.Println("update error:", err)
        return
    }
    fmt.Printf("更新了%d行数据\n", n)
}
删除
func deleteRow(id int) {
    sqlStr := `delete from s_user where i_d=?`
    ret, err := db.Exec(sqlStr, id)
    if err != nil {
        fmt.Println("delete error:", err)
        return
    }
    n, err := ret.RowsAffected()
    if err != nil {
        fmt.Println("update error:", err)
        return
    }
    fmt.Printf("删除了%d行数据!", n)
}
MySQL预处理
  • 优化MySQL服务器重复执行SQL语句,可以提升服务器性能,节省编译成本
  • 避免SQL注入问题
func preInsert() {
    sqlStr := `insert into s_user (user_name,password) values(?,?)`
    stmt, err := db.Prepare(sqlStr)
    if err != nil {
        fmt.Println("prepare error:", err)
        return
    }
    defer stmt.Close()
    // 通过stmt进行操作
    m := map[string]string{
        "test1": "console.log(321)",
        "test2": "console.log(654)",
        "test3": "wangxiangji",
        "test4":  "tianyue",
    }
    for k, v := range m {
        ret, err := stmt.Exec(k, v)
        if err != nil {
            fmt.Println("insert error:", err)
            continue
        }
        _, err = ret.RowsAffected()
        if err != nil {
            fmt.Println("insert error:", err)
            continue
        }
        fmt.Printf("%sinsert success\n", k)
    }
}
MySQL事务处理

事务:一个最小的不可再分的工作单元。通常一个事务对应一个完整的业务,同时这个完整的业务需要执行多次的DML(insert、update、delete)语句共同联合完成。Innndb引擎数据库才支持事务。

相关方法

  • tx.Begin()
  • tx.Rollback()
  • tx.Commit()
func transactionDemo() {
    tx, err := db.Begin()
    if err != nil {
        fmt.Println("begin error:", err)
        return
    }
    sqlStr1 := `update s_user set password="18" where i_d=8`
    sqlStr2 := `update s_user set password="22" where i_d=9`
    _, err = tx.Exec(sqlStr1)
    if err != nil {
        // 错误回滚
        tx.Rollback()
        fmt.Println("sql1 running error:", err)
        return
    }
    _, err = tx.Exec(sqlStr2)
    if err != nil {
        tx.Rollback()
        fmt.Println("sql2 running error:", err)
        return
    }
    err = tx.Commit()
    if err != nil {
        tx.Rollback()
        fmt.Println("commit running error:", err)
        return
    }
    fmt.Println("事务执行成功")
}

转载请注明原文链接:go学习笔记(二) —— 操作MySQL
喜欢 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址