GO語言中怎么實現Mysql數據庫的CURD操作

這期內容當中小編將會給大家帶來有關GO語言中怎么實現Mysql數據庫的CURD操作，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

一、先導入驅動包和增強版Mysql操作庫Sqlx

package main

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

此處需要導入導入mysql驅動包和增強版Mysql操作庫Sqlx。
如果不清楚如何導入第三方包，請查看我的技術博客：手把手教你怎么使用Go語言第三方庫。

二、insert操作

//執行insert操作
func main()  {
    //連接數據庫
    //driverName:mysql,表示驅動器的名稱是mysql也就上面"github.com/go-sql-driver/mysql"導入的驅動器。
    //dataSourceName：root:123456@tcp(localhost:3306)/mydb 賬戶名:密碼@tcp(ip:端口)/數據庫名稱
    //sqlx.Open返回一個*sqlx.DB和錯誤。
    db, _ := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
    defer db.Close()
    //執行增刪改
    //query里面是sql語句。
    result, e := db.Exec("insert into person(name,age,rmb,gender,brithday) values(?,?,?,?,?);", "小揚", 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("受影響的行數=",rowsAffected)
    fmt.Println("最后一行的ID=",lastInsertId)
}

使用sqlx包的Open連接數據庫。

driverName:mysql,表示驅動器的名稱是mysql也就上面"github.com/go-sql-driver/mysql"導入的驅動器。
dataSourceName是root:123456@tcp(localhost:3306)/mydb 它的含義是 賬戶名:密碼@tcp(ip:端口)/數據庫名稱。
sqlx.Open返回一個*sqlx.DB和錯誤。
然后執行db.Exec()操作。

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

第一個參數是query語句。

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

RowsAffected()求受影響的行數。RowsAffected返回update, insert, or delete影響的行數。不是每一個數據庫和數據庫驅動可能支持這個。
LastInsertId()求插入的最后一行的ID。
LastInsertId返回數據庫生成的最后一個ID。通常，這來自插入新行時的“自動遞增”列。不是所有數據庫都支持此功能。

三、delete操作

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

還是執行db.Exec()，第一個參數是delete語句。

查看該操作是否執行成功。

成功！！！試一試吧！

四、update操作

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

成功執行！

來看一看結果吧！

現在可以看到數據更新成功。將id為1的數據的name項更新為”大揚“。
這里兩個？，后面就要有兩個參數。

五、select操作

package main

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

type Person struct {
    // 對應name表字段
    Name string `db:"name"`
    // 對應age表字段
    Age int `db:"age"`
    // 對應rmb表字段
    Money float64 `db:"rmb"`
}

func main()  {
    db, _ := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
    defer db.Close()

    //預定義Person切片用于接收查詢結果
    var ps []Person
    //執行查詢，得到Perosn對象的集合，丟入預定義的ps地址
    e := db.Select(&ps, "select name,age,rmb from person where name like ?;", "%揚")
    if e != nil{
        fmt.Println("err=",e)
    }
    fmt.Println("查詢成功",ps)
}

Person結構體里面的屬性對應數據庫里面的字段。比如：

Age int `db:"age"`

表示Age對應表里面的字段age。

type Person struct {
 // 對應name表字段
 Name string `db:"name"`
 // 對應age表字段
 Age int `db:"age"`
 // 對應rmb表字段
 Money float64 `db:"rmb"`
}

var ps []Person

因為查詢的結果可能為多條，所以使用Person切片。然后將查詢結果放入ps中
提示：要使用ps的指針！

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

下面我們來看看查詢結果：

上述就是小編為大家分享的GO語言中怎么實現Mysql數據庫的CURD操作了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。