快捷導(dǎo)航

使用GO語(yǔ)言實(shí)現(xiàn)Mysql數(shù)據(jù)庫(kù)CURD的簡(jiǎn)單示例

更新時(shí)間：2021年08月05日 10:28:15 作者：ReganYue

本文主要介紹了使用GO語(yǔ)言實(shí)現(xiàn)Mysql數(shù)據(jù)庫(kù)CURD的簡(jiǎn)單示例，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

〇、介紹驅(qū)動(dòng)包和增強(qiáng)版Mysql操作庫(kù)Sqlx

go-mysql-driver是go語(yǔ)言標(biāo)準(zhǔn)庫(kù)(SDK)database/sql的”加工產(chǎn)品“，質(zhì)量有保障！
go-mysql-driver運(yùn)行時(shí)間雖然比較長(zhǎng)，但是內(nèi)存使用較少。
go-mysql-driver實(shí)現(xiàn)了database/sql，即便不是mysql，是使用其他數(shù)據(jù)庫(kù)，也能夠使用該包。
go-mysql-driver接口設(shè)計(jì)得比較好，上手較快。
對(duì)于Sqlx，它其實(shí)也是go語(yǔ)言標(biāo)準(zhǔn)庫(kù)(SDK)database/sql的”加工產(chǎn)品“。
Sqlx也可以用于其他數(shù)據(jù)庫(kù)。
Sqlx包其實(shí)最大最大的優(yōu)點(diǎn)是在查詢方面，也就是使用select時(shí)優(yōu)化得比較好。比原來(lái)的使用查詢方便了不止一點(diǎn)。

一、先導(dǎo)入驅(qū)動(dòng)包和增強(qiáng)版Mysql操作庫(kù)Sqlx

package main

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

此處需要導(dǎo)入導(dǎo)入mysql驅(qū)動(dòng)包和增強(qiáng)版Mysql操作庫(kù)Sqlx。
如果不清楚如何導(dǎo)入第三方包，請(qǐng)查看我的技術(shù)博客：手把手教你怎么使用Go語(yǔ)言第三方庫(kù)。

二、insert操作

//執(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)
}

使用sqlx包的Open連接數(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ò)誤。
然后執(zhí)行db.Exec()操作。

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

第一個(gè)參數(shù)是query語(yǔ)句。

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

RowsAffected()求受影響的行數(shù)。RowsAffected返回update, insert, or delete影響的行數(shù)。不是每一個(gè)數(shù)據(jù)庫(kù)和數(shù)據(jù)庫(kù)驅(qū)動(dòng)可能支持這個(gè)。
LastInsertId()求插入的最后一行的ID。
LastInsertId返回?cái)?shù)據(jù)庫(kù)生成的最后一個(gè)ID。通常，這來(lái)自插入新行時(shí)的“自動(dòng)遞增”列。不是所有數(shù)據(jù)庫(kù)都支持此功能。

三、delete操作

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

還是執(zhí)行db.Exec()，第一個(gè)參數(shù)是delete語(yǔ)句。

查看該操作是否執(zhí)行成功。

成功?。?！試一試吧！

四、update操作

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

成功執(zhí)行！

來(lái)看一看結(jié)果吧！

現(xiàn)在可以看到數(shù)據(jù)更新成功。將id為1的數(shù)據(jù)的name項(xiàng)更新為”大揚(yáng)“。
這里兩個(gè)？，后面就要有兩個(gè)參數(shù)。

五、select操作

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)
}

Person結(jié)構(gòu)體里面的屬性對(duì)應(yīng)數(shù)據(jù)庫(kù)里面的字段。比如：

Age int `db:"age"`

表示Age對(duì)應(yīng)表里面的字段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

因?yàn)椴樵兊慕Y(jié)果可能為多條，所以使用Person切片。然后將查詢結(jié)果放入ps中
提示：要使用ps的指針！

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

下面我們來(lái)看看查詢結(jié)果：

到此這篇關(guān)于使用GO語(yǔ)言實(shí)現(xiàn)Mysql數(shù)據(jù)庫(kù)CURD的簡(jiǎn)單示例的文章就介紹到這了,更多相關(guān)GO語(yǔ)言Mysql數(shù)據(jù)庫(kù)CURD內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: