go database/sql sql-driver/mysql 操作

這里使用的是github.com/Go-SQL-Driver/MySQL，

所以需要下載一個github.com/Go-SQL-Driver/MySQL

引入 database/sql 和 github.com/Go-SQL-Driver/MySQL

這里實現了對數據庫的 增、刪、改、查、事務

這里直接上代碼，代碼中有詳細的解釋。並且這些操作都經過我實際操作

 

引入需要的包

import(
    "database/sql"
    _"github.com/Go-SQL-Driver/MySQL"
    "log"
    "strconv"
    //"reflect"    //獲取變量類型用
)

 

增：

func main (){
    //insert 
    name := "name"
    pwd := "password"
    nickname := "nickname"
    db,err := sql.Open("mysql","go_mysql_user:go_mysql_pwd@tcp(localhost:3306)/go_mysql?charset=utf8")
    defer db.Close()  //只有在前面用了 panic[拋出異常] 這時defer才能起作用，如果鏈接數據的時候出問題，他會往err寫數據。defer:延遲，這里立刻申請了一個關閉sql 鏈接的草錯，defer 后的方法，或延遲執行。在函數拋出異常一會被執行
    if err != nil{
            panic(err.Error())
            log.Println(err)
            return
    }
    
    insert_sql := "insert into users (name,pwd,nickname) value (?,?,?),(?,?,?),(?,?,?),(?,?,?)"
    stmt,err := db.Prepare(insert_sql)        //准備一個sql操作，返回一個*Stmt,用戶后面的執行,這個Stmt可以被多次執行，或者並發執行
    /*
    *    這個stmt的主要方法:Exec、Query、QueryRow、Close
    */
    if err != nil {
            log.Println(err)
            return 
    }
    res,err := stmt.Exec(name,pwd,nickname,name,pwd,nickname,name,pwd,nickname,name,pwd,nickname)
    if err != nil {
            log.Println(err)
            return 
    }
    lastInsertId,err := res.LastInsertId()        //批量插入的時候LastInserId返回的是第一條id,單條插入則返回這條的id
    //lastInsertId,err := res.RowsAffected()        //插入的是后RowsAffected 返回的是插入的條數
    if err != nil {
            log.Println(err)
            return 
    }
    //log.Println(reflect.TypeOf(lastInsertId))    //打印變量類型
    last_insert_id_string := strconv.FormatInt(lastInsertId,10)    //int64 轉string 需要引入 strconv包
    log.Println("lastInsertId = " + last_insert_id_string)
}

 

刪：

func main (){
    //delete
    del_sql := "delete from users where id=?"
    del_stmt,del_err := db.Prepare(del_sql)
    del_stmt.Exec(6)//不返回任何結果
}

 

改：

func main (){
    //update
    update_sql := "update users set name=? where id=?"
    update_stmt,update_err := db.Prepare(update_sql)
    if update_err != nil {
            log.Println(update_err)
            return;
    }
    update_res,update_err := update_stmt.Exec("username",9)
    if update_err != nil {
            log.Printf("%v",update_err)
            return
    }
    affect_count,_ := update_res.RowsAffected()    //返回影響的條數,注意有兩個返回值
    log.Printf("%v",affect_count)
}

 

查一條：

type User struct{
    id int
    name string
    pwd string
    nickname string
}

func main (){
    //select
    var user User
    select_sql := "select * from users where id > ?"
    select_err := db.QueryRow(select_sql,11).Scan(&user.id,&user.name,&user.pwd,&user.nickname)//查詢一條，返回一條結果。並賦值到user這個結構體類型的變量中,就算查詢到的是多條，單返回的還是一條
    if select_err != nil {//如果沒有查詢到任何數據就進入if中err：no rows in result set
            log.Println(select_err)
            return
    }
    log.Println(user)
}

 

查多條：

func main (){
    //查詢多條
    select_rows,select_err := db.Query(select_sql,16)
    if select_err != nil {
            log.Println(select_err)
            return
    }
    defer select_rows.Close()
    for select_rows.Next(){
        var id int
        var name string
        var pwd string
        var nickname string
        if err := select_rows.Scan(&id,&name,&pwd,&nickname); err != nil {
                log.Println(err)
                return
        }
        log.Printf("id=%v,name=%v,pwd=%v,nickname=%v",id,name,pwd,nickname)
    }

}

 

事務：

func main (){

    //事務
    tx,err := db.Begin()        //聲明一個事務的開始
    if err != nil {
            log.Println(err)
            return
    }
    insert_sql := "insert into users (name,pwd,nickname) value(?,?,?)"
    insert_stmt,insert_err := tx.Prepare(insert_sql)
    if insert_err != nil {
            log.Println(insert_err)
            return
    }
    insert_res,insert_err := insert_stmt.Exec("tx_name","tx_pwd","tx_nickname")
    last_insert_id,_ := insert_res.LastInsertId()
    log.Println(last_insert_id)
    defer tx.Rollback()            //回滾之前上面的last_login_id是有的，但在回滾后該操作沒有被提交，被回滾了，所以上面打印的Last_login_id的這條數據是不存在與數據庫表中的
    //tx.Commit()                        //這里提交了上面的操作，所以上面的執行的sql 會在數據庫中產生一條數據

}

 

知識點總結和注意事項：

db,err := sql.Open("mysql","數據庫登錄名:數據庫密碼@tcp(服務器:端口)/數據庫名?charset=utf8") 對應修改；

defer db.Close()　　defer 是延遲或異常或者該方法結束時執行的操作。這里表示有異常就關閉db 可與 panic(err.Error())=》拋出異常。配合使用。一種情況不可執行＝》你的方法進入了死循環，該方法不會結束與異常則不可執行。

LastInsertId()　　獲取插入第一條的id　　有用

RowsAffected()　　獲取影響/插入的條數　　有用

reflect.TypeOf(i)　　reflect包中TypeOf 返回的是變量i的類型

strconv.FormatInt(int64位變量,10)　　strconv包中FormatInt將int64位的變量轉為string 具體是用另一篇文章中有總結
其他都在代碼中一些返回值 和使用。

mymysql與GO-MYSQL_DRIVER對比

1 go-mysql-driver是實現了golang標准庫database/sql的產物。底層實現比較有保證

2 go-mysql-driver雖然每個命令的運行時間比mymysql長，但是內存使用少得非常明顯，這點兩方算打平。

3 go-mysql-driver實現了database/sql，如果數據庫換成其他的話，不需要更改應用邏輯的代碼。

4 go-mysql-driver實現了database/sql，這個接口的設計也是非常好的，基本和php中的pdo一樣，上手和學習成本低。

晚安~~gogogo